首页 > 其他 > 详细

Mybatis实习笔记--2

时间:2015-10-26 13:57:48      阅读:282      评论:0      收藏:0      [点我收藏+]
package com.vitoh.mybatis.utils;

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.Reader;

/**
 * Created by vitohuang on 15/10/22.
 */
public class MyBatisSessionFactory {

    private static String CONFIG = "mybatis.cfg.xml";

    private static final ThreadLocal<SqlSession> threadLoacl = new ThreadLocal<SqlSession>();

    private static SqlSessionFactory sessionFactory;

    private static Reader reader;

    static{
        buildSessionFactory();
    }

    /**
     * 初始化SqlSessionFactory
     */
    public static void buildSessionFactory(){
        try{
            //第一步读取配置文件信息
            reader = Resources.getResourceAsReader(CONFIG);
            //第二步通过 SqlSessionFactoryBuilder 实例化 SqlSessionFactory
            sessionFactory = new SqlSessionFactoryBuilder().build(reader);
        }catch(Exception e){
            System.out.println("SessionFactory 创建失败");
            e.printStackTrace();
        }
    }

    /**
     * 获取数据库操作对象
     * @return
     */
    public static SqlSession getSession(){
        SqlSession session = (SqlSession)threadLoacl.get();
        if(session == null ){
            if(sessionFactory == null) buildSessionFactory();
            session = sessionFactory != null ? sessionFactory.openSession() : null;
            threadLoacl.set(session);
        }
        return session;
    }

    /**
     * 关闭数据库操作对象
     */
    public static void closeSession(){
        SqlSession session = (SqlSession)threadLoacl.get();
        if(session != null) session.close();
        threadLoacl.remove();
    }

    /**
     * 提交
     */
    public static void commit(){
        SqlSession session = (SqlSession)threadLoacl.get();
        if(session != null) session.commit();
    }

    /**
     * 回滚
     */
    public static void rollback(){
        SqlSession session = (SqlSession)threadLoacl.get();
        if(session != null) session.rollback();
    }

    /**
     * 获取SqlSessionFactory
     * @return
     */
    public static SqlSessionFactory getSessionFactory() {
        return sessionFactory;
    }
}


Mybatis实习笔记--2

原文:http://my.oschina.net/vitoh/blog/522047

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!