Spring6 的JdbcTemplate的JDBC模板类的详细使用说明

兜兜零元  金牌会员 | 2024-5-19 23:04:52 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 873|帖子 873|积分 2619

1. Spring6 的JdbcTemplate的JDBC模板类的详细使用说明

@
目次

每博一文案
  1. 他伸直双臂，举过头顶，两只手握在一起，伸了个懒腰，望着天地交接的地方，声音飘渺，嗯，有人说高中喜欢的人是能记一辈子的。
  2. 你信吗？
  3. 他侧着头望着他，邢武对他笑，笑得那么云淡风轻，眼神却那么复杂，声音透过风有些不真切地传了过去。
  4. 你这么优秀，不能回在感情上。
  5. 那一瞬间，晴也身上仿佛迸发出耀眼自信的光芒，转过身，逆着光昂起下巴说，一辈子很长，可以做很多事，但我不会把它用来记住一个人。
  6. 我晴也不可能毁在任何事情上。
  7. 信我，我不是懦夫。
  8. 如果我敢拿未来赌一把，你会让我输吗？
  9. 晴也把选择权重新拾了起来，郑重地交还到邢武手中。
  10. 他知道邢武的担忧和闪躲，也知道他的顾虑和徘徊。
  11. 无论是他的家庭，他的出身，他的背景，让他不敢去想以后。
  12. 所以晴也把自己的决心赤裸裸地洒在这片戈壁滩上，让他清晰地感受着，神情凝重地望着邢武，身影被夕阳拉得颀长，那一刻，他只感觉到一股强大的力量撞进他的心脏。
  13. 仿佛藏着排山倒海的光束向他奔腾而来，那么强烈，那么坚定。
  14. 他的生命中从来没有出现过这样一个人，一个不惧天地万物，不怕世俗捆绑的女孩儿，一个浑身是光让他看见未来的女孩儿。
  15. 一个充满智慧，勇敢，把命运牢牢攥在手中的女孩儿。
  16. 他忽然很怕眼前的这个女孩儿，怕过了这辈子就再也遇不到了。
  17. 如果他都敢赌，他又有什么理由退缩呢？
  18.                                                         ——————《耀眼》
复制代码
JdbcTemplate 是Spring 提供的一个JDBC模板类，是对JDBC的封装，简化JDBC代码，当然，你也可以不消，可以让Spring集成其它的ORM框架，例如：MyBatis，Hibernate 等。此中JDBC关于数据库的连接也是一个紧张的内容，想要相识更多的大家可以移步至：✏️✏️✏️ JDBC_ChinaRainbowSea的博客-CSDN博客
下面我们正式开始对 JdbcTemplate 上的学习，完成增删改查。
2. 环境预备

这里，我们新建一个模块，方便学习，如下：因为我们这里是Spring6，而Spring6最低支持的JDK是17，以是我这里是 JDK17的。

新建好模块以后，我们需要导入相干的依赖，这里我们通过 maven 导入依赖。关于Maven 的内容呢，大家可以移步至：✏️✏️✏️Maven_ChinaRainbowSea的博客-CSDN博客  ，进行更多的学习相识
具体的依赖有：

  • spring context 依赖 (spring6 的依赖)
  • mysql-connector-java(关于MySQL驱动的依赖，因为我们要连接数据库，这里我们连接的是MySQL数据库)
  • spring-jdbc (spring jdbc，这个依赖中有JdbcTemplate)
  • junit (Junit4 单位测试依赖)
特殊的另有这个，也得添加上

  1. <repositories>
  2.         <repository>
  3.             <id>repository.spring.milestone</id>
  4.             <name>Spring Milestone Repository</name>
  5.             <url>https://repo.spring.io/milestone</url>
  6.         </repository>
  7.     </repositories>
复制代码
  1.     4.0.0    com.rainbowsea    spring6-009-jdbc-blog    1.0-SNAPSHOT            17        17        <repositories>
  2.         <repository>
  3.             <id>repository.spring.milestone</id>
  4.             <name>Spring Milestone Repository</name>
  5.             <url>https://repo.spring.io/milestone</url>
  6.         </repository>
  7.     </repositories>                                org.springframework            spring-context            6.0.11                                    mysql            mysql-connector-java            8.0.30                                    org.springframework            spring-jdbc            6.0.0-M2                                    junit            junit            4.13.2            test            
