成人午夜视频全免费观看高清-秋霞福利视频一区二区三区-国产精品久久久久电影小说-亚洲不卡区三一区三区一区

MyBatis系列：（5）動態(tài)SQL

1、動態(tài)SQL操作之查詢

在安達等地區(qū)，都構建了全面的區(qū)域性戰(zhàn)略布局，加強發(fā)展的系統(tǒng)性、市場前瞻性、產品創(chuàng)新能力，以專注、極致的服務理念，為客戶提供成都網站設計、成都網站建設 網站設計制作定制網站,公司網站建設,企業(yè)網站建設,品牌網站設計,營銷型網站,外貿網站建設,安達網站建設費用合理。

查詢條件不確定，需要根據情況產生SQL語法，這種情況叫動態(tài)SQL

    <select id="dynamicFind" parameterType="map" resultMap="empMap">
        select emp_id,emp_name,emp_sal from emp
        <where>
            <if test="pid != null">
                and emp_id = #{pid}
            </if>
            <if test="pname != null">
                and emp_name like #{pname}
            </if>
            <if test="psal != null">
                and emp_sal &lt; #{psal}
            </if>
        </where>
    </select>

MyBatis系列：（5）動態(tài)SQL

2、動態(tài)SQL操作之更新

更新條件不確定，需要根據情況產生SQL語法，這種情況叫動態(tài)SQL

    <update id="dynamicUpdate" parameterType="map">
        update emp
        <set>
            <if test="pname != null">
                emp_name = #{pname},
            </if>
            <if test="psal != null">
                emp_sal = #{psal},
            </if>
        </set>
        where emp_id = #{pid}
    </update>

MyBatis系列：（5）動態(tài)SQL

3、動態(tài)SQL操作之刪除

根據多個id進行刪除

    <delete id="dynamicDeleteArray">
        delete from emp where emp_id in
        <!-- foreach用于迭代數組元素
             open表示開始符號
             close表示結束符合
             separator表示元素間的分隔符
             item表示迭代的數組，屬性值可以任意，但提倡與方法的數組名相同
             #{pid}表示數組中的每個元素值
         -->        
        <foreach collection="array" open="(" close=")" separator="," item="pid" >
            #{pid}
        </foreach>
    </delete>
    
    <delete id="dynamicDeleteList">
        delete from emp where emp_id in
        <foreach collection="list" open="(" close=")" separator="," item="pid">
            #{pid}
        </foreach>
    </delete>

MyBatis系列：（5）動態(tài)SQL

4、動態(tài)SQL操作之添加

根據條件，添加數據

    <!-- sql片段對應字段名,id屬性值任意 -->
    <sql id="key">
        <!-- 去掉最后一個,號 -->
        <trim suffixOverrides=",">
            <if test="id != null">
                emp_id,
            </if>
            <if test="name != null">
                emp_name,
            </if>
            <if test="sal != null">
                emp_sal,
            </if>
        </trim>
    </sql>
    
    <!-- sql片段對應?,id屬性值任意 -->
    <sql id="value">
        <!-- 去掉最后一個,號 -->
        <trim suffixOverrides=",">
            <if test="id != null">
                #{id},
            </if>
            <if test="name != null">
                #{name},
            </if>
            <if test="sal != null">
                #{sal},
            </if>
        </trim>
    </sql>
    <!-- <include refid="key"/>和<include refid="value"/>表示引用上面定義的sql片段 -->
    <insert id="dynamicInsert" parameterType="emp">
        insert into emp(<include refid="key"></include>) values(<include refid="value"></include>)
    </insert>

MyBatis系列：（5）動態(tài)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

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
    PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
    "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.rk.entity.Emp">
    <!-- 當實體屬性與表字段名不相同的時候，必須書寫以下代碼
         當實體屬性與表字段名相同的時候，以下代碼可選 （可寫可不寫）
     -->
    <resultMap type="emp" id="empMap">
        <id property="id" column="emp_id"/>
        <result property="name" column="emp_name"/>
        <result property="sal" column="emp_sal"/>
    </resultMap>
    <!-- 1、動態(tài)SQL之SELECT -->
    <select id="dynamicFind" parameterType="map" resultMap="empMap">
        select emp_id,emp_name,emp_sal from emp
        <where>
            <if test="pid != null">
                and emp_id = #{pid}
            </if>
            <if test="pname != null">
                and emp_name like #{pname}
            </if>
            <if test="psal != null">
                and emp_sal &lt; #{psal}
            </if>
        </where>
    </select>
    
    <!-- 2、動態(tài)SQL之UPDATE -->
    <!-- set標簽自動判斷哪個是最后一個字段，會自動去掉最后一個,號 -->
    <update id="dynamicUpdate" parameterType="map">
        update emp
        <set>
            <if test="pname != null">
                emp_name = #{pname},
            </if>
            <if test="psal != null">
                emp_sal = #{psal},
            </if>
        </set>
        where emp_id = #{pid}
    </update>
    
    <!-- 3、動態(tài)SQL之DELETE -->
    <delete id="dynamicDeleteArray">
        delete from emp where emp_id in
        <!-- foreach用于迭代數組元素
             open表示開始符號
             close表示結束符合
             separator表示元素間的分隔符
             item表示迭代的數組，屬性值可以任意，但提倡與方法的數組名相同
             #{pid}表示數組中的每個元素值
         -->        
        <foreach collection="array" open="(" close=")" separator="," item="pid" >
            #{pid}
        </foreach>
    </delete>
    
    <delete id="dynamicDeleteList">
        delete from emp where emp_id in
        <foreach collection="list" open="(" close=")" separator="," item="pid">
            #{pid}
        </foreach>
    </delete>
    
    <!-- 4、動態(tài)SQL之INSERT -->
    <!-- sql片段對應字段名,id屬性值任意 -->
    <sql id="key">
        <!-- 去掉最后一個,號 -->
        <trim suffixOverrides=",">
            <if test="id != null">
                emp_id,
            </if>
            <if test="name != null">
                emp_name,
            </if>
            <if test="sal != null">
                emp_sal,
            </if>
        </trim>
    </sql>
    
    <!-- sql片段對應?,id屬性值任意 -->
    <sql id="value">
        <!-- 去掉最后一個,號 -->
        <trim suffixOverrides=",">
            <if test="id != null">
                #{id},
            </if>
            <if test="name != null">
                #{name},
            </if>
            <if test="sal != null">
                #{sal},
            </if>
        </trim>
    </sql>
    <!-- <include refid="key"/>和<include refid="value"/>表示引用上面定義的sql片段 -->
    <insert id="dynamicInsert" parameterType="emp">
        insert into emp(<include refid="key"></include>) values(<include refid="value"></include>)
    </insert>

