【Spring5】使用JdbcTemplate操作mysql数据库

男娘i 2023-09-23 15:18 112阅读 0赞

![在这里插入图片描述][c280b56967794581bf00941877068b1f.png]

--------------------

### 文章目录 ###

*  1 JdbcTemplate简介及操作准备
 *  2 添加操作
 *  3 修改与删除操作
 *  4 数据库查询操作
 *   *  4.1 返回一个值
     *  4.2 返回对象
     *  4.3 返回集合
 *  5 批量操作
 *   *  5.1 批量添加与修改
     *  5.2 批量修改与批量删除
 *  写在最后

--------------------

# 1 JdbcTemplate简介及操作准备 #

Spring框架对JDBC进行封装，使用JdbcTemplate方便对数据库的操作。

**操作准备：**

**1.导入相关依赖，文末附下载链接。**  
![在这里插入图片描述][7126e13bdc614093949784c5d673668d.png]

**2.创建数据库，便于使用。以在mysql数据库中创建user\_db为例。**  
![在这里插入图片描述][39d116030b224b2a81bdeb5736d79bcc.png]

3.配置xml文件，添加数据库连接相关信息，如密码用户名等。**（连接池的配置）**  
![在这里插入图片描述][f395455c4a924b7c8485f8a909c3d493.png]

**4.配置JdbcTemplate对象，注入DataSource。**  
![在这里插入图片描述][bc2625722a4a42e78d89ca596c805524.png]

5.创建一个Service类，创建Dao类，在Dao类中注入jdbcTemplate对象。需要开启组件扫描，完整的spring配置文件如下：  
![在这里插入图片描述][5b84c03836f0450e84881eabe695a56f.png]

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xmlns:context="http://www.springframework.org/schema/context"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                                http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
        
        <context:component-scan base-package="com.ithxh.spring5"></context:component-scan>
    
    
        
        <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
              destroy-method="close">
            <property name="url" value="jdbc:mysql:///user_db"/>
            <property name="username" value="root"/>
            <property name="password" value="111"/>
            <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
        </bean>
    
        
        <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
            
            <property name="dataSource" ref="dataSource"></property>
        </bean>
    </beans>

6.在各类上添加对应的注解。  
![在这里插入图片描述][37d3f66e1d354b14a179063a68cec123.png]

![在这里插入图片描述][9657fe1e2f6f476c83aaeb70ef3d6433.png]

至此，准备工作就完成啦！

--------------------

# 2 添加操作 #

1.在user\_db数据库中创建t\_user表，sql语句如下：

CREATE TABLE t_user(
        user_id BIGINT PRIMARY KEY NOT NULL ,
        username VARCHAR(100) NOT NULL ,
        ustatus VARCHAR(50) NOT NULL
    )

2.新建一个包entity用于存放实体类，创建t\_user表对应的实体类User，并添加相应的set、get方法。  
![在这里插入图片描述][ff9ba21d53974491a3ee253cfd74a87a.png]

3.编写service和dao，在dao中进行数据库的添加操作。 UserDao接口声明add方法，UserService进行添加操作，而 **UserDaoImp具体实现数据库的添加操作。** 需要使用jdbcTemplate的update方法。  
![在这里插入图片描述][09eda9ef3e6d4e86bbcae4dd339e42d4.png]  
第一个参数为编写的sql语句，第二个参数为可变参数，用于设置值。

![在这里插入图片描述][587e9b439645413781dde219c34f01a0.png]  
具体代码如下：  
UserDao

import com.ithxh.spring5.entity.User;
    
    /**
     * @author 兴趣使然黄小黄
     * @version 1.0
     */
    public interface UserDao {
        
        void add(User user);
    }

UserDaoImp