复制代码
3. 数据预备

首先，我们创建一个名为 spring6的数据库，想要相识SQL语句的内容的，大家可以移步至✏️✏️✏️ SQL语法学习_ChinaRainbowSea的博客-CSDN博客
  1. /* 判断该数据库是否存在，不存在，创建*/
  2. CREATE DATABASE IF NOT EXISTS spring6;
复制代码
然后在 spring6 数据库中创建一个名为 user 的数据表
  1. CREATE TABLE `user`  (
  2.   `id` int NOT NULL AUTO_INCREMENT,
  3.   `real_name` varchar(255) ,
  4.   `age` int ,
  5.   PRIMARY KEY (`id`) USING BTREE
  6. ) ;
  8. -- ----------------------------
  9. -- Records of user
  10. -- ----------------------------
  11. INSERT INTO `user` VALUES (1, '李四', 33);
  12. INSERT INTO `user` VALUES (2, '李华', 20);
  13. INSERT INTO `user` VALUES (3, '李华', 21);
复制代码


预备实体类：表user对应的实体类User。根据user 数据表布局创建对于的Bean 实体类。
注意： 这里我们界说用对应简单类型的包装类，来界说成员变量，防止数据库的数值为Null时，报错，中断。
  1. package com.rainbowsea.spring6.bean;
  4. /**
  5. * user 数据表对应的映射的 bean 对象
  6. */
  7. public class User {
  10.     // 定义包装类，作为属性类型，防止 数据库中的数值为 null，报错
  11.     private Integer id;
  12.     private String realName;
  13.     private Integer age;
  15.     public User(Integer id, String realName, Integer age) {
  16.         this.id = id;
  17.         this.realName = realName;
  18.         this.age = age;
  19.     }
  22.     public User() {
  23.     }
  26.     public Integer getId() {
  27.         return id;
  28.     }
  30.     public void setId(Integer id) {
  31.         this.id = id;
  32.     }
  34.     public String getRealName() {
  35.         return realName;
  36.     }
  38.     public void setRealName(String realName) {
  39.         this.realName = realName;
  40.     }
  42.     public Integer getAge() {
  43.         return age;
  44.     }
  46.     public void setAge(Integer age) {
  47.         this.age = age;
  48.     }
  50.     @Override
  51.     public String toString() {
  52.         return "User{" +
  53.                 "id=" + id +
  54.                 ", realName='" + realName + '\'' +
  55.                 ", age=" + age +
  56.                 '}';
  57.     }
  58. }
复制代码
配置编写相干的spring.xml的信息
JdbcTemplate 是Spring 提供好的类，这类的完整类名是：org.springframework.jdbc.core.JdbcTemplate 。这个类上的使用，我们 new 对象就好了，而Spring 可以帮我们 new 对象，以是，我们就将这个new JdbcTemplate 对象这件事交给 Spring 来做。直接将这个类配置到 spring.xml 的配置文件当中，纳入 Bean管理即可。

我们来看一下这个JdbcTemplate源码：

以是这里，我们只需要配置好 DataSource 数据源，用来连接数据库即可，将DataSource 属性进行 set 注入赋值上。可以看到JdbcTemplate中有一个DataSource属性，这个属性是数据源，我们都知道连接数据库需要Connection对象，而天生Connection对象是数据源负责的。以是我们需要给JdbcTemplate设置数据源属性。
所有的数据源都是要实现javax.sql.DataSource接口的。这个数据源可以自己写一个，也可以用写好的，比如：阿里巴巴的德鲁伊连接池，c3p0，dbcp等。我们这里自己先手写一个数据源。
自己的数据源，数据源存在的目标是为了提供 Connection 对象；只要实现了DataSource 接口的都是数据源：德鲁伊连接池，C3p0连接池，dbcp连接池，都实现了DataSource 接口
如下：

