备案控制台
开发者社区 数据库 文章 正文

Spring系列文章：Spring使用JdbcTemplate

2024-04-09 21
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
RDS MySQL Serverless 基础系列，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
RDS MySQL Serverless 高可用系列，价值2615元额度，1个月
简介： Spring系列文章：Spring使用JdbcTemplate

一、简介

JdbcTemplate是Spring提供的⼀个JDBC模板类，是对JDBC的封装，简化JDBC代码。 当然，你也可以不⽤，可以让Spring集成其它的ORM框架，例如：MyBatis、Hibernate等。

第一步：引入依赖

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>6.0.2</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>
        <!--新增的依赖：spring jdbc，这个依赖中有JdbcTemplate-->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>6.0.2</version>
        </dependency>

二、整合JdbcTemplate

第二步：编写Spring配置⽂件

JdbcTemplate是Spring提供好的类，这类的完整类名是： org.springframework.jdbc.core.JdbcTemplate 我们怎么使⽤这个类呢？new对象就可以了。怎么new对象，Spring最在⾏了。直接将这个类配置到 Spring配置⽂件中，纳⼊Bean管理即可。

<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"></bean>

可以看到JdbcTemplate中有⼀个DataSource属性，这个属性是数据源，我们都知道连接数据库需要 Connection对象，⽽⽣成Connection对象是数据源负责的。

所以我们需要给JdbcTemplate设置数据源 属性。 所有的数据源都是要实现javax.sql.DataSource接⼝的。这个数据源可以⾃⼰写⼀个，也可以⽤写好的， ⽐如：阿⾥巴巴的德鲁伊连接池，c3p0，dbcp等。我们这⾥⾃⼰先⼿写⼀个数据源。

public class MyDataSource implements DataSource {
    // 添加4个属性
    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> T unwrap(Class<T> iface) throws SQLException {
        return null;
    }
 
    @Override
    public boolean isWrapperFor(Class<?> iface) throws SQLException {
        return false;
    }
}

写完数据源，我们需要把这个数据源传递给JdbcTemplate。因为JdbcTemplate中有⼀个DataSource属 性：

<?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">
    <bean id="myDataSource" class="com.springcode.example.entity.MyDataSource">
        <property name="driver" value="com.mysql.cj.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/spring6"/>
        <property name="username" value="root"/>
        <property name="password" value="root"/>
    </bean>
    
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="myDataSource"/>
    </bean>
</beans>

三、增删改查

1、增加

 
public class SpringTest {
    @Test
    public void test(){
        // 获取JdbcTemplate对象
        ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring.xml");
        JdbcTemplate jdbcTemplate = applicationContext.getBean("jdbcTemplate", JdbcTemplate.class);
                /*注意：insert delete update的sql语句，都是执⾏update⽅法。update⽅法有两个参数：
                第⼀个参数：要执⾏的SQL语句。（SQL语句中可能会有占位符 ? ）
                第⼆个参数：可变⻓参数，参数的个数可以是0个，也可以是多个。⼀般是SQL语句中有⼏个问号，
                则对应⼏个参数。*/
                String sql = "insert into t_user(id,real_name,age) values(?,?,?)";
        int count = jdbcTemplate.update(sql, null, "张三", 30);
        System.out.println("插⼊的记录条数：" + count);
    }
}

2、修改

public class SpringTest {
    @Test
    public void test(){
        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);
    }
}

3、删除

public class SpringTest {
    @Test
    public void test(){
        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);
    }
}

4、查询一个对象

public class SpringTest {
    @Test
    public void test(){
        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 = ?";
        /*
        queryForObject⽅法三个参数：
        第⼀个参数：sql语句
        第⼆个参数：Bean属性值和数据库记录⾏的映射对象。在构造⽅法中指定映射的对象类型。
        第三个参数：可变⻓参数，给sql语句的占位符问号传值。
         */
        User user = jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<>(User.class), 2);
        System.out.println(user);
    }
}

5、查询多个对象

public class SpringTest {
    @Test
    public void test(){
        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<User> users = jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(User.class));
        System.out.println(users);
    }
}

6、查询⼀个值

public class SpringTest {
    @Test
    public void test(){
        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);
    }
}

7、批量添加

public class SpringTest {
    @Test
    public void test(){
        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<Object[]> list = new ArrayList<>();
        list.add(objs1);
        list.add(objs2);
        list.add(objs3);
        int[] count = jdbcTemplate.batchUpdate(sql, list);
        System.out.println(Arrays.toString(count));
    }
}

8、批量修改

public class SpringTest {
    @Test
    public void test(){
        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<Object[]> list = new ArrayList<>();
        list.add(objs1);
        list.add(objs2);
        list.add(objs3);
        int[] count = jdbcTemplate.batchUpdate(sql, list);
        System.out.println(Arrays.toString(count));
    }
}

9、批量删除

public class SpringTest {
    @Test
    public void test(){
        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<Object[]> list = new ArrayList<>();
        list.add(objs1);
        list.add(objs2);
        list.add(objs3);
        int[] count = jdbcTemplate.batchUpdate(sql, list);
        System.out.println(Arrays.toString(count));
    }
}

10、使⽤回调函数

public class SpringTest {
    @Test
    public void test(){
        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<User>() {
            @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);
    }
}

