天天看点

JAVA入门[18]-JdbcTemplate简单实例

JdbcTemplate是最基本的Spring JDBC模板,这个模板支持简单的JDBC数据库访问功能以及基于索引参数的查询。

Spring数据访问模板:在数据库操作过程中,有很大一部分重复工作,比如事务控制、管理资源以及处理异常等,Spring的模板类处理这些固定部分。同时,应用程序相关的数据访问在回调的实现中处理,包括语句、绑定参数以及整理结果等。这样一来,我们只需关心自己的数据访问逻辑即可。

JAVA入门[18]-JdbcTemplate简单实例

Spring的JDBC框架承担了资源管理和异常处理的工作,从而简化了JDBC代码,我们只需要编写从数据库读写数据的必需代码就万事大吉了。

我们的学习目标就是动手写一个demo,实现对Category的CRUD操作。

1.创建表

mysql新建数据库store,然后执行如下sql:

 db_store.sql

2.我用的IDE是IdeaIU,通过maven构建项目,通过xml配置spring。完成后的代码结构为:

JAVA入门[18]-JdbcTemplate简单实例

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>&lt;dependencies&gt;</code>

<code>    </code><code>&lt;dependency&gt;</code>

<code>        </code><code>&lt;groupId&gt;junit&lt;/groupId&gt;</code>

<code>        </code><code>&lt;artifactId&gt;junit&lt;/artifactId&gt;</code>

<code>        </code><code>&lt;version&gt;</code><code>4.12</code><code>&lt;/version&gt;</code>

<code>    </code><code>&lt;/dependency&gt;</code>

<code>    </code><code>&lt;!-- Mysql数据库链接jar包 --&gt;</code>

<code>        </code><code>&lt;groupId&gt;mysql&lt;/groupId&gt;</code>

<code>        </code><code>&lt;artifactId&gt;mysql-connector-java&lt;/artifactId&gt;</code>

<code>        </code><code>&lt;version&gt;</code><code>5.1</code><code>.</code><code>21</code><code>&lt;/version&gt;</code>

<code>        </code><code>&lt;scope&gt;runtime&lt;/scope&gt;</code>

<code>&lt;/dependencies&gt;</code>

5.配置applicationContext.xml

需要配置dataSource作为jdbcTemplate的数据源。然后配置CategoryDao bean,构造注入了jdbcTemplate对象。完整的applicationContext.xml如下:

<code>&lt;?xml version=</code><code>"1.0"</code> <code>encoding=</code><code>"UTF-8"</code><code>?&gt;</code>

<code>&lt;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>&gt;</code>

<code>    </code><code>&lt;bean id=</code><code>"dataSource"</code> <code>class</code><code>=</code><code>"org.springframework.jdbc.datasource.DriverManagerDataSource"</code><code>&gt;</code>

<code>        </code><code>&lt;property name=</code><code>"driverClassName"</code> <code>value=</code><code>"com.mysql.jdbc.Driver"</code><code>&gt;&lt;/property&gt;</code>

<code>        </code><code>&lt;property name=</code><code>"url"</code> <code>value=</code><code>"jdbc:mysql://localhost:3306/store"</code><code>&gt;&lt;/property&gt;</code>

<code>        </code><code>&lt;property name=</code><code>"username"</code> <code>value=</code><code>"root"</code><code>&gt;&lt;/property&gt;</code>

<code>        </code><code>&lt;property name=</code><code>"password"</code> <code>value=</code><code>"root"</code><code>&gt;&lt;/property&gt;</code>

<code>    </code><code>&lt;/bean&gt;</code>

<code>    </code><code>&lt;bean id=</code><code>"jdbcTemplate"</code> <code>class</code><code>=</code><code>"org.springframework.jdbc.core.JdbcTemplate"</code><code>&gt;</code>

<code>        </code><code>&lt;property name=</code><code>"dataSource"</code> <code>ref=</code><code>"dataSource"</code><code>&gt;&lt;/property&gt;</code>

<code>    </code> 

<code>    </code><code>&lt;bean id=</code><code>"categoryDao"</code> <code>class</code><code>=</code><code>"CategoryDao"</code><code>&gt;</code>

<code>        </code><code>&lt;constructor-arg ref=</code><code>"jdbcTemplate"</code><code>&gt;&lt;/constructor-arg&gt;</code>

<code>&lt;/beans&gt;</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) -&gt; {</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&lt;Category&gt; getAll(){</code>

<code>        </code><code>String sql=</code><code>"SELECT Id,Name FROM Category"</code><code>;</code>

<code>        </code><code>List&lt;Category&gt; result=jdbcTemplate.query(sql, (resultSet, i) -&gt; {</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&lt;Category&gt; 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:,如需转载请自行联系原作者