重写此中的**public Connection getConnection() throws SQLException ** 方法，注意是没有参数的。
  1. @Override
  2.     public Connection getConnection() throws SQLException {
  3.         try {
  4.             // 注册驱动
  5.             Class<?> clazz = Class.forName(driver);
  6.             // 获取数据库连接对象
  7.             Connection connection = DriverManager.getConnection(url, userName, password);
  9.             System.out.println(connection);
  10.             return connection;
  12.         } catch (Exception e) {
  13.             e.printStackTrace();
  14.         }
  15.         return null;
  16.     }
复制代码
  1. package com.rainbowsea.spring6.bean;import javax.sql.DataSource;import java.io.PrintWriter;import java.sql.Connection;import java.sql.DriverManager;import java.sql.SQLException;import java.sql.SQLFeatureNotSupportedException;import java.util.logging.Logger;/** * 自己的数据源，数据源存在的目标是为了提供 Connection 对象 * 只要实现了DataSource 接口的都是数据源 * 德鲁伊连接池，C3p0连接池，dbcp连接池，都实现了DataSource 接口 */public class MyDataSource implements DataSource {    private String driver;    private String url;    private String userName;    private String password;    public MyDataSource() {    }    public MyDataSource(String driver, String url, String userName, String password) {        this.driver = driver;        this.url = url;        this.userName = userName;        this.password = password;    }    public String getDriver() {        return driver;    }    public void setDriver(String driver) {        this.driver = driver;    }    public String getUrl() {        return url;    }    public void setUrl(String url) {        this.url = url;    }    public String getUserName() {        return userName;    }    public void setUserName(String userName) {        this.userName = userName;    }    public String getPassword() {        return password;    }    public void setPassword(String password) {        this.password = password;    }    @Override    public String toString() {        return "MyDataSource{" +                "driver='" + driver + '\'' +                ", url='" + url + '\'' +                ", userName='" + userName + '\'' +                ", password='" + password + '\'' +                '}';    }    @Override
  2.     public Connection getConnection() throws SQLException {
  3.         try {
  4.             // 注册驱动
  5.             Class<?> clazz = Class.forName(driver);
  6.             // 获取数据库连接对象
  7.             Connection connection = DriverManager.getConnection(url, userName, password);
  9.             System.out.println(connection);
  10.             return connection;
  12.         } catch (Exception e) {
  13.             e.printStackTrace();
  14.         }
  15.         return null;
  16.     }    @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;    }}
复制代码
写完数据源，我们需要把这个数据源传递给JdbcTemplate。因为JdbcTemplate中有一个DataSource属性;同时获取为该 DataSource 数据源，通过Spring的set 注入，为此中的成员变量赋值。就是连接我们MySQL数据库的一些信息。如下：
  1.         <bean id="dataSource" >
  2.             <property name="driver" value="com.mysql.cj.jdbc.Driver"></property>
  3.             <property name="url" value="jdbc:mysql://localhost:3306/spring6"></property>
  4.             <property name="userName" value="root"></property>
  5.             <property name="password" value="123"></property>
  6.         </bean>
复制代码
这时候，我们就可以将这个数据源传递给JdbcTemplate。因为JdbcTemplate中有一个DataSource属性。

  1.         <bean id="dataSource" >
  2.             <property name="driver" value="com.mysql.cj.jdbc.Driver"></property>
  3.             <property name="url" value="jdbc:mysql://localhost:3306/spring6"></property>
  4.             <property name="userName" value="root"></property>
  5.             <property name="password" value="123"></property>
  6.         </bean>                    
复制代码
这里，我们的环境预备好了，数据表也预备好了，下面就可以开始通过Spring 的JdbcTemplate 操纵数据库了（对数据库进行增删改查）的操纵了。具体内容如下。
4. 开始

4.1 从数据表中插入(添加)数据

首先，我们通过 Spring 读取上面我们配置好的spinrg.xml 文件当中的，从而实例化 JdbcTemplate 类对象。

