java--使用jdbcTemplate进行增删改查

Posted 郑*杰

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了java--使用jdbcTemplate进行增删改查相关的知识,希望对你有一定的参考价值。

一、设置数据库连接信息 

文件名:jdbc.propries
jdbc.url=jdbc:mysql://10.0.2.4:63306/test1111111?useUnicode=true&characterEncoding=utf-8&useSSL=false
jdbc.username=gac_trav
jdbc.password=gac@6666
jdbc.driverClassName=com.mysql.cj.jdbc.Driver

 二、配置druid数据源信息,获取jdbcTemplate对象

<?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:property-placeholder location="classpath:jdbc.propries"></context:property-placeholder>
    <bean id="druidDataSource" class="com.alibaba.druid.pool.DruidDataSource">
        <property name="url" value="$jdbc.url"></property>
        <property name="username" value="$jdbc.username"></property>
        <property name="password" value="$jdbc.password"></property>
        <property name="driverClassName" value="$jdbc.driverClassName"></property>
    </bean>
<!--创建jdbcTemplate对象,注入数据源-->
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="druidDataSource"></property>
    </bean>
</beans>

三、获取jdbcTemplate对象,进行数据相关操作

package com.ruqi.jdbctemplate;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.test.context.junit.jupiter.SpringJUnitConfig;

import java.util.List;

@SpringJUnitConfig(locations = "classpath:beans.xml")
public class JdbcTemplateTest 

    @Autowired
    private JdbcTemplate jdbcTemplate; //拿到数据连接对象后,就可以进行增删改查

    // 增删改操作
    @Test
    public void testJdbcTemplate()
        String sql = "INSERT INTO t_emp VALUES(null,?,?,?);";
        int rows = jdbcTemplate.update(sql, "小明", 20, "男");
        System.out.println(rows);
    

    //查询结果设置到对象中
    @Test
    public void testSelectObject()
        String sql = "select id, name, age, sex from t_emp where id = ?";
//        写法一
        User returnUser1 = jdbcTemplate.queryForObject(sql, (rs, rowNum) -> 
            User user = new User();
            user.setAge(rs.getInt("age"));
            user.setName(rs.getString("name"));
            user.setId(rs.getInt("id"));
            user.setSex(rs.getString("sex"));
            return user;
        , 1);
        System.out.println(returnUser1);
//        写法二,本质上跟写法一是一样的
        User returnUser2 = jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<>(User.class), 2);
        System.out.println(returnUser2);
    

    //返回多条数据放到一个集合
    @Test
    public void selectObjectList()
        String sql = "select id, name, age, sex from t_emp;";
        List<User> userList = jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(User.class));
        System.out.println(userList);
    

    // 返回单个值,第二个参数填写返回的数据类型
    @Test
    public void selectValueObject()
        String sql = "select count(1) from t_emp;";
        Integer count = jdbcTemplate.queryForObject(sql, Integer.class);
        System.out.println(count);
    

spring学习spring的jdbcTemplate(增删改查封装)

Spring的jdbcTemplate操作

1、Spring框架一站式框架

(1)针对javaee三层,每一层都有解决技术

(2)到dao 层,使用 jdbcTemplate 

2、Spring对不同的持久化都进行了封装

  (1)jdbcTemplate  对  jdbc 进行封装

3、jdbcTemplate 使用和 dbutils 使用很相似,都是对数据库进行 crud 操作

4、使用jdbcTemplate 实现增删改查操作

增加:

  1、导入 jdbcTemplate 相关jar 包

    

  一定要导入相关数据库驱动的  jar 包

  2、创建对象,设置数据库信息

  3、创建jdbcTemplate 对象,设置数据源

  4、调用 jdbcTemplate 对象里面的方法实现操作

//1、增加操作
    @Test
    public void add(){
        //创建对象,设置数据库信息
        DriverManagerDataSource dataSource=new DriverManagerDataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql://localhost:3306/url_data");
        dataSource.setUsername("root");
        dataSource.setPassword("123");
        //创建jdbcTemplate 对象,设置数据源
        JdbcTemplate jdbcTemplate=new JdbcTemplate(dataSource);
        //调用 jdbcTemplate 对象里面的方法实现操作
        //c创建sql语句
        String sql="insert into user values(?,?)";
        int row=jdbcTemplate.update(sql, "zhansan","man");
        System.out.println("JdbcTemplateDemo1.add()"+row);
    }

