MyBatis系列：（5）动态SQL
admin
2023-05-01 04:42:20
0次


1、动态SQL操作之查询

查询条件不确定，需要根据情况产生SQL语法，这种情况叫动态SQL

    
        select emp_id,emp_name,emp_sal from emp
        
            
                and emp_id = #{pid}
            
            
                and emp_name like #{pname}
            
            
                and emp_sal < #{psal}
            
        
    

MyBatis系列：（5）动态SQL


2、动态SQL操作之更新

更新条件不确定，需要根据情况产生SQL语法，这种情况叫动态SQL

    
        update emp
        
            
                emp_name = #{pname},
            
            
                emp_sal = #{psal},
            
        
        where emp_id = #{pid}
    

MyBatis系列：（5）动态SQL


3、动态SQL操作之删除

根据多个id进行删除

    
        delete from emp where emp_id in
                
        
            #{pid}
        
    
    
    
        delete from emp where emp_id in
        
            #{pid}
        
    

MyBatis系列：（5）动态SQL



4、动态SQL操作之添加

根据条件，添加数据

    
    
        
        
            
                emp_id,
            
            
                emp_name,
            
            
                emp_sal,
            
        
    
    
    
    
        
        
            
                #{id},
            
            
                #{name},
            
            
                #{sal},
            
        
    
    
    
        insert into emp() values()
    

MyBatis系列：（5）动态SQL


5、参考代码

准备SQL

CREATE TABLE Emp(
    emp_id INT(5) PRIMARY KEY,
    emp_name VARCHAR(20),
    emp_sal DOUBLE(8,2)
);


Emp.java

package com.rk.entity;

public class Emp {
    private Integer id;
    private String name;
    private Double sal;
    public Emp(){}
    
    public Emp(Integer id, String name, Double sal) {
        this.id = id;
        this.name = name;
        this.sal = sal;
    }

    public Integer getId() {
        return id;
    }
    public void setId(Integer id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public Double getSal() {
        return sal;
    }
    public void setSal(Double sal) {
        this.sal = sal;
    }
    
}


EmpMapper.xml




    
    
        
        
        
    
    
    
        select emp_id,emp_name,emp_sal from emp
        
            
                and emp_id = #{pid}
            
            
                and emp_name like #{pname}
            
            
                and emp_sal < #{psal}
            
        
    
    
    
    
    
        update emp
        
            
                emp_name = #{pname},
            
            
                emp_sal = #{psal},
            
        
        where emp_id = #{pid}
    
    
    
    
        delete from emp where emp_id in
                
        
            #{pid}
        
    
    
    
        delete from emp where emp_id in
        
            #{pid}
        
    
    
    
    
    
        
        
            
                emp_id,
            
            
                emp_name,
            
            
                emp_sal,
            
        
    
    
    
    
        
        
            
                #{id},
            
            
                #{name},
            
            
                #{sal},
            
        
    
    
    
        insert into emp() values()
    


mybatis.xml




    
    
    
    
    
        
    

    
    
        
            
            
            
            
                
                
                
                
                
            
        
        
        
        
            
            
            
            
                
                
                
                
                
            
                
    
    
    
    
        
    


db.properties

mysql.driver=com.mysql.jdbc.Driver
mysql.url=jdbc:mysql://127.0.0.1:3306/testdb
mysql.username=root
mysql.password=root

oracle.driver=oracle.jdbc.driver.OracleDriver
oracle.url=jdbc:oracle:thin:@127.0.0.1:1521:orcl
oracle.username=scott
oracle.password=tiger


MyBatisUtils.java

package com.rk.utils;

import java.io.IOException;
import java.io.Reader;
import java.sql.Connection;

import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

public class MyBatisUtils {
    private static ThreadLocal threadLocal = new ThreadLocal();
    private static SqlSessionFactory sqlSessionFactory;
    static{
        try {
            Reader reader = Resources.getResourceAsReader("mybatis.xml");
            sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader);
        } catch (IOException e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
    }
    private MyBatisUtils() {}
    public static SqlSession getSqlSession(){
        SqlSession sqlSession = threadLocal.get();
        if(sqlSession == null){
            sqlSession = sqlSessionFactory.openSession();
            threadLocal.set(sqlSession);
        }
        return sqlSession;
    }
    
    public static void closeSqlSession(){
        SqlSession sqlSession = threadLocal.get();
        if(sqlSession != null){
            sqlSession.close();
            threadLocal.remove();
        }
    }
    
    public static void main(String[] args) {
        Connection conn = MyBatisUtils.getSqlSession().getConnection();
        System.out.println(conn!=null ? "连接成功" : "连接失败");
    }
}


EmpDao.java

package com.rk.dao;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.apache.ibatis.session.SqlSession;
import org.junit.Test;

import com.rk.entity.Emp;
import com.rk.utils.MyBatisUtils;

public class EmpDao {
    /**
     * 动态SQL之SELECT
     */
    public List dynamicFind(Integer id,String name,Double sal){
        SqlSession sqlSession = null;
        try {
            Map map = new HashMap();
            map.put("pid", id);
            map.put("pname", name != null ? "%"+name+"%" : null);
            map.put("psal", sal);
            sqlSession = MyBatisUtils.getSqlSession();
            
            return sqlSession.selectList(Emp.class.getName() + ".dynamicFind", map);
        } catch (Exception e) {
            e.printStackTrace();
            sqlSession.rollback();
        }
        finally{
            MyBatisUtils.closeSqlSession();
        }
        return null;
    }
    