然后使用：jdbcTemplate.update() 的方法，执行SQL语句。
需要注意的是：在Spring当中的JdbcTemplate，对于数据库上的增删改，执行SQL语句都是使用update() 的方法处理的。

  • 第一个参数：String sql
  • 第二个参数:  @Nullable Object... args 是一个可变参数(是一个数组)，表现
    表现：SQL语句当中的?  占位符的要填入的值。

返回值：int 表现修改/更新的记录条数。


  1. package com.rainbowsea.test;
  3. import org.junit.Test;
  4. import org.springframework.context.ApplicationContext;
  5. import org.springframework.context.support.ClassPathXmlApplicationContext;
  6. import org.springframework.jdbc.core.JdbcTemplate;
  8. public class JdbcTest {
  10.     @Test
  11.     public void testInsert() {
  12.         // 获取JdbcTemplate对象
  13.         ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring6.xml");
  14.         JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class);
  15.         // 执行插入操作
  16.         // 注意：insert delete update的sql语句，都是执行update方法。,? 表示占位符
  17.         // 因为 id 是自增的，所以，这里我们不赋值
  19.         String sql = "insert into user(real_name,age) values(?,?)";
  20.         // 返回修改的记录条数
  21.         int count = jdbcTemplate.update(sql,  "张三", 30);
  22.         System.out.println("插入的记录条数：" + count);
  23.     }
  24. }
复制代码

4.2 从数据表中修改数据

在Spring当中的JdbcTemplate，对于数据库上的增删改，执行SQL语句都是使用update() 的方法处理的。
我们这里：将id 为1的，real_name修改为：张小六，age 为 18
  1. package com.rainbowsea.test;
  3. import org.junit.Test;
  4. import org.springframework.context.ApplicationContext;
  5. import org.springframework.context.support.ClassPathXmlApplicationContext;
  6. import org.springframework.jdbc.core.JdbcTemplate;
  8. public class JdbcTest {
  11.     @Test
  12.     public void testUpdate() {
  13.         // 获取JdbcTemplate对象
  14.         ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring6.xml");
  15.         JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class);
  16.         // 执行插入操作
  17.         // 注意：insert delete update的sql语句，都是执行update方法。,? 表示占位符
  18.         // 执行更新操作
  19.         String sql = "update user2 set real_name = ?, age = ? where id = ?";
  20.         int count = jdbcTemplate.update(sql, "张小六", 18, 1);
  21.         System.out.println(count);
  22.     }
  23. }
复制代码

4.3 从数据表中删除数据

在Spring当中的JdbcTemplate，对于数据库上的增删改，执行SQL语句都是使用update() 的方法处理的。
我们这里：将id 为4的一条记录删除了。
  1. package com.rainbowsea.test;
  3. import org.junit.Test;
  4. import org.springframework.context.ApplicationContext;
  5. import org.springframework.context.support.ClassPathXmlApplicationContext;
  6. import org.springframework.jdbc.core.JdbcTemplate;
  8. public class JdbcTest {
  10.     @Test
  11.     public void testDelete() {
  12.         // 获取JdbcTemplate对象
  13.         ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring6.xml");
  14.         JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class);
  15.         // 执行插入操作
  16.         // 编写SQL语句，? 表示占位符
  17.         String sql = "delete from user2 where id = ?";
  18.         // 执行更新操作
  19.         // 注意：insert delete update的sql语句，都是执行update方法。
  20.         // 返回修改的记录条数
  21.         int count = jdbcTemplate.update(sql,  4);
  22.         System.out.println("插入的记录条数：" + count);
  23.     }
  24. }
复制代码

4.4 从数据表中查询一个对象

关于查询一条记录，使用 jdbcTemplate.queryForObject() 方法：


  • 第一个参数：String sql 要执行的SQL语句
  • 第二个参数：BeanPropertyRowMapper 与对应数据库表中 bean 类的相映射的类。一般用： new BeanPropertyRowMapper(T.class) 这样的对象装配上。Bean属性值和数据库记录行的映射对象。在构造方法中指定映射的对象类型。



  • 第三个参数：SQL语句当中的 ？ 占位符。可变长参数，给sql语句的占位符问号传值。
  • 返回值：运用了泛型，也就是对应数据库表中在Java当中相对应，映射的 bean 类。

