JdbcTemplate的使用

为了使JDBC更加易于使用，Spring在JDBC API上定义了一个抽象层，为此建立一个JDBC存取框架。

JdbcTemplate默认自动提交事务。

1. JdbcTemplate常用API介绍

在JdbcTemplate中增删改操作统一调用update方法。查询操作调用queryForObject、query方法。

• 增删改操作：

• jdbcTemplate.update(String sql, Object[] args);

• String sql：要执行的update、insert、delete语句

• Object[] args：sql语句中需要的参数

• 批量增删改

• jdbcTemplate.batchUpdate(String sql, List<Object[]> args);

• String sql：要执行的update、insert、delete语句

• List<Object[]> args：要批量添加的信息集合，可以理解为List<User>

• 查询单个数值（用于聚合函数count()、avg()、sum()、min()、max()）

• jdbcTemplate.queryForObject(String sql,Class clazz,Object... args);

• String sql：要执行的sql语句

• Class clazz：要返回的类型

• Object... args：sql语句中需要的参数

• 查询单个对象

• jdbcTemplate.queryForObject(String sql, RowMapper<T> rm,Object... args);

• String sql：要执行的sql语句

• RowMapper<T> rm：将查询的结果映射到泛型T指定的实体类中。

• Object... args：sql语句中需要的参数

• 查询多个对象

• jdbcTemplate.query(String sql, RowMapper<T> rm, Object... args);

• String sql：要执行的sql语句

• RowMapper<T> rm：将查询的结果映射到泛型T指定的实体类中。

• Object... args：sql语句中需要的参数

2、添加Maven依赖

1.  
   <!-- Spring-ORM，这个依赖中包含了Spring-JDBC -->
2.  
   <dependency>
3.  
   <groupId>org.springframework</groupId>
4.  
   <artifactId>spring-orm</artifactId>
5.  
   </dependency>
6.  
    
7.  
   <!-- spring-context spring核心依赖 -->
8.  
   <dependency>
9.  
   <groupId>org.springframework</groupId>
10.  
    <artifactId>spring-context</artifactId>
11.  
    </dependency>
12.  
     
13.  
    <!-- junit依赖 单元测试 -->
14.  
    <dependency>
15.  
    <groupId>junit</groupId>
16.  
    <artifactId>junit</artifactId>
17.  
    <version>4.12</version>
18.  
    <scope>test</scope>
19.  
    </dependency>
20.  
     
21.  
    <!-- 数据源 -->
22.  
    <dependency>
23.  
    <groupId>com.alibaba</groupId>
24.  
    <artifactId>druid</artifactId>
25.  
    <version>1.1.10</version>
26.  
    </dependency>
27.  
     
28.  
    <!-- mysql连接驱动 -->
29.  
    <dependency>
30.  
    <groupId>mysql</groupId>
31.  
    <artifactId>mysql-connector-java</artifactId>
32.  
    <version>5.1.9</version>
33.  
    </dependency>

3、编写配置文件

1. 数据库相关信息properties文件

1.  
   # 用户名
2.  
   db.username=root
3.  
   # 密码
4.  
   db.password=123456
5.  
   # jdbc连接
6.  
   db.url=jdbc:mysql://localhost:3306/test
7.  
   # jdbc驱动
8.  
   db.driverClassName=com.mysql.jdbc.Driver

2）Spring配置文件

配置文件中主要包括：加载properties配置文件、装配DruidDataSource对象、装配JdbcTemplate对象。

1.  
   <?xml version="1.0" encoding="UTF-8"?>
2.  
   <beans xmlns="http://www.springframework.org/schema/beans"
3.  
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4.  
   xmlns:context="http://www.springframework.org/schema/context"
5.  
   xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd">
6.  
    
7.  
   <!-- 加载数据库配置文件 -->
8.  
   <context:property-placeholder location="classpath:db.properties"/>
9.  
    
10.  
    <!-- 装配Druid数据源 -->
11.  
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
12.  
    <property name="username" value="${db.username}"/>
13.  
    <property name="password" value="${db.password}"/>
14.  
    <property name="url" value="${db.url}"/>
15.  
    <property name="driverClassName" value="${db.driverClassName}"/>
16.  
    </bean>
17.  
     
18.  
    <!-- 装配JdbcTemplate -->
19.  
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
20.  
    <property name="dataSource" ref="dataSource"/>
21.  
    </bean>
22.  
     
23.  
    </beans>

4、测试

1.  
   @Test
2.  
   public void testJdbcTemplateApi01(){
3.  
       // 创建IOC容器
4.  
   ApplicationContext applicationContext = new ClassPathXmlApplicationContext("classpath:applicationContext.xml");
5.  
       // 获取jdbcTemplate对象
6.  
   JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class);
7.  
    
8.  
       // 增加
9.  
       String insertSql = "insert into tbl_dept(dept_name) values(?)";
10.  
        int insertCount = jdbcTemplate.update(insertSql, "业务部门");
11.  
        System.out.println("新增条数：" insertCount);
12.  
       
13.  
        // 删除
14.  
        String delSql = "delete from tbl_dept where dept_id = ?";
15.  
        int delCount = jdbcTemplate.update(delSql, 4);
16.  
        System.out.println("删除个数：" insertCount);
17.  
       
18.  
        // 修改
19.  
        String updateSql = "update tbl_dept set dept_name = ? where dept_id = ?";
20.  
        int updateCount = jdbcTemplate.update(updateSql, "人事2部门", 3);
21.  
        System.out.println("修改个数：" updateCount);
22.  
       
23.  
        // 批量新增数据
24.  
        String insertEmpSql = "insert into tbl_employee(last_name,email,salary,dept_id) values(?,?,?,?)";
25.  
        List<Object[]> args = new ArrayList<>();
26.  
        args.add(new Object[]{"zs","zs@163.com",500,1});
27.  
        args.add(new Object[]{"ls","ls@163.com",500,2});
28.  
        args.add(new Object[]{"ww","ww@163.com",500,3});
29.  
        args.add(new Object[]{"zl","zl@163.com",500,3});
30.  
       
31.  
        int[] batchUpdateCount = jdbcTemplate.batchUpdate(insertEmpSql, args);
32.  
        System.out.println("批量新增个数：" Arrays.toString(batchUpdateCount));
33.  
     
34.  
    // 查询单个数值
35.  
    String querySingleNum = "select count(*) from tbl_employee";
36.  
        // 返回查询到的记录总数
37.  
    Integer count = jdbcTemplate.queryForObject(querySingleNum, Integer.class);
38.  
    System.out.println(count);
39.  
     
40.  
    // 查询单个对象
41.  
    String querySingleObject = "select id,last_name as lastName,email,salary,dept_id as deptId from tbl_employee where id = ?";
42.  
        // 执行sql后，通过rowMapper将结果映射到实体类对象中并返回
43.  
    Employee employee = jdbcTemplate.queryForObject(querySingleObject, new BeanPropertyRowMapper<>(Employee.class), 3);
44.  
    System.out.println(employee);
45.  
     
46.  
    // 查询多个对象
47.  
    String queryObjects = "select id,last_name,email,salary,dept_id from tbl_employee";
48.  
        // 执行sql后，通过rowMapper将结果映射到实体类对象，将实体类对象放入List集合中并返回
49.  
    List<Employee> employeeList = jdbcTemplate.query(queryObjects, new BeanPropertyRowMapper<>(Employee.class));
50.  
    for (Employee emp : employeeList) {
51.  
    System.out.println(emp);
52.  
    }
53.  
    }