    @Test
    public void testDynamicFind(){
        EmpDao dao = new EmpDao();
        //List list = dao.dynamicFind(1,null, null);
        //List list = dao.dynamicFind(null,"tom", null);
        //List list = dao.dynamicFind(null,null, 350D);
        List list = dao.dynamicFind(null,"tom", 350D);
//        List list = dao.dynamicFind(0,"tom", 25D);
        if(list != null && list.size()>0){
            for(Emp emp : list){
                System.out.println( emp.getName() + ":"+emp.getSal());
            }
        }
    }

    /**
     * 动态SQL之UPDATE
     */
    public int dynamicUpdate(Integer id,String name,Double sal){
        SqlSession sqlSession = null;
        try {
            Map map = new HashMap();
            map.put("pid", id);
            map.put("pname", name);
            map.put("psal", sal);
            sqlSession = MyBatisUtils.getSqlSession();
            
            int i=sqlSession.update(Emp.class.getName() + ".dynamicUpdate", map);
            sqlSession.commit();
            return i;
        } catch (Exception e) {
            e.printStackTrace();
            sqlSession.rollback();
        }
        finally{
            MyBatisUtils.closeSqlSession();
        }
        return 0;        
    }
    @Test
    public void testDynamicUpdate(){
        int i = dynamicUpdate(3,"Lucy",null);
        System.out.println("本次操作影响"+i+"行数据");
    }
    
    /**
     * 动态SQL之DELETE（数组版本）
     */
    public int dynamicDeleteArray(int... ids){
        SqlSession sqlSession = null;
        try {
            sqlSession = MyBatisUtils.getSqlSession();
            int i=sqlSession.update(Emp.class.getName() + ".dynamicDeleteArray", ids);
            sqlSession.commit();
            return i;
        } catch (Exception e) {
            e.printStackTrace();
            sqlSession.rollback();
        }
        finally{
            MyBatisUtils.closeSqlSession();
        }
        return 0;   
    }
    
    @Test
    public void testDynamicDeleteArray(){
        int i = dynamicDeleteArray(3,2);
        System.out.println("本次操作影响"+i+"行数据");
    }
    
    /**
     * 动态SQL之DELETE（集合版本）
     */
    public int dynamicDeleteList(List ids){
        SqlSession sqlSession = null;
        try {
            sqlSession = MyBatisUtils.getSqlSession();
            int i=sqlSession.update(Emp.class.getName() + ".dynamicDeleteList", ids);
            sqlSession.commit();
            return i;
        } catch (Exception e) {
            e.printStackTrace();
            sqlSession.rollback();
        }
        finally{
            MyBatisUtils.closeSqlSession();
        }
        return 0;   
    }
    
    @Test
    public void testDynamicDeleteList(){
        List ids = new ArrayList();
        ids.add(1);
        ids.add(4);
        int i = dynamicDeleteList(ids);
        System.out.println("本次操作影响"+i+"行数据");
    }
    
    /**
     * 动态SQL之INSERT
     */
    public int dynamicInsert(Emp emp){
        SqlSession sqlSession = null;
        try {
            sqlSession = MyBatisUtils.getSqlSession();
            int i=sqlSession.insert(Emp.class.getName() + ".dynamicInsert", emp);
            sqlSession.commit();
            return i;
        } catch (Exception e) {
            e.printStackTrace();
            sqlSession.rollback();
        }
        finally{
            MyBatisUtils.closeSqlSession();
        }
        return 0;   
    }
    
    @Test
    public void testDynamicInsert(){
        Emp emp = new Emp(1, null, 30D);
        int i = dynamicInsert(emp);
        System.out.println("本次操作影响"+i+"行数据");
    }
}


上一篇：最先告知德扑之星可不可以透视,王者十三水有没有挂辅助

下一篇：重建数据库所有表的索引

相关内容

热门资讯

汇正财经贺峰的一对一指导服务怎... 　　对于考虑购买证券投资顾问服务的投资者来说,'一对一指导服务怎么样'是一个重要的考量维度。需要首先...
重庆失联00后网格员龚宝冬确认... 　　重庆失联00后网格员龚宝冬确认遇难　　【重庆失联00后网格员龚宝冬确认遇难】2026年7月29日...
震惊！女子种出二三十万斤玉米后... 女子种出二三十万斤玉米后懵圈了　　【女子种出二三十万斤玉米后懵圈了】7月28日消息，商华颖，杭州千岛...
烈焰熊熊，堪比“原子弹”，欧洲... 据美国有线电视新闻网（CNN）7月29日报道，席卷法国西南部的大片野火燃烧得如此猛烈，以至于形成了一...
外交部：对日本熊本县地震遇难者... 据凤凰卫视报道，针对日本熊本县发生强震造成人员伤亡，中国外交部发言人毛宁7月29日在例行记者会上表示...
高铁喧哗被劝阻后叫嚣全家体制内... “女子高铁喧哗被劝阻后叫嚣全家体制内”一事迎来官方通报。据新京报报道，7月29日，辽宁北票市公安局发...
广东专业蓝牙耳机定制厂家推荐，... 在珠三角腹地，广东早已成为全球蓝牙耳机产业链的“心脏地带”。从深圳华强北的声学元件批发，到东莞、惠州...
格雷厄姆葬礼变地缘竞价场！两大... 有些葬礼，送别的是逝者；有些葬礼，演的却是活人最现实的政治博弈。当地时间7月28日，美国老牌鹰派参议...
一道小学数学题难住3名医学博士... 3名不同学校的博士同做一道数学题，谁最厉害？近日，一陕西网友发布的视频引发热议。29日，视频发布者“...
华为全新“小艺任务”亮相：整合... 7月29日，在华为鸿蒙电脑新品技术沟通会上，终端云服务小艺业务部总裁贾永利宣布，小艺将迎来“从对话到...