这里我们查询一个id为1的，此中的ID，real_name，age 的一条记录
  1. import com.rainbowsea.spring6.bean.User;
  2. import org.junit.Test;
  3. import org.springframework.context.ApplicationContext;
  4. import org.springframework.context.support.ClassPathXmlApplicationContext;
  5. import org.springframework.jdbc.core.BeanPropertyRowMapper;
  6. import org.springframework.jdbc.core.JdbcTemplate;
  8. public class JdbcTest {
  10.     @Test
  11.     public void testSelectOne() {
  12.         // 获取JdbcTemplate对象
  13.         ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring6.xml");
  14.         JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class);
  15.         // 执行插入操作
  16.         // 编写SQL语句，? 表示占位符
  17.         String sql = "select id, real_name, age from user2 where id = ?";
  18.         // 执行更新操作
  19.         // 返回对应查询到的 Bean 类
  20.         User user = jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<>(User.class), 1);
  21.         System.out.println(user);
  22.     }
  23. }
复制代码

4.5 从数据表中查询一个值

查询数据表当中有几条记录，对应查询数据表中的一个值的内容，我们同样还是使用：jdbcTemplate.queryForObject() 方法来进行。不同的是，这个参数是两个的，是对应的类对象，

  • 比如这里我们查询的是一个数据表中有几条记录，几条记录，就是一个值了，一个数值类型的类对象了，可以是 int.class，也可以是 long.class，还可以是 short.class 因为只要是数值类型就可以了。
  • 返回值是对应类的包装类，


  1. import com.rainbowsea.spring6.bean.User;
  2. import org.junit.Test;
  3. import org.springframework.context.ApplicationContext;
  4. import org.springframework.context.support.ClassPathXmlApplicationContext;
  5. import org.springframework.jdbc.core.BeanPropertyRowMapper;
  6. import org.springframework.jdbc.core.JdbcTemplate;
  8. import java.util.List;
  10. public class JdbcTest {
  13.     /**
  14.      * 查询数据表中的一个值
  15.      */
  16.     @Test
  17.     public void testSelectOneValue() {
  18.         // 获取JdbcTemplate对象
  19.         ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring6.xml");
  20.         JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class);
  21.         // 执行插入操作
  22.         // 编写SQL语句，? 表示占位符
  23.         // 执行select
  24.         String sql = "select count(1) from user2";
  25.         // 返回对应数据类型的包装类
  26.         Integer count = jdbcTemplate.queryForObject(sql, int.class);
  27.         System.out.println(count);
  28.     }
  29. }
复制代码

用 Long.class 也是可以的。

4.6 从数据表中查询多条记录

查询数据表中的多个对象，我们就要使用：jdbcTemplate.query() 方法了

  • 第一个参数：同样还是：要执行的SQL语句
  • 第二个参数：。Bean属性值和数据库记录行的映射对象。在构造方法中指定映射的对象类型。；BeanPropertyRowMapper 与对应数据库表中 bean 类的相映射的类。一般用： new BeanPropertyRowMapper(T.class) 这样的对象装配上。
  • 返回值：是一个List 聚集了，因为我们查询到的多条记录，天然就是存储到聚集当中去了。

这里我们查询，user2 表中的所有用户的所有信息。
  1. import com.rainbowsea.spring6.bean.User;
  2. import org.junit.Test;
  3. import org.springframework.context.ApplicationContext;
  4. import org.springframework.context.support.ClassPathXmlApplicationContext;
  5. import org.springframework.jdbc.core.BeanPropertyRowMapper;
  6. import org.springframework.jdbc.core.JdbcTemplate;
  8. import java.util.List;
  10. public class JdbcTest {
  12.     /**
  13.      * 查询多条记录
  14.      */
  15.     @Test
  16.     public void testSelectAll() {
  17.         // 获取JdbcTemplate对象
  18.         ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring6.xml");
  19.         JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class);
  20.         // 执行插入操作
  21.         // 编写SQL语句，? 表示占位符
  22.         // 执行select
  23.         String sql = "select id, real_name, age from user2";
  24.         List<User> users = jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(User.class));
  25.         System.out.println(users);
  27.     }
  28. }
