MyBatisUitls.java工具类⚡️

package com.singerw.utils;

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

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 SqlSessionUtil {

    private static SqlSessionFactory sqlSessionFactory = null;

    // 使用ThreadLocal 来管理我们的 SqlSession
    private static ThreadLocal<SqlSession> threadLocal = new ThreadLocal<SqlSession>();

    static {
        // 指定mybaits的全局配置文件的路径
        String resource = "mybatis-config.xml";
        // 输入流读取配置文件
        InputStream inputStream = null;
        try {
            inputStream = Resources.getResourceAsStream(resource);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        // 通过FactoryBuilder 得到 SqlSessionFactory
        sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);

        // 释放inputStream
        try {
            inputStream.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

    /**
	 * 
	 * @return
	 */
    public static SqlSession getSqlSession() {

        // 要先去threadLocal 看看是否有和当前线程绑定的那个sqlsession如果有 直接使用 没有再创建 op~ session
        SqlSession session = threadLocal.get();
        if (session == null) {
            // 通过sqlSessionFactory得到SqlSession
            session = sqlSessionFactory.openSession();
            // 得到了这个session,就将其放在threadLocal中
            threadLocal.set(session);
        }
        return session;
    }

    /**
	 * 
	 */
    public static void closeSqlSession() {
        // 从当前线程中获取 SqlSession对象
        SqlSession session = threadLocal.get();
        // 如果对象 不为空
        if (session != null) {
            // 从threadLocal 中移除
            threadLocal.remove();
            session.close();
        }
    }
}