jdbcTemplate使用

墨蓝 2024-04-06 10:08 86阅读 0赞

## 一、jdbcTemplate简介 ##

### 1、什么是jdbcTemplate ###

*  JdbcTemplate是Spring对JDBC的封装，目的是使JDBC更加易于使用。
 *  Spring对数据库的操作在jdbc上面做了深层次的封装，使用spring的注入功能，可以把DataSource注册到JdbcTemplate之中。

### 2、常用的方法 ###

1.  execute方法：可以用于执行任何SQL语句，一般用于执行`DDL语句`
2.  update方法及batchUpdate方法：update方法用于执行`新增、修改、删除`等语句；batchUpdate方法用于执行批处理相关语句
3.  query方法及queryForXXX方法：用于执行查询相关语句

## 二、jdbcTemplate使用 ##

### 1、添加依赖 ###

<dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-jdbc</artifactId>
      <version>5.3.9</version>
    </dependency>
        
    
     <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context</artifactId>
        <version>5.3.9</version>
    </dependency>
        
     
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-tx</artifactId>
       <version>5.3.9</version>
    </dependency>
        
    
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <version>1.18.20</version>
    </dependency>

### 2、数据库结构 ###

注意：数据库主键自动递增，插入语句不用管主键

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

### 3、bean实体类 ###

import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.NoArgsConstructor;
    
    import java.io.Serializable;
    
    @Data
    @AllArgsConstructor
    @NoArgsConstructor
    public class TUser implements Serializable {
        
    
        private Integer id;
        private String username;
        private String password;
    
    }

### 4、yaml文件配置数据库 ###

#MySql8.0
    spring:
      datasource:
        driverClassName: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://localhost:3306/order_system?useSSL=false&characterEncoding=utf-8&useUnicode=true&serverTimezone=Asia/Shanghai
        username: root
        password: 123456

### 5、具体代码使用 ###

#### （1）添加数据 ####

String sql = "INSERT INTO T_USER(username,password) VALUES(?,?)";
    jdbcTemplate.update(sql,"肘子","猪肉");

#### （2）修改数据 ####

String sql = "UPDATE T_USER SET USERNAME = ?, PASSWORD = ? WHERE ID =?";
    int i = jdbcTemplate.update(sql,"鸡腿","鸡心",2);

#### （3）删除数据 ####

String sql = "DELETE FROM T_USER WHERE id = ?;";
    int i = jdbcTemplate.update(sql,2);

### （4）批量操作 batchUpdate ###

**方法源码：**

![在这里插入图片描述][a3d58cd8c05a438198d5dd6f586d1f18.png]  
由源码可以看出，需要传入两个参数，**SQL语句**以及**参数list**

#### ①批量添加 ####

String sql = "INSERT INTO T_USER(username,password) VALUES(?,?)";
            List<Object[]> list = new ArrayList<>();
            Object[] o1 = {
        "Python", "xyxy"};
            Object[] o2 = {
        "java", "非官方的"};
            Object[] o3 = {
        "c#", "xydfgdxy"};
            Object[] o4 = {
        "c++", "gdfgty"};
            list.add(o1);
            list.add(o2);
            list.add(o3);
            list.add(o4);
            int[] inrArr = jdbcTemplate.batchUpdate(sql, list);

#### ②批量修改 ####

String sql = "UPDATE T_USER SET USERNAME = ?,PASSWORD = ? WHERE ID = ?";
            List<Object[]> list = new ArrayList<>();
            Object[] o1 = {
        "ENGLISH", "FERUY",116};
            Object[] o2 = {
        "汉语", "非官FFDV方的",117};
            Object[] o3 = {
        "鳄鱼#", "DSF",118};
            Object[] o4 = {
        "法国++", "DSDSDSFGEG分",119};
            list.add(o1);
            list.add(o2);
            list.add(o3);
            list.add(o4);
            int[] inrArr = jdbcTemplate.batchUpdate(sql, list);

#### ③批量删除 ####

String sql = "DELETE FROM T_USER WHERE ID = ?";
            List<Object[]> list = new ArrayList<>();
            Object[] o1 = {
        116};
            Object[] o2 = {
        117};
            Object[] o3 = {
        118};
            Object[] o4 = {
        119};
            list.add(o1);
            list.add(o2);
            list.add(o3);
            list.add(o4);
            int[] inrArr = jdbcTemplate.batchUpdate(sql, list);

### （5）查询 ###

String sql = "SELECT * FROM T_USER WHERE PASSWORD LIKE concat('%', ?, '%')";
            List<TUser> userList = jdbcTemplate.query(sql, new RowMapper<TUser>() {
        
                @Override
                public TUser mapRow(ResultSet rs, int rowNum) throws SQLException {
        
                    TUser tUser = new TUser();
                    tUser.setId(rs.getInt("id"));
                    tUser.setUsername(rs.getString("username"));
                    tUser.setPassword(rs.getString("password"));
                    return tUser;
                }
            }, "g");

***注意：***

定义的SQL语句是一个like查询语句，但是不能直接写成`String sql = "SELECT * FROM T_USER WHERE PASSWORD LIKE %?%";`这种形式，系统无法分辨，要通过`concat`进行字符串拼接。

如果是Oracle，用`||`进行拼接，`SELECT * FROM T_USER WHERE PASSWORD LIKE '%'|| ? ||'%'`

#### 附加：自定义RowMapper实现类，实现mapRow方法 ####

import com.example.domain.TUser;
    import org.springframework.jdbc.core.RowMapper;
    
    import java.sql.ResultSet;
    import java.sql.SQLException;
    
    public class TUserRowMapper implements RowMapper<TUser> {
        
        @Override
        public TUser mapRow(ResultSet rs, int rowNum) throws SQLException {
        
            TUser tUser = new TUser();
            tUser.setId(rs.getInt("id"));
            tUser.setUsername(rs.getString("username"));
            tUser.setPassword(rs.getString("password"));
            return tUser;
        }
    }

**业务代码：**

String sql = "SELECT * FROM T_USER WHERE PASSWORD LIKE concat('%', ?, '%')";
    List<TUser> userList = jdbcTemplate.query(sql,new TUserRowMapper(),"g");

### 拓展连接：[NamedParameterJdbcTemplate使用详解][NamedParameterJdbcTemplate] ###

[cf0dc14c95ef4d06b5e57df634af5d3b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/06/8e4efb6cb160420e9742219c15bfc7ed.png
[a3d58cd8c05a438198d5dd6f586d1f18.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/06/b144576e76d040f38b4deb66d6fb12b7.png
[NamedParameterJdbcTemplate]: https://blog.csdn.net/m0_58680865/article/details/126901687