使用spring的jdbcTemplate-----用jdbc模板跟新数据库

1,用语句创建器更新数据库
第一个回调接口是PreparedStatementCreator,实现这个接口来覆盖整个更新过程语句创建任务和参数绑定任务。为了将一个

User对象插入到数据库中，要像下面这样来实现PreparedStatementCreator接口。

public class InsertPreparedStatementCreator implements PreparedStatementCreator{
	private User user;
	
	public InsertPreparedStatementCreator(User user){
		this.user = user;
	}	

	public PreparedStatement createPreparedStatement(Connection conn){
		
		String sql = "insert into user(username,password) values(?,?);
		PreparedStatement ps  = conn.prepareStatement(sql);
		ps.setString(1,user.getUsername());
		ps.setString(2,user.getPassword());
		return ps;
	}
}

 

 

在实现PreparedStatementCreator接口时，会得到数据库连接，它将作为createPreparedStatement()方法的参数，要做的就是

在连接上创建PreparedStatement对象，作为方法的返回值，注意，方法签名中声明抛出了SQLException,这意味着不需要亲自

处理异常。
现在就可以用这个语句创建器来插入数据了。

public class JdbcUserDao implements UserDao{
	
	...........

	public void insert(User user){
		
		JdbcTemplate jdbcTemplate  = new JdbcTemplate(dataSource);
		jdbcTemplate.insert(new InsertPreparedStatementCreator(user));
	}
}

 

 

一般来说，如果接口只在一个方法里使用，最好将PreparedStatementCreator接口和其他的回调接口做为内部类来实现，这是

应为可以直接从内部类中存取局部变量和方法参数，而不是将它作为构造参数进行传递，对这些变量和参数的唯一限制是将它

们必须被声明为final的。

public class JdbcUserDao implements UserDao{

	...........

	public void insert(final User user){
	
		JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);	
		
		jdbcTemplate.update(new PreparedStatementCreator(Connection conn)throws SQLException{
	
			String sql = "insert into user(username ,password) values (?,?)";
			PreparedStatement ps = conn.prepareStatement(sql);
			ps.setString(1,user.getUsername());
			ps.setString(2,user.getPassword());
	
			return ps;
		});
	}
}

 

 

2,用语句设值器更新数据库
第二个回调接口是PreparedStatementSetter,顾名思义，它只执行整个过程中的参数绑定任务。

public class JdbcUserDao implements UserDao{
	

	public void insert(final User user){

		String sql ="insert into user vlaues (?,?)";
		JdbcTemplate jdbcTemplate  = new JdbcTemplate(dataSource);
		
		jdbcTemplate.update(sql,new PreparedStatementSetter(){
	
			public void setValue(PreparedStatement ps)throws Exception{

				ps.setString(1,user.getUsername());
				ps.setString(2,user.getPassword());
			}
		});
	}
}

 

 

另一个版本的update()模板方法接受sql语句和PreparedStatementSetter对象作为参数，该方法会替换从SQL语句中创建

PreparedStatement对象，使用这个接口，所要做的就是参数绑定到PreparedStatement对象上。

 

3,用SQL语句和参数值更新数据库

最后，最简单的update()方法接受SQL语句和对象数组作为语句参数，它会替换从SQL语句中创建的PreparedStatement对象并绑

定参数，因此，不必覆盖整个更新过程的任何任务。

public JdbcUserDao implements UserDao{

	public void insert(final User user){

		String sql ="insert into user values (?,?)";
		JdbcTemplate jdbcTemplate  = new JdbcTemplate(dataSource);

		jdbcTemplate.update(sql,new Object[]{user.getUsername(),user,getPassword()});
		
	}
}

 

 

前面介绍了三种不同的update()方法，最后一种最简单，因为不必实现任何接口，与之相反，第一种最灵活，可以在执行

PreparedStatement对象之前对它进行任意预处理，

 

4，批处理更新数据库

 

假定我们一次插入一批数据到数据库，如果多次调用insert()方法，速度会非常慢 ，因为SQL语句要重复的编译，因此，最好

在DAO接口上添加一个新的方法，插入已批量用户。

 

public interface UserDao{

	.......

	public void insert(List<User> user);

}

 

JdbcTemplate模板也为批量跟新数据提供了batchUpdate()模板方法，它需要一个sql语句和一个

BatchPreparedStatementSetter对象作为参数，这个 方法中，语句编译一次，执行多次。

public class JdbcUserDao implements UserDao{

	public void inser(final List<User> user){
		
		String sql ="insert into User values(?,?)";
		JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);

		jdbcTemplate.batchUpdate(sql,new BatchPreparedStatementSetter(){

			public int getBatchSize(){

				return user.size();
			}

			public void setValue(PreparedStatement ps,int i)throws SQLException{
		
				User user = user.get(i);		
				ps.setString(1,user.getUsername());
				ps.setString(2,user.getPassword());
			}
		});
	}
}

 

使用下面的测试数据，批量插入数据

public class Main{

	public static void main(String[] args){

		User use1 = new User("kang","fei");
		User use2 = new User("zhang","fei");

		UserDao userDao = =new JdbcUserDao();
		userDao.insert(Arrays.asList(new User[]{use2,use2}));
	}
}