Spring知识点总结(五)Spring整合JDBC

时间:2022-09-14 14:57:49

 1. 回顾JDBC
        a. java操作关系型数据的API。导入相关数据库的驱动包后可以通过JDBC提供的接口来操作数据库。
        b. 实现JDBC的六个步骤
            注册数据库驱动
            获取数据库连接
            获取传输器对象
            传输sql执行获取结果集对象
            遍历结果集获取信息
            关闭资源
        c. 数据库连接池(数据源)
    C3P0连接池

2.Spring整合JDBC

      a. 导入相关开发包
            Spring知识点总结(五)Spring整合JDBC


        b. 将数据源交于Spring管理


            Spring知识点总结(五)Spring整合JDBC

Spring知识点总结(五)Spring整合JDBC


        c.通过spring获取数据源,获取连接,操作数据库

Spring知识点总结(五)Spring整合JDBC

3.Spring中的JDBC模板类

        使用模板类,能够极大的简化原有JDBC的编程过程,让数据库操作变得简单.
        a. 在Spring中配置JDBC模板类
            Spring知识点总结(五)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);
}