四、使⽤德鲁伊连接池

上面数据源是⽤我们⾃⼰写的。也可以使⽤别⼈写好的。例如⽐较⽜的德鲁伊连接池。

第⼀步：引⼊德鲁伊连接池的依赖。

<dependency>
 <groupId>com.alibaba</groupId>
 <artifactId>druid</artifactId>
 <version>1.1.8</version>
</dependency>

第⼆步：将德鲁伊中的数据源配置到spring配置⽂件中。和配置我们⾃⼰写的⼀样。

<?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">
 
    <bean id="druidDataSource" class="com.alibaba.druid.pool.DruidDataSource">
        <property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/spring6"/>
        <property name="username" value="root"/>
        <property name="password" value="root"/>
    </bean>
    
 
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="druidDataSource"/>
    </bean>
</beans>

测试

 
public class SpringTest {
    @Test
    public void test(){
        // 获取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(?,?,?)";
        int count = jdbcTemplate.update(sql, null, "张三", 30);
        System.out.println("插⼊的记录条数：" + count);
    }
}


文章标签：
云数据库 RDS MySQL 版
Java
Spring
数据库连接
mybatis
数据库
相关实践学习
基于CentOS快速搭建LAMP环境
本教程介绍如何搭建LAMP环境，其中LAMP分别代表Linux、Apache、MySQL和PHP。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
程序三两行
目录
相关文章
Zh.晨光
|
6天前
|
SQL Java 数据库连接
Spring 模板技术JdbcTemplate
Spring 模板技术JdbcTemplate
Zh.晨光
32 0
Spring 模板技术JdbcTemplate
零零年夏
|
9月前
|
Java Spring 容器
【Spring】Spring常用注解（中）
【Spring】Spring常用注解（中）
零零年夏
31 0
零零年夏
|
9月前
|
Java Spring 容器
【Spring】Spring常用注解（下）
【Spring】Spring常用注解（下）
零零年夏
54 0
零零年夏
|
9月前
|
XML Java 数据格式
【Spring】Spring常用注解（上）
【Spring】Spring常用注解（上）
零零年夏
36 0
杨宸杨
|
9月前
|
SQL 存储 Java
Spring JdbcTemplate（上）
Spring JdbcTemplate（上）
杨宸杨
61 0
杨宸杨
|
9月前
|
Java Spring
Spring JdbcTemplate（下）
Spring JdbcTemplate（下）
杨宸杨
58 0
时间不会赖着不走
|
11月前
|
XML Java 数据库连接
spring中的JdbcTemplate
spring中的JdbcTemplate
时间不会赖着不走
61 0
小蔡coding
|
XML Java 关系型数据库
Spring--Spring5事物管理（2）
Spring--Spring5事物管理（2）
小蔡coding
75 0
小蔡coding
|
XML Java API
Spring--Spring5事物管理（1）
Spring--Spring5事物管理（1）
小蔡coding
48 0
QGS
|
Java 数据库连接 Spring
Spring6—JdbcTemplate基础
记Spring6—JdbcTemplate基础
QGS
226 1
Spring6—JdbcTemplate基础

热门文章

最新文章

  • 1
    袋鼠云数据中台专栏（五）：数栈，企业级一站式数据中台PaaS
  • 2
    利用Serverless Kubernetes和Kaniko快速自动化构建容器镜像
  • 3
    阿里云oss收费标准
  • 4
    SpringBoot开发案例之整合Kafka实现消息队列
  • 5
    LINQ 图解
  • 6
    keepalived高可用LVS与Nginx
  • 7
    beyondhedefang的意义
  • 8
    v-on 指令
  • 9
    Java 8的一些常见用法
  • 10
    LLVM每日谈之十六 LLVM的学习感悟
  • 1
    构建高效可靠的微服务架构：后端开发的新趋势
    22
  • 2
    Kubernetes 集群的监控与日志管理最佳实践
    30
  • 3
    苹果app开发apple-app-site-association文件配置
    18
  • 4
    阿里云MaxCompute携手华大基因打造精准医疗应用云平台，十万基因组计算成本降低至1000美金以内
    303
  • 5
    构建高效自动化运维系统：DevOps与AI的融合
    25
  • 6
    深入理解PHP中的命名空间
    15
  • 7
    深度学习在图像识别中的应用及其挑战
    17
  • 8
    提升软件测试效率：智能化测试工具的应用与展望
    17
  • 9
    阿里云容器服务
    29
  • 10
    为什么是容器编排技术
    18

    • 相关课程

    更多
  • 5天实战Spring Boot 2.5
  • 5天突破Spring Cloud
  • Spring Boot 2.5.x开发实战
  • 精通Spring Cloud Alibaba
  • Spring Cloud Alibaba Nacos 详解（上）
  • Spring Cloud Alibaba Nacos 详解（下）

    • 相关电子书

    更多
  • Spring Boot 2.5开发实战
  • Java Spring Boot开发实战系列课程【第6讲】：Spring Boot 2.0实战MyBatis与优化(Java面试题)
  • Java Spring Boot开发实战系列课程【第15讲】：Spring Boot 2.0 API与Spring REST Docs实战

    • 相关实验场景

    更多
  • 从零搭建Spring Boot的Hello World
    • 下一篇
    2024年阿里云免费云服务器及学生云服务器申请教程参考