1. 回顾JDBC
a. java操作关系型数据的API。导入相关数据库的驱动包后可以通过JDBC提供的接口来操作数据库。
b. 实现JDBC的六个步骤
注册数据库驱动
获取数据库连接
获取传输器对象
传输sql执行获取结果集对象
遍历结果集获取信息
关闭资源
c. 数据库连接池(数据源)
C3P0连接池
2.Spring整合JDBC
a. 导入相关开发包
b. 将数据源交于Spring管理
c.通过spring获取数据源,获取连接,操作数据库
3.Spring中的JDBC模板类
使用模板类,能够极大的简化原有JDBC的编程过程,让数据库操作变得简单.
a. 在Spring中配置JDBC模板类
b. 使用JDBC模板类实现增删改查
@Test
public void test02() throws SQLException{
DataSource source = (DataSource) context.getBean("dataSource");
Connection conn = source.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from users");
ResultSet rs = ps.executeQuery();
while(rs.next()){
int id = rs.getInt("id");
String name = rs.getString("name");
int age = rs.getInt("age");
User user = new User(id,name,age);
System.out.println(user);
}
} @Test
public void test03() throws SQLException{
JdbcTemplate jdbcTemplate = (JdbcTemplate) context.getBean("jdbcTemplate");
List<Map<String,Object>> list = jdbcTemplate.queryForList("select * from users");
System.out.println(list);
}
@Test
public void test04() throws SQLException{
JdbcTemplate jdbcTemplate = (JdbcTemplate) context.getBean("jdbcTemplate");
SqlRowSet srs = jdbcTemplate.queryForRowSet("select * from users where id = ?",2);
srs.next();
System.out.println(srs.getString("name"));
}
@Test
public void test05() throws SQLException{
JdbcTemplate jdbcTemplate = (JdbcTemplate) context.getBean("jdbcTemplate");
int n = jdbcTemplate.update("insert into users values (null,?,?)", "ddd",23);
System.out.println("修改成功,影响到的行数为:"+n);
}
@Test
public void test06() throws SQLException{
JdbcTemplate jdbcTemplate = (JdbcTemplate) context.getBean("jdbcTemplate");
int n = jdbcTemplate.update("update users set age = ? where id = ?", 33,4);
System.out.println("修改成功,影响到的行数为:"+n);
}
@Test
public void test07() throws SQLException{
JdbcTemplate jdbcTemplate = (JdbcTemplate) context.getBean("jdbcTemplate");
int n = jdbcTemplate.update("delete from users where id = ?", 4);
System.out.println("修改成功,影响到的行数为:"+n);
}
c. 使用RowMapper封装bean
RowMapper接口定义了对象到列的映射关系,可以帮助我们在查询时自动封装bean。
public class UserRowMapper implements RowMapper<User> { @Override
public User mapRow(ResultSet rs, int i) throws SQLException {
User user = new User();
user.setId(rs.getInt("id"));
user.setName(rs.getString("name"));
user.setAge(rs.getInt("age"));
return user;
} } /**
* 使用RowMap封装bean
*/
@Test
public void test08(){
JdbcTemplate jdbcTemplate = (JdbcTemplate) context.getBean("jdbcTemplate");
List<User> list = jdbcTemplate.query("select * from users",new UserRowMapper());
System.out.println(list);
}
/**
* 使用RowMap封装bean
*/
@Test
public void test09(){
JdbcTemplate jdbcTemplate = (JdbcTemplate) context.getBean("jdbcTemplate");
User user = jdbcTemplate.queryForObject("select * from users where id = ?",new UserRowMapper(),2);
System.out.println(user);
}
d. 使用BeanPropertyRowMapper自动进行映射
BeanPropertyRowMapper内部可以使用指定类进行反射(内省)来获知类内部的属性信息,自动映射到表的列。使用它一定要注意,类的属性名要和对应表的列名必须对应的上,否则属性无法自动映射。BeanPropertyRowMapper底层通过反射(内省)来实现,相对于之前自己写的RowMapper效率比较低。
/**
* 通过BeanPropertyRowMapper实现自动封装bean
*/
@Test
public void test10(){
JdbcTemplate jdbcTemplate = (JdbcTemplate) context.getBean("jdbcTemplate");
List<User> list = jdbcTemplate.query("select * from users", new BeanPropertyRowMapper(User.class));
System.out.println(list);
}
/**
* 通过BeanPropertyRowMapper实现自动封装bean
*/
@Test
public void test11(){
JdbcTemplate jdbcTemplate = (JdbcTemplate) context.getBean("jdbcTemplate");
User user = jdbcTemplate.queryForObject("select * from users where id = ?", new BeanPropertyRowMapper(User.class),2);
System.out.println(user);
}