一、关于JdbcTemplate

jdbctemplate是最基本的spring jdbc模板，这个模板支持简单的jdbc数据库访问功能以及基于索引参数的查询。

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

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

二、Spring JdbcTemplate实例

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

1.创建表

mysql新建数据库store，然后执行如下sql：

create table Category (Id int not null,Name varchar(80) null,constraint pk_category primary key (Id));ｉｎｓｅｒｔ INTO category(id,Name) valUES (1,'女装');ｉｎｓｅｒｔ INTO category(id,Name) VALUES (2,'美妆');ｉｎｓｅｒｔ INTO category(id,Name) VALUES (3,'书籍');

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

3.创建实体类Category

public class Category{    private int cateId;    private String cateName;    public int getCateId() {        return cateId;    }    public void setCateId(int cateId) {        this.cateId = cateId;    }    public String getCateName() {        return cateName;    }    public void setCateName(String cateName) {        this.cateName = cateName;    }    @Override    public String toString() {        return "id="+cateId+" name="+cateName;    }}

4.修改pom.xml，引入相关依赖。

    <dependencies>        <dependency>            <groupId>junit</groupId>            <artifactId>junit</artifactId>            <version>4.12</version>        </dependency>        <!-- Mysql数据库链接jar包 -->        <dependency>            <groupId>mysql</groupId>            <artifactId>mysql-connector-java</artifactId>            <version>5.1.21</version>            <scope>runtime</scope>        </dependency>    </dependencies>

5.配置applicationContext.xml

需要配置dataSource作为jdbcTemplate的数据源。然后配置CategoryDao bean，构造注入了jdbcTemplate对象。完整的applicationContext.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 ">    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">        <property name="driverClassName" value="com.mysql.jdbc.Driver"></property>        <property name="url" value="jdbc:mysql://localhost:3306/store"></property>        <property name="username" value="root"></property>        <property name="password" value="root"></property>    </bean>    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">        <property name="dataSource" ref="dataSource"></property>    </bean>        <bean id="categoryDao" class="CategoryDao">        <constructor-arg ref="jdbcTemplate"></constructor-arg>    </bean></beans>

6.数据访问实现类CategoryDao

CategoryDao构造函数包含了参数jdbcTemplate，然后实现了常用的数据访问操作。可以看到，我们只要关注具体的sql语句就可以了。另外，在getById()和getAll()方法中使用了lambda语法。

import org.springframework.jdbc.core.JdbcTemplate;import org.springframework.jdbc.core.RowMapper;import java.sql.ResultSet;import java.sql.SQLException;import java.util.List;import java.util.Map;/** * Created by 陈敬 on 2017/6/6. */public class CategoryDao {    private JdbcTemplate jdbcTemplate;    public CategoryDao(JdbcTemplate jdbcTemplate) {        this.jdbcTemplate = jdbcTemplate;    }    public int add(Category category) {        String sql = "ｉｎｓｅｒｔ INTO category(id,name)VALUES(?,?)";        return jdbcTemplate.ｕｐｄａｔｅ(sql, category.getCateId(), category.getCateName());    }    public int ｕｐｄａｔｅ(Category category) {        String sql = "ｕｐｄａｔｅ Category SET Name=? WHERE Id=?";        return jdbcTemplate.ｕｐｄａｔｅ(sql, category.getCateName(), category.getCateId());    }    public int ｄｅｌｅｔｅ(int id) {        String sql = "ｄｅｌｅｔｅ FROM Category WHERE Id=?";        return jdbcTemplate.ｕｐｄａｔｅ(sql, id);    }    public int count(){        String sql="ｓｅｌｅｃｔ COUNT(0) FROM Category";        return jdbcTemplate.queryForObject(sql,Integer.class);    }    public Category getById(int id) {        String sql = "ｓｅｌｅｃｔ Id,Name FROM Category WHERE Id=?";        return jdbcTemplate.queryForObject(sql, (ResultSet rs, int rowNumber) -> {            Category category = new Category();            category.setCateId(rs.getInt("Id"));            category.setCateName(rs.getString("Name"));            return category;        }, id);    }    public List<Category> getAll(){        String sql="ｓｅｌｅｃｔ Id,Name FROM Category";        List<Category> result=jdbcTemplate.query(sql, (resultSet, i) -> {            Category category = new Category();            category.setCateId(resultSet.getInt("Id"));            category.setCateName(resultSet.getString("Name"));            return category;        });        return result;    }}

7.测试

@ContextConfiguration(locations = "classpath:applicationContext.xml")@RunWith(SpringJUnit4ClassRunner.class)public class testCategoryDao {    @Autowired    private CategoryDao categoryDao;    @Test    public void testAdd() {        Category category = new Category();        category.setCateId(4);        category.setCateName("母婴");        int result = categoryDao.add(category);        System.out.println(result);    }    @Test    public void testUpdate() {        Category category = new Category();        category.setCateId(4);        category.setCateName("男装");        int result = categoryDao.ｕｐｄａｔｅ(category);        System.out.println(result);    }    @Test    public void testGetById() {        int id = 4;        Category category = categoryDao.getById(id);        System.out.println(category.toString());    }    @Test    public void testGetAll() {        List<Category> categories = categoryDao.getAll();        for (Category item : categories) {            System.out.println(item);        }    }    @Test    public void testCount() {        int count = categoryDao.count();        System.out.println(count);    }    @Test    public void testDelete() {        int id = 4;        int result = categoryDao.ｄｅｌｅｔｅ(id);        System.out.println(result);    }}

标签： jdbctemplate