JdbcTemplate是最基本的Spring JDBC模闆,這個模闆支援簡單的JDBC資料庫通路功能以及基于索引參數的查詢。
Spring資料通路模闆:在資料庫操作過程中,有很大一部分重複工作,比如事務控制、管理資源以及處理異常等,Spring的模闆類處理這些固定部分。同時,應用程式相關的資料通路在回調的實作中處理,包括語句、綁定參數以及整理結果等。這樣一來,我們隻需關心自己的資料通路邏輯即可。

Spring的JDBC架構承擔了資源管理和異常處理的工作,進而簡化了JDBC代碼,我們隻需要編寫從資料庫讀寫資料的必需代碼就萬事大吉了。
我們的學習目标就是動手寫一個demo,實作對Category的CRUD操作。
1.建立表
mysql建立資料庫store,然後執行如下sql:
db_store.sql
2.我用的IDE是IdeaIU,通過maven建構項目,通過xml配置spring。完成後的代碼結構為:
3.建立實體類Category
<code>public</code> <code>class</code> <code>Category{</code>
<code> </code><code>private</code> <code>int</code> <code>cateId;</code>
<code> </code><code>private</code> <code>String cateName;</code>
<code> </code><code>public</code> <code>int</code> <code>getCateId() {</code>
<code> </code><code>return</code> <code>cateId;</code>
<code> </code><code>}</code>
<code> </code><code>public</code> <code>void</code> <code>setCateId(</code><code>int</code> <code>cateId) {</code>
<code> </code><code>this</code><code>.cateId = cateId;</code>
<code> </code><code>public</code> <code>String getCateName() {</code>
<code> </code><code>return</code> <code>cateName;</code>
<code> </code><code>public</code> <code>void</code> <code>setCateName(String cateName) {</code>
<code> </code><code>this</code><code>.cateName = cateName;</code>
<code> </code><code>@Override</code>
<code> </code><code>public</code> <code>String toString() {</code>
<code> </code><code>return</code> <code>"id="</code><code>+cateId+</code><code>" name="</code><code>+cateName;</code>
<code>}</code>
4.修改pom.xml,引入相關依賴。
<code><dependencies></code>
<code> </code><code><dependency></code>
<code> </code><code><groupId>junit</groupId></code>
<code> </code><code><artifactId>junit</artifactId></code>
<code> </code><code><version></code><code>4.12</code><code></version></code>
<code> </code><code></dependency></code>
<code> </code><code><!-- Mysql資料庫連結jar包 --></code>
<code> </code><code><groupId>mysql</groupId></code>
<code> </code><code><artifactId>mysql-connector-java</artifactId></code>
<code> </code><code><version></code><code>5.1</code><code>.</code><code>21</code><code></version></code>
<code> </code><code><scope>runtime</scope></code>
<code></dependencies></code>
5.配置applicationContext.xml
需要配置dataSource作為jdbcTemplate的資料源。然後配置CategoryDao bean,構造注入了jdbcTemplate對象。完整的applicationContext.xml如下:
<code><?xml version=</code><code>"1.0"</code> <code>encoding=</code><code>"UTF-8"</code><code>?></code>
<code><beans xmlns=</code><code>"http://www.springframework.org/schema/beans"</code>
<code> </code><code>xmlns:xsi=</code><code>"http://www.w3.org/2001/XMLSchema-instance"</code>
<code> </code><code>xsi:schemaLocation=</code><code>"http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd"</code><code>></code>
<code> </code><code><bean id=</code><code>"dataSource"</code> <code>class</code><code>=</code><code>"org.springframework.jdbc.datasource.DriverManagerDataSource"</code><code>></code>
<code> </code><code><property name=</code><code>"driverClassName"</code> <code>value=</code><code>"com.mysql.jdbc.Driver"</code><code>></property></code>
<code> </code><code><property name=</code><code>"url"</code> <code>value=</code><code>"jdbc:mysql://localhost:3306/store"</code><code>></property></code>
<code> </code><code><property name=</code><code>"username"</code> <code>value=</code><code>"root"</code><code>></property></code>
<code> </code><code><property name=</code><code>"password"</code> <code>value=</code><code>"root"</code><code>></property></code>
<code> </code><code></bean></code>
<code> </code><code><bean id=</code><code>"jdbcTemplate"</code> <code>class</code><code>=</code><code>"org.springframework.jdbc.core.JdbcTemplate"</code><code>></code>
<code> </code><code><property name=</code><code>"dataSource"</code> <code>ref=</code><code>"dataSource"</code><code>></property></code>
<code> </code>
<code> </code><code><bean id=</code><code>"categoryDao"</code> <code>class</code><code>=</code><code>"CategoryDao"</code><code>></code>
<code> </code><code><constructor-arg ref=</code><code>"jdbcTemplate"</code><code>></constructor-arg></code>
<code></beans></code>
6.資料通路實作類CategoryDao
CategoryDao構造函數包含了參數jdbcTemplate,然後實作了常用的資料通路操作。可以看到,我們隻要關注具體的sql語句就可以了。另外,在getById()和getAll()方法中使用了lambda文法。
<code>import</code> <code>org.springframework.jdbc.core.JdbcTemplate;</code>
<code>import</code> <code>org.springframework.jdbc.core.RowMapper;</code>
<code>import</code> <code>java.sql.ResultSet;</code>
<code>import</code> <code>java.sql.SQLException;</code>
<code>import</code> <code>java.util.List;</code>
<code>import</code> <code>java.util.Map;</code>
<code>/**</code>
<code> </code><code>* Created by 陳敬 on 2017/6/6.</code>
<code> </code><code>*/</code>
<code>public</code> <code>class</code> <code>CategoryDao {</code>
<code> </code><code>private</code> <code>JdbcTemplate jdbcTemplate;</code>
<code> </code><code>public</code> <code>CategoryDao(JdbcTemplate jdbcTemplate) {</code>
<code> </code><code>this</code><code>.jdbcTemplate = jdbcTemplate;</code>
<code> </code><code>public</code> <code>int</code> <code>add(Category category) {</code>
<code> </code><code>String sql = </code><code>"INSERT INTO category(id,name)VALUES(?,?)"</code><code>;</code>
<code> </code><code>return</code> <code>jdbcTemplate.update(sql, category.getCateId(), category.getCateName());</code>
<code> </code><code>public</code> <code>int</code> <code>update(Category category) {</code>
<code> </code><code>String sql = </code><code>"UPDATE Category SET Name=? WHERE Id=?"</code><code>;</code>
<code> </code><code>return</code> <code>jdbcTemplate.update(sql, category.getCateName(), category.getCateId());</code>
<code> </code><code>public</code> <code>int</code> <code>delete(</code><code>int</code> <code>id) {</code>
<code> </code><code>String sql = </code><code>"DELETE FROM Category WHERE Id=?"</code><code>;</code>
<code> </code><code>return</code> <code>jdbcTemplate.update(sql, id);</code>
<code> </code><code>public</code> <code>int</code> <code>count(){</code>
<code> </code><code>String sql=</code><code>"SELECT COUNT(0) FROM Category"</code><code>;</code>
<code> </code><code>return</code> <code>jdbcTemplate.queryForObject(sql,Integer.</code><code>class</code><code>);</code>
<code> </code><code>public</code> <code>Category getById(</code><code>int</code> <code>id) {</code>
<code> </code><code>String sql = </code><code>"SELECT Id,Name FROM Category WHERE Id=?"</code><code>;</code>
<code> </code><code>return</code> <code>jdbcTemplate.queryForObject(sql, (ResultSet rs, </code><code>int</code> <code>rowNumber) -> {</code>
<code> </code><code>Category category = </code><code>new</code> <code>Category();</code>
<code> </code><code>category.setCateId(rs.getInt(</code><code>"Id"</code><code>));</code>
<code> </code><code>category.setCateName(rs.getString(</code><code>"Name"</code><code>));</code>
<code> </code><code>return</code> <code>category;</code>
<code> </code><code>}, id);</code>
<code> </code><code>public</code> <code>List<Category> getAll(){</code>
<code> </code><code>String sql=</code><code>"SELECT Id,Name FROM Category"</code><code>;</code>
<code> </code><code>List<Category> result=jdbcTemplate.query(sql, (resultSet, i) -> {</code>
<code> </code><code>category.setCateId(resultSet.getInt(</code><code>"Id"</code><code>));</code>
<code> </code><code>category.setCateName(resultSet.getString(</code><code>"Name"</code><code>));</code>
<code> </code><code>});</code>
<code> </code><code>return</code> <code>result;</code>
7.測試
<code>@ContextConfiguration</code><code>(locations = </code><code>"classpath:applicationContext.xml"</code><code>)</code>
<code>@RunWith</code><code>(SpringJUnit4ClassRunner.</code><code>class</code><code>)</code>
<code>public</code> <code>class</code> <code>testCategoryDao {</code>
<code> </code><code>@Autowired</code>
<code> </code><code>private</code> <code>CategoryDao categoryDao;</code>
<code> </code><code>@Test</code>
<code> </code><code>public</code> <code>void</code> <code>testAdd() {</code>
<code> </code><code>Category category = </code><code>new</code> <code>Category();</code>
<code> </code><code>category.setCateId(</code><code>4</code><code>);</code>
<code> </code><code>category.setCateName(</code><code>"母嬰"</code><code>);</code>
<code> </code><code>int</code> <code>result = categoryDao.add(category);</code>
<code> </code><code>System.out.println(result);</code>
<code> </code><code>public</code> <code>void</code> <code>testUpdate() {</code>
<code> </code><code>category.setCateName(</code><code>"男裝"</code><code>);</code>
<code> </code><code>int</code> <code>result = categoryDao.update(category);</code>
<code> </code><code>public</code> <code>void</code> <code>testGetById() {</code>
<code> </code><code>int</code> <code>id = </code><code>4</code><code>;</code>
<code> </code><code>Category category = categoryDao.getById(id);</code>
<code> </code><code>System.out.println(category.toString());</code>
<code> </code><code>public</code> <code>void</code> <code>testGetAll() {</code>
<code> </code><code>List<Category> categories = categoryDao.getAll();</code>
<code> </code><code>for</code> <code>(Category item : categories) {</code>
<code> </code><code>System.out.println(item);</code>
<code> </code><code>}</code>
<code> </code><code>public</code> <code>void</code> <code>testCount() {</code>
<code> </code><code>int</code> <code>count = categoryDao.count();</code>
<code> </code><code>System.out.println(count);</code>
<code> </code><code>public</code> <code>void</code> <code>testDelete() {</code>
<code> </code><code>int</code> <code>result = categoryDao.delete(id);</code>
本文轉自 陳敬(Cathy) 部落格園部落格,原文連結http://www.cnblogs.com/janes/p/6971839.html:,如需轉載請自行聯系原作者