复制代码

4.7 从数据表中批量添加数据

对于数据表中的批量添加数据，我们这里需要用上：jdbcTemplate.batchUpdate() 方法

  • 第一个参数：String sql 要执行的SQL语句
  • 第二个参数： List batchArgs 是一个List聚集当中存储 Object[ ] 数组，注意是数组，这个List 就是，我们批量插入数据时，对于SQL语句当中的 ? 占位符的传值，因为这个参数是： List batchArgs，以是我们需要将我们 ？占位符的值，放入到List 聚集当中，再作为参数，传给jdbcTemplate.batchUpdate()  方法。


  • 返回值：就是你各个批量插入的记录的，各个成功的记录条数，比如这里我们批量添加了3条记录，那么假如三条记录都插入成功了的话，就是[1,1,1]。表现每执行一次这个："insert into user2(real_name,age) values(?,?)"; SQL语句就会影响到一条记录。
插入这条记录，产生了一条记录的影响。
三条记录，各自都是只产生了一条记录的影响


  1. import com.rainbowsea.spring6.bean.User;
  2. import org.junit.Test;
  3. import org.springframework.context.ApplicationContext;
  4. import org.springframework.context.support.ClassPathXmlApplicationContext;
  5. import org.springframework.jdbc.core.BeanPropertyRowMapper;
  6. import org.springframework.jdbc.core.JdbcTemplate;
  8. import java.util.ArrayList;
  9. import java.util.Arrays;
  10. import java.util.List;
  12. public class JdbcTest {
  15.     /**
  16.      * 批量添加数据
  17.      */
  18.     @Test
  19.     public void testAddBatch() {
  20. // 获取JdbcTemplate对象
  21.         ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring6.xml");
  22.         JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class);
  23.         // 批量添加，id 是自增的，这里可以省略
  24.         String sql = "insert into user2(real_name,age) values(?,?)";
  26.         Object[] objs1 = {"小花", 20};
  27.         Object[] objs2 = {"小明", 21};
  28.         Object[] objs3 = {"小刚", 22};
  30. // 将要修改的数据封装到 List 集合当中，再作为参数传入
  31.         List<Object[]> list = new ArrayList<>();
  32.         list.add(objs1);
  33.         list.add(objs2);
  34.         list.add(objs3);
  36.         int[] count = jdbcTemplate.batchUpdate(sql, list);
  37.         System.out.println(Arrays.toString(count));
  38.     }
  39. }
复制代码

4.8 从数据表中批量修改数据

从数据表中批量修改数据还是使用：jdbcTemplate.batchUpdate() 方法。唯一不同的就是执行的SQL语句不同而已。下面我们将id 为 5,6,7 的 age 改为 10,11,12

  1. import com.rainbowsea.spring6.bean.User;
  2. import org.junit.Test;
  3. import org.springframework.context.ApplicationContext;
  4. import org.springframework.context.support.ClassPathXmlApplicationContext;
  5. import org.springframework.jdbc.core.BeanPropertyRowMapper;
  6. import org.springframework.jdbc.core.JdbcTemplate;
  8. import java.util.ArrayList;
  9. import java.util.Arrays;
  10. import java.util.List;
  12. public class JdbcTest {
  14.     /**
  15.      * 批量修改
  16.      */
  17.     @Test
  18.     public void testUpdateBatch() {
  19.         // 获取JdbcTemplate对象
  20.         ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring6.xml");
  21.         JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class);
  22.         // 批量修改
  23.         String sql = "update user2 set age = ? where id = ?";
  24.         Object[] objs1 = { 10, 5};
  25.         Object[] objs2 = { 11, 6};
  26.         Object[] objs3 = { 12, 7};
  28.         // 将要修改的数据封装到 List 集合当中，再作为参数传入
  29.         List<Object[]> list = new ArrayList<>();
  30.         list.add(objs1);
  31.         list.add(objs2);
  32.         list.add(objs3);
  34.         int[] count = jdbcTemplate.batchUpdate(sql, list);
  35.         System.out.println(Arrays.toString(count));
  36.     }
  37. }
复制代码

