获取SQL 思考:Mybatis是如何获取SQL的?即是如何获取到我们写的mapper文件的? 其实我们有在XML配置文件中配置标签来加载我们的mapper文件。 Mybatis加载mapper文件有几种方式? 官网文档给了答案:总共有四种方式()。 源码 前文了解了XML配置解析器XMLConfigBuilder的parse()方法便是加载配置文件生成一个Configuration对象的入口方法; 上篇了解了通过扫描environments标签如何获取数据源,下面会执行一个mapperElement方法来解析mappers标签,root。evalNode(mappers)返回的是一个value是mappers标签中内容的XNode对象;mapperElement(root。evalNode(mappers)); 进入方法,会有限判断有没有package标签,如何没有则会去获取该子node的三个属性,然后3个if分别处理。 无论是哪种方式最后都会执行MapperBuilderAssistant类中的addMappedStatement方法,之后会将解析的sql信息后封装成的MappedStatement对象放在全局配置类的一个Map属性mappedStatements中。configuration。addMappedStatement(statement);protectedfinalMapString,MappedStatementmappedStatementsnewStrictMapMappedStatement(MappedStatementscollection)。conflictMessageProducer((savedValue,targetValue)。pleasechecksavedValue。getResource()andtargetValue。getResource());执行sql 再贴一下我们的测试demo:Testpublicvoidtest()throwsIOException{InputStreaminputResources。getResourceAsStream(SqlSessionConfig。xml);SqlSessionFactorysessionFactorynewSqlSessionFactoryBuilder()。build(input);SqlSessionsqlSessionsessionFactory。openSession();LevelDaodaosqlSession。getMapper(LevelDao。class);ListLevelalldao。findAll();} 在生成SqlSessionFactory对象后,会调用openSession()。已知在前面执行build方法时把数据源和sql都存储在了全局配置类Configuration中,在该方法中则会从配置类中获取Environment(其中包含数据源信息)、TransactionFactory(事务)、Executor(执行器)来生成一个默认的DefaultSqlSession对象返回。privateSqlSessionopenSessionFromDataSource(ExecutorTypeexecType,TransactionIsolationLevellevel,booleanautoCommit){Ttry{finalEnvironmentenvironmentconfiguration。getEnvironment();finalTransactionFactorytransactionFactorygetTransactionFactoryFromEnvironment(environment);txtransactionFactory。newTransaction(environment。getDataSource(),level,autoCommit);finalExecutorexecutorconfiguration。newExecutor(tx,execType);returnnewDefaultSqlSession(configuration,executor,autoCommit);}catch(Exceptione){closeTransaction(tx);mayhavefetchedaconnectionsoletscallclose()throwExceptionFactory。wrapException(Erroropeningsession。Cause:e,e);}finally{ErrorContext。instance()。reset();}} Executor(执行器)一共分为三种:简单、复用、批量,默认SimpleExecutor。CachingExecutor也实现了Executor接口,严格来说CachingExecutor不是一个真正的实现,它会委托给BaseExecutor去实现。此处不做细讲。publicenumExecutorType{SIMPLE,REUSE,BATCH} 到此我们了解到openSession()方法只是获取到一些信息,生成了一个执行器,还没有开始sql执行流程。 接下来测试demo中继续执行LevelDaodaosqlSession。getMapper(LevelDao。class); 则会调用configuration。getMapper(type,this),继续调用mapperRegistry。getMapper(type,sqlSession),其内部是获取具体Class从MapperRegistry类中的Map中获取MapperProxyFactory,该MAP中的元素是我们在执行newSqlSessionFactoryBuilder()。build(input)方法扫描mapper标签时且是package或class的方式存放进去的;privatefinalMapC?,MapperProxyF?knownMappersnewHashMap(); 最后通过SqlSession调用MapperProxyFactory类生成了一个代理对象并返回。 我们调用的Listalldao。findAll();实际上最后是会调用这个代理对象MapperProxy中的invoke方法publicObjectinvoke(Objectproxy,Methodmethod,Object〔〕args)throwsThrowable{try{if(Object。class。equals(method。getDeclaringClass())){returnmethod。invoke(this,args);}elseif(method。isDefault()){if(privateLookupInMethodnull){returninvokeDefaultMethodJava8(proxy,method,args);}else{returninvokeDefaultMethodJava9(proxy,method,args);}}}catch(Throwablet){throwExceptionUtil。unwrapThrowable(t);}finalMapperMethodmapperMethodcachedMapperMethod(method);returnmapperMethod。execute(sqlSession,args);} 当我们执行到我们自定义的方法时会执行execute方法,这句最终就会执行增删改查了; 再往下一层,就是执行JDBC那一套了,获取链接,执行,得到ResultSet,解析ResultSet映射成JavaBean。 最后总结一下具体流程:Mybatis读取XML配置文件后会将内容放在一个Configuration类中,SqlSessionFactoryBuilder会读取Configuration类中信息创建SqlSessionFactory。在初始化SqlSessionFactory时,Mapper接口进行注册,注册在了名为MapperRegistry类的HashMap中,keyMapperclass,value创建当前Mapper的工厂。SqlSessionFactory创建SqlSession。SqlSession中可以通过getMapper()拿到代理对象,SqlSession。getMapper运用了JDK动态代理,产生了目标Mapper接口的代理对象。动态代理的代理类是MapperProxy,这里边mapperMethod。execute(sqlSession,args)最终完成了增删改查方法的调用。