</mapper>

mybatis.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="db.properties"/>
    
    <!-- 設置類型別名 -->
    <typeAliases>
        <typeAlias type="com.rk.entity.Emp" alias="emp"/>
    </typeAliases>

    <!-- 設置一個默認的連接環(huán)境信息 -->
    <environments default="MySQL_development">
        <environment id="mysql_development">
            <!-- mybatis使用jdbc事務管理方式 -->
            <transactionManager type="JDBC"/>
            <!-- mybatis使用連接池方式來獲取連接 -->
            <dataSource type="POOLED">
                <!-- 配置與數據庫交互的4個必要屬性 -->
                <property name="driver" value="${mysql.driver}"/>
                <property name="url" value="${mysql.url}"/>
                <property name="username" value="${mysql.username}"/>
                <property name="password" value="${mysql.password}"/>
            </dataSource>
        </environment>
        
        <!-- 連接環(huán)境信息，取一個任意唯一的名字 -->
        <environment id="oracle_development">
            <!-- mybatis使用jdbc事務管理方式 -->
            <transactionManager type="jdbc"/>
            <!-- mybatis使用連接池方式來獲取連接 -->
            <dataSource type="pooled">
                <!-- 配置與數據庫交互的4個必要屬性 -->
                <property name="driver" value="${oracle.driver}"/>
                <property name="url" value="${oracle.url}"/>
                <property name="username" value="${oracle.username}"/>
                <property name="password" value="${oracle.password}"/>
            </dataSource>
        </environment>        
    </environments>
    
    <!-- 加載映射文件-->
    <mappers>
        <mapper resource="com/rk/entity/EmpMapper.xml"/>
    </mappers>
</configuration>

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<SqlSession> threadLocal = new ThreadLocal<SqlSession>();
    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 {
    /**
     * 動態(tài)SQL之SELECT
     */
    public List<Emp> dynamicFind(Integer id,String name,Double sal){
        SqlSession sqlSession = null;
        try {
            Map<String, Object> map = new HashMap<String, Object>();
            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<Emp> list = dao.dynamicFind(1,null, null);
        //List<Emp> list = dao.dynamicFind(null,"tom", null);
        //List<Emp> list = dao.dynamicFind(null,null, 350D);
        List<Emp> list = dao.dynamicFind(null,"tom", 350D);
//        List<Emp> list = dao.dynamicFind(0,"tom", 25D);
        if(list != null && list.size()>0){
            for(Emp emp : list){
                System.out.println( emp.getName() + ":"+emp.getSal());
            }
        }
    }

    /**
     * 動態(tài)SQL之UPDATE
     */
    public int dynamicUpdate(Integer id,String name,Double sal){
        SqlSession sqlSession = null;
        try {
            Map<String, Object> map = new HashMap<String, Object>();
            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+"行數據");
    }
    
    /**
     * 動態(tà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+"行數據");
    }
    
    /**
     * 動態(tài)SQL之DELETE（集合版本）
     */
    public int dynamicDeleteList(List<Integer> 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<Integer> ids = new ArrayList<Integer>();
        ids.add(1);
        ids.add(4);
        int i = dynamicDeleteList(ids);
        System.out.println("本次操作影響"+i+"行數據");
    }
    
    /**
     * 動態(tà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+"行數據");
    }
}

分享名稱：MyBatis系列：（5）動態(tài)SQL
鏈接URL：http://jinyejixie.com/article6/gdpjog.html

成都網站建設公司_創(chuàng)新互聯(lián)，為您提供動態(tài)網站、網頁設計公司、企業(yè)建站、響應式網站、外貿網站建設、自適應網站

廣告

聲明：本網站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)

成都網頁設計公司
海南省| 富锦市| 扎兰屯市| 揭阳市| 建德市| 雅安市| 瑞安市| 襄城县| 西华县| 台山市| 黄石市| 紫金县| 营山县| 江达县| 华蓥市| 通江县| 明溪县| 新绛县| 黄陵县| 嘉禾县| 镶黄旗| 毕节市| 南江县| 昌平区| 安塞县| 襄汾县| 汉寿县| 岗巴县| 临邑县| 横山县| 太谷县| 炎陵县| 庆阳市| 丰城市| 拉萨市| 综艺| 明光市| 伽师县| 延安市| 克什克腾旗| 昭觉县|