Spring+SpringMVC+Mybatis使用註解方式配置雙資料來源
阿新 • • 發佈：2019-02-18
場景描述：
在開發過程中A系統在建立角色，給角色授權之時，要將角色的許可權存入到B系統之中，由於另外B系統不提供對許可權的操作介面，只能修改他的角色許可權庫。
我這裡使用的配置雙資料來源，雙sessionFactory，雙事務，雙掃描、的方法，至於動態切換的等使用後再分享。
開始配置：
至於其他環節的搭建這裡就不做配置了，前提是一個可以允許的ssm框架。
在spring的核心配置檔案中做文章。
1、這裡使用的是資原始檔匯入資料庫的驅動、url等資訊，配置雙份
#mysql database setting jdbc.type=mysql jdbc.driver=com.mysql.jdbc.Driver #jdbc.url=jdbc:mysql://192.168.32.175:3306/weiqiao?useUnicode=true&characterEncoding=utf-8 jdbc.url=jdbc:mysql://localhost:3306/weiqiao?useUnicode=true&characterEncoding=utf-8 jdbc.username=root jdbc.password=root ##finebi資料庫 jdbc2.type=mysql jdbc2.driver=com.mysql.jdbc.Driver #jdbc2.url=jdbc:mysql://192.168.32.175:3306/weiqiao?useUnicode=true&characterEncoding=utf-8 jdbc2.url=jdbc:mysql://localhost:3306/weiqiao-finebi?useUnicode=true&characterEncoding=utf-8 jdbc2.username=root jdbc2.password=root jdbc2.pool.init=1 jdbc2.pool.minIdle=3 jdbc2.pool.maxActive=20 jdbc2.testSql=SELECT 'x' FROM DUAL
2、配置雙份DataSource
<!-- 資料來源配置, 使用 BoneCP 資料庫連線池 --> <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"> <!-- 資料來源驅動類可不寫，Druid預設會自動根據URL識別DriverClass --> <property name="driverClassName" value="${jdbc.driver}" /> <!-- 基本屬性 url、user、password --> <property name="url" value="${jdbc.url}" /> <property name="username" value="${jdbc.username}" /> <property name="password" value="${jdbc.password}" /> <!-- 配置初始化大小、最小、最大 --> <property name="initialSize" value="${jdbc.pool.init}" /> <property name="minIdle" value="${jdbc.pool.minIdle}" /> <property name="maxActive" value="${jdbc.pool.maxActive}" /> <!-- 配置獲取連線等待超時的時間 --> <property name="maxWait" value="60000" /> <!-- 配置間隔多久才進行一次檢測，檢測需要關閉的空閒連線，單位是毫秒 --> <property name="timeBetweenEvictionRunsMillis" value="60000" /> <!-- 配置一個連線在池中最小生存的時間，單位是毫秒 --> <property name="minEvictableIdleTimeMillis" value="300000" /> <property name="validationQuery" value="${jdbc.testSql}" /> <property name="testWhileIdle" value="true" /> <property name="testOnBorrow" value="false" /> <property name="testOnReturn" value="false" /> <!-- 開啟PSCache，並且指定每個連線上PSCache的大小（Oracle使用） <property name="poolPreparedStatements" value="true" /> <property name="maxPoolPreparedStatementPerConnectionSize" value="20" /> --> <!-- 配置監控統計攔截的filters --> <property name="filters" value="stat" /> </bean> <!-- finebi資料庫 20170727 --> <!-- 資料來源配置, 使用 BoneCP 資料庫連線池 --> <bean id="dataSource2" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"> <!-- 資料來源驅動類可不寫，Druid預設會自動根據URL識別DriverClass --> <property name="driverClassName" value="${jdbc2.driver}" /> <!-- 基本屬性 url、user、password --> <property name="url" value="${jdbc2.url}" /> <property name="username" value="${jdbc2.username}" /> <property name="password" value="${jdbc2.password}" /> <!-- 配置初始化大小、最小、最大 --> <property name="initialSize" value="${jdbc2.pool.init}" /> <property name="minIdle" value="${jdbc2.pool.minIdle}" /> <property name="maxActive" value="${jdbc2.pool.maxActive}" /> <!-- 配置獲取連線等待超時的時間 --> <property name="maxWait" value="60000" /> <!-- 配置間隔多久才進行一次檢測，檢測需要關閉的空閒連線，單位是毫秒 --> <property name="timeBetweenEvictionRunsMillis" value="60000" /> <!-- 配置一個連線在池中最小生存的時間，單位是毫秒 --> <property name="minEvictableIdleTimeMillis" value="300000" /> <property name="validationQuery" value="${jdbc2.testSql}" /> <property name="testWhileIdle" value="true" /> <property name="testOnBorrow" value="false" /> <property name="testOnReturn" value="false" /> <!-- 配置監控統計攔截的filters --> <property name="filters" value="stat" /> </bean>
3、配置雙sessionfactory,其中的typeAliasesPackage和typeAliasesSuperType屬性是掃描mapper
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
<property name="dataSource" ref="dataSource"/>
<property name="typeAliasesPackage" value="com.thinkgem.jeesite"/>
<property name="typeAliasesSuperType" value="com.thinkgem.jeesite.common.persistence.BaseEntity"/>
<property name="mapperLocations" value="classpath:/mappings/**/*.xml"/>
<property name="configLocation" value="classpath:/mybatis-config.xml"></property>
</bean>
<!-- finebi資料庫 20170727-->
<bean id="sqlSessionFactory2" class="org.mybatis.spring.SqlSessionFactoryBean">
<property name="dataSource" ref="dataSource2"/>
<property name="typeAliasesPackage" value="com.thinkgem.finebi"/> 4、配置雙dao注入，注意這裡兩個資料庫的java程式碼在不同的包下
<!-- 掃描basePackage下所有以@MyBatisDao註解的介面 -->
<bean id="mapperScannerConfigurer" class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" />
<property name="basePackage" value="com.thinkgem.jeesite"/>
<property name="annotationClass" value="com.thinkgem.jeesite.common.persistence.annotation.MyBatisDao"/>
</bean>
<!-- finebi資料庫 20170727 掃描basePackage下所有以@MyBatisDao註解的介面 -->
<bean id="mapperScannerConfigurer2" class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory2" />
<property name="basePackage" value="com.thinkgem.finebi"/>
<property name="annotationClass" value="com.thinkgem.jeesite.common.persistence.annotation.MyBatisDao"/>
</bean>5、定義雙事務
<!-- 定義事務 -->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource" />
</bean>
<!-- finebi資料庫 20170727 定義事務 -->
<bean id="transactionManager2" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource2" />
</bean>6、配置雙事務掃描
<!-- 配置 Annotation 驅動，掃描@Transactional註解的類定義事務 -->
<tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/>
<!-- finebi資料庫 20170727 配置 Annotation 驅動，掃描@Transactional註解的類定義事務 -->
<tx:annotation-driven transaction-manager="transactionManager2" proxy-target-class="true"/>7、如果你執行後發現執行B系統資料庫的操作報錯，找不到表，應該就是下面的配置出錯了，你有沒有給第二個資料來源的包做自動掃描，由於第二個資料來源沒有controller，就沒有排除他。
<!-- 使用Annotation自動註冊Bean，解決事物失效問題：在主容器中不掃描@Controller註解，在SpringMvc中只掃描@Controller註解。 -->
<context:component-scan base-package="com.thinkgem.jeesite"><!-- base-package 如果多個，用“,”分隔 -->
<context:exclude-filter type="annotation" expression="org.springframework.stereotype.Controller"/>
</context:component-scan>
<!-- finebi掃描 -->
<context:component-scan base-package="com.thinkgem.finebi"/>8、然後是後臺程式碼的處理，我這裡還沒有完全寫好，簡單貼一點
包
操作
public void saveRole(Role role) {
if (StringUtils.isBlank(role.getId())){
role.preInsert();
roleDao.insert(role);
//同時將角色的許可權新增到finebi資料庫
Curep curep = new Curep(25, 7, 105, 1, 1, 1);
curepService.save(curep);
//呼叫FineBI介面重新整理快取
String result = HttpClientUtils.requestGET("http://localhost:37799/WebReport/ReportServer?op=sessionmgr&cmd=clean");
System.out.println("http-result:"+result);
// 同步到Activiti
saveActivitiGroup(role);
}else{
role.preUpdate();
roleDao.update(role);
}
// 更新角色與選單關聯
roleDao.deleteRoleMenu(role);
if (role.getMenuList().size() > 0){
roleDao.insertRoleMenu(role);
}
// 更新角色與部門關聯
roleDao.deleteRoleOffice(role);
if (role.getOfficeList().size() > 0){
roleDao.insertRoleOffice(role);
}
// 同步到Activiti
saveActivitiGroup(role);
// 清除使用者角色快取
UserUtils.removeCache(UserUtils.CACHE_ROLE_LIST);
// // 清除許可權快取
// systemRealm.clearAllCachedAuthorizationInfo();
}
9、最後給出spring-context.xml的完整配置。
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context" xmlns:jdbc="http://www.springframework.org/schema/jdbc"
xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:util="http://www.springframework.org/schema/util" xmlns:task="http://www.springframework.org/schema/task" xsi:schemaLocation="
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.1.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.1.xsd
http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-4.1.xsd
http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-4.1.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.1.xsd
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.1.xsd
http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.1.xsd"
default-lazy-init="true">
<description>Spring Configuration</description>
<!-- 載入配置屬性檔案 -->
<context:property-placeholder ignore-unresolvable="true" location="classpath:jeesite.properties" />
<!-- 載入應用屬性例項，可通過 @Value("#{APP_PROP['jdbc.driver']}") String jdbcDriver 方式引用 -->
<util:properties id="APP_PROP" location="classpath:jeesite.properties" local-override="true"/>
<!-- 使用Annotation自動註冊Bean，解決事物失效問題：在主容器中不掃描@Controller註解，在SpringMvc中只掃描@Controller註解。 -->
<context:component-scan base-package="com.thinkgem.jeesite"><!-- base-package 如果多個，用“,”分隔 -->
<context:exclude-filter type="annotation" expression="org.springframework.stereotype.Controller"/>
</context:component-scan>
<!-- finebi掃描 -->
<context:component-scan base-package="com.thinkgem.finebi"/>
<!-- MyBatis begin -->
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
<property name="dataSource" ref="dataSource"/>
<property name="typeAliasesPackage" value="com.thinkgem.jeesite"/>
<property name="typeAliasesSuperType" value="com.thinkgem.jeesite.common.persistence.BaseEntity"/>
<property name="mapperLocations" value="classpath:/mappings/**/*.xml"/>
<property name="configLocation" value="classpath:/mybatis-config.xml"></property>
</bean>
<!-- finebi資料庫 20170727-->
<bean id="sqlSessionFactory2" class="org.mybatis.spring.SqlSessionFactoryBean">
<property name="dataSource" ref="dataSource2"/>
<property name="typeAliasesPackage" value="com.thinkgem.jeesite"/>
<property name="typeAliasesSuperType" value="com.thinkgem.jeesite.common.persistence.BaseEntity"/>
<property name="mapperLocations" value="classpath:/mappings/**/*.xml"/>
<property name="configLocation" value="classpath:/mybatis-config.xml"></property>
</bean>
<!-- 掃描basePackage下所有以@MyBatisDao註解的介面 -->
<bean id="mapperScannerConfigurer" class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" />
<property name="basePackage" value="com.thinkgem.jeesite"/>
<property name="annotationClass" value="com.thinkgem.jeesite.common.persistence.annotation.MyBatisDao"/>
</bean>
<!-- finebi資料庫 20170727 掃描basePackage下所有以@MyBatisDao註解的介面 -->
<bean id="mapperScannerConfigurer2" class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory2" />
<property name="basePackage" value="com.thinkgem.finebi"/>
<property name="annotationClass" value="com.thinkgem.jeesite.common.persistence.annotation.MyBatisDao"/>
</bean>
<!-- 定義事務 -->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource" />
</bean>
<!-- finebi資料庫 20170727 定義事務 -->
<bean id="transactionManager2" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource2" />
</bean>
<!-- 配置 Annotation 驅動，掃描@Transactional註解的類定義事務 -->
<tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/>
<!-- finebi資料庫 20170727 配置 Annotation 驅動，掃描@Transactional註解的類定義事務 -->
<tx:annotation-driven transaction-manager="transactionManager2" proxy-target-class="true"/>
<!-- MyBatis end -->
<!-- 配置 JSR303 Bean Validator 定義 -->
<bean id="validator" class="org.springframework.validation.beanvalidation.LocalValidatorFactoryBean" />
<!-- 快取配置 -->
<bean id="cacheManager" class="org.springframework.cache.ehcache.EhCacheManagerFactoryBean">
<property name="configLocation" value="classpath:${ehcache.configFile}" />
</bean>
<!-- 計劃任務配置，用 @Service @Lazy(false)標註類，用@Scheduled(cron = "0 0 2 * * ?")標註方法 -->
<task:executor id="executor" pool-size="10"/> <task:scheduler id="scheduler" pool-size="10"/>
<task:annotation-driven scheduler="scheduler" executor="executor" proxy-target-class="true"/>
<!-- 資料來源配置, 使用 BoneCP 資料庫連線池 -->
<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
<!-- 資料來源驅動類可不寫，Druid預設會自動根據URL識別DriverClass -->
<property name="driverClassName" value="${jdbc.driver}" />
<!-- 基本屬性 url、user、password -->
<property name="url" value="${jdbc.url}" />
<property name="username" value="${jdbc.username}" />
<property name="password" value="${jdbc.password}" />
<!-- 配置初始化大小、最小、最大 -->
<property name="initialSize" value="${jdbc.pool.init}" />
<property name="minIdle" value="${jdbc.pool.minIdle}" />
<property name="maxActive" value="${jdbc.pool.maxActive}" />
<!-- 配置獲取連線等待超時的時間 -->
<property name="maxWait" value="60000" />
<!-- 配置間隔多久才進行一次檢測，檢測需要關閉的空閒連線，單位是毫秒 -->
<property name="timeBetweenEvictionRunsMillis" value="60000" />
<!-- 配置一個連線在池中最小生存的時間，單位是毫秒 -->
<property name="minEvictableIdleTimeMillis" value="300000" />
<property name="validationQuery" value="${jdbc.testSql}" />
<property name="testWhileIdle" value="true" />
<property name="testOnBorrow" value="false" />
<property name="testOnReturn" value="false" />
<!-- 開啟PSCache，並且指定每個連線上PSCache的大小（Oracle使用）
<property name="poolPreparedStatements" value="true" />
<property name="maxPoolPreparedStatementPerConnectionSize" value="20" /> -->
<!-- 配置監控統計攔截的filters -->
<property name="filters" value="stat" />
</bean>
<!-- finebi資料庫 20170727 -->
<!-- 資料來源配置, 使用 BoneCP 資料庫連線池 -->
<bean id="dataSource2" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
<!-- 資料來源驅動類可不寫，Druid預設會自動根據URL識別DriverClass -->
<property name="driverClassName" value="${jdbc2.driver}" />
<!-- 基本屬性 url、user、password -->
<property name="url" value="${jdbc2.url}" />
<property name="username" value="${jdbc2.username}" />
<property name="password" value="${jdbc2.password}" />
<!-- 配置初始化大小、最小、最大 -->
<property name="initialSize" value="${jdbc2.pool.init}" />
<property name="minIdle" value="${jdbc2.pool.minIdle}" />
<property name="maxActive" value="${jdbc2.pool.maxActive}" />
<!-- 配置獲取連線等待超時的時間 -->
<property name="maxWait" value="60000" />
<!-- 配置間隔多久才進行一次檢測，檢測需要關閉的空閒連線，單位是毫秒 -->
<property name="timeBetweenEvictionRunsMillis" value="60000" />
<!-- 配置一個連線在池中最小生存的時間，單位是毫秒 -->
<property name="minEvictableIdleTimeMillis" value="300000" />
<property name="validationQuery" value="${jdbc2.testSql}" />
<property name="testWhileIdle" value="true" />
<property name="testOnBorrow" value="false" />
<property name="testOnReturn" value="false" />
<!-- 配置監控統計攔截的filters -->
<property name="filters" value="stat" />
</bean>
<!-- 資料來源配置, 使用應用伺服器的資料庫連線池
<jee:jndi-lookup id="dataSource" jndi-name="java:comp/env/jdbc/jeesite" />-->
<!-- 資料來源配置, 不使用連線池
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="${jdbc.driver}" />
<property name="url" value="${jdbc.url}" />
<property name="username" value="${jdbc.username}"/>
<property name="password" value="${jdbc.password}"/>
</bean>-->
</beans>由於最近又添加了controller了之後，發現一些新問題。
原來的方法，如果mapper中查詢結果是實體類的話會顯示發現不了實體類，專案啟動的時候會報一些實體類的錯。我們可以做以下修改，可以解決問題：
方法：
<bean id="sqlSessionFactory2" class="org.mybatis.spring.SqlSessionFactoryBean">
<property name="dataSource" ref="dataSource2"/>
<property name="typeAliasesPackage" value="com.thinkgem.jeesite"/>
<property name="typeAliasesSuperType" value="com.thinkgem.jeesite.common.persistence.BaseEntity"/>
<property name="mapperLocations" value="classpath:/mappings/**/*.xml"/>
<property name="configLocation" value="classpath:/mybatis-config.xml"></property>
</bean>最後祝大家工作順利，本人QQ895890836，