13 JdbcTemplate

JdbcTemplate是Spring提供的一个JDBC模板类，是对JDBC的封装，简化JDBC代码。
当然，你也可以不用，可以让 Spring 集成其它的 ORM 框架，例如：MyBatis、Hibernate 等。
接下来我们简单来学习一下，使用 JdbcTemplate 完成增删改查。

13.1 环境准备¶

数据库表：t_user
![[13.01-1.png]] IDEA 中新建模块：spring 6-007-jdbc
![[13.01-2.png]]

引入相关依赖：¶

<?xml version="1.0" encoding="UTF-8"?>  
<project xmlns="http://maven.apache.org/POM/4.0.0"  
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">  
    <modelVersion>4.0.0</modelVersion>  

    <groupId>com.powernode</groupId>  
    <artifactId>spring6-007-jdbc</artifactId>  
    <version>1.0-SNAPSHOT</version>  
    <packaging>jar</packaging>  

    <repositories>  
        <repository>  
            <id>repository.spring.milestone</id>  
            <name>Spring Milestone Repository</name>  
            <url>https://repo.spring.io/milestone</url>  
        </repository>  
    </repositories>  

    <dependencies>  
        <dependency>  
            <groupId>org.springframework</groupId>  
            <artifactId>spring-context</artifactId>  
            <version>6.0.0-M2</version>  
        </dependency>  
        <dependency>  
            <groupId>junit</groupId>  
            <artifactId>junit</artifactId>  
            <version>4.13.2</version>  
            <scope>test</scope>  
        </dependency>  
        <dependency>  
            <groupId>mysql</groupId>  
            <artifactId>mysql-connector-java</artifactId>  
            <version>8.0.30</version>  
        </dependency>  
        <dependency>  
            <groupId>org.springframework</groupId>  
            <artifactId>spring-jdbc</artifactId>  
            <version>6.0.0-M2</version>  
        </dependency>  
    </dependencies>  
</project>

准备实体类：表 t_user 对应的实体类 User。¶

package com.powernode.spring6.bean;

/**
 * @author 动力节点
 * @version 1.0
 * @className User
 * @since 1.0
 */
public class User {
    private Integer id;
    private String realName;
    private Integer age;

    @Override
    public String toString() {
        return "User{" +
                "id=" + id +
                ", realName='" + realName + '\'' +
                ", age=" + age +
                '}';
    }

    public User() {
    }

    public User(Integer id, String realName, Integer age) {
        this.id = id;
        this.realName = realName;
        this.age = age;
    }

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getRealName() {
        return realName;
    }

    public void setRealName(String realName) {
        this.realName = realName;
    }

    public Integer getAge() {
        return age;
    }

    public void setAge(Integer age) {
        this.age = age;
    }
}

编写 Spring 配置文件：¶

JdbcTemplate 是 Spring 提供好的类，这类的完整类名是：org.springframework.jdbc.core.JdbcTemplate

我们怎么使用这个类呢？new 对象就可以了。怎么 new 对象，Spring 最在行了。直接将这个类配置到 Spring 配置文件中，纳入 Bean 管理即可。

<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
</beans>

JdbcTemplate 源码¶

![[13.01-3.png]] ![[13.01-4.png]]

可以看到 JdbcTemplate 中有一个 DataSource 属性，这个属性是数据源，我们都知道连接数据库需要 Connection 对象，而生成 Connection 对象是数据源负责的。 所以我们需要给 JdbcTemplate 设置数据源属性。

所有的数据源都是要实现 javax.sql.DataSource 接口的。 这个数据源可以自己写一个，也可以用写好的，比如：阿里巴巴的德鲁伊连接池，c 3 p 0，dbcp 等。 我们这里自己先手写一个数据源。

自定义数据源：¶

