一、什么是JDBCTemplate
数据库的连接,释放资源,增删查改需要写大量重复繁杂的代码,Spring框架对就JDBC做了一个简单封装。提供了一个JDBCTemplate对象简化JDBC的开发。
例如下面这个转账的方法:
1、使用jdbctemplate前:
public boolean Money(String fromName,String toName,double money){
Connection conn = null;
PreparedStatement preparedStatement1 = null;
PreparedStatement preparedStatement2 = null;
try {
conn = JDBCUtils.getConnection();
conn.setAutoCommit(false); //开启事务
String sql1 = "update db1.account set balance = balance - ? where name = ?";
String sql2 = "update db1.account set balance = balance + ? where name = ?";
preparedStatement1 = conn.prepareStatement(sql1);
preparedStatement2 = conn.prepareStatement(sql2);
preparedStatement1.setDouble(1,money);
preparedStatement1.setString(2,fromName);
preparedStatement2.setDouble(1,money);
preparedStatement2.setString(2,toName);
preparedStatement1.executeUpdate();
preparedStatement2.executeUpdate();
conn.commit(); //提交事务
} catch (Exception e) {
try {
if(conn != null)
conn.rollback(); //若发生异常则回滚事务
} catch (SQLException ex) {
ex.printStackTrace();
return false;
}
e.printStackTrace();
return false;
}finally {
JDBCUtils.close(preparedStatement1,conn);
JDBCUtils.close(preparedStatement2,null);
}
return true;
}
2、使用jdbctemplate后:
public boolean Money(String fromName,String toName,double money){
//创建JDBCTemplate对象
JdbcTemplate template = new JdbcTemplate(JDBCUtils.getDataSource());
String sql1 = "update db1.account set balance = balance - ? where name = ?";
String sql2 = "update db1.account set balance = balance + ? where name = ?";
template.update(sql1, money,fromName);
template.update(sql2, money,toName);
}
二、步骤
1、导入jar包(JDBCTemplate相关jar包-Java文档类资源-CSDN文库)
2、创建JdbcTemplate对象
依赖于数据源DataSource
JdbcTemplate template = new JdbcTemplate(JDBCUtils.getDataSource());
3、调用JdbcTemplate的方法来完成CRUD的操作
- update():执行DML语句。增、删、改语句
/** * 1. 修改1号数据的 salary 为 10000 */ @Test public void test1(){ //2. 定义sql String sql = "update emp set salary = 10000 where id = 1001"; //3. 执行sql int count = template.update(sql); System.out.println(count); } /** * 2. 添加一条记录 */ @Test public void test2(){ String sql = "insert into emp(id,ename,dept_id) values(?,?,?)"; int count = template.update(sql, 1015, "郭靖", 10); System.out.println(count); } /** * 3.删除刚才添加的记录 */ @Test public void test3(){ String sql = "delete from emp where id = ?"; int count = template.update(sql, 1015); System.out.println(count); }
- queryForMap():查询结果将结果集封装为map集合,将列名作为key,将值作为value 将这条记录封装为一个map集合 注意:这个方法查询的结果集长度只能是1
/** * 4.查询id为1001的记录,将其封装为Map集合 * 注意:这个方法查询的结果集长度只能是1 */ @Test public void test4(){ String sql = "select * from emp where id = ? or id = ?"; Map<String, Object> map = template.queryForMap(sql, 1001,1002); System.out.println(map); //{id=1001, ename=孙悟空, job_id=4, mgr=1004, joindate=2000-12-17, salary=10000.00, bonus=null, dept_id=20} }
- queryForList():查询结果将结果集封装为list集合 注意:将每一条记录封装为一个Map集合,再将Map集合装载到List集合中
/** * 5. 查询所有记录,将其封装为List */ @Test public void test5(){ String sql = "select * from emp"; List<Map<String, Object>> list = template.queryForList(sql); for (Map<String, Object> stringObjectMap : list) { System.out.println(stringObjectMap); } }
- query():查询结果,将结果封装为JavaBean对象 query的参数:RowMapper 一般我们使用BeanPropertyRowMapper实现类。可以完成数据到JavaBean的自动封装new BeanPropertyRowMapper<类型>(类型.class)
/** * 6. 查询所有记录,将其封装为Emp对象的List集合 */ @Test public void test6(){ String sql = "select * from emp"; List<Emp> list = template.query(sql, new RowMapper<Emp>() { @Override public Emp mapRow(ResultSet rs, int i) throws SQLException { Emp emp = new Emp(); int id = rs.getInt("id"); String ename = rs.getString("ename"); int job_id = rs.getInt("job_id"); int mgr = rs.getInt("mgr"); Date joindate = rs.getDate("joindate"); double salary = rs.getDouble("salary"); double bonus = rs.getDouble("bonus"); int dept_id = rs.getInt("dept_id"); emp.setId(id); emp.setEname(ename); emp.setJob_id(job_id); emp.setMgr(mgr); emp.setJoindate(joindate); emp.setSalary(salary); emp.setBonus(bonus); emp.setDept_id(dept_id); return emp; } }); for (Emp emp : list) { System.out.println(emp); } } /** * 6. 查询所有记录,将其封装为Emp对象的List集合 */ @Test public void test6_2(){ String sql = "select * from emp"; List<Emp> list = template.query(sql, new BeanPropertyRowMapper<Emp>(Emp.class)); for (Emp emp : list) { System.out.println(emp); } }
- queryForObject:查询结果,将结果封装为对象
/** * 7. 查询总记录数 */ @Test public void test7(){ String sql = "select count(id) from emp"; Long total = template.queryForObject(sql, Long.class); System.out.println(total); }