4.9 从数据表中批量删除数据

从数据表中批量删除数据还是使用：jdbcTemplate.batchUpdate() 方法。唯一不同的就是执行的SQL语句不同而已。下面我们将user 数据表中的 id 为 5,6,7 的记录删除了。
  1. import com.rainbowsea.spring6.bean.User;
  2. import org.junit.Test;
  3. import org.springframework.context.ApplicationContext;
  4. import org.springframework.context.support.ClassPathXmlApplicationContext;
  5. import org.springframework.jdbc.core.BeanPropertyRowMapper;
  6. import org.springframework.jdbc.core.JdbcTemplate;
  8. import java.util.ArrayList;
  9. import java.util.Arrays;
  10. import java.util.List;
  12. public class JdbcTest {
  15.     /**
  16.      * 批量删除
  17.      */
  18.     @Test
  19.     public void testDeleteBatch() {
  20.         // 获取JdbcTemplate对象
  21.         ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring6.xml");
  22.         JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class);
  24.         // 批量删除
  25.         String sql = "delete from user2 where id = ?";
  26.         Object[] objs1 = {5};
  27.         Object[] objs2 = {6};
  28.         Object[] objs3 = {7};
  30.         // 将要修改的数据封装到 List 集合当中，再作为参数传入
  31.         List<Object[]> list = new ArrayList<>();
  32.         list.add(objs1);
  33.         list.add(objs2);
  34.         list.add(objs3);
  36.         int[] count = jdbcTemplate.batchUpdate(sql, list);
  37.         System.out.println(Arrays.toString(count));
  38.     }
  39. }
复制代码

4.10 JdbcTemplate 使用回调函数

使用回调函数，可以到场的更加细节：例如：假如你想写JDBC代码，可以使用callback回调函数
想要执行回调函数，用使用上 jdbcTemplate.execute() 方法，


  • 第一个参数是：String sql 要执行的SQL语句
  • 第二个参数是：PreparedStatementCallback action ，是个接口，我们要传其实例化对象，

PreparedStatementCallback，一般我们通常是使用 lambda 表达式 ，简化代码。


需要注意的是：注册回调函数，当execute 方法执行的时候，回调函数中的doInPreparedStatement()会被调用

  • 返回值：就是这里运用的泛型，返回值，就是你传的 T.class 的 Bean 对象。
这里我们使用回调函数，查询 user 数据表中 id 为 2的 用户的，id, real_name，age 的记录信息
  1. import com.rainbowsea.spring6.bean.User;
  2. import org.junit.Test;
  3. import org.springframework.context.ApplicationContext;
  4. import org.springframework.context.support.ClassPathXmlApplicationContext;
  5. import org.springframework.dao.DataAccessException;
  6. import org.springframework.jdbc.core.BeanPropertyRowMapper;
  7. import org.springframework.jdbc.core.JdbcTemplate;
  8. import org.springframework.jdbc.core.PreparedStatementCallback;
  10. import java.sql.PreparedStatement;
  11. import java.sql.ResultSet;
  12. import java.sql.SQLException;
  13. import java.util.ArrayList;
  14. import java.util.Arrays;
  15. import java.util.List;
  17. public class JdbcTest {
  20.     /**
  21.      * 回调函数
  22.      * 如果你想写JDBC代码，可以使用callback回调函数
  23.      */
  24.     @Test
  25.     public void testCallback() {
  26.         ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring6.xml");
  27.         JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class);
  28.         // 准备 sql语句
  29.         String sql = "select id,real_name,age from user2 where id = ?";
  31.         // 注册回调函数，当execute 方法执行的时候，回调函数中的doInPreparedStatement()会被调用
  32.         User user = jdbcTemplate.execute(sql, new PreparedStatementCallback<User>() {
  34.             @Override
  35.             public User doInPreparedStatement(PreparedStatement ps) throws SQLException, DataAccessException {
  36.                 User user = null;
  37.                 // 1 表示第一个占位符，?的下标， 为 2
  38.                 ps.setInt(1,2);
  39.                 ResultSet resultSet = ps.executeQuery();
  40.                 if(resultSet.next()) {
  41.                     int id = resultSet.getInt("id");
  42.                     String realName = resultSet.getString("real_name");
  43.                     int age = resultSet.getInt("age");
  45.                     user = new User(id,realName,age);
  46.                 }
  48.                 return user;
  49.             }
  50.         });
  52.         System.out.println(user);
  55.     }
  56. }