import com.ithxh.spring5.entity.User;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.jdbc.core.JdbcTemplate;
    import org.springframework.stereotype.Repository;
    
    /**
     * @author 兴趣使然黄小黄
     * @version 1.0
     */
    @Repository
    public class UserDaoImp implements UserDao{
        
    
        //注入JdbcTemplate
        @Autowired
        private JdbcTemplate jdbcTemplate;
    
        //实现添加的方法
        @Override
        public void add(User user) {
        
            //编写sql语句
            String sql = "insert into t_user values(?,?,?)";
            //调用方法实现
            Object[] args = {
        user.getUserId(), user.getUsername(), user.getUstatus()};
            int update = jdbcTemplate.update(sql, args);//返回影响行数
            System.out.println("影响的行数: " + update);
        }
    }

UserService

import com.ithxh.spring5.dao.UserDao;
    import com.ithxh.spring5.entity.User;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    /**
     * @author 兴趣使然黄小黄
     * @version 1.0
     */
    @Service
    public class UserService {
        
    
        //注入dao
        @Autowired
        private UserDao userDao;
    
        //添加的方法
        public void addUser(User user){
        
            userDao.add(user);
        }
    }

4.编写测试类，尝试给表添加数据。

@Test
        public void testJdbcTemplate(){
        
            ApplicationContext context =
                    new ClassPathXmlApplicationContext("bean.xml");
            UserService userService = context.getBean("userService", UserService.class);
            User user = new User();
            user.setUserId("120");
            user.setUsername("黄小黄");
            user.setUstatus("true");
            userService.addUser(user);
        }

![在这里插入图片描述][972c049d64e047c1837adfa015bd296b.png]  
![请添加图片描述][26f621f60ea549c2bb0863da6af32694.png]

--------------------

# 3 修改与删除操作 #

修改与删除操作大体与添加操作一致，只需要修改相应的sql语句。这里对核心代码进行简述：

**修改和删除操作**

UserDaoImp中实现修改和删除的方法

//实现修改的方法
        @Override
        public void update(User user) {
        
            String sql = "update t_user set user_id = ?, username = ?, ustatus = ?";
            Object[] args = {
        user.getUserId(), user.getUsername(), user.getUstatus()};
            int update = jdbcTemplate.update(sql, args);
            System.out.println("影响的行数: " + update);
        }
    
        //实现删除的方法
        @Override
        public void delete(String id) {
        
            String sql = "delete from t_user where user_id = ?";
            int update = jdbcTemplate.update(sql, id);
            System.out.println(update);
        }

需要注意，UserDao应该对修改和删除方法进行声明，UserService中则需要像这样，调用UserDaoImp中的方法：  
![在这里插入图片描述][160742a1ee95496dbd80350f09c531c4.png]

测试修改：

@Test
        public void testJdbcTemplate(){
        
            ApplicationContext context =
                    new ClassPathXmlApplicationContext("bean.xml");
            UserService userService = context.getBean("userService", UserService.class);
            User user = new User();
            user.setUserId("111");
            user.setUsername("懒羊羊");
            user.setUstatus("true");
            userService.updateUser(user);
        }

![在这里插入图片描述][0fb79524bea34bb4b653779b73c28030.png]

测试删除：

![在这里插入图片描述][c6f1d39060ff4f3faf34b49edf455b89.png]

--------------------

# 4 数据库查询操作 #

## 4.1 返回一个值 ##

示例：查询表中有多少条记录，返回的是一个值，表示表中数据的条数

//查询有多少条记录
        @Override
        public int findCountUser() {
        
            String sql = "select count(*) from t_user";
            Integer res = jdbcTemplate.queryForObject(sql, Integer.class);//第二个参数是返回值类型
            return res;
        }

## 4.2 返回对象 ##

示例：查询用户详细信息。

通过jdbcTemlate中的queryForObject方法实现：  
![在这里插入图片描述][6ea0f9c724aa45e3ba243a5fad3e00ef.png]

*  第一个参数：sql语句；
 *  第二个参数：RowMapper，是一个接口，返回不同类型的数据，使用这个接口的实现类完成数据的封装。
 *  第三个参数：sql语句值。

首先先在数据库中t\_user表插入如下信息：

INSERT INTO t_user VALUES (111, '黄小黄', 'true');
    INSERT INTO t_user VALUES (222, '懒羊羊', 'true');

在UserDao中声明，UserDaoImp中实现查询方法，UserService使用：

