使用多數據源的場景應該是很多的，如操作同一臺服務器上不同的數據庫，或者多地機器上的相同或不相同數據庫。

　　雖然涉及到不同數據庫時，我們也許可以通過跨庫操作的方式，如 other.user 使用同一數據源來操作數據庫，但是，這樣明顯使得應用很難擴展，單數據庫將無法拆離。使用多數據源操作則可以解決這個問題。

　　在spring中怎樣使用多數據源？本文通過實踐方式，讓我配置多數據源有個參考。（不得不說，java中很大的一個難點就在于配置環境）

　　從入口處更改，web.xml中添加引用spring配置文件：

<?xml version="1.0" encoding="UTF-8"?> <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd" version="3.0"><display-name>c</display-name><filter><filter-name>characterEncodingFilter</filter-name><filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class><init-param><param-name>encoding</param-name><param-value>UTF-8</param-value></init-param><init-param><param-name>forceEncoding</param-name><param-value>true</param-value></init-param></filter><filter-mapping><filter-name>characterEncodingFilter</filter-name><url-pattern>/*</url-pattern></filter-mapping><servlet><servlet-name>dispatcherServlet</servlet-name><servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class><init-param><param-name>contextConfigLocation</param-name><param-value>classpath:applicationContext.xml</param-value></init-param><load-on-startup>1</load-on-startup></servlet><!-- URL重寫 --><filter><filter-name>UrlRewriteFilter</filter-name><filter-class>org.tuckey.web.filters.urlrewrite.UrlRewriteFilter</filter-class></filter><filter-mapping><filter-name>UrlRewriteFilter</filter-name><url-pattern>/*</url-pattern><dispatcher>REQUEST</dispatcher><dispatcher>FORWARD</dispatcher></filter-mapping><servlet-mapping><servlet-name>dispatcherServlet</servlet-name><url-pattern>/api/*</url-pattern></servlet-mapping><display-name>c</display-name><welcome-file-list><welcome-file>index.html</welcome-file></welcome-file-list><filter> <filter-name>JAMonFilter</filter-name> <filter-class>com.xx.core.web.filter.PageMonFilter</filter-class> <init-param><param-name>flag</param-name><param-value>true</param-value></init-param></filter> <filter-mapping> <filter-name>JAMonFilter</filter-name> <url-pattern>/*</url-pattern> </filter-mapping><servlet><servlet-name>exceptions</servlet-name> <jsp-file>/jamon/exceptions.jsp</jsp-file> </servlet> <servlet> </web-app>