```Java title:MyDataSource.java package com.powernode.spring6.jdbc; import java.sql.SQLFeatureNotSupportedException; import java.util.logging.Logger;

/** * @author 动力节点 * @version 1.0 * @className MyDataSource * @since 1.0 */ public class MyDataSource implements DataSource { private String driver; private String url; private String username; private String password;

// 提供4个setter方法
public void setDriver(String driver) {
    this.driver = driver;
}

public void setUrl(String url) {
    this.url = url;
}

public void setUsername(String username) {
    this.username = username;
}

public void setPassword(String password) {
    this.password = password;
}

// 重点写怎么获取Connection对象就行。其他方法不用管。
@Override
public Connection getConnection() throws SQLException {
    try {
        Class.forName(driver);
        Connection conn = DriverManager.getConnection(url, username, password);
        return conn;
    } catch (Exception e) {
        e.printStackTrace();
    }
    return null;
}

@Override
public Connection getConnection(String username, String password) throws SQLException {
    return null;
}

@Override
public PrintWriter getLogWriter() throws SQLException {
    return null;
}

@Override
public void setLogWriter(PrintWriter out) throws SQLException {
}

@Override
public void setLoginTimeout(int seconds) throws SQLException {
}

@Override
public int getLoginTimeout() throws SQLException {
    return 0;
}

@Override
public Logger getParentLogger() throws SQLFeatureNotSupportedException {
    return null;
}

@Override
public T unwrap(Class iface) throws SQLException {
    return null;
}

@Override
public boolean isWrapperFor(Class iface) throws SQLException {
    return false;
}

} ```

Spring 配置文件：¶

xml <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd"> </beans>

到这里环境就准备好了。

13.2 新增¶

编写测试程序：¶

```Java title:JdbcTest.java package com.powernode.spring6.test;

import org.junit.Test; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; import org.springframework.jdbc.core.JdbcTemplate;

/** * @author 动力节点 * @version 1.0 * @className JdbcTest * @since 1.0 */ public class JdbcTest { @Test public void testInsert(){ // 获取JdbcTemplate对象 ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring.xml"); JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class); // 执行插入操作 // 注意：insert delete update的sql语句，都是执行update方法。 String sql = "insert into t_user(id,real_name,age) values(?,?,?)"; int count = jdbcTemplate.update(sql, null, "张三", 30); System.out.println("插入的记录条数：" + count); } }

`update` 方法有两个参数：  
- 第一个参数：要执行的 SQL 语句。（SQL 语句中可能会有占位符 `?` ）  
- 第二个参数：可变长参数，参数的个数可以是 0 个，也可以是多个。一般是 SQL 语句中有几个问号，则对应几个参数。  


---
## 13.3 修改  

```Java title:testUpdate.java
@Test
public void testUpdate(){
    // 获取JdbcTemplate对象
    ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring.xml");
    JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class);
    // 执行更新操作
    String sql = "update t_user set real_name = ?, age = ? where id = ?";
    int count = jdbcTemplate.update(sql, "张三丰", 55, 1);
    System.out.println("更新的记录条数：" + count);
}

执行结果：¶

![[13.04-1.png]]

13.4 删除¶

```java title:删除记录 @Test
public void testDelete(){
// 获取JdbcTemplate对象
ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring.xml");
JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class);
// 执行delete
String sql = "delete from t_user where id = ?";
int count = jdbcTemplate.update(sql, 1);
System.out.println("删除了几条记录：" + count);
}

执行结果：
![[13.04-2.png]]


---
## 13.5 查询一个对象

```java title:查询单个对象
@Test  
public void testSelectOne(){  
    // 获取JdbcTemplate对象  
    ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring.xml");  
    JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class);  
    // 执行select  
    String sql = "select id, real_name, age from t_user where id = ?";  
    User user = jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<>(User.class), 2);  
    System.out.println(user);  
}

执行结果： ![[13.05-1.png]]

queryForObject 方法三个参数：
- 第一个参数：sql 语句
- 第二个参数：Bean 属性值和数据库记录行的映射对象。在构造方法中指定映射的对象类型。
- 第三个参数：可变长参数，给 sql 语句的占位符问号传值。

13.6 查询多个对象¶