//查询返回对象
        @Override
        public User findUserInfo(String id) {
        
            String sql = "select * from t_user where user_id = ?";
            User user = jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<User>(User.class), id);
            return user;
        }

查询测试：

![在这里插入图片描述][357a669a538f46278b494724e88743b2.png]

## 4.3 返回集合 ##

与返回对象类似，这里以查询user信息为例，返回t\_user中的所有记录

通过jdbcTemlate中的query方法实现：  
![在这里插入图片描述][c5ab9e890ea64641b454bb2264e688db.png]

*  第一个参数：sql语句；
 *  第二个参数：RowMapper，是一个接口，返回不同类型的数据，使用这个接口的实现类完成数据的封装。
 *  第三个参数：sql语句值（没有可以省略）。

在UserDao中声明，UserDaoImp中实现查询方法，UserService使用：

//查询返回集合
        @Override
        public List<User> findAllUser() {
        
            String sql = "select * from t_user";
            List<User> userList = jdbcTemplate.query(sql, new BeanPropertyRowMapper<User>(User.class));
            return userList;
        }

测试并遍历：

![在这里插入图片描述][f5c44f0651854441b791d16992c1dea2.png]

--------------------

# 5 批量操作 #

对表中多条记录进行操作，批量操作主要通过javaTemplate中的batchUpdate方法实现  
![在这里插入图片描述][abfc48652add49c398acc0931e4ba27b.png]

*  第一个参数：sql语句；
 *  第二个参数：List集合，添加多条记录数据。

## 5.1 批量添加与修改 ##

UserDaoImp类中批量添加的代码如下：

//批量添加
        @Override
        public void batchAddUser(List<Object[]> batchArgs) {
        
            String sql = "insert into t_user values(?,?,?)";
            int[] update = jdbcTemplate.batchUpdate(sql, batchArgs);
            System.out.println("影响的行数: " + update);
        }

测试类中批量添加：

@Test
        public void testJdbcTemplate(){
        
            ApplicationContext context =
                    new ClassPathXmlApplicationContext("bean.xml");
            UserService userService = context.getBean("userService", UserService.class);
            //向表中添加三条记录
            List<Object[]> batchArgs = new ArrayList<>();
            Object[] o1 = {
        1, "nezuko", "true"};
            Object[] o2 = {
        2, "dog", "true"};
            Object[] o3 = {
        3, "participant", "true"};
            batchArgs.add(o1);
            batchArgs.add(o2);
            batchArgs.add(o3);
            userService.batchAdd(batchArgs);
        }

![在这里插入图片描述][aa85de1d507146cebca83976f6efede0.png]  
![在这里插入图片描述][254f3f98a3a4452b9049dc4a61dbb3c9.png]

## 5.2 批量修改与批量删除 ##

批量修改与批量删除与批量添加类似，只需要更改相应的sql语句，这里只展示核心代码：

**批量修改**

//批量修改
        @Override
        public void batchUpdate(List<Object[]> batchArgs) {
        
            String sql = "update t_user set username = ?, ustatus = ? where user_id = ?";
            int[] update = jdbcTemplate.batchUpdate(sql, batchArgs);
            System.out.println("影响的行数: " + Arrays.toString(update));
        }

**批量删除**

//批量删除
        @Override
        public void batchDelete(List<Object[]> batchArgs) {
        
            String sql = "delete from t_user where user_id = ?";
            int[] update = jdbcTemplate.batchUpdate(sql, batchArgs);
            System.out.println("影响的行数: " + Arrays.toString(update));
        }

--------------------

# 写在最后 #

至此，使用JdbcTemplate进行数据库简单的增删改查操作已经讲解完了，下一节将会继续讲解有关事务的操作，JdbcTemplate实验相关环境依赖已经上传，下载链接附上：[druid-1.1.9.jar+mysql-connector-java-8.0.29.jar等JdbcTempate操作资源 ][druid-1.1.9.jar_mysql-connector-java-8.0.29.jar_JdbcTempate_]

![在这里插入图片描述][7e0ff0501697426a84cd0a1f4eecfdc1.gif_pic_center]