2. 在application.xml中添加多數據源配置：

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans"xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx"xmlns:aop="http://www.springframework.org/schema/aop" xmlns:mvc="http://www.springframework.org/schema/mvc"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"xmlns:mongo="http://www.springframework.org/schema/data/mongo"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context-4.0.xsdhttp://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx-4.0.xsdhttp://www.springframework.org/schema/aophttp://www.springframework.org/schema/aop/spring-aop-4.0.xsdhttp://www.springframework.org/schema/mvchttp://www.springframework.org/schema/mvc/spring-mvc-4.0.xsdhttp://www.springframework.org/schema/data/mongohttp://www.springframework.org/schema/data/mongo/spring-mongo-1.5.xsd"><bean class="com.xx.c.common.utils.SpringContextsUtil" /><bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"destroy-method="close"><property name="url" value="${jdbc.url}" /><property name="driverClassName" value="${jdbc.driver}" /><property name="maxActive" value="${pool.maxPoolSize}" /><property name="username" value="${jdbc.username}" /><property name="password" value="${jdbc.password}" /><!-- 超過時間限制是否回收 --><property name="removeAbandoned" value="true" /><!-- 超時時間；單位為秒。180秒=3分鐘 --><property name="removeAbandonedTimeout" value="${pool.removeAbandonedTimeout}" /><!-- 配置獲取連接等待超時的時間 --><property name="maxWait" value="${pool.maxWait}" /><!-- 配置間隔多久才進行一次檢測，檢測需要關閉的空閑連接，單位是毫秒 --><property name="timeBetweenEvictionRunsMillis" value="${pool.timeBetweenEvictionRunsMillis}" /><!-- 配置一個連接在池中最小生存的時間，單位是毫秒 --><property name="minEvictableIdleTimeMillis" value="${pool.minEvictableIdleTimeMillis}" /><property name="validationQuery" value="${pool.validationQuery} " /><property name="testWhileIdle" value="true" /><property name="testOnBorrow" value="false" /><property name="testOnReturn" value="false" /></bean><bean id="dataSource_c" class="com.alibaba.druid.pool.DruidDataSource"destroy-method="close"><property name="url" value="${jdbc2.url}" /><property name="driverClassName" value="${jdbc2.driver}" /><property name="maxActive" value="${pool2.maxPoolSize}" /><property name="username" value="${jdbc2.username}" /><property name="password" value="${jdbc2.password}" /><property name="removeAbandoned" value="true" /><property name="removeAbandonedTimeout" value="${pool2.removeAbandonedTimeout}" /><property name="maxWait" value="${pool2.maxWait}" /><property name="timeBetweenEvictionRunsMillis" value="${pool2.timeBetweenEvictionRunsMillis}" /><property name="minEvictableIdleTimeMillis" value="${pool2.minEvictableIdleTimeMillis}" /><property name="validationQuery" value="${pool2.validationQuery} " /><property name="testWhileIdle" value="true" /><property name="testOnBorrow" value="false" /><property name="testOnReturn" value="false" /></bean><context:component-scan base-package="com.xx.c"><context:exclude-filter type="annotation"expression="org.springframework.stereotype.Controller" /></context:component-scan><context:component-scan base-package="com.xx.c.pojo.config" /><bean class="com.xx.framework.web.v1_0_0.ServerController" /><!-- spring的屬性加載器，加載properties文件中的屬性 --><bean class="com.xx.zkc.property.PropertyPlaceholderConfigurer"><property name="systemPropertiesModeName" value="SYSTEM_PROPERTIES_MODE_OVERRIDE" /><property name="ignoreResourceNotFound" value="true" /><property name="locations"><list><value>classpath*:/spring/conf.properties</value></list></property></bean><bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"><property name="dataSource" ref="dataSource" /><property name="configLocation" value="classpath:mybatis-config.xml" /></bean><bean id="sqlSessionFactory_c" class="org.mybatis.spring.SqlSessionFactoryBean"><property name="dataSource" ref="dataSource_c" /><property name="configLocation" value="classpath:mybatis-config.xml" /></bean><bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate"scope="prototype"><constructor-arg index="0" ref="sqlSessionFactory" /></bean><bean id="sqlSession_c" class="org.mybatis.spring.SqlSessionTemplate"scope="prototype"><constructor-arg index="0" ref="sqlSessionFactory_c" /></bean><mongo:mongo id="mongo" replica-set="${mongodb.url}"><mongo:options connections-per-host="${mongo.connections.per.host}"threads-allowed-to-block-for-connection-multiplier="${mongo.threads.allowed.to.block.for.connection.multiplier}"connect-timeout="${mongo.connect.timeout}" max-wait-time="${mongo.max.wait.time}"auto-connect-retry="${mongo.auto.connect.retry}" socket-keep-alive="${mongo.socket.keep.alive}"socket-timeout="${mongo.socket.timeout}" slave-ok="${mongo.slave.ok}"write-number="${mongo.write.number}" write-timeout="${mongo.write.timeout}"write-fsync="${mongo.write.fsync}" /></mongo:mongo><bean id="mappingContext"class="org.springframework.data.mongodb.core.mapping.MongoMappingContext" /><bean id="defaultMongoTypeMapper"class="org.springframework.data.mongodb.core.convert.DefaultMongoTypeMapper"><constructor-arg name="typeKey"><null /></constructor-arg></bean><bean id="mongoDbFactory"class="org.springframework.data.mongodb.core.SimpleMongoDbFactory"><constructor-arg ref="mongo" /><constructor-arg name="databaseName" value="${mongodb.databaseName}" /></bean><bean id="mappingMongoConverter"class="org.springframework.data.mongodb.core.convert.MappingMongoConverter"><constructor-arg name="mappingContext" ref="mappingContext" /><property name="typeMapper" ref="defaultMongoTypeMapper" /><constructor-arg name="mongoDbFactory" ref="mongoDbFactory" /></bean><bean id="mongodbReadPreference" class="com.mongodb.ReadPreference"factory-method="secondaryPreferred" /><bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate"><property name="readPreference" ref="mongodbReadPreference" /><constructor-arg name="mongoConverter" ref="mappingMongoConverter" /><constructor-arg name="mongoDbFactory" ref="mongoDbFactory" /></bean><!-- 事務 控制 begin --><bean name="transactionManager"class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSource"></property></bean><tx:annotation-driven transaction-manager="transactionManager" /><!-- 事務 控制 end --><!-- action begin --><bean name='requestMappingHandlerMapping'class='com.xx.core.web.spring.annotation.PackageURLRequestMappingHandlerMapping'><property name='packageBase' value='com.xx.c.action'></property><property name="interceptors"><list><bean class="com.xx.core.web.spring.interceptor.SessionInterceptor"><property name="on" value="${system.check.permission}" /><property name="sessionTimeout" value="${system.timeout}" /><property name="userSessionDao" ref="userSessionDao" /><property name="systemDao" ref="systemDao" /></bean></list></property></bean><!-- dao --><import resource="dao.xml" /><!-- service --><import resource="service.xml" /><!-- activemq --><import resource="applicationContext-activemq.xml" /><!-- redis --><import resource="applicationContext-redis.xml" /><!-- dubbo --><import resource="applicationContext-dubbo.xml" /><import resource="applicationContext-dubbo-consumer.xml" /><import resource="classpath:spring/xx-c-kafka-consumer.xml" /><import resource="applicationContext-rabbitmq-producer.xml"/><import resource="applicationContext-rabbitmq-consumer.xml"/><beanclass="org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter"><property name="messageConverters"><list><beanclass="com.xx.core.web.spring.convert.JSONHttpMessageConverter"></bean><beanclass="org.springframework.http.converter.StringHttpMessageConverter"></bean><beanclass="org.springframework.http.converter.ByteArrayHttpMessageConverter"></bean><beanclass="org.springframework.http.converter.xml.SourceHttpMessageConverter"></bean><beanclass="org.springframework.http.converter.support.AllEncompassingFormHttpMessageConverter"></bean></list></property><property name="customArgumentResolvers"><list><bean class="com.xx.core.web.spring.bind.TIDArgumentResolver" /><beanclass="com.xx.core.web.spring.bind.RequestAttributeArgumentResolver" /><bean class="com.xx.core.web.spring.bind.ClientIPArgumentResolver" /><beanclass="com.xx.core.web.spring.bind.SessionUserIdArgumentResolver" /></list></property></bean><bean id="dealException" class="com.xx.core.web.spring.interceptor.ExceptionAop"></bean><aop:config><!-- 對異常的集中處理 --><aop:aspect id="exceptionAop" ref="dealException"><aop:pointcut id="exceptionPointCut"expression="execution(* com.xx.c.action.*.*.*(..))" /><aop:around pointcut-ref="exceptionPointCut" method="deal" /></aop:aspect></aop:config><beanclass="org.springframework.aop.framework.autoproxy.BeanNameAutoProxyCreator"><property name="beanNames"><list><value>systemDictDao</value><value>userDao</value><value>infoDao</value></list></property><property name="interceptorNames"><list><value>jamonInterceptor</value></list></property></bean><bean id="jamonInterceptor"class="org.springframework.aop.interceptor.JamonPerformanceMonitorInterceptor"></bean><bean id="multipartResolver"class="org.springframework.web.multipart.commons.CommonsMultipartResolver"p:defaultEncoding="utf-8" p:maxUploadSize="104857600" /><context:component-scan base-package="com.xx.c.action"name-generator="com.xx.core.web.spring.annotation.FullPackageBeanNameGenerator" /> <!-- action end --><!-- Spring托管線程池 --><bean id="threadPoolTaskExecutor"class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"><!-- 線程池活躍的線程數 --><property name="corePoolSize" value="50" /><!-- 線程池最大活躍的線程數 --><property name="maxPoolSize" value="75" /><!-- 隊列的最大容量 <property name ="queueCapacity" value ="2000" /> --><!-- <property name="WaitForTasksToCompleteOnShutdown" value="true" /> --></bean><bean id="mapper" class="org.dozer.spring.DozerBeanMapperFactoryBean"><property name="mappingFiles"><list> <value>classpath:/dozerBeanMapping.xml</value><value>classpath:/dozerBeanMapping2.xml</value></list></property></bean> </beans>

