一、关于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));INSERT INTO category(id,Name) VALUES (1,'女装');INSERT INTO category(id,Name) VALUES (2,'美妆');INSERT 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,引入相关依赖。
junit junit 4.12 mysql mysql-connector-java 5.1.21 runtime
5.配置applicationContext.xml
需要配置dataSource作为jdbcTemplate的数据源。然后配置CategoryDao bean,构造注入了jdbcTemplate对象。完整的applicationContext.xml如下:
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 = "INSERT INTO category(id,name)VALUES(?,?)"; return jdbcTemplate.update(sql, category.getCateId(), category.getCateName()); } public int update(Category category) { String sql = "UPDATE Category SET Name=? WHERE Id=?"; return jdbcTemplate.update(sql, category.getCateName(), category.getCateId()); } public int delete(int id) { String sql = "DELETE FROM Category WHERE Id=?"; return jdbcTemplate.update(sql, id); } public int count(){ String sql="SELECT COUNT(0) FROM Category"; return jdbcTemplate.queryForObject(sql,Integer.class); } public Category getById(int id) { String sql = "SELECT 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 ListgetAll(){ String sql="SELECT Id,Name FROM Category"; List 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.update(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() { Listcategories = 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.delete(id); System.out.println(result); }}
完整代码: