[java Spring JdbcTemplate配合mysql实现数据批量删除

news2024/11/25 0:54:47

之前的文章 java Spring JdbcTemplate配合mysql实现数据批量添加和文章java Spring JdbcTemplate配合mysql实现数据批量修改
先后讲解了 mysql数据库的批量添加和批量删除操作会了这两个操作之后批量删除就不要太简单

我们看到数据库这里我们用的是mysql工具
在这里插入图片描述
这里我们有一个test数据库然后下面有一个 user_list 表
我们将用他的后三条数据演示批量删除

首先创建一个java项目然后引入对应的所需依赖
在这里插入图片描述
然后在src下创建目录 dao
在dao目录下创建接口我这里叫 BookDao
参考代码如下

package dao;

import mydata.user_list;
import java.util.List;

public interface BookDao {

    void deleteUser(List<Object []> user_list);
}

我们定义了一个抽象的deleteUser批量删除方法接受一个泛型为数组类型的list集合为参数

然后在 dao目录下创建一个类叫 BookDaoImpl
参考代码如下

package dao;

import mydata.user_list;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

import java.util.Arrays;
import java.util.List;

@Repository
public class BookDaoImpl implements BookDao {
    @Autowired
    private JdbcTemplate jdbcTemplate;

    @Override
    public void deleteUser(List<Object []> user_list) {
        String sql = "delete FROM `user_list` WHERE user_id like ?;";
        int[] ints = jdbcTemplate.batchUpdate(sql,user_list);
        System.out.println(Arrays.toString(ints));
    }
}

这里引入了了JdbcTemplate 这个类中就包含了很多数据库操作然后我们实现了BookDao 接口并重写了他里面的deleteUser方法调用了jdbcTemplate下的batchUpdate方法

这个方法有两参数第一个是一段sql语句这里我们已经写了一段基本的删除sql语句而另一个则是一个数组泛型list 数组的每一个下标就是一个条件对应 sql语句中的 ?
最后这个方法返回一个int数组类型的变量告诉你每一次sql影响的行数
然后我们将这个返回值拿到并输出

然后我们在src下创建目录叫 senvice senvice包下创建类叫 BookService

参考代码如下

package senvice;

import dao.BookDao;
import mydata.user_list;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

@Service
public class BookService {
    @Autowired
    protected BookDao BookDao;

    public void deleteUser(List<Object []> user_list){
        BookDao.deleteUser(user_list);
    }
}

这里纯属就是多掏一层来满足架构

然后在src下创建bean.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: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="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
             destroy-method="close">
              <property name="url" value="jdbc:mysql:///test" /><!--对应SQLyog里的数据库-->
              <property name="username" value="root" />            <!-- 用户名 -->
              <property name="password" value="root" />        <!-- 密码 -->
              <property name="driverClassName" value="com.mysql.jdbc.Driver" />
       </bean>

       <!-- JdbcTemplate对象 -->
       <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
              <!--注入dataSource属性-->
              <property name="dataSource" ref="dataSource"></property>
       </bean>

       <context:component-scan base-package="senvice"></context:component-scan>
       <context:component-scan base-package="dao"></context:component-scan>

</beans>

这里我们声明链接本地test数据库然后 username用户名我这里是root 密码 password 我设置的还是root 然后打开了src下 senvice包和dao包的注解扫描

最后在src下创建测试类参考代码如下


import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import senvice.BookService;

import java.util.ArrayList;
import java.util.List;

public class text {
    public static void main(String args[]) {
        ApplicationContext context = new ClassPathXmlApplicationContext("bean.xml");
        BookService bookService = context.getBean("bookService", BookService.class);
        List<Object[]> batehArgs = new ArrayList<>();
        Object[] o1 = {10};
        Object[] o2 = {11};
        Object[] o3 = {12};
        batehArgs.add(o1);
        batehArgs.add(o2);
        batehArgs.add(o3);
        bookService.deleteUser(batehArgs);
    }
}