mybatis使用のSqlSession取得

mybatisを使用する場合(springを結合しない)、一般的にSqlSessionを作成します.

/**
 * 
 */
package com.odianyun.steel.test.effective;

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

import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

import com.ibatis.common.resources.Resources;

/**
 * @author diaoxingguo
 *
 */
public class MyBatisSqlSessionFactory {
    private static SqlSessionFactory sqlSessionFactory;

    public static SqlSessionFactory getSqlSessionFactory(){
        if(null == sqlSessionFactory){
            InputStream inputStream;
            try {
                inputStream = Resources.getResourceAsStream("mybatis-config.xml");
                sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }


        return sqlSessionFactory;
    }

    public static SqlSession getSqlSession(){
        return getSqlSessionFactory().openSession();
    }
}

sqlSessionを使用してデータベース操作を行う場合は、2つの方法があります.1つはインタフェースを使用する形式です.2つ目は、ネーミングスペースを直接呼び出すsqlを実行することである.

public interface BookMapper{
    void insertBook(Book book);
}

MyBatisSqlSessionFactory.getSqlSession().getMapper(BookMapper.class).insertBook(book);

MyBatisSqlSessionFactory.getSqlSession().insert("insertBook", book);

この記事は主に、SqlSessionFactoryBuilder、SqlSessionFactoryとSqlSessionまずSqlSessionFactoryBuilderを見てみましょう.このクラスではbuild()メソッドのリロードです.

 public SqlSessionFactory build(InputStream inputStream, String environment, Properties properties) {
    try {
      XMLConfigBuilder parser = new XMLConfigBuilder(inputStream, environment, properties);
      return build(parser.parse());
    } catch (Exception e) {
      throw ExceptionFactory.wrapException("Error building SqlSession.", e);
    } finally {
      ErrorContext.instance().reset();
      try {
        inputStream.close();
      } catch (IOException e) {
        // Intentionally ignore. Prefer previous error.
      }
    }
  }

  public SqlSessionFactory build(Configuration config) {
    return new DefaultSqlSessionFactory(config);
  }

肝心な数行は

XMLConfigBuilder parser = new XMLConfigBuilder(inputStream, environment, properties);
return build(parser.parse());

このうち、これはプロファイルの解析です.前のいくつかの記事で述べましたが、後で分析を続けます.ここは先に省略します.次にDefaultSqlSessionFactoryを返し、DefaultSqlSessionFactoryはSqlSessionFactoryの実装クラスです.そしてコンフィギュレーション情報コンフィギュレーションを登録しました.これでSqlSessionFactoryを取得しました.次に、DefaultSqlSessionFactoryクラスのメソッドを見てみましょう.クラスにはopenSession()メソッドのリロードも多く、パラメータには主にトランザクション独立性レベル、実行タイプ、データベース接続が含まれており、自動的にコミットできます.まずパラメータのない

public SqlSession openSession() {
    return openSessionFromDataSource(configuration.getDefaultExecutorType(), null, false);
  }

private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit) {
    Transaction tx = null;
    try {
      final Environment environment = configuration.getEnvironment();
      final TransactionFactory transactionFactory = getTransactionFactoryFromEnvironment(environment);
      tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);
      final Executor executor = configuration.newExecutor(tx, execType);
      return new DefaultSqlSession(configuration, executor, autoCommit);
    } catch (Exception e) {
      closeTransaction(tx); // may have fetched a connection so lets call close()
      throw ExceptionFactory.wrapException("Error opening session.  Cause: " + e, e);
    } finally {
      ErrorContext.instance().reset();
    }
  }

構成情報のデータベース接続を取得してからトランザクションを読み込み、デフォルトではManagedTransactionFactory、次にトランザクションと実行タイプ(デフォルトではsample)を登録し、最後にDefaultSqlSessionに戻ります.