SpringBoot使用JdbcTemplate操作数据库

2024-12-19 15:47:32

前言

本文是对SpringBoot使用JdbcTemplate操作数据库的一个介绍，提供一个小的Demo供大家参考。

操作数据库的方式有很多，本文介绍使用SpringBoot结合JdbcTemplate。

新建项目

新建一个项目。pom文件中加入Jdbc依赖，完整pom如下：

<?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.dalaoyang</groupId>
  <artifactId>springboot_jdbc</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>jar</packaging>

  <name>springboot_jdbc</name>
  <description>springboot_jdbc</description>

  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.5.9.RELEASE</version>
    <relativePath/> <!-- lookup parent from repository -->
  </parent>

  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    <java.version>1.8</java.version>
  </properties>

  <dependencies>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-jdbc</artifactId>
    </dependency>

    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-devtools</artifactId>
      <scope>runtime</scope>
    </dependency>
    <dependency>
      <groupId>mysql</groupId>
      <artifactId>mysql-connector-java</artifactId>
      <scope>runtime</scope>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
      <scope>test</scope>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

  </dependencies>

  <build>
    <plugins>
      <plugin>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-maven-plugin</artifactId>
      </plugin>
    </plugins>
  </build>

</project>

配置文件如下：

##端口号
server.port=8888

##数据库配置
##数据库地址
spring.datasource.url=jdbc:mysql://localhost:3306/test?characterEncoding=utf8&useSSL=false
##数据库用户名
spring.datasource.username=root
##数据库密码
spring.datasource.password=123456
##数据库驱动
spring.datasource.driver-class-name=com.mysql.jdbc.Driver

新建一个实体类User，其中需要注意的是，User类实现了RowMapper类，重写了mapRow方法，完整代码如下：

package com.dalaoyang.entity;

import org.springframework.jdbc.core.RowMapper;
import java.sql.ResultSet;
import java.sql.SQLException;

/**
 * @author dalaoyang
 * @project springboot_learn
 * @package com.dalaoyang.entity
 * @email yangyang@dalaoyang.cn
 * @date 2018/7/25
 */
public class User implements RowMapper<User> {
  private int id;
  private String user_name;
  private String pass_word;

  public User(int id, String user_name, String pass_word) {
    this.id = id;
    this.user_name = user_name;
    this.pass_word = pass_word;
  }

  public User() {
  }

  public User(String user_name, String pass_word) {
    this.user_name = user_name;
    this.pass_word = pass_word;
  }

  public int getId() {
    return id;
  }

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

  public String getUser_name() {
    return user_name;
  }

  public void setUser_name(String user_name) {
    this.user_name = user_name;
  }

  public String getPass_word() {
    return pass_word;
  }

  public void setPass_word(String pass_word) {
    this.pass_word = pass_word;
  }

  @Override
  public User mapRow(ResultSet resultSet, int i) throws SQLException {
    User user = new User();
    user.setId(resultSet.getInt("id"));
    user.setUser_name(resultSet.getString("user_name"));
    user.setPass_word(resultSet.getString("pass_word"));
    return user;
  }
}

常用CURD操作大致使用以下三个方法:

1.execute方法，用于直接执行SQL语句
2.update方法，用户新增修改删除操作
3.query方法，用于查询方法

本文和往常一样，用Controller进行测试，注入JdbcTemplate。完整代码如下，下面会对测试方法进行介绍：

package com.dalaoyang.controller;

import com.dalaoyang.entity.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

/**
 * @author dalaoyang
 * @project springboot_learn
 * @package com.dalaoyang.controller
 * @email yangyang@dalaoyang.cn
 * @date 2018/7/25
 */
@RestController
public class UserController {

  @Autowired
  private JdbcTemplate jdbcTemplate;

  //http://localhost:8888/createTable
  @GetMapping("createTable")
  public String createTable(){
    String sql = "CREATE TABLE `user` (\n" +
        " `id` int(11) NOT NULL AUTO_INCREMENT,\n" +
        " `user_name` varchar(255) DEFAULT NULL,\n" +
        " `pass_word` varchar(255) DEFAULT NULL,\n" +
        " PRIMARY KEY (`id`)\n" +
        ") ENGINE=InnoDB AUTO_INCREMENT=7 DEFAULT CHARSET=utf8;\n" +
        "\n";
    jdbcTemplate.execute(sql);
    return "创建User表成功";
  }

