摘要：三大巨頭結果集再通過反射機制映射到對象上面，便做好了數據的映射關于映射具體內容可查閱資料及源碼到這我們已經完成了一個簡易的框架了通過手寫一個簡單的框架，我們就可以看得懂源碼了，學習框架設計的思路并且增強我們的內功

1.創建SqlSessionFactory實例.

2.實例化過程中，加載配置文件創建configuration對象.

3.通過factory創建SqlSession對象,把configuaration傳入SqlSession.

4.通過SqlSession獲取mapper接口動態代理

5.通過代理對調sqlsession中查詢方法;

6.sqlsession將查詢方法轉發給executor;

7.executor基于JDBC訪問數據庫獲取數據;

8.executor通過反射將數據轉換成POJO并返回給sqlsession;

9.數據返回給調用者

上節講到快速入門mybatis的demo三大階段

// 1.讀取mybatis配置文件創SqlSessionFactory
String resource = "mybatis-config.xml";
InputStream inputStream = Resources.getResourceAsStream(resource);
sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
inputStream.close();
//-------------第二階段-------------
// 2.獲取sqlSession
SqlSession sqlSession = sqlSessionFactory.openSession();
// 3.獲取對應mapper
TUserMapper mapper = sqlSession.getMapper(TUserMapper.class);

//-------------第三階段-------------
// 4.執行查詢語句并返回結果
TUser user = mapper.selectByPrimaryKey(1);
System.out.println(user.toString());

第一階段先把配置文件加載到內存，包括數據庫信息和mapper.xml。

針對mapper.xml我們定義一個MappedStatement類來存入相應信息.

public class MappedStatement {
    //此處忽略getset方法
    private String namespace;//xml里面的namespace即mapper接口路徑
    
    private String sourceId;//mapper接口路徑+xml里面的每一個id
    
    private String sql;//sql語句
    
    private String resultType;//返回類型    

}

再定義一個全局配置信息即Configuration存放所有配置信息：

public class Configuration {
    //記錄mapper xml文件存放的位置
    public static final String MAPPER_CONFIG_LOCATION = "config";
    //記錄數據庫連接信息文件存放位置
    public static final String DB_CONFIG_FILE = "db.properties";
    
    private String dbUrl;

    private String dbUserName;

    private String dbPassword;

    private String dbDriver;

    //mapper xml解析完以后select節點的信息存放在mappedStatements,key為MappedStatement里面 
     //的sourceId
    protected final Map mappedStatements = new HashMap();
    
    //為mapper接口生成動態代理的方法
public  T getMapper(Class type, SqlSession sqlSession) {
    return MapperProxyFactory.getMapperProxy(sqlSession, type);
}
}

SqlSessionFactory實例化，并加載configuaration對象信息,這樣就把所有的配置信息加載到內存里

public class SqlSessionFactory {
    //配置對象全局唯一 加載數據庫信息和mapper文件信息
    private Configuration conf = new Configuration();

    public SqlSessionFactory() {
        //加載數據庫信息
         loadDbInfo();
         //加載mapper文件信息
         loadMappersInfo();
    }
    
    private void loadMappersInfo() {
        URL resources =null;
        resources = SqlSessionFactory.class.getClassLoader().getResource(conf.MAPPER_CONFIG_LOCATION);
        File mappers = new File(resources.getFile());
        if(mappers.isDirectory()){
            File[] listFiles = mappers.listFiles();
            for (File file : listFiles) {
                loadMapperInfo(file);
            }
        }
    }

    private void loadMapperInfo(File file) {
        // 創建saxReader對象  
        SAXReader reader = new SAXReader();  
        // 通過read方法讀取一個文件 轉換成Document對象  
        Document document=null;
        try {
            document = reader.read(file);
        } catch (DocumentException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }  
        //獲取根節點元素對象  
        Element node = document.getRootElement();
        //獲取命名空間
        String namespace = node.attribute("namespace").getData().toString();
        //獲取select子節點列表
        List selects = node.elements("select");
        for (Element element : selects) {//遍歷select節點，將信息記錄到MappedStatement對象，并登記到configuration對象中
            MappedStatement mappedStatement = new MappedStatement();
            String id = element.attribute("id").getData().toString();
            String resultType = element.attribute("resultType").getData().toString();
            String sql = element.getData().toString();
            String sourceId = namespace+"."+id;
            mappedStatement.setSourceId(sourceId);
            mappedStatement.setResultType(resultType);
            mappedStatement.setSql(sql);
            mappedStatement.setNamespace(namespace);
            conf.getMappedStatements().put(sourceId, mappedStatement);//登記到configuration對象中
        }
    }

    private void loadDbInfo() {
        InputStream dbIn = SqlSessionFactory.class.getClassLoader().getResourceAsStream(conf.DB_CONFIG_FILE);
         Properties p = new Properties();
         try {
            p.load(dbIn);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
         conf.setDbDriver(p.get("jdbc.driver").toString());
         conf.setDbPassword(p.get("jdbc.password").toString());
         conf.setDbUrl(p.get("jdbc.url").toString());
         conf.setDbUserName(p.get("jdbc.username").toString());
    }
    public SqlSession openSession(){
        SqlSession sqlSession  = new DefaultSqlSession(conf);
        return sqlSession;
    }
}

第二階段為獲取Sqlsession并且從sqlsession獲取mapper動態代理.

Sqlsession

mybatis暴露給外部的接口，實現增刪改查的能力

1.對外提供數據訪問的api

2.對內將請求轉發給executor

3.executor基于JDBC訪問數據庫

public class DefaultSqlSession implements SqlSession {
       
       //配置對象全局唯一 加載數據庫信息和mapper文件信息
       private Configuration conf;
       
       //真正提供數據庫訪問能力的對象
       private Executor executor;
       
   
       public DefaultSqlSession(Configuration conf) {
           super();
           this.conf = conf;
           executor = new SimpleExecutor(conf);
       }
   
       public  T selectOne(String statement, Object parameter) {
           List