（3）.mybatis編寫工具類

編寫工具類

復用與重構

復用：使用方法與函數，復用的類，構成JAR包。（工具類屬於復用）

一。創建工具類（一般在src下創建util包，在util包下創建工具類）。

例如：MybatisUtilds為工具類：

 二：本工具類，作用如下：

1.創建和初始化SqlSessionFactory封裝成方法

2.能夠創建在一定范圍內（線程）有效的SqlSession

3.能夠關閉在一定范圍內（）有效的SqlSession

4.能夠進行事務控制

5.一些額外的支持Dao層便捷開發的方法

實現：

ThreadLocal:線程本地存儲（只能存儲一個對象，但是可以保證這個線程一直有效，除非線程銷毀）

ThreadGroup:線程組

ThreadPool：線程池

泛型方法：

public static <T> T getMapper(Class<T> tClass){
    return open().getMapper(tClass);
}

eg:

    public static void rollback(){
        SqlSession session = threadLocal.get();
        if(session!=null) session.rollback();
        UsersMapper dao=session.getMapper(UsersMapper.class); NewsMapper newDao=session.getMapper(NewsMapper.class);
    }
    public static <T> T getMapper(Class<T> tClass){ return open().getMapper(tClass); }

可更改：

public static void rollback(){
        SqlSession session = threadLocal.get();
        if(session!=null) session.rollback();
        UsersMapper dao=getMapper(UsersMapper.class); NewsMapper newDao=getMapper(NewsMapper.class); } public static <T> T getMapper(Class<T> tClass){ return open().getMapper(tClass); }

 三：完整代碼：

MybatisUtils類：

package com.util;

import com.dao.NewsMapper;
import com.dao.UsersMapper;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

import java.io.IOException;
import java.io.InputStream;

public class MybatisUtils {
    /**
     * 1.創建和初始化SqlSessionFactory
     * 2.能夠創建在一定范圍內（線程）有效的SqlSession
     * 3.能夠關閉在一定范圍內（）有效的SqlSession
     * 4.能夠進行事務控制
     * 5.一些額外的支持Dao層便捷開發的方法
     *  * 場景1：重定向
     *  * me -> A(伊濱)      1request->response   1線程
     *  *    -> B(西工)      2request->response   2線程
     *  *    -> C(澗西)      3request->response   3線程
     *  *    -> A(伊濱)      4request->response   4線程
     *  * 場景2：轉發         1request->response   1線程
     *  * me -> A(伊濱)
     *  *             -電話-> B(西工)
     *  *             -電話-> C(澗西)
     *  *     <-
     *  * 多線程環境下訪問SqlSession是同一個么、需要是同一個么？  不是同一個
     *  * 單線程環境下訪問SqlSession是同一個么、需要是同一個么？  是同一個
     */
    static final String CONFIG_FILE = "mybatis-config.xml";
    static SqlSessionFactory factory;
    static{
        initFactory(CONFIG_FILE);
    }
    public static void initFactory(String configName){
        SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
        try {
            InputStream resourceAsStream =
                    Resources.getResourceAsStream(configName);
            factory = builder.build(resourceAsStream);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    static ThreadLocal<SqlSession> threadLocal = new ThreadLocal<>();
    public static SqlSession open(){
        SqlSession session = threadLocal.get();
        if(session==null){
            session = factory.openSession();
            threadLocal.set(session);//線程綁定session，保證每次調用的是同一個線程
        }
        return session;
    }
    public static void close(){
        SqlSession session = threadLocal.get();
        if(session!=null){
            session.close();
            threadLocal.set(null);
        }
    }
    public static void commit(){
        SqlSession session = threadLocal.get();
        if(session!=null) session.commit();
    }
    public static void rollback(){
        SqlSession session = threadLocal.get();
        if(session!=null) session.rollback();
        UsersMapper dao=getMapper(UsersMapper.class);
        NewsMapper newDao=getMapper(NewsMapper.class);
    }
    public static <T> T getMapper(Class<T> tClass){
        return open().getMapper(tClass);
    }

}

 

測試類MybatisUtilsTest：

package com.dao;

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

import static com.util.MybatisUtils.open;

public class MybatisUtilsTest {
    //單線程測試
    @Test
    public void openInUniqueThread() throws InterruptedException{
        SqlSession s1=open();
        Thread.sleep(2000);
        SqlSession s2=open();
        Thread.sleep((int)(Math.random()*10000)+1000);
        SqlSession s3=open();
        Thread.sleep((int)(Math.random()*10000)+1000);
        assert s1==s2&&s1==s3;
    }
    //多線程測試
    SqlSession s1 = null;//全局變量
    SqlSession s2 = null;
    SqlSession s3 = null;
    @Test
    public void openInMultiplyThread() throws InterruptedException {
        // 匿名類對象（匿名內部類）。1.創建匿名內部類（thread）2.重寫run方法 3.創建對象
        new Thread(){//子線程
            public void run(){
                s1 = open();
            }
        }.start();
        new Thread(){
            public void run(){
                s2 = open();
            }
        }.start();
        new Thread(){
            public void run(){
                s3 = open();
            }
        }.start();
        // 等待，輪訓
        while(true){
            if(s1 != null && s2 != null && s3 != null){
                System.out.println("結束了！");
                break;
            }
            System.out.println("等待：s1=" + s1 +",s2=" + s2 + ",s3=" + s3);
            Thread.sleep(10);
        }
        assert s1 != s2 && s2 != s3 && s1 != s3;//主線程，s1,S2,S3為子線程。
    }

}