  //http://localhost:8888/saveUserSql
  @GetMapping("saveUserSql")
  public String saveUserSql(){
    String sql = "INSERT INTO USER (USER_NAME,PASS_WORD) VALUES ('dalaoyang','123')";
    int rows= jdbcTemplate.update(sql);
    return "执行成功，影响"+rows+"行";
  }

  //http://localhost:8888/saveUser?userName=lisi&passWord=111
  @GetMapping("saveUser")
  public String saveUser(String userName,String passWord){
    int rows= jdbcTemplate.update("INSERT INTO USER (USER_NAME,PASS_WORD) VALUES (?,?)",userName,passWord);
    return "执行成功，影响"+rows+"行";
  }

  //http://localhost:8888/updateUserPassword?id=1&passWord=111
  @GetMapping("updateUserPassword")
  public String updateUserPassword(int id,String passWord){
    int rows= jdbcTemplate.update("UPDATE USER SET PASS_WORD = ? WHERE ID = ?",passWord,id);
    return "执行成功，影响"+rows+"行";
  }

  //http://localhost:8888/deleteUserById?id=1
  @GetMapping("deleteUserById")
  public String deleteUserById(int id){
    int rows= jdbcTemplate.update("DELETE FROM USER WHERE ID = ?",id);
    return "执行成功，影响"+rows+"行";
  }

  //http://localhost:8888/batchSaveUserSql
  @GetMapping("batchSaveUserSql")
  public String batchSaveUserSql(){
    String sql =
        "INSERT INTO USER (USER_NAME,PASS_WORD) VALUES (?,?)" ;
    List<Object[]> paramList = new ArrayList<>();
    for (int i = 0; i < 10; i++) {
      String[] arr = new String[2];
      arr[0] = "zhangsan"+i;
      arr[1] = "password"+i;
      paramList.add(arr);
    }
    jdbcTemplate.batchUpdate(sql,paramList);
    return "执行成功";
  }

  //http://localhost:8888/getUserByUserName?userName=zhangsan0
  @GetMapping("getUserByUserName")
  public List getUserByUserName(String userName){
    String sql = "SELECT * FROM USER WHERE USER_NAME = ?";
    //写法很多种
    //下面列举两种写法，都可以实现
    //List<User> list= jdbcTemplate.query(sql,new Object[]{userName}, new BeanPropertyRowMapper(User.class));
    List<User> list= jdbcTemplate.query(sql,new User(),new Object[]{userName});
    return list;
  }

  //http://localhost:8888/getMapById?id=1
  @GetMapping("getMapById")
  public Map getMapById(Integer id){
    String sql = "SELECT * FROM USER WHERE ID = ?";
    Map map= jdbcTemplate.queryForMap(sql,id);
    return map;
  }

  //http://localhost:8888/getUserById?id=1
  @GetMapping("getUserById")
  public User getUserById(Integer id){
    String sql = "SELECT * FROM USER WHERE ID = ?";
    User user= jdbcTemplate.queryForObject(sql,new User(),new Object[]{id});
    return user;
  }

}

测试方法介绍

1.createTable方法
使用execute方法创建User表

2.saveUserSql方法
使用update方法，传入参数sql语句，直接执行插入操作

3.saveUser方法
使用update方法，传入sql语句和对应字段值，进行插入操作

4.updateUserPassword方法
使用update方法，传入sql语句和对应字段值，进行修改操作

5.deleteUserById方法
使用update方法，传入sql语句和对应字段值，进行删除操作

6.batchSaveUserSql方法
使用batchUpdate方法，传入sql和参数集合，进行批量更新

7.getUserByUserName方法
使用query方法，传入sql，实体对象，查询参数，这里就用到了实体类重写的mapRow方法

8.getMapById方法
使用queryForMap方法，传入sql和参数，返回Map

9.getUserById方法
使用queryForObject方法，传入sql，实体对象，查询参数，返回User实体类，这里也用到了实体类重写的mapRow方法

具体使用方法还有很多，请参考文档:

https://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/jdbc/core/JdbcTemplate.html

注意

出现下图错误不要担心，如图

出现这个错误是因为sql在参数问号的时候多写了引号造成的，这也是我在写demo的时候犯下的错误。

源码下载：大老杨码云

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我们。

Spring 中jdbcTemplate 实现执行多条sql语句示例

