SqlSessionFactory与SqlSession

package com.fly.util;

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

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

/**
 * MyBatis 工具类：应用级单例管理 SqlSessionFactory
 * 
 * 设计要点：
 * 1. 静态代码块初始化，保证类加载时即完成 Factory 创建
 * 2. SqlSessionFactoryBuilder 在创建完 Factory 后即被释放（方法作用域）
 * 3. SqlSessionFactory 作为静态变量全局唯一（应用作用域）
 */
public class MyBatisUtil {
    
    private static SqlSessionFactory sqlSessionFactory;
    
    static {
        String resource = "mybatis-config.xml";
        try (InputStream inputStream = Resources.getResourceAsStream(resource)) {
            // Builder 是局部变量，build() 后即被回收
            sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
            System.out.println("【初始化】SqlSessionFactory 创建成功，应用级单例");
        } catch (IOException e) {
            throw new RuntimeException("MyBatis 初始化失败: " + e.getMessage(), e);
        }
    }
    
    /**
     * 获取全局唯一的 SqlSessionFactory
     */
    public static SqlSessionFactory getSqlSessionFactory() {
        return sqlSessionFactory;
    }
    
    // 禁止实例化
    private MyBatisUtil() {}
}

// 方式1：默认开启事务，手动提交
SqlSession session = factory.openSession();

// 方式2：指定是否自动提交
SqlSession session = factory.openSession(true);  // 自动提交
SqlSession session = factory.openSession(false); // 手动提交（默认）

// 方式3：指定连接隔离级别
SqlSession session = factory.openSession(Connection.TRANSACTION_READ_COMMITTED);

// 方式4：指定是否自动提交 + 隔离级别
SqlSession session = factory.openSession(Connection.TRANSACTION_READ_COMMITTED, true);

// 方式5：指定 Executor 类型（SIMPLE/REUSE/BATCH）
SqlSession session = factory.openSession(ExecutorType.BATCH);

package com.fly.test;

import com.fly.entity.Student;
import com.fly.mapper.StudentMapper;
import com.fly.util.MyBatisUtil;
import org.apache.ibatis.session.SqlSession;

public class SessionLifecycleDemo {
    
    /**
     * 查询操作：try-with-resources 自动关闭 Session
     */
    public Student findStudentById(int id) {
        // SqlSession 是方法作用域，每次请求新建
        try (SqlSession session = MyBatisUtil.getSqlSessionFactory().openSession()) {
            StudentMapper mapper = session.getMapper(StudentMapper.class);
            Student student = mapper.findById(id);
            
            System.out.println("【查询结果】id=" + id + " => " + student.getName());
            return student;
        } // Session 自动关闭，Connection 归还连接池
    }
    
    /**
     * 插入操作：需要手动提交事务
     */
    public int insertStudent(Student student) {
        try (SqlSession session = MyBatisUtil.getSqlSessionFactory().openSession()) {
            StudentMapper mapper = session.getMapper(StudentMapper.class);
            int rows = mapper.insert(student);
            
            // 非自动提交模式下，必须手动 commit
            session.commit();
            System.out.println("【插入成功】影响行数: " + rows + ", 新学生: " + student.getName());
            return rows;
        }
    }
    
    /**
     * 错误示范：将 SqlSession 作为实例变量（线程不安全！）
     */
    // private SqlSession badSession = MyBatisUtil.getSqlSessionFactory().openSession(); // 严禁！
}