mybatis高级版 利用动态sql片段加入 foreach 循环拼接 实现 单表批量查询、批量修改、批量删除、批量添加。

摘要

mybatis高级版  利用动态sql片段加入 foreach 循环拼接 实现 单表进行批量查询、批量修改、批量删除、批量添加。

第一步建表

以员工表单表为例
create table emp1(
id varchar2(20) primary key,
name varchar2(20)unique not null,
password varchar2(6) check(length(password)=6)not null,
salary number(8,2),
age varchar2(3),
sex varchar2(3) check(sex in('男','女')),
entryday date,
status varchar(2) check(status in('1','2'))
);

--创建 序列
create sequence empid_seq start with 1 increment by 1;

第二步创建库表对应的实体类

package com.entity;
import java.io.Serializable;
import java.util.Date;
//库表  Emp1 对应的实体 类
public class Empl1 implements Serializable {
private String id;
private String name;
private String password;
private double salary;
private String age;
private String sex;
//入职日期
private Date entryday;
private String status;
//有参无参 get/set tostring 方法此处省略

mybatis-config.xml 核心配置文件

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd" >
<configuration>
<!-- 读入小配置文件 -->
<properties resource="jdbc.properties"></properties>
<!-- 开启二级缓存（以及缓存默认打开） -->
<settings>
<setting name="cacheEnabled" value="true"/>
</settings>
<!-- 给实体类起别名 -->
<typeAliases>
<typeAlias type="com.entity.Empl1" alias="Empl1" />
<typeAlias type="com.entity.Identification" alias="Identification"/>
</typeAliases>
<environments default="oracle">
<environment id="oracle">
<transactionManager type="JDBC"></transactionManager>
<dataSource type="POOLED">
<property name="driver" value="${driver}"/>
<property name="url" value="${url}"/>
<property name="username" value="${user}"/>
<property name="password" value="${password}"/>
</dataSource>
</environment>
</environments>

<!-- 管理mapper文件 -->
<mappers>
<mapper resource="com/empdaotest/Emp1DaoImplTest.xml" />
</mappers>
</configuration>

创建 Dao 对应的接口 及mapper文件处理

一个方法对应一个文件 便于阅读

批量查询处理

对应接口中的方法：
package com.empdaotest;
import com.entity.Empl1;
import java.util.List;
import org.apache.ibatis.annotations.Param;
public interface Emp1DaoTest {
//对应接口中的方法：
//测试批量查询
public List<Empl1> selects3(@Param("list")List<String> list);
}
对应mapeer文件实现的动态sql 语句
<!--将共有的查询结果进行提取 方便后期使用支架引用-->
<sql id="Empl1_sql3">
id,name,password,salary,age,sex,entryday,status
</sql>

<!-- 测试批量查询  仿照枚举查询 -->
<select id="selects3" resultType="Empl1">
select <include refid="Empl1_sql3"></include> from emp1
where id in
<foreach collection="list" open="(" item="id" separator="," close=")" >
#{id}
</foreach>
</select>

/**
解释说明：collection="list" 表示 传入的集合参数名称为list
item="id" 表示 根据id查询 此处id名称应于表格字段相同
*/

Test测试类

//测试批量查询
@Test
public void testselect3(){

List<String> arrayList = new ArrayList<String>();
arrayList.add("1");
arrayList.add("2");
List<Empl1> list = emp1DaoTest.selects3(arrayList);
for (Empl1 empl1 : list) {
System.out.println(empl1);

}
}

批量删除处理

接口同上
对应接口中的方法：
//根据 id 删除  利用动态sql 批量处理
public void deleteByIdsEmp1Dao1(@Param("list")List<String> list);
对应mapeer文件实现的动态sql 语句

<!-- 根据 id 批量 删除 -->
<delete id="deleteByIdsEmp1Dao1" >
delete  from emp1 where id  in
<foreach collection="list" open="(" item="id" separator="," close=")" >
#{id}
</foreach>
</delete>

批量插入处理

接口同上
对应接口中的方法：
//测试批量插入
public void addEmpl1all(@Param("list")List<Empl1> list);

对应mapeer文件实现的动态sql 语句

<!-- 测试批量插入 item="item" 中的item表示临时的对象名称引用 -->
<insert id="addEmpl1all" parameterType="Empl1" >
begin
<foreach collection="list" item="item" index="index" separator=";">
insert into emp1(id,name,password,salary,age,sex,entryday,status) values
(empid_seq.nextval,
#{item.name},
#{item.password},
#{item.salary},
#{item.age},
#{item.sex},
#{item.entryday},
#{item.status})
</foreach>
;end;
</insert>

Test测试：
//测试批量插入
@Test
public void addEmplistTest(){
List<Empl1> list = new ArrayList<Empl1>();

Empl1 empl1 = new Empl1 ();
String sex1="男";
empl1.setSex (sex1);
empl1.setName ("tttt");
empl1.setPassword ("123456");
empl1.setSalary (22.66);
empl1.setAge ("18");
empl1.setStatus ("2");
Date date = new Date ();
empl1.setEntryday (date);
list.add(empl1);

Empl1 empl2 = new Empl1 ();
String sex2="男";
empl2.setSex (sex2);
empl2.setName ("dd");
empl2.setPassword ("123456");
empl2.setSalary (22.66);
empl2.setAge ("18");
empl2.setStatus ("1");
Date date2 = new Date ();

empl2.setEntryday (date2);
list.add(empl2);

emp1DaoTest.addEmpl1all(list);
sqlSession.commit();
}

批量修改处理

接口同上
对应接口中的方法：
//测试批量修改
public void updateEmpl1all(@Param("list")List<Empl1> list);

对应mapeer文件实现的动态sql 语句

<!-- 测试批量修改  item="emp" 中 emp表示对象形参 -->
<update id="updateEmpl1all" parameterType="Empl1">
begin
<foreach collection="list" item="emp" index="index" separator=";">
update emp1 set
name=#{emp.name},salary=#{emp.salary},age=#{emp.age}
where id=#{emp.id}
</foreach>
;end;
</update>

Test测试：
//测试批量修改
@Test
public void updateAlllTest(){
List<Empl1> list = new ArrayList<Empl1>();
Empl1 empl1 = new Empl1();
empl1.setName("挑花开");
empl1.setAge("10");
empl1.setSalary(2000);
empl1.setId("21");

list.add(empl1);
Empl1 empl2 = new Empl1();
empl2.setName("美人");
empl2.setAge("20");
empl2.setSalary(2000);
empl2.setId("41");
list.add(empl2);
emp1DaoTest.updateEmpl1all(list);
sqlSession.commit();
}