修改:

    // 2、修改操作
    @Test
    public void update() {
        // 创建对象,设置数据库信息
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql://localhost:3306/url_data");
        dataSource.setUsername("root");
        dataSource.setPassword("123");
        // 创建jdbcTemplate 对象,设置数据源
        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
        // 调用 jdbcTemplate 对象里面的方法实现操作
        // c创建sql语句
        String sql = "update user set sex=? where name=?";
        int row = jdbcTemplate.update(sql, "woman","zhangsan");
        System.out.println("JdbcTemplateDemo1.add()=" + row);
    }

删除:

    // 3、删除操作
    @Test
    public void delete() {
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql://localhost:3306/url_data");
        dataSource.setUsername("root");
        dataSource.setPassword("123");
        // 创建jdbcTemplate 对象,设置数据源
        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
        // 调用 jdbcTemplate 对象里面的方法实现操作
        // c创建sql语句
        String sql = "delete from user where name=?";
        int row = jdbcTemplate.update(sql, "zhangsan");
        System.out.println("JdbcTemplateDemo1.add()=" + row);
    }

查看:

jdbcutil  用于 jdbcTemplate 的区别
    /*
     * (1)jdbcutils
     *  QueryRunner  runner = new QueryRunner(datasource);
     *  
     *  返回对象
     *  runner.query(sql, new BeanHandler<User>(User.class));
     *  
     *  返回list
     *  runner.query(sql, new BeanListHandler<User>(User.class));
     *  
     * (2)jdbcTemplate实现查询,有接口RowMapper
     * jdbcTemplate针对这个接口没有实现具体的类,得到不同类型的数据需要自己心境数据的封装
     */

(1)查询返回某一个值

public void count() {
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql://localhost:3306/url_data");
        dataSource.setUsername("root");
        dataSource.setPassword("123");
        // 创建jdbcTemplate 对象,设置数据源
        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
        String sql="select count(*) from user";
        //第一个参数是sql 语句
        //迭戈参数 返回类型的class
        int count=jdbcTemplate.queryForObject(sql, Integer.class);
        System.out.println(count);
    }

(2)查询返回某一个对象

原始方式:

