zoukankan      html  css  js  c++  java
  • Sqlsession 的理解

    MyBatis的持久化解决方案是将用户从原始的JDBC访问中解放出来,用户只需要定义需要操作的SQL语句,无须关注底层的JDBC操作,就可以以面向对象的方式来进行持久化层操作.底层数据库连接的获取,数据访问的实现,事务控制等都无须用户关心,从而将应用层从底层的JDBC/JTA API抽取出来.通过配置文件管理JDBC连接,让MyBatis解决持久化的实现.在MyBatis中的常见对象有SqlSessionFactory和SqlSession.本文这种介绍一下两者的概念和使用.

    一、 SqlSessionFactory

    SqlSessionFactory是MyBatis的关键对象,它是个单个数据库映射关系经过编译后的内存镜像.SqlSessionFactory对象的实例可以通过SqlSessionFactoryBuilder对象类获得,而SqlSessionFactoryBuilder则可以从XML配置文件或一个预先定制的Configuration的实例构建出SqlSessionFactory的实例.每一个MyBatis的应用程序都以一个SqlSessionFactory对象的实例为核心.同时SqlSessionFactory也是线程安全的,SqlSessionFactory一旦被创建,应该在应用执行期间都存在.在应用运行期间不要重复创建多次,建议使用单例模式.SqlSessionFactory是创建SqlSession的工厂.

    package org.apache.ibatis.session;
    
    
    
    import java.sql.Connection;
    
    
    
    public interface SqlSessionFactory {
    
    
    
      SqlSession openSession();//这个方法最经常用,用来创建SqlSession对象.
    
    
    
      SqlSession openSession(boolean autoCommit);
    
      SqlSession openSession(Connection connection);
    
      SqlSession openSession(TransactionIsolationLevel level);
    
    
    
      SqlSession openSession(ExecutorType execType);
    
      SqlSession openSession(ExecutorType execType, boolean autoCommit);
    
      SqlSession openSession(ExecutorType execType, TransactionIsolationLevel level);
    
      SqlSession openSession(ExecutorType execType, Connection connection);
    
    
    
      Configuration getConfiguration();
    
    
    
    }

    二、SqlSession

    SqlSession是MyBatis的关键对象,是执行持久化操作的独享,类似于JDBC中的Connection.它是应用程序与持久层之间执行交互操作的一个单线程对象,也是MyBatis执行持久化操作的关键对象.SqlSession对象完全包含以数据库为背景的所有执行SQL操作的方法,它的底层封装了JDBC连接,可以用SqlSession实例来直接执行被映射的SQL语句.每个线程都应该有它自己的SqlSession实例.SqlSession的实例不能被共享,同时SqlSession也是线程不安全的,绝对不能讲SqlSeesion实例的引用放在一个类的静态字段甚至是实例字段中.也绝不能将SqlSession实例的引用放在任何类型的管理范围中,比如Servlet当中的HttpSession对象中.使用完SqlSeesion之后关闭Session很重要,应该确保使用finally块来关闭它.

     1 //SqlSession接口源码如下所示:
     2 
     3 package org.apache.ibatis.session;
     4 
     5 import java.io.Closeable;
     6 import java.sql.Connection;
     7 import java.util.List;
     8 import java.util.Map;
     9 
    10 import org.apache.ibatis.executor.BatchResult;
    11 
    12 public interface SqlSession extends Closeable {
    13 
    14   <T> T selectOne(String statement);
    15 
    16   <T> T selectOne(String statement, Object parameter);
    17 
    18   <E> List<E> selectList(String statement);
    19 
    20   <E> List<E> selectList(String statement, Object parameter);
    21 
    22   <E> List<E> selectList(String statement, Object parameter, RowBounds rowBounds);
    23 
    24   <K, V> Map<K, V> selectMap(String statement, String mapKey);
    25 
    26   <K, V> Map<K, V> selectMap(String statement, Object parameter, String mapKey);
    27 
    28   <K, V> Map<K, V> selectMap(String statement, Object parameter, String mapKey, RowBounds rowBounds);
    29 
    30   void select(String statement, Object parameter, ResultHandler handler);
    31 
    32   void select(String statement, ResultHandler handler);
    33 
    34   void select(String statement, Object parameter, RowBounds rowBounds, ResultHandler handler);
    35 
    36   int insert(String statement);
    37 
    38   int insert(String statement, Object parameter);
    39 
    40   int update(String statement);
    41 
    42   int update(String statement, Object parameter);
    43 
    44   int delete(String statement);
    45 
    46   int delete(String statement, Object parameter);
    47 
    48   void commit();
    49 
    50   void commit(boolean force);
    51 
    52   void rollback();
    53 
    54   void rollback(boolean force);
    55 
    56   List<BatchResult> flushStatements();
    57 
    58   void close();
    59 
    60   void clearCache();
    61 
    62   Configuration getConfiguration();
    63 
    64   <T> T getMapper(Class<T> type);
    65 
    66   Connection getConnection();
    67 }

    三、SqlSessionFactory和SqlSession实现过程

     

    mybatis框架主要是围绕着SqlSessionFactory进行的,创建过程大概如下:

    (1)、定义一个Configuration对象,其中包含数据源、事务、mapper文件资源以及影响数据库行为属性设置settings
    
    (2)、通过配置对象,则可以创建一个SqlSessionFactoryBuilder对象
    
    (3)、通过 SqlSessionFactoryBuilder 获得SqlSessionFactory 的实例。
    
    (4)、SqlSessionFactory 的实例可以获得操作数据的SqlSession实例,通过这个实例对数据库进行操作
    

    并且如果想按照上述方式得到SqlSessionFactory,最好使用下面的mybatis-config.xml类似的配置.在这里mybatis-config.xml配置文件是没有和Spring配置文件整合过得,如果项目中mybaits的配置文件和Spring配置文件整合过了,则下面的代码运行估计会出错,因为一般spring和mybatis整合过之后,mybatis的配置文件基本没有存在的必要了,之前在mybatis中配置的数据源和事务这两个方面,一般的做法都会spring的配置文件,则下面的代码加载mybatis-config.xml的时候,得不到必要的信息,创建的过程中会有问题.所以在这里先给一份mybatis-config.xml单独的配置文件. 1 <?xml version="1.0" encoding="UTF-8"?> 2 2 <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd">

     3  3 <configuration>
     4  4 
     5  5     <!-- 加载数据库属性文件 -->
     6  6     <properties resource="jdbc.properties">
     7  7     </properties>
     8  8     <!-- 可以配置多个运行环境,但是每个 SqlSessionFactory 实例只能选择一个运行环境 一、development:开发模式 二、work:工作模式 -->
     9  9     <environments default="development">
    10 10         <!--id属性必须和上面的default一样 -->
    11 11         <environment id="development">
    12 12             <transactionManager type="JDBC" />
    13 13             <!--dataSource 元素使用标准的 JDBC 数据源接口来配置 JDBC 连接对象源 -->
    14 14             <dataSource type="POOLED">
    15 15                 <property name="driver" value="${jdbc.driver}" />
    16 16                 <property name="url" value="${jdbc.url}" />
    17 17                 <property name="username" value="${jdbc.username}" />
    18 18                 <property name="password" value="${jdbc.password}" />
    19 19             </dataSource>
    20 20         </environment>
    21 21     </environments>
    22 22  <!-- 在配置文件中 关联包下的 接口类-->
    23 23 <mappers> 24 24 <mapper resource="com/ys/mapper/userMapper.xml"/> 25 25 </mappers> 26 26 </configuration>

    下面的这行代码功能是通过配置文件mybatis-config.xml,创建SqlSessionFactory对象,然后产生SqlSession,执行SQL语句.而mybatis的初始化发生在:

    SqlSessionFactory sqlSessionFactory =  new SqlSessionFactoryBuilder().build(resourceAsStream);
    如果是spring和mybaits整合之后的配置文件,一般以这种方式实现,SqlSessionFactory的创建:
    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> <property name="dataSource" ref="dataSource"></property> <!-- 自动扫描mapping.xml文件 --> <property name="mapperLocations" value="classpath:com/cn/mapper/*.xml"></property> </bean>
    /**
    *关于SqlSessionFactory和SqlSession两个对象给一个具体的使用过程:
    */
    1
    package com.cn.testIUserService; 2 3 import java.io.IOException; 4 import java.io.InputStream; 5 import org.apache.ibatis.io.Resources; 6 import org.apache.ibatis.session.SqlSession; 7 import org.apache.ibatis.session.SqlSessionFactory; 8 import org.apache.ibatis.session.SqlSessionFactoryBuilder; 9 10 import com.cn.entity.User; 11 12 public class MyBatisTest { 13 14 public static void main(String[] args) { 15 try { 16 //读取mybatis-config.xml文件 17 InputStream resourceAsStream = Resources.getResourceAsStream("mybatis-config.xml"); 18 //初始化mybatis,创建SqlSessionFactory类的实例 19 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(resourceAsStream); 20 //创建session实例 21 SqlSession session = sqlSessionFactory.openSession(); 22 /* 23 * 接下来在这里做很多事情,到目前为止,目的已经达到得到了SqlSession对象.通过调用SqlSession里面的方法, 24 * 可以测试MyBatis和Dao层接口方法之间的正确性,当然也可以做别的很多事情,在这里就不列举了 25 */ 26 //插入数据 27 User user = new User(); 28 user.setC_password("123"); 29 user.setC_username("123"); 30 user.setC_salt("123"); 31 //第一个参数为方法的完全限定名:位置信息+映射文件当中的id 32 session.insert("com.cn.dao.UserMapping.insertUserInformation", user); 33 //提交事务 34 session.commit(); 35 //关闭session 36 session.close(); 37 } catch (IOException e) { 38 e.printStackTrace(); 39 } 40 } 41 }
    结合上述SqlSessionFactory和SqlSession使用过程和结构图,涉及到的方法为下面步骤,结合源码中的方法为下面的步骤:
    第一步首先SqlSessionFactoryBuilder去读取mybatis的配置文件,然后build一个DefaultSqlSessionFactory,即得到SqlSessionFactory
    //源码中涉及的包和具体方法为:
    //涉及的包为:package org.apache.ibatis.session;
    
    //第一个类为:SqlSessionFactoryBuilder,设计到此类的方法为下面部分:
    public SqlSessionFactory build(InputStream inputStream) {
        return build(inputStream, null, null);
      }
    
    public SqlSessionFactory build(InputStream inputStream, String environment, Properties properties) {
        try {
          //通过XMLConfigBuilder解析配置文件,解析的配置相关信息都会封装为一个Configuration对象
          XMLConfigBuilder parser = new XMLConfigBuilder(inputStream, environment, properties);
          //然后返回一个DefaultSqlSessionFactory
          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.
          }
        }
      }
    
     //得到DefaultSqlSessionFactory
     public SqlSessionFactory build(Configuration config) {
       return new DefaultSqlSessionFactory(config);
     }
    
    //第二个类为:DefaultSqlSessionFactory,涉及的方法为:
      public DefaultSqlSessionFactory(Configuration configuration) {
        this.configuration = configuration;
      }

    第二步,获取到SqlSessionFactory之后,就可以利用SqlSessionFactory方法的openSession来获取SqlSession对象了。
    得到SqlSession对象之后就可以利用SqlSession内部的方法进行CRUD操作了。
    
    注意一点,Connection对象是在SqlSession对象创建之后进行CURD操作中创建的。深入查找之后找到在ManagedTransaction类中找到获取Connection对象的关键代码如下:

    private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit) { 2 Transaction tx = null; 3 try { 4 //通过Confuguration对象去获取Mybatis相关配置信息, Environment对象包含了数据源和事务的配置 5 // execType为执行器类型,配置文件中定义 6 // SimpleExecutor -- SIMPLE 就是普通的执行器。 7 //ReuseExecutor -执行器会重用预处理语句(prepared statements) 8 //BatchExecutor --它是批量执行器 9 final Environment environment = configuration.getEnvironment(); 10 final TransactionFactory transactionFactory = getTransactionFactoryFromEnvironment(environment); 11 tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit); 12 //定义执行器,是对statement的封装 13 final Executor executor = configuration.newExecutor(tx, execType); 14 //最后返回一个SqlSession 15 return new DefaultSqlSession(configuration, executor, autoCommit); 16 } catch (Exception e) { 17 closeTransaction(tx); // may have fetched a connection so lets call close() 18 throw ExceptionFactory.wrapException("Error opening session. Cause: " + e, e); 19 } finally { 20 ErrorContext.instance().reset(); 21 } 22 }
     1   protected void openConnection() throws SQLException {
     2     if (log.isDebugEnabled()) {
     3       log.debug("Opening JDBC Connection");
     4     }
     5     //dataSource 来源有三种,JndiDatasource,PooledDataSource,UnpooledDataSource,配置文件中定义
     6     this.connection = this.dataSource.getConnection();
     7     if (this.level != null) {
     8       this.connection.setTransactionIsolation(this.level.getLevel());
     9     }
    10   }

    PooledDataSource和UnPooledDataSource的区别是PooledDataSource使用了连接池。为什么使用连接池呢?因为创建一个Connection对象的过程,在底层就相当于和数据库建立的通信连接,在建立通信连接的过程,消耗了非常多的时间,而往往我们建立连接后(即创建Connection对象后),就执行一个简单的SQL语句,然后就要抛弃掉,这是一个非常大的资源浪费!mybatis针对这一个问题提出的PooledDataSource使用了连接池

    --------------------- 

    作者:可乐丶 

    来源:CSDN 

    原文:https://blog.csdn.net/u013412772/article/details/73648537 

    版权声明:本文为博主原创文章,转载请附上博文链接!

    前言:学习框架一个比较好的路径阅读源码.本文介绍的SqlSessionFactory和SqlSession.可以通过了解SqlSessionFactory接口和SqlSession接口以及两个的实现类入手,去看源码了解实现过程.最好能把项目下载到本地,慢慢分析实现过程.
    Myabtis官网:http://www.mybatis.org/ github地址:https://github.com/mybatis/mybatis-3


    MyBatis的持久化解决方案是将用户从原始的JDBC访问中解放出来,用户只需要定义需要操作的SQL语句,无须关注底层的JDBC操作,就可以以面向对象的方式来进行持久化层操作.底层数据库连接的获取,数据访问的实现,事务控制等都无须用户关心,从而将应用层从底层的JDBC/JTA API抽取出来.通过配置文件管理JDBC连接,让MyBatis解决持久化的实现.在MyBatis中的常见对象有SqlSessionFactory和SqlSession.本文这种介绍一下两者的概念和使用.
    一、 SqlSessionFactorySqlSessionFactory是MyBatis的关键对象,它是个单个数据库映射关系经过编译后的内存镜像.SqlSessionFactory对象的实例可以通过SqlSessionFactoryBuilder对象类获得,而SqlSessionFactoryBuilder则可以从XML配置文件或一个预先定制的Configuration的实例构建出SqlSessionFactory的实例.每一个MyBatis的应用程序都以一个SqlSessionFactory对象的实例为核心.同时SqlSessionFactory也是线程安全的,SqlSessionFactory一旦被创建,应该在应用执行期间都存在.在应用运行期间不要重复创建多次,建议使用单例模式.SqlSessionFactory是创建SqlSession的工厂.
    //SqlSessionFactory接口源码如下所示:
    package org.apache.ibatis.session;
    import java.sql.Connection;
    public interface SqlSessionFactory {
      SqlSession openSession();//这个方法最经常用,用来创建SqlSession对象.
      SqlSession openSession(boolean autoCommit);  SqlSession openSession(Connection connection);  SqlSession openSession(TransactionIsolationLevel level);
      SqlSession openSession(ExecutorType execType);  SqlSession openSession(ExecutorType execType, boolean autoCommit);  SqlSession openSession(ExecutorType execType, TransactionIsolationLevel level);  SqlSession openSession(ExecutorType execType, Connection connection);
      Configuration getConfiguration();
    }12345678910111213141516171819202122二、SqlSessionSqlSession是MyBatis的关键对象,是执行持久化操作的独享,类似于JDBC中的Connection.它是应用程序与持久层之间执行交互操作的一个单线程对象,也是MyBatis执行持久化操作的关键对象.SqlSession对象完全包含以数据库为背景的所有执行SQL操作的方法,它的底层封装了JDBC连接,可以用SqlSession实例来直接执行被映射的SQL语句.每个线程都应该有它自己的SqlSession实例.SqlSession的实例不能被共享,同时SqlSession也是线程不安全的,绝对不能讲SqlSeesion实例的引用放在一个类的静态字段甚至是实例字段中.也绝不能将SqlSession实例的引用放在任何类型的管理范围中,比如Servlet当中的HttpSession对象中.使用完SqlSeesion之后关闭Session很重要,应该确保使用finally块来关闭它.
    //SqlSession接口源码如下所示:
    package org.apache.ibatis.session;
    import java.io.Closeable;import java.sql.Connection;import java.util.List;import java.util.Map;
    import org.apache.ibatis.executor.BatchResult;
    public interface SqlSession extends Closeable {
      <T> T selectOne(String statement);
      <T> T selectOne(String statement, Object parameter);
      <E> List<E> selectList(String statement);
      <E> List<E> selectList(String statement, Object parameter);
      <E> List<E> selectList(String statement, Object parameter, RowBounds rowBounds);
      <K, V> Map<K, V> selectMap(String statement, String mapKey);
      <K, V> Map<K, V> selectMap(String statement, Object parameter, String mapKey);
      <K, V> Map<K, V> selectMap(String statement, Object parameter, String mapKey, RowBounds rowBounds);
      void select(String statement, Object parameter, ResultHandler handler);
      void select(String statement, ResultHandler handler);
      void select(String statement, Object parameter, RowBounds rowBounds, ResultHandler handler);
      int insert(String statement);
      int insert(String statement, Object parameter);
      int update(String statement);
      int update(String statement, Object parameter);
      int delete(String statement);
      int delete(String statement, Object parameter);
      void commit();
      void commit(boolean force);
      void rollback();
      void rollback(boolean force);
      List<BatchResult> flushStatements();
      void close();
      void clearCache();
      Configuration getConfiguration();
      <T> T getMapper(Class<T> type);
      Connection getConnection();}1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768三、SqlSessionFactory和SqlSession实现过程mybatis框架主要是围绕着SqlSessionFactory进行的,创建过程大概如下:
    (1)、定义一个Configuration对象,其中包含数据源、事务、mapper文件资源以及影响数据库行为属性设置settings
    (2)、通过配置对象,则可以创建一个SqlSessionFactoryBuilder对象
    (3)、通过 SqlSessionFactoryBuilder 获得SqlSessionFactory 的实例。
    (4)、SqlSessionFactory 的实例可以获得操作数据的SqlSession实例,通过这个实例对数据库进行操作1234567并且如果想按照上述方式得到SqlSessionFactory,最好使用下面的mybatis-config.xml类似的配置.在这里mybatis-config.xml配置文件是没有和Spring配置文件整合过得,如果项目中mybaits的配置文件和Spring配置文件整合过了,则下面的代码运行估计会出错,因为一般spring和mybatis整合过之后,mybatis的配置文件基本没有存在的必要了,之前在mybatis中配置的数据源和事务这两个方面,一般的做法都会spring的配置文件,则下面的代码加载mybatis-config.xml的时候,得不到必要的信息,创建的过程中会有问题.所以在这里先给一份mybatis-config.xml单独的配置文件.
    <?xml version="1.0" encoding="UTF-8"?>  <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN"  "http://mybatis.org/dtd/mybatis-3-config.dtd">  
    <configuration>       <!-- 加载类路径下的属性文件 -->      <properties resource="db.properties"/>  
        <!-- 设置类型别名 -->      <typeAliases>          <typeAlias type="cn.itcast.javaee.mybatis.app04.Student" alias="student"/>      </typeAliases>  
        <!-- 设置一个默认的连接环境信息 -->      <environments default="mysql_developer">  
            <!-- 连接环境信息,取一个任意唯一的名字 -->          <environment id="mysql_developer">              <!-- mybatis使用jdbc事务管理方式 -->              <transactionManager type="jdbc"/>              <!-- mybatis使用连接池方式来获取连接 -->              <dataSource type="pooled">                  <!-- 配置与数据库交互的4个必要属性 -->                  <property name="driver" value="${mysql.driver}"/>                  <property name="url" value="${mysql.url}"/>                  <property name="username" value="${mysql.username}"/>                  <property name="password" value="${mysql.password}"/>              </dataSource>          </environment>  
            <!-- 连接环境信息,取一个任意唯一的名字 -->          <environment id="oracle_developer">              <!-- mybatis使用jdbc事务管理方式 -->              <transactionManager type="jdbc"/>              <!-- mybatis使用连接池方式来获取连接 -->              <dataSource type="pooled">                  <!-- 配置与数据库交互的4个必要属性 -->                  <property name="driver" value="${oracle.driver}"/>                  <property name="url" value="${oracle.url}"/>                  <property name="username" value="${oracle.username}"/>                  <property name="password" value="${oracle.password}"/>              </dataSource>          </environment>      </environments>  
        <!-- 加载映射文件-->      <mappers>          <mapper resource="cn/itcast/javaee/mybatis/app14/StudentMapper.xml"/>      </mappers>  
    </configuration>  123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051下面的这行代码功能是通过配置文件mybatis-config.xml,创建SqlSessionFactory对象,然后产生SqlSession,执行SQL语句.而mybatis的初始化发生在:
    SqlSessionFactory sqlSessionFactory =  new SqlSessionFactoryBuilder().build(resourceAsStream);12如果是spring和mybaits整合之后的配置文件,一般以这种方式实现,SqlSessionFactory的创建:
    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">        <property name="dataSource" ref="dataSource"></property>        <!-- 自动扫描mapping.xml文件 -->        <property name="mapperLocations" value="classpath:com/cn/mapper/*.xml"></property></bean>12345关于SqlSessionFactory和SqlSession两个对象给一个具体的使用过程:
    package com.cn.testIUserService;
    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;
    import com.cn.entity.User;
    public class MyBatisTest {
        public static void main(String[] args) {        try {            //读取mybatis-config.xml文件            InputStream resourceAsStream = Resources.getResourceAsStream("mybatis-config.xml");            //初始化mybatis,创建SqlSessionFactory类的实例            SqlSessionFactory sqlSessionFactory =  new SqlSessionFactoryBuilder().build(resourceAsStream);            //创建session实例            SqlSession session = sqlSessionFactory.openSession();            /*             * 接下来在这里做很多事情,到目前为止,目的已经达到得到了SqlSession对象.通过调用SqlSession里面的方法,             * 可以测试MyBatis和Dao层接口方法之间的正确性,当然也可以做别的很多事情,在这里就不列举了             */            //插入数据            User user = new User();            user.setC_password("123");            user.setC_username("123");            user.setC_salt("123");            //第一个参数为方法的完全限定名:位置信息+映射文件当中的id            session.insert("com.cn.dao.UserMapping.insertUserInformation", user);            //提交事务            session.commit();            //关闭session            session.close();        } catch (IOException e) {            e.printStackTrace();        }    }}1234567891011121314151617181920212223242526272829303132333435363738394041针对上面的代码给出详细的说明关于SqlSessionFactory和SqlSession创建过程涉及的内容.


    结合上述SqlSessionFactory和SqlSession使用过程和结构图,涉及到的方法为下面步骤,结合源码中的方法为下面的步骤:
    第一步首先SqlSessionFactoryBuilder去读取mybatis的配置文件,然后build一个DefaultSqlSessionFactory,即得到SqlSessionFactory1//源码中涉及的包和具体方法为://涉及的包为:package org.apache.ibatis.session;
    //第一个类为:SqlSessionFactoryBuilder,设计到此类的方法为下面部分:public SqlSessionFactory build(InputStream inputStream) {    return build(inputStream, null, null);  }
    public SqlSessionFactory build(InputStream inputStream, String environment, Properties properties) {    try {      //通过XMLConfigBuilder解析配置文件,解析的配置相关信息都会封装为一个Configuration对象      XMLConfigBuilder parser = new XMLConfigBuilder(inputStream, environment, properties);      //然后返回一个DefaultSqlSessionFactory      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.      }    }  }
     //得到DefaultSqlSessionFactory public SqlSessionFactory build(Configuration config) {   return new DefaultSqlSessionFactory(config); }
    //第二个类为:DefaultSqlSessionFactory,涉及的方法为:  public DefaultSqlSessionFactory(Configuration configuration) {    this.configuration = configuration;  }123456789101112131415161718192021222324252627282930313233343536第二步,获取到SqlSessionFactory之后,就可以利用SqlSessionFactory方法的openSession来获取SqlSession对象了。1private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit) {  Transaction tx = null;  try {    //通过Confuguration对象去获取Mybatis相关配置信息, Environment对象包含了数据源和事务的配置    // execType为执行器类型,配置文件中定义    // SimpleExecutor -- SIMPLE 就是普通的执行器。    //ReuseExecutor -执行器会重用预处理语句(prepared statements)    //BatchExecutor --它是批量执行器    final Environment environment = configuration.getEnvironment();    final TransactionFactory transactionFactory = getTransactionFactoryFromEnvironment(environment);    tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);    //定义执行器,是对statement的封装    final Executor executor = configuration.newExecutor(tx, execType);    //最后返回一个SqlSession    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();  }}12345678910111213141516171819202122得到SqlSession对象之后就可以利用SqlSession内部的方法进行CRUD操作了。
    注意一点,Connection对象是在SqlSession对象创建之后进行CURD操作中创建的。深入查找之后找到在ManagedTransaction类中找到获取Connection对象的关键代码如下:
      protected void openConnection() throws SQLException {    if (log.isDebugEnabled()) {      log.debug("Opening JDBC Connection");    }    //dataSource 来源有三种,JndiDatasource,PooledDataSource,UnpooledDataSource,配置文件中定义    this.connection = this.dataSource.getConnection();    if (this.level != null) {      this.connection.setTransactionIsolation(this.level.getLevel());    }  }12345678910PooledDataSource和UnPooledDataSource的区别是PooledDataSource使用了连接池。为什么使用连接池呢?因为创建一个Connection对象的过程,在底层就相当于和数据库建立的通信连接,在建立通信连接的过程,消耗了非常多的时间,而往往我们建立连接后(即创建Connection对象后),就执行一个简单的SQL语句,然后就要抛弃掉,这是一个非常大的资源浪费!mybatis针对这一个问题提出的PooledDataSource使用了连接池。--------------------- 作者:可乐丶 来源:CSDN 原文:https://blog.csdn.net/u013412772/article/details/73648537 版权声明:本文为博主原创文章,转载请附上博文链接!

  • 相关阅读:
    poj2392 Space Elevator(多重背包问题)
    poj1703 Find them, Catch them(并查集的应用)
    HDU 1867 A + B for you again(KMP算法的应用)
    HDU 1358 Period(kmp简单解决)
    nyoj 460 项链 (区间dp)
    Python内置函数(9)——callable--转载
    Python的hasattr() getattr() setattr() 函数使用方法详解--转载
    python assert 断言详细用法格式
    sam文件格式
    Linux中重定向--转载
  • 原文地址:https://www.cnblogs.com/minixiong/p/10135257.html
Copyright © 2011-2022 走看看