[c280b56967794581bf00941877068b1f.png]: https://img-blog.csdnimg.cn/c280b56967794581bf00941877068b1f.png
[7126e13bdc614093949784c5d673668d.png]: https://img-blog.csdnimg.cn/7126e13bdc614093949784c5d673668d.png
[39d116030b224b2a81bdeb5736d79bcc.png]: https://img-blog.csdnimg.cn/39d116030b224b2a81bdeb5736d79bcc.png
[f395455c4a924b7c8485f8a909c3d493.png]: https://img-blog.csdnimg.cn/f395455c4a924b7c8485f8a909c3d493.png
[bc2625722a4a42e78d89ca596c805524.png]: https://img-blog.csdnimg.cn/bc2625722a4a42e78d89ca596c805524.png
[5b84c03836f0450e84881eabe695a56f.png]: https://img-blog.csdnimg.cn/5b84c03836f0450e84881eabe695a56f.png
[37d3f66e1d354b14a179063a68cec123.png]: https://img-blog.csdnimg.cn/37d3f66e1d354b14a179063a68cec123.png
[9657fe1e2f6f476c83aaeb70ef3d6433.png]: https://img-blog.csdnimg.cn/9657fe1e2f6f476c83aaeb70ef3d6433.png
[ff9ba21d53974491a3ee253cfd74a87a.png]: https://img-blog.csdnimg.cn/ff9ba21d53974491a3ee253cfd74a87a.png
[09eda9ef3e6d4e86bbcae4dd339e42d4.png]: https://img-blog.csdnimg.cn/09eda9ef3e6d4e86bbcae4dd339e42d4.png
[587e9b439645413781dde219c34f01a0.png]: https://img-blog.csdnimg.cn/587e9b439645413781dde219c34f01a0.png
[972c049d64e047c1837adfa015bd296b.png]: https://img-blog.csdnimg.cn/972c049d64e047c1837adfa015bd296b.png
[26f621f60ea549c2bb0863da6af32694.png]: https://img-blog.csdnimg.cn/26f621f60ea549c2bb0863da6af32694.png
[160742a1ee95496dbd80350f09c531c4.png]: https://img-blog.csdnimg.cn/160742a1ee95496dbd80350f09c531c4.png
[0fb79524bea34bb4b653779b73c28030.png]: https://img-blog.csdnimg.cn/0fb79524bea34bb4b653779b73c28030.png
[c6f1d39060ff4f3faf34b49edf455b89.png]: https://img-blog.csdnimg.cn/c6f1d39060ff4f3faf34b49edf455b89.png
[6ea0f9c724aa45e3ba243a5fad3e00ef.png]: https://img-blog.csdnimg.cn/6ea0f9c724aa45e3ba243a5fad3e00ef.png
[357a669a538f46278b494724e88743b2.png]: https://img-blog.csdnimg.cn/357a669a538f46278b494724e88743b2.png
[c5ab9e890ea64641b454bb2264e688db.png]: https://img-blog.csdnimg.cn/c5ab9e890ea64641b454bb2264e688db.png
[f5c44f0651854441b791d16992c1dea2.png]: https://img-blog.csdnimg.cn/f5c44f0651854441b791d16992c1dea2.png
[abfc48652add49c398acc0931e4ba27b.png]: https://img-blog.csdnimg.cn/abfc48652add49c398acc0931e4ba27b.png
[aa85de1d507146cebca83976f6efede0.png]: https://img-blog.csdnimg.cn/aa85de1d507146cebca83976f6efede0.png
[254f3f98a3a4452b9049dc4a61dbb3c9.png]: https://img-blog.csdnimg.cn/254f3f98a3a4452b9049dc4a61dbb3c9.png
[druid-1.1.9.jar_mysql-connector-java-8.0.29.jar_JdbcTempate_]: https://download.csdn.net/download/m0_60353039/87088057
[7e0ff0501697426a84cd0a1f4eecfdc1.gif_pic_center]: https://img-blog.csdnimg.cn/7e0ff0501697426a84cd0a1f4eecfdc1.gif#pic_center