```java title:查询多个对象 @Test
public void testSelectAll(){
// 获取JdbcTemplate对象
ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring.xml");
JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class);
// 执行select
String sql = "select id, real_name, age from t_user";
List users = jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(User.class));
System.out.println(users);
}

执行结果：
![[13.06-1.png]]


---
## 13.7 查询一个值

```java title:查询单个值
@Test  
public void testSelectOneValue(){  
    // 获取JdbcTemplate对象  
    ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring.xml");  
    JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class);  
    // 执行select  
    String sql = "select count(1) from t_user";  
    Integer count = jdbcTemplate.queryForObject(sql, int.class); // 这里用Integer.class也可以  
    System.out.println("总记录条数：" + count);  
}

执行结果： ![[13.07-1.png]]

13.8 批量添加¶

```java title:批量添加记录 @Test
public void testAddBatch(){
// 获取JdbcTemplate对象
ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring.xml");
JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class);
// 批量添加
String sql = "insert into t_user(id,real_name,age) values(?,?,?)";

Object[] objs1 = {null, "小花", 20};  
Object[] objs2 = {null, "小明", 21};  
Object[] objs3 = {null, "小刚", 22};  
List list = new ArrayList<>();  
list.add(objs1);  
list.add(objs2);  
list.add(objs3);

int[] count = jdbcTemplate.batchUpdate(sql, list);  
System.out.println(Arrays.toString(count));

} ``` 执行结果： ![[13.08-1.png]]

13.9 批量修改¶

java title:批量修改记录 @Test public void testUpdateBatch(){ // 获取JdbcTemplate对象 ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring.xml"); JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class); // 批量修改 String sql = "update t_user set real_name = ?, age = ? where id = ?"; Object[] objs1 = {"小花11", 10, 2}; Object[] objs2 = {"小明22", 12, 3}; Object[] objs3 = {"小刚33", 9, 4}; List list = new ArrayList<>(); list.add(objs1); list.add(objs2); list.add(objs3); int[] count = jdbcTemplate.batchUpdate(sql, list); System.out.println(Arrays.toString(count)); }

执行结果： ![[13.09-1.png]]

13.10 批量删除¶

```java title:批量删除记录 @Test
public void testDeleteBatch(){
// 获取JdbcTemplate对象
ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring.xml");
JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class);
// 批量删除
String sql = "delete from t_user where id = ?";
Object[] objs1 = {2};
Object[] objs2 = {3};
Object[] objs3 = {4};
List list = new ArrayList<>();
list.add(objs1);
list.add(objs2);
list.add(objs3);
int[] count = jdbcTemplate.batchUpdate(sql, list);
System.out.println(Arrays.toString(count));
}

执行结果：
![[13.10-1.png]]


---
## 13.11 使用回调函数

使用回调函数，可以参与的更加细节：

```java title:使用回调函数
@Test  
public void testCallback(){  
    // 获取JdbcTemplate对象  
    ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring.xml");  
    JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class);  
    String sql = "select id, real_name, age from t_user where id = ?";  

    User user = jdbcTemplate.execute(sql, new PreparedStatementCallback() {  
        @Override  
        public User doInPreparedStatement(PreparedStatement ps) throws SQLException, DataAccessException {  
            User user = null;  
            ps.setInt(1, 5);  
            ResultSet rs = ps.executeQuery();  
            if (rs.next()) {  
                user = new User();  
                user.setId(rs.getInt("id"));  
                user.setRealName(rs.getString("real_name"));  
                user.setAge(rs.getInt("age"));  
            }  
            return user;  
        }  
    });  
    System.out.println(user);  
}

执行结果： ![[13.11-1.png]]

13.12 使用德鲁伊连接池¶

之前数据源是用我们自己写的。也可以使用别人写好的。例如比较牛的德鲁伊连接池。
第一步：引入德鲁伊连接池的依赖。（毕竟是别人写的）

```xml title:引入德鲁伊依赖
com.alibaba
druid
1.1.8

第二步：将德鲁伊中的数据源配置到 spring 配置文件中。和配置我们自己写的一样。

```xml title:配置德鲁伊数据源
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
</beans>

测试结果： ![[13.12-1.png]]