3. 在dao.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"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd"><!-- import this --><bean id="userDao" class="com.xx.c.dao.user.UserDaoImpl"><property name="sqlSession" ref="sqlSession" /><property name="mongoTemplate" ref ="mongoTemplate" /></bean><bean id="infoDao" class="com.xx.c.dao.content.ConInfoDaoImpl"><property name="sqlSession" ref="sqlSession_c" /></bean> </beans>

4. 在具體的sql當中實現數據操作：

<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD Mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd"><mapper namespace="com.xx.c.dao.user.UserDao"><resultMap id="userMap" type="User"><id column="user_id" property="userId" /><result column="username" property="userName" /><result column="sex" property="sex" /></resultMap><resultMap id="userInfoMap" type="UserInfoBean"><id column="user_id" property="userId" /><result column="card_id" property="cardId" /><result column="username" property="phone" /><result column="id_card_address" property="idCardAddress" /><result column="reg_time" property="regTime" /><result column="logintime" property="logintime" /><result column="last_time" property="lastTime" /><result column="reg_ip" property="regIp" /><result column="up_ip" property="upIp" /><result column="last_ip" property="lastIp" /><result column="download_channel" property="downloadChannel" /><result column="guarantor1" property="guarantor1" /><result column="guarantor_phone1" property="guarantor_phone1" /></resultMap><sql id="getUserCond"><where><if test="userId != null">and u.user_id = #{userId}</if><if test="userName != null and userName != ''">and u.username = #{userName}</if></where></sql><select id="getUser" resultMap="userMap" parameterType="User">select u.* from users_info u<include refid="getUserCond" /></select><insert id="addDebitCardBindChannel" parameterType="DebitCardBindChannelBean">insert intonzz (user_id,channel,card_no,request_id,status)values (#{userId},#{channel},#{cardNo},#{requestId},#{status})</insert><update id="updateDebitCardBindChannel" parameterType="DebitCardBindChannelBean">updatenzzset status=#{status},request_id=#{requestId}whereuser_id=#{userId} and card_no=#{cardNo}and channel=#{channel}</update> </mapper>

5. 完善一下，使用別名，使sql寫的時候更簡短：

<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE configurationPUBLIC "-//mybatis.org//DTD Config 3.0//EN""http://mybatis.org/dtd/mybatis-3-config.dtd"><configuration> <settings> <setting name="logPrefix" value="dao."/> </settings> <!-- 配置別名，以便在引用時簡寫 --><typeAliases><typeAlias alias="User" type="com.xx.c.pojo.user.User" /><typeAlias alias="CardBinBean" type="com.xx.c.pojo.user.CardBinBean"/><typeAlias alias="UserCreditLogBean" type="com.xx.c.pojo.user.UserCreditLogBean"/><typeAlias alias="InfoBean" type="com.xx.c.pojo.content.ContentInfo" /> </typeAliases><mappers><mapper resource="com/xx/c/dao/impl/User.xml"/><mapper resource="com/xx/c/dao/impl/Info.xml"/> </mappers></configuration>

?

以上，就已經完成了一整個spring操作多數據源的mybatis了。

總結

以上是生活随笔為你收集整理的如何使用spring配合mybatis配置多个数据源并应用？的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。