复制代码

4.11 JdbcTemplate 共同使用上德鲁伊连接池

上面演示的是用我们自己写的数据源。这里我们其实也是可以使用别人写好的。例如比较牛的德鲁伊连接池。
第一步：引入德鲁伊连接池的依赖。（毕竟是别人写的，我需要导入，才能使用），使用 maven 导入。
  1.         <dependency>
  2.             <groupId>com.alibaba</groupId>
  3.             <artifactId>druid</artifactId>
  4.             <version>1.1.8</version>
  5.         </dependency>
复制代码
第二步：将德鲁伊中的数据源配置到 spring.xml 配置文件中。和配置我们自己写的一样。就是一些：对应数据库的注册驱动，指明数据库的所在位置，以及连接数据库的账号和密码。
需要特殊注意的是：注意这里是:driverClassName,是简单类型进行set注入对属性赋值，简单类型可以用 value


而假如是使用：driver，用 ref了


这里我们用：driverClassName，进行简单类型的set 注入，对 this.driver 成员变量的属性赋值。
  1.         <bean id="dataSource" >
  2.             <property name="driver" value="com.mysql.cj.jdbc.Driver"></property>
  3.             <property name="url" value="jdbc:mysql://localhost:3306/spring6"></property>
  4.             <property name="userName" value="root"></property>
  5.             <property name="password" value="123"></property>
  6.         </bean>        
复制代码
下面，我们测试，使用德鲁伊数据库连接池，进行对数据库的查询：
查询id 为1的一条记录。


查询成功。
我们再使用德鲁伊进行多个数据的查询。同样也是没有问题的。

5. 总结：


  • JdbcTemplate 是Spring 提供的一个JDBC模板类，是对JDBC的封装，简化JDBC代码，当然，你也可以不消，可以让Spring集成其它的ORM框架，例如：MyBatis，Hibernate 等。
  • 使用JdbcTemplate 需要导入的如下 jar依赖
    1. 1. spring context 依赖 (spring6 的依赖)
    2. 2. mysql-connector-java(关于MySQL驱动的依赖，因为我们要连接数据库，这里我们连接的是MySQL数据库)
    3. 3. spring-jdbc (spring jdbc，这个依赖中有JdbcTemplate)
    4. 4. junit (Junit4 单元测试依赖)
    5.       
    复制代码
  • 在Spring当中的JdbcTemplate，对于数据库上的增删改，执行SQL语句都是使用update() 的方法处理的。
  • 关于查询一条记录，使用 jdbcTemplate.queryForObject() 方法：
  • 查询数据表中的多个对象，我们就要使用：jdbcTemplate.query() 方法了
  • 查询数据表当中有几条记录，对应查询数据表中的一个值的内容，我们同样还是使用：jdbcTemplate.queryForObject() 方法来进行。不同的是，这个参数是两个的，是对应的类对象。需要注意的第二个参数，使用的是：对应返回类型的 T.class 类
  • 使用回调函数，可以到场的更加细节：例如：假如你想写JDBC代码，可以使用callback回调函数
    想要执行回调函数，用使用上 jdbcTemplate.execute() 方法， 需要注意的是：注册回调函数，当execute 方法执行的时候，回调函数中的doInPreparedStatement()会被调用
  • 对于数据表中的批量添加删除修改数据，我们这里需要用上：jdbcTemplate.batchUpdate() 方法
6. 最后：

“在这个最后的篇章中，我要表达我对每一位读者的感激之情。你们的关注和回复是我创作的动力源泉，我从你们身上吸取了无尽的灵感与勇气。我会将你们的鼓励留在心底，继续在其他的领域奋斗。感谢你们，我们总会在某个时刻再次相遇。”


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？立即注册

x
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

兜兜零元

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

存储 挺好的 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表