说一下Spring框架中使用jdbcTemplate实现多条sql语句的执行: 很多情况下我们需要处理一件事情的时候需要对多个表执行多个sql语句,比如淘宝下单时,我们确认付款时要对自己银行账户的表里减去订单所需的钱数,即需要更新银行账户的表,同时需要更新淘宝订单的表将订单状态改为"已付款",这就需要先后执行多个sql(仅仅用于表达执行多的SQL的举例说明,具体淘宝如何实现并不是很清楚~~~~~); 但如果这中间出现电脑断网断电等问题,仅将我们银行账户的钱扣掉了,订单状态并没有改,那我
详解spring boot中使用JdbcTemplate

本文将介绍如何将spring boot 与 JdbcTemplate一起工作. Spring对数据库的操作在jdbc上面做了深层次的封装,使用spring的注入功能,可以把DataSource注册到JdbcTemplate之中. JdbcTemplate 是在JDBC API基础上提供了更抽象的封装,并提供了基于方法注解的事务管理能力. 通过使用SpringBoot自动配置功能并代替我们自动配置beans. 数据源配置在maven中,我们需要增加spring-boot-starter-jdbc
spring实现jdbctemplate添加事务支持示例

复制代码代码如下: public interface JdbcTemplate extends JdbcOperations {public abstract void beginTranstaion(); public abstract void commit(); public abstract void rollback();} 复制代码代码如下: public class JdbcTemplateImpl extends org.springframework.jdbc.core.J
springboot使用JdbcTemplate完成对数据库的增删改查功能

首先新建一个简单的数据表,通过操作这个数据表来进行演示 DROP TABLE IF EXISTS `items`; CREATE TABLE `items` ( `id` int(11) NOT NULL AUTO_INCREMENT, `title` varchar(255) DEFAULT NULL, `name` varchar(10) DEFAULT NULL, `detail` varchar(255) DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE
Spring Boot中使用jdbctemplate 操作MYSQL数据库实例

最近在学习使用Spring Boot连接数据库,今天学习了使用jdbctemplate 操作MYSQL数据库,下面就留个笔记不废话,先来代码 pom文件: <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
SpringBoot JdbcTemplate批量操作的示例代码

前言在我们做后端服务Dao层开发,特别是大数据批量插入的时候,这时候普通的ORM框架(Mybatis.hibernate.JPA)就无法满足程序对性能的要求了.当然我们又不可能使用原生的JDBC进行操作,那样尽管效率会高,但是复杂度会上升. 综合考虑我们使用Spring中的JdbcTemplate和具名参数namedParameterJdbcTemplate来进行批量操作. 改造前在开始讲解之前,我们首先来看下之前的JPA是如何批量操作的. 实体类User: public class App
使用jdbcTemplate查询返回自定义对象集合代码示例

1.在UserInfo.java中添加一个Map转换为UserInfo的方法 public static UserInfo toObject(Map map) { UserInfo userInfo = new UserInfo(); userInfo.setId((Integer) map.get(id)); userInfo.setUname((String) map.get(uname)); userInfo.setUnumber((Integer) map.get(unumber));
spring的jdbctemplate的crud的基类dao

复制代码代码如下: import java.util.List; /*** * 基本接口 * * @author xyq * @param <T> * */public interface BaseDaoInf<T> { /*** * 查询接口 * * @return */ public List<T> find(String sql, Object[] parameters, Class<T> cl); /*** * 添加,更新,删除接
Java 使用JdbcTemplate 中的queryForList发生错误解决办法

Java 使用JdbcTemplate 中的queryForList发生错误解决办法在开发项目中遇到JdbcTemplate 中的queryForList发生错误,很是头疼,在网上找了相关资料,可以帮忙解决,这里记录下, 一.问题描述: 查询时使用JdbcTemplate 中的queryForList发生错误,如下: 查询方法如下: jdbcTemplate.queryForList(selectSql.toString(), entityClass) 查询sql如下: s
JdbcTemplate方法介绍与增删改查操作实现

JdbcTemplate介绍为了使 JDBC 更加易于使用,Spring 在 JDBCAPI 上定义了一个抽象层, 以此建立一个JDBC存取框架,Spring Boot Spring Data-JPA. 作为 SpringJDBC 框架的核心, JDBC 模板的设计目的是为不同类型的JDBC操作提供模板方法. 每个模板方法都能控制整个过程,并允许覆盖过程中的特定任务. 通过这种方式,可以在尽可能保留灵活性的情况下,将数据库存取的工作量降到最低. JdbcTemplate方法介绍 JdbcTem

SpringBoot使用JdbcTemplate操作数据库

相关推荐

随机推荐