在使用普通的 JDBC 資料庫時,就會很麻煩的寫不必要的代碼來處理異常,打開和關閉資料庫連接等。但 Spring JDBC 框架負責所有的低層細節,從開始打開連接,準備和執行 SQL 語句,處理異常,處理事務,到最後關閉連接。所以當從資料庫中獲取數據時,你所做的是定義連接參數,指定要執行的 SQL ... ...
在使用普通的 JDBC 資料庫時,就會很麻煩的寫不必要的代碼來處理異常,打開和關閉資料庫連接等。但 Spring JDBC 框架負責所有的低層細節,從開始打開連接,準備和執行 SQL 語句,處理異常,處理事務,到最後關閉連接。
所以當從資料庫中獲取數據時,你所做的是定義連接參數,指定要執行的 SQL 語句,每次迭代完成所需的工作。
Spring JDBC 提供幾種方法和資料庫中相應的不同的類與介面。我將給出使用 JdbcTemplate 類框架的經典和最受歡迎的方法。這是管理所有資料庫通信和異常處理的中央框架類。
JdbcTemplate 類
JdbcTemplate 類執行 SQL 查詢、更新語句和存儲過程調用,執行迭代結果集和提取返回參數值。它也捕獲 JDBC 異常並轉換它們到 org.springframework.dao 包中定義的通用類、更多的信息、異常層次結構。
JdbcTemplate 類的實例是線程安全配置的。所以你可以配置 JdbcTemplate 的單個實例,然後將這個共用的引用安全地註入到多個 DAOs 中。
使用 JdbcTemplate 類時常見的做法是在你的 Spring 配置文件中配置數據源,然後共用數據源 bean 依賴註入到 DAO 類中,併在數據源的設值函數中創建了 JdbcTemplate。
想要理解帶有 jdbc 模板類的 Spring JDBC 框架的相關概念,讓我們編寫一個簡單的示例,來實現下述 Student 表的所有 CRUD 操作。
CREATE TABLE Student( ID INT NOT NULL AUTO_INCREMENT, NAME VARCHAR(20) NOT NULL, AGE INT NOT NULL, PRIMARY KEY (ID) );
在繼續之前,讓我們適當地使用 Eclipse IDE 並按照如下所示的步驟創建一個 Spring 應用程式:
步驟 | |
---|---|
1 | 創建一個名為 SpringExample 的項目,併在創建的項目中的 src 文件夾下創建包 com.cnblogs。 |
2 | 使用 Add External JARs 選項添加必需的 Spring 庫 |
3 | 在項目中添加 Spring JDBC 指定的最新的庫 mysql-connector-java.jar,org.springframework.jdbc.jar 和 org.springframework.transaction.jar。如果這些庫不存在,你可以下載它們。 |
4 | 創建 DAO 介面 StudentDAO 併列出所有必需的方法。儘管這一步不是必需的而且你可以直接編寫 StudentJDBCTemplate 類,但是作為一個好的實踐,我們最好還是做這一步。 |
5 | 在 com.cnblogs 包下創建其他的必需的 Java 類 Student,StudentMapper,StudentJDBCTemplate 和 MainApp 。 |
6 | 確保你已經在 TEST 資料庫中創建了 Student 表。並確保你的 MySQL 伺服器運行正常,且你可以使用給出的用戶名和密碼讀/寫訪問資料庫。 |
7 | 在 src 文件夾下創建 Beans 配置文件 Beans.xml。 |
8 | 最後一步是創建所有的 Java 文件和 Bean 配置文件的內容並按照如下所示的方法運行應用程式。 |
以下是數據訪問對象介面文件 StudentDAO.java 的內容:
package com.cnblogs; import java.util.List; import javax.sql.DataSource; public interface StudentDAO { /** * This is the method to be used to initialize * database resources ie. connection. */ public void setDataSource(DataSource ds); /** * This is the method to be used to create * a record in the Student table. */ public void create(String name, Integer age); /** * This is the method to be used to list down * a record from the Student table corresponding * to a passed student id. */ public Student getStudent(Integer id); /** * This is the method to be used to list down * all the records from the Student table. */ public List<Student> listStudents(); /** * This is the method to be used to delete * a record from the Student table corresponding * to a passed student id. */ public void delete(Integer id); /** * This is the method to be used to update * a record into the Student table. */ public void update(Integer id, Integer age); }
下麵是 Student.java 文件的內容:
package com.cnblogs; public class Student { private Integer age; private String name; private Integer id; public void setAge(Integer age) { this.age = age; } public Integer getAge() { return age; } public void setName(String name) { this.name = name; } public String getName() { return name; } public void setId(Integer id) { this.id = id; } public Integer getId() { return id; } }
以下是 StudentMapper.java 文件的內容:
package com.cnblogs; import java.sql.ResultSet; import java.sql.SQLException; import org.springframework.jdbc.core.RowMapper; public class StudentMapper implements RowMapper<Student> { public Student mapRow(ResultSet rs, int rowNum) throws SQLException { Student student = new Student(); student.setId(rs.getInt("id")); student.setName(rs.getString("name")); student.setAge(rs.getInt("age")); return student; } }
下麵是為定義的 DAO 介面 StudentDAO 的實現類文件 StudentJDBCTemplate.java:
package com.cnblogs; import java.util.List; import javax.sql.DataSource; import org.springframework.jdbc.core.JdbcTemplate; public class StudentJDBCTemplate implements StudentDAO { private DataSource dataSource; private JdbcTemplate jdbcTemplateObject; public void setDataSource(DataSource dataSource) { this.dataSource = dataSource; this.jdbcTemplateObject = new JdbcTemplate(dataSource); } public void create(String name, Integer age) { String SQL = "insert into Student (name, age) values (?, ?)"; jdbcTemplateObject.update( SQL, name, age); System.out.println("Created Record Name = " + name + " Age = " + age); return; } public Student getStudent(Integer id) { String SQL = "select * from Student where id = ?"; Student student = jdbcTemplateObject.queryForObject(SQL, new Object[]{id}, new StudentMapper()); return student; } public List<Student> listStudents() { String SQL = "select * from Student"; List <Student> students = jdbcTemplateObject.query(SQL, new StudentMapper()); return students; } public void delete(Integer id){ String SQL = "delete from Student where id = ?"; jdbcTemplateObject.update(SQL, id); System.out.println("Deleted Record with ID = " + id ); return; } public void update(Integer id, Integer age){ String SQL = "update Student set age = ? where id = ?"; jdbcTemplateObject.update(SQL, age, id); System.out.println("Updated Record with ID = " + id ); return; } }
以下是 MainApp.java 文件的內容:
package com.cnblogs; import java.util.List; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; import com.cnblogs.StudentJDBCTemplate; public class MainApp { public static void main(String[] args) { ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml"); StudentJDBCTemplate studentJDBCTemplate = (StudentJDBCTemplate)context.getBean("studentJDBCTemplate"); System.out.println("------Records Creation--------" ); studentJDBCTemplate.create("Zara", 11); studentJDBCTemplate.create("Nuha", 2); studentJDBCTemplate.create("Ayan", 15); System.out.println("------Listing Multiple Records--------" ); List<Student> students = studentJDBCTemplate.listStudents(); for (Student record : students) { System.out.print("ID : " + record.getId() ); System.out.print(", Name : " + record.getName() ); System.out.println(", Age : " + record.getAge()); } System.out.println("----Updating Record with ID = 2 -----" ); studentJDBCTemplate.update(2, 20); System.out.println("----Listing Record with ID = 2 -----" ); Student student = studentJDBCTemplate.getStudent(2); System.out.print("ID : " + student.getId() ); System.out.print(", Name : " + student.getName() ); System.out.println(", Age : " + student.getAge()); } }
下述是配置文件 Beans.xml 的內容:
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd "> <!-- Initialization for data source --> <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource"> <property name="driverClassName" value="com.mysql.jdbc.Driver"/> <property name="url" value="jdbc:mysql://localhost:3306/TEST"/> <property name="username" value="root"/> <property name="password" value="password"/> </bean> <!-- Definition for studentJDBCTemplate bean --> <bean id="studentJDBCTemplate" class="com.cnblogs.StudentJDBCTemplate"> <property name="dataSource" ref="dataSource" /> </bean> </beans>
當你完成創建源和 bean 配置文件後,運行應用程式。如果你的應用程式一切運行順利的話,將會輸出如下所示的消息:
------Records Creation-------- Created Record Name = Zara Age = 11 Created Record Name = Nuha Age = 2 Created Record Name = Ayan Age = 15 ------Listing Multiple Records-------- ID : 1, Name : Zara, Age : 11 ID : 2, Name : Nuha, Age : 2 ID : 3, Name : Ayan, Age : 15 ----Updating Record with ID = 2 ----- Updated Record with ID = 2 ----Listing Record with ID = 2 ----- ID : 2, Name : Nuha, Age : 20
你可以嘗試自己刪除在我的例子中我沒有用到的操作,但是現在你有一個基於 Spring JDBC 框架的工作應用程式,你可以根據你的項目需求來擴展這個框架,添加複雜的功能。還有其他方法來訪問你使用 NamedParameterJdbcTemplate 和 SimpleJdbcTemplate 類的資料庫,所以如果你有興趣學習這些類的話,那麼你可以查看 Spring 框架的參考手冊。