您好,登錄后才能下訂單哦!
1、創建項目maven,方便依賴下載。使用的jar如下:
<dependencies> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context</artifactId> <version>5.0.8.RELEASE</version> </dependency> <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis-spring</artifactId> <version>2.0.0</version> </dependency> <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis</artifactId> <version>3.4.6</version> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>5.1.34</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jdbc</artifactId> <version>5.0.8.RELEASE</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-core</artifactId> <version>5.0.8.RELEASE</version> </dependency> </dependencies>
2、創建包com >config、dao、service、test
3、使用spring創建AppConfig文件,創建Bean>SqlSessionFactoryBean、DataSourceBean
1、spring注解@Configuration,說明是配置層
2、注冊掃描映射
3、注冊包掃描器
4、創建SqlSessionFactoryBean
5、創建數據源Bean
package com.config; import org.mybatis.spring.SqlSessionFactoryBean; import org.mybatis.spring.annotation.MapperScan; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.Configuration; import org.springframework.jdbc.datasource.DriverManagerDataSource; import javax.sql.DataSource; @Configuration @MapperScan("com.dao")//注解 與XML<mybatis:scan base-package="org.mybatis.spring.sample.mapper" /> //注冊包中遞歸搜索映射器 @ComponentScan("com")//注冊Bean public class AppConfig { @Bean @Autowired public SqlSessionFactoryBean sqlSessionFactoryBean(DataSource dataSource ){ SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean(); sqlSessionFactoryBean.setDataSource(dataSource); return sqlSessionFactoryBean; } @Bean public DataSource getDataSource(){ DriverManagerDataSource dataSource = new DriverManagerDataSource(); dataSource.setDriverClassName("com.mysql.jdbc.Driver"); dataSource.setUsername("root"); dataSource.setPassword("110226wjwj"); dataSource.setUrl("jdbc:mysql://localhost:3306/mybatis_wjw?useUnicode=true&characterEncoding=UTF-8&useSSL=false"); return dataSource; } }
4、創建Dao接口
1、創建query方法并使用注解@Select(Mybatis提供,mybatis-spring官網有相關解釋)
package com.dao; import org.apache.ibatis.annotations.Select; import java.util.List; import java.util.Map; public interface UserDao { @Select ("select * from t_user where tid =3") public List<Map> query(); }
5、創建服務層
1、注解服務層
2、引入DaoBean
package com.service; import com.dao.UserDao; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; //spring注解中service與component意思差不多,區別在于component是中立注解,而service是業務邏輯層的注解 //@Component @Service public class UserService { @Autowired UserDao userDao; public void query(){ System.out.println(userDao.query()); } }
6、測試
1、創建application
2、創建service
package com.test; import com.config.AppConfig; import com.service.UserService; import org.springframework.context.annotation.AnnotationConfigApplicationContext; public class MainTest { public static void main(String args[]){ AnnotationConfigApplicationContext acc = new AnnotationConfigApplicationContext(AppConfig.class); UserService us = acc.getBean(UserService.class); us.query(); } }
jar包之家:https://mvnrepository.com/artifact
使用spring依賴注入mapper 根據官網提示需要
<mybatis:scan base-package="org.mybatis.spring.sample.mapper" />==@MapperScan(“需要注入的包”)
mybatis缺點:使用XML方式與dao開發結合出現嚴重的臃腫現象,需要維護很多sql語句。
測試的時候出現這個問題。(版本導致,我直接將最新[mybatis-spring]的導入進來就沒問題了)
上面的問題解決后有出現這個問題,此問題出現的原因是java compiler改成8就OK了
測試結果:
重點:
mybatis運行原理
我們可以看到,再測試類中用的是UserService對象調用Dao接口中的query,但是mybatis是如何實現將接口轉換成對象的呢? 答案:動態代理 ,我們常用的代理(proxy)一共有兩種:cglib和jdk兩用代理模式
無論哪一種最終都是使用反射機制進行代理。詳情自己查看度娘(哈哈@0@)
mybatis源碼解析
DefaultSqlSession下如何實現返回一條數據的:底層調用的是selectList方法,對返回的結果集進行數量判斷如果==1則直接放回,>1直接拋出TooManyResultsException(感覺很傻,有些妄自菲薄!)
public <T> T selectOne(String statement, Object parameter) { List<T> list = this.selectList(statement, parameter); if (list.size() == 1) { return list.get(0); } else if (list.size() > 1) { throw new TooManyResultsException("Expected one result (or null) to be returned by selectOne(), but found: " + list.size()); } else { return null; } }
下面我們繼續看selectList是如何實現的
public <E> List<E> selectList(String statement, Object parameter, RowBounds rowBounds) { List var5; try { MappedStatement ms = this.configuration.getMappedStatement(statement); var5 = this.executor.query(ms, this.wrapCollection(parameter), rowBounds, Executor.NO_RESULT_HANDLER); } catch (Exception var9) { throw ExceptionFactory.wrapException("Error querying database. Cause: " + var9, var9); } finally { ErrorContext.instance().reset(); } return var5; }
我們來看看這個defaultSqlSession.configuration.getMappedStatement方法具體是什么
結論:再啟動項目的時候,mybatis會進行初始化,這個初始化就是將我們的"包+類+方法名"作為key 和 sql語句作為value 的鍵值對形式賦給下面Map類型的mappedStatements
protected final Map<String, MappedStatement> mappedStatements;
這也是為什么我們使用XML方式一定要將方法名字與id對應上才能使用,如果對應不上再進行Id傳值的時候找不到對應的key。
繼續往下分析:
已發帖子詢問大神具體是什么原因導致不進入124行,等大佬們回答后我將公布結果。直接看看executor是什么鬼
是一個接口,https://blog.csdn.net/ykzhen2015/article/details/50315027
protected Set<BeanDefinitionHolder> doScan(String... basePackages) { Assert.notEmpty(basePackages, "At least one base package must be specified"); Set<BeanDefinitionHolder> beanDefinitions = new LinkedHashSet(); String[] var3 = basePackages; int var4 = basePackages.length; for(int var5 = 0; var5 < var4; ++var5) { String basePackage = var3[var5]; Set<BeanDefinition> candidates = this.findCandidateComponents(basePackage); Iterator var8 = candidates.iterator(); while(var8.hasNext()) { BeanDefinition candidate = (BeanDefinition)var8.next(); ScopeMetadata scopeMetadata = this.scopeMetadataResolver.resolveScopeMetadata(candidate); candidate.setScope(scopeMetadata.getScopeName()); String beanName = this.beanNameGenerator.generateBeanName(candidate, this.registry); if (candidate instanceof AbstractBeanDefinition) { this.postProcessBeanDefinition((AbstractBeanDefinition)candidate, beanName); } if (candidate instanceof AnnotatedBeanDefinition) { AnnotationConfigUtils.processCommonDefinitionAnnotations((AnnotatedBeanDefinition)candidate); } if (this.checkCandidate(beanName, candidate)) { BeanDefinitionHolder definitionHolder = new BeanDefinitionHolder(candidate, beanName); definitionHolder = AnnotationConfigUtils.applyScopedProxyMode(scopeMetadata, definitionHolder, this.registry); beanDefinitions.add(definitionHolder); this.registerBeanDefinition(definitionHolder, this.registry); } } } return beanDefinitions; }
關于mybatis中的executor與一級緩存的關系:https://www.jb51.net/article/159394.htm
這里引出一個經典問題,關于mybatis一級緩存問題,這個緩存存儲在session中,當sql關閉的時候就會自動銷毀,涉及到mybatis中的session生命周期問題
為什么mybatis與spring結合后一級緩存會失效?以為SqlSession是由SqlSessionFactoryBean生成,二這個SqlSessionFactoryBean是由spring管理,也就是此時的session是由spring進行管理的并不是mybatis管理,所以此時session緩存會失效。
public interface Executor { ResultHandler NO_RESULT_HANDLER = null; int update(MappedStatement var1, Object var2) throws SQLException; <E> List<E> query(MappedStatement var1, Object var2, RowBounds var3, ResultHandler var4, CacheKey var5, BoundSql var6) throws SQLException; <E> List<E> query(MappedStatement var1, Object var2, RowBounds var3, ResultHandler var4) throws SQLException; <E> Cursor<E> queryCursor(MappedStatement var1, Object var2, RowBounds var3) throws SQLException; List<BatchResult> flushStatements() throws SQLException; void commit(boolean var1) throws SQLException; void rollback(boolean var1) throws SQLException; CacheKey createCacheKey(MappedStatement var1, Object var2, RowBounds var3, BoundSql var4); boolean isCached(MappedStatement var1, CacheKey var2); void clearLocalCache(); void deferLoad(MappedStatement var1, MetaObject var2, String var3, CacheKey var4, Class<?> var5); Transaction getTransaction(); void close(boolean var1); boolean isClosed(); void setExecutorWrapper(Executor var1); }
mybatis-spring依賴中MapperScannerRegistrar的作用:registerBeanDefinitions方法中的doScan()此方法是將Mapper掃描到初始化中。原理就是獲取到項目路徑找到對應的classes路徑,獲取了com.dao包名,將獲取的路徑+包名轉成文件夾,循環獲取文件夾下面的文件(UserDao.class),然后使用將UserDao拿到。此時包名+類名都拿到后使用Class.forName(包名+類名)反射出對象,進行bean注冊
總結運行原理:
初始化信息(數據庫連接信息,掃描mapper包中的class用于創建bean對象,spring中的類applicationFactory用于創建變對象、mapper中的xml的id與sql放到MapperStatement對象中)
其中對于掃描mapper包中的class路徑+參數basePackages轉成文件夾,然后循環找到所有的類名,使用.......(請看MapperScannerRegistrar引出的doScan方法)
執行過程:根據SqlSessionFactoryBean創建出sqlSession,調用selectList方法,之后根據參數(nameSpaceName+id)作為key找到MapperStatement對象中存儲的value獲取到sql語句,再有Executor(mybatis默認使用 CacheExecutor)執行sql語句查詢出結果集
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。