//原始方式
public void testJdbc() throws SQLException {
        Connection conn=null;
        PreparedStatement pstmt=null;
        ResultSet rs=null;
        //加载驱动
        try {
            Class.forName("com.mysql.jdbc.Driver");
            //创建连接
            conn=(Connection) DriverManager.getConnection("jdbc:mysql://localhost/url_data", "root", "123");
            String sql="select * from user where username=?";
            //预编译
            pstmt=(PreparedStatement) conn.prepareStatement(sql);
            pstmt.setString(1, "lisi");
            rs=pstmt.executeQuery();
            //遍历结果集
            while(rs.next()){
                //得到返回的结果值
                String name=rs.getString("username");
                String sex=rs.getString("sex");
                User user=new User();
                user.setUsername(name);
                user.setSex(sex);
                System.out.println(user);
            }
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally{
                rs.close();
                pstmt.close();
                conn.close();
        }
    }

jdbc 方式:

 

    @Test
    public void FindObject() {
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql://localhost:3306/url_data");
        dataSource.setUsername("root");
        dataSource.setPassword("123");
        // 创建jdbcTemplate 对象,设置数据源
        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
        String sql="select * from user where name=?";
        //调用jdbcTemplate
        //第一个参数:sql语句 
        //第二个人参数:类似于 dbutils 中的接口RowMapper,需要自己写实现类,实现具体方法,实现数据封装
        //第三个参数: 可变参数(sql中传的值)
        User user = jdbcTemplate.queryForObject(sql, new MyRowMapper(),"lisi");
        System.out.println(user.getName());
    }

写一个非public class

class MyRowMapper implements RowMapper<User>{
    
    //num:行号
    public User mapRow(ResultSet rs, int index) throws SQLException {
        //1、从结果集里面把数据得到
        String name=rs.getString("name");
        String sex=rs.getString("sex");
        //2、把没我们得到的数据封装到对象里面
        User user=new User();
        user.setName(name);
        user.setSex(sex);
        return user;
    }
    
}
匿名内部类

(3)查询返回 list 集合

 

    public void FindList(){
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql://localhost:3306/url_data");
        dataSource.setUsername("root");
        dataSource.setPassword("123");
        // 创建jdbcTemplate 对象,设置数据源
        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
        String sql="select * from user";
        //调用jdbcTemplate
        //第一个参数:sql 语句
        //第二个参数RowMapper 接口
        //第三个参数:可变参数,可以省略
        List<User> list=jdbcTemplate.query(sql, new MyRowMapperList());
        for(int i=0;i<list.size();i++){
            System.out.println(list.get(i));
        }
    }

实现RowMapper类

class MyRowMapperList implements RowMapper<User>{
    
    //index:行号
    public User mapRow(ResultSet rs, int index) throws SQLException {
        //1、从结果集里面把数据得到
        String name=rs.getString("name");
        String sex=rs.getString("sex");
        //2、把没我们得到的数据封装到对象里面
        User user=new User();
        user.setName(name);
        user.setSex(sex);
        return user;
    }

5、Spring 配置 c3p0 连接池 和dao  使用jdbcTemplate

(1)Spring 配置 c3p0 连接池

  - 导入 jar 包

  

原始的 c3p0 写法

        ComboPooledDataSource datasource=new ComboPooledDataSource();
        datasource.setDriverClass("com.mysql.jdbc.Driver");
        datasource.setJdbcUrl("jdbc:mysql://localhost:3306/url_data");
        datasource.setUser("root");
        datasource.setPassword("123");
        

在xml中配置 c3p0

		<!-- 配置  c3p0 -->
		<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
			<!-- 注入属性值 -->
			<property name="driverClass" value="com.mysql.jdbc.Driver"></property>
			<property name="jdbcUrl" value="jdbc:mysql://localhost:3306/url_data"></property>
			<property name="user" value="root"></property>
			<property name="password" value="123"></property>
		</bean>

  

(2)dao  使用jdbcTemplate

   1、创建 service 和 dao 对象,配置 service  和 dao 对象

  2、创建 JdbcTemplate 对象,把 模板对象注入到 dao 里面

  3、在 jdbcTemplate 对象里面注入 dataSource 对象

Service类

package cn.itcast.c3p0;

public class UserService {

    private UserDao userDao;

    public void setUserDao(UserDao userDao) {
        this.userDao = userDao;
    }
    
    public void add(){
        System.out.println("service add.....");
        userDao.add();
    }
}

dao类

package cn.itcast.c3p0;

import org.springframework.jdbc.core.JdbcTemplate;

public class UserDao {
    
    //要得到jdbcTemplate 对象
    private JdbcTemplate jdbcTemplate;

    public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
      this.jdbcTemplate = jdbcTemplate;
    }

public void add(){
        String sql="insert into user values(?,?)";
        jdbcTemplate.update(sql,"大力","man");
    }
}

c3p0.xml 配置:

<?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:content="http://www.springframework.org/schema/context"
    xmlns:aop="http://www.springframework.org/schema/aop" 
    xmlns:tx="http://www.springframework.org/schema/tx"
    xsi:schemaLocation="
        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd
        http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd
        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">
        <!-- bean definitions here -->
    
        <!-- 配置  c3p0 -->
        <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
            <!-- 注入属性值 -->
            <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
            <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/url_data"></property>
            <property name="user" value="root"></property>
            <property name="password" value="123"></property>
        </bean>
        <!-- 创建service 和 Dao。在Service 中调用dao -->
        
        <bean id="userService" class="cn.itcast.c3p0.UserService">
            <!-- 注入Dao -->
            <property name="userDao" ref="userDao"></property>
        </bean>
        
        <bean id="userDao" class="cn.itcast.c3p0.UserDao">
            <!-- 注入jdbctemplate对象 -->
            <property name="jdbcTemplate" ref="jdbcTemplate"></property>
        </bean>
        
        
        <!-- 创建JdbcTemplate对象 -->
        <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
            <!-- 把dataSource 传到 jdbcTemplate里面-->
            <property name="dataSource" ref="dataSource"></property>
        </bean>
</beans>

测试:

    public void testC(){
        ApplicationContext context=new ClassPathXmlApplicationContext("c3p0.xml");
        UserService userService=(UserService) context.getBean("userService");
        userService.add();
    }

测试结果:

在数据库 user 表里添加一条数据

 

以上是关于java--使用jdbcTemplate进行增删改查的主要内容,如果未能解决你的问题,请参考以下文章

Java Spring-JdbcTemplate增删改查

使用JdbcTemplate操作数据库(增删改查)。具体代码+讲解 上篇

JdbcTemplate(增删改查以及以注释实现增删改查)

JdbcTemplate增删改查案例

JdbcTemplate实现增删改查操作

Spring5学习笔记(11) — “JdbcTemplate 操作数据库(增删改)”