备案控制台
探索云世界
开发者社区 数据库 文章 正文

springMVC多数据源使用 跨库跨连接

2018-02-13 2697
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
云数据库 Redis 版，社区版 2GB
推荐场景：
搭建游戏排行榜
云数据库 RDS MySQL Serverless，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
云数据库 RDS MySQL Serverless，价值2615元额度，1个月
简介：

springMVC多数据源使用 跨库跨连接http://www.bieryun.com/1244.html


有的时候项目中可能要从另外一个系统取数据  如果另外一个系统能提供接口就很好解决 如果没有接口 便可以配置多个数据源切换访问

<1>:这是数据源和事务扫描注入的配置 访问多个数据源只需要建立多个数据源和事务这一套配置文件

这是第一个数据源

[html] view plain copy

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.     xmlns:context="http://www.springframework.org/schema/context"
  5.     xmlns:jdbc="http://www.springframework.org/schema/jdbc"
  6.     xmlns:jee="http://www.springframework.org/schema/jee"
  7.     xmlns:tx="http://www.springframework.org/schema/tx"
  8.     xmlns:aop="http://www.springframework.org/schema/aop"
  9.     xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
  10.     xsi:schemaLocation="
  11.         http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
  12.         http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd
  13.         http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-3.2.xsd
  14.         http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.2.xsd
  15.         http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd
  16.         http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.2.xsd
  17.         http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd
  18.         http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"
  19.     default-lazy-init="true">
  21.     <description>Spring公共配置 </description>
  23.     <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
  24.         <property name="locations">
  25.             <list>
  26.                 <value>classpath:resources.properties</value>
  27.                 <!--  <value>classpath:memcached.properties</value> -->
  28.             </list>
  29.         </property>
  30.     </bean>
  32.     <!-- dubbo配置 -->
  33.     <!-- <dubbo:application name="xaUserRegPro" />
  34.     <dubbo:registry address="multicast://" />
  35.     <dubbo:reference id="userRegProService" interface="com.xinnet.xa.service.UserRegProService"  timeout="6000"/> -->
  37.  <!-- **************** druid 监控连接池配置 ***************** -->
  38.     <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
  40.         <!-- 基本属性 url、user、password -->
  41.         <property name="url" value="${url}" />
  42.         <property name="username" value="${username}" />
  43.         <property name="password" value="${password}" />
  45.         <!-- 配置初始化大小、最小、最大 -->
  46.         <property name="initialSize" value="${initialSize}" />
  47.         <property name="minIdle" value="${minIdle}" />
  48.         <property name="maxActive" value="${maxActive}" />
  50.         <!-- 配置获取连接等待超时的时间 -->
  51.         <property name="maxWait" value="${maxWait}" />
  53.         <!-- 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒 -->
  54.         <property name="timeBetweenEvictionRunsMillis" value="60000" />
  56.         <!-- 配置一个连接在池中最小生存的时间，单位是毫秒 -->
  57.         <property name="minEvictableIdleTimeMillis" value="300000" />
  58.         <property name="validationQuery" value="SELECT 'x'" />
  59.         <property name="testWhileIdle" value="true" />
  60.         <property name="testOnBorrow" value="false" />
  61.         <property name="testOnReturn" value="false" />
  63.         <!-- 打开PSCache，并且指定每个连接上PSCache的大小  -->
  64.         <!-- 如果用Oracle，则把poolPreparedStatements配置为true，mysql可以配置为false。分库分表较多的数据库，建议配置为false -->
  65.         <property name="poolPreparedStatements" value="${poolPreparedStatements}" />
  66.         <property name="maxPoolPreparedStatementPerConnectionSize" value="20" />
  68.         <!-- 对泄漏的连接 自动关闭 -->
  69.         <property name="removeAbandoned" value="${removeAbandoned}" /> <!-- 打开removeAbandoned功能 -->
  70.         <property name="removeAbandonedTimeout" value="${removeAbandonedTimeout}" /> <!-- 1800秒，也就是30分钟 -->
  71.         <property name="logAbandoned" value="${logAbandoned}" /> <!-- 关闭abanded连接时输出错误日志 -->
  73.         <!-- 配置监控统计拦截的filters -->
  74.         <property name="filters" value="mergeStat" />
  75.         <!--  <property name="filters" value="stat" /> -->
  76.         <!-- 慢日志查询  缺省为3秒  修改为10秒 10000 -->
  77.         <property name="connectionProperties" value="druid.stat.slowSqlMillis=5000" />
  79.         <!-- DruidDataSource各自独立 ， 支持配置公用监控数据 -->
  80.         <!-- <property name="useGloalDataSourceStat" value="true" /> -->
  81.     </bean>
  83.     <!-- druid 监控  spring  -->
  84.     <bean id="druid-stat-interceptor" class="com.alibaba.druid.support.spring.stat.DruidStatInterceptor"/>
  85.     <bean id="druid-stat-pointcut" class="org.springframework.aop.support.JdkRegexpMethodPointcut" scope="prototype">
  86.         <property name="patterns">
  87.             <list>
  88.                 <value>com.xinnet.*.service.*</value>
  89.             </list>
  90.         </property>
  91.     </bean>
  92.     <aop:config>
  93.         <aop:advisor advice-ref="druid-stat-interceptor" pointcut-ref="druid-stat-pointcut" />
  94.     </aop:config>
  96.     <!-- MyBatis Mapper.XMl 配置 -->
  97.     <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
  98.         <property name="dataSource" ref="dataSource" />
  99.         <property name="configLocation" value="classpath:config/mybatis.xml" />
  100.         <property name="mapperLocations">
  101.             <list>
  102.             <!-- 自动匹配Mapper映射文件  -->
  103.                 <value>classpath:mapper/**/*-mapper.xml</value>
  104.             </list>
  105.         </property>
  106.         <!-- 添加插件 -->
  107.         <property name="plugins">
  108.             <array>
  109.                 <ref bean="pagePlugin" />
  110.             </array>
  111.         </property>
  112.     </bean>
  114.     <!-- 支持文件上传相关 -->
  115.     <bean id="multipartResolver" class="org.springframework.web.multipart.commons.CommonsMultipartResolver"/>
  117.     <!-- 分页插件，根据方言自动添加分页信息，默认要求 -->
  118.     <bean id="pagePlugin" class="com.xinnet.core.mybatis.plugin.PagePlugin">
  119.         <property name="properties">
  120.             <props>
  121.                 <prop key="dialect">com.xinnet.core.mybatis.dialet.MySQLDialect</prop>
  122.                 <prop key="pageSqlId">.*query.*</prop>
  123.             </props>
  124.         </property>
  125.     </bean>
  126.     <!-- redis客户端 -->
  127.      <!-- jedis pool配置  -->
  128.     <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
  129.         <property name="maxActive" value="${redis.maxActive}" />
  130.         <property name="maxIdle" value="${redis.maxIdle}" />
  131.         <property name="maxWait" value="${redis.maxWait}" />
  132.         <property name="testOnBorrow" value="${redis.testOnBorrow}" />
  133.     </bean>
  135.     <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
  136.         <property name="usePool" value="true"></property>
  137.         <property name="hostName" value="${redis.host}" />
  138.         <property name="port" value="${redis.port}" />
  139.         <property name="password" value="${redis.pass}" />
  140.         <property name="timeout" value="${redis.timeout}" />
  141.         <property name="database" value="${redis.default.db}"></property>
  142.         <constructor-arg index="0" ref="jedisPoolConfig" />
  143.     </bean>
  144.     <bean id="redisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate">
  145.         <property name="connectionFactory" ref="jedisConnectionFactory" />
  146.     </bean>
  148.     <!-- ***************事务配置************** -->
  149.     <tx:annotation-driven transaction-manager="transactionManager"/>
  150.     <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  151.         <property name="dataSource" ref="dataSource" />
  152.     </bean>
  153.     <aop:config>
  154.              <aop:advisor pointcut="execution(* com.xinnet..service..*.*(..))"  advice-ref="txAdvice" />
  155.     </aop:config>
  156.     <tx:advice id="txAdvice" transaction-manager="transactionManager">
  157.         <tx:attributes>
  158.             <tx:method name="get*" read-only="true" />
  159.             <tx:method name="query*" read-only="true" />
  160.             <tx:method name="find*" read-only="true" />
  161.             <tx:method name="load*" read-only="true" />
  162.             <tx:method name="select*" read-only="true" />
  163.             <tx:method name="count*" read-only="true" />
  164.             <tx:method name="search*" read-only="true" />
  165.             <tx:method name="list*" read-only="true" />
  166.             <tx:method name="*" propagation="REQUIRED" rollback-for="Exception" />
  167.         </tx:attributes>
  168.     </tx:advice>
  169.     <aop:aspectj-autoproxy proxy-target-class="true"/>
  170.     <!-- 开启注解事务 只对当前配置文件有效 -->
  172.     <!-- 扫描注解Bean -->
  173.     <context:component-scan base-package="com.xinnet">
  174.         <context:include-filter type="annotation" expression="org.springframework.stereotype.Repository"/>
  175.         <context:include-filter type="annotation" expression="org.springframework.stereotype.Service"/>
  176.         <context:exclude-filter type="annotation" expression="org.springframework.stereotype.Controller"/>
  177.     </context:component-scan>
  178.      <!-- 隐式地向 Spring 容器注册 -->
  179.     <context:annotation-config/>
  181. </beans>

<2>这是第二个数据源 和第一个数据源一样 需要有事务 扫描注解
不同的是数据源的 url  username 和password 用的是第二个数据源的连接  用户名和密码

[html] view plain copy

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.     xmlns:context="http://www.springframework.org/schema/context"
  5.     xmlns:jdbc="http://www.springframework.org/schema/jdbc"
  6.     xmlns:jee="http://www.springframework.org/schema/jee"
  7.     xmlns:tx="http://www.springframework.org/schema/tx"
  8.     xmlns:aop="http://www.springframework.org/schema/aop"
  9.     xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
  10.     xsi:schemaLocation="
  11.         http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
  12.         http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd
  13.         http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-3.2.xsd
  14.         http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.2.xsd
  15.         http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd
  16.         http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.2.xsd
  17.         http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd
  18.         http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"
  19.     default-lazy-init="true">
  21.     <description>Spring公共配置 </description>
  23.     <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
  24.         <property name="locations">
  25.             <list>
  26.                 <value>classpath:resources.properties</value>
  27.                 <!--  <value>classpath:memcached.properties</value> -->
  28.             </list>
  29.         </property>
  30.     </bean>
  32.  <!-- **************** druid 监控连接池配置 *****************  -->
  33.     <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
  35.         <!-- 基本属性 url、user、password -->
  36.         <property name="url" value="${url2}" />
  37.         <property name="username" value="${username2}" />
  38.         <property name="password" value="${password2}" />
  40.         <!-- 配置初始化大小、最小、最大 -->
  41.         <property name="initialSize" value="${initialSize}" />
  42.         <property name="minIdle" value="${minIdle}" />
  43.         <property name="maxActive" value="${maxActive}" />
  45.         <!-- 配置获取连接等待超时的时间 -->
  46.         <property name="maxWait" value="${maxWait}" />
  48.         <!-- 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒 -->
  49.         <property name="timeBetweenEvictionRunsMillis" value="60000" />
  51.         <!-- 配置一个连接在池中最小生存的时间，单位是毫秒 -->
  52.         <property name="minEvictableIdleTimeMillis" value="300000" />
  53.         <property name="validationQuery" value="SELECT 'x'" />
  54.         <property name="testWhileIdle" value="true" />
  55.         <property name="testOnBorrow" value="false" />
  56.         <property name="testOnReturn" value="false" />
  58.         <!-- 打开PSCache，并且指定每个连接上PSCache的大小  -->
  59.         <!-- 如果用Oracle，则把poolPreparedStatements配置为true，mysql可以配置为false。分库分表较多的数据库，建议配置为false -->
  60.         <property name="poolPreparedStatements" value="${poolPreparedStatements}" />
  61.         <property name="maxPoolPreparedStatementPerConnectionSize" value="20" />
  63.         <!-- 对泄漏的连接 自动关闭 -->
  64.         <property name="removeAbandoned" value="${removeAbandoned}" /> <!-- 打开removeAbandoned功能 -->
  65.         <property name="removeAbandonedTimeout" value="${removeAbandonedTimeout}" /> <!-- 1800秒，也就是30分钟 -->
  66.         <property name="logAbandoned" value="${logAbandoned}" /> <!-- 关闭abanded连接时输出错误日志 -->
  68.         <!-- 配置监控统计拦截的filters -->
  69.         <property name="filters" value="mergeStat" />
  70.         <!--  <property name="filters" value="stat" /> -->
  71.         <!-- 慢日志查询  缺省为3秒  修改为10秒 10000 -->
  72.         <property name="connectionProperties" value="druid.stat.slowSqlMillis=5000" />
  74.         <!-- DruidDataSource各自独立 ， 支持配置公用监控数据 -->
  75.         <!-- <property name="useGloalDataSourceStat" value="true" /> -->
  76.     </bean>
  78.     <!-- druid 监控  spring  -->
  79.     <bean id="druid-stat-interceptor" class="com.alibaba.druid.support.spring.stat.DruidStatInterceptor"/>
  80.     <bean id="druid-stat-pointcut" class="org.springframework.aop.support.JdkRegexpMethodPointcut" scope="prototype">
  81.         <property name="patterns">
  82.             <list>
  83.                 <value>com.xinnet.*.service.*</value>
  84.             </list>
  85.         </property>
  86.     </bean>
  87.     <aop:config>
  88.         <aop:advisor advice-ref="druid-stat-interceptor" pointcut-ref="druid-stat-pointcut" />
  89.     </aop:config>
  91.     <!-- MyBatis Mapper.XMl 配置 -->
  92.     <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
  93.         <property name="dataSource" ref="dataSource" />
  94.         <property name="configLocation" value="classpath:config/mybatis.xml" />
  95.         <property name="mapperLocations">
  96.             <list>
  97.             <!-- 自动匹配Mapper映射文件  -->
  98.                 <value>classpath:mapper/**/*-mapper.xml</value>
  99.             </list>
  100.         </property>
  101.         <!-- 添加插件 -->
  102.         <property name="plugins">
  103.             <array>
  104.                 <ref bean="pagePlugin" />
  105.             </array>
  106.         </property>
  107.     </bean>
  109.     <!-- 支持文件上传相关 -->
  110.     <bean id="multipartResolver" class="org.springframework.web.multipart.commons.CommonsMultipartResolver"/>
  112.     <!-- 分页插件，根据方言自动添加分页信息，默认要求 -->
  113.     <bean id="pagePlugin" class="com.xinnet.core.mybatis.plugin.PagePlugin">
  114.         <property name="properties">
  115.             <props>
  116.                 <prop key="dialect">com.xinnet.core.mybatis.dialet.MySQLDialect</prop>
  117.                 <prop key="pageSqlId">.*query.*</prop>
  118.             </props>
  119.         </property>
  120.     </bean>
  121.     <!-- redis客户端 -->
  122.      <!-- jedis pool配置  -->
  123.     <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
  124.         <property name="maxActive" value="${redis.maxActive}" />
  125.         <property name="maxIdle" value="${redis.maxIdle}" />
  126.         <property name="maxWait" value="${redis.maxWait}" />
  127.         <property name="testOnBorrow" value="${redis.testOnBorrow}" />
  128.     </bean>
  130.     <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
  131.         <property name="usePool" value="true"></property>
  132.         <property name="hostName" value="${redis.host}" />
  133.         <property name="port" value="${redis.port}" />
  134.         <property name="password" value="${redis.pass}" />
  135.         <property name="timeout" value="${redis.timeout}" />
  136.         <property name="database" value="${redis.default.db}"></property>
  137.         <constructor-arg index="0" ref="jedisPoolConfig" />
  138.     </bean>
  139.     <bean id="redisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate">
  140.         <property name="connectionFactory" ref="jedisConnectionFactory" />
  141.     </bean>
  143.     <!-- ***************事务配置************** -->
  144.     <tx:annotation-driven transaction-manager="transactionManager"/>
  145.     <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  146.         <property name="dataSource" ref="dataSource" />
  147.     </bean>
  148.     <aop:config>
  149.              <aop:advisor pointcut="execution(* com.xinnet..service..*.*(..))"  advice-ref="txAdvice" />
  150.     </aop:config>
  151.     <tx:advice id="txAdvice" transaction-manager="transactionManager">
  152.         <tx:attributes>
  153.             <tx:method name="get*" read-only="true" />
  154.             <tx:method name="query*" read-only="true" />
  155.             <tx:method name="find*" read-only="true" />
  156.             <tx:method name="load*" read-only="true" />
  157.             <tx:method name="select*" read-only="true" />
  158.             <tx:method name="count*" read-only="true" />
  159.             <tx:method name="search*" read-only="true" />
  160.             <tx:method name="list*" read-only="true" />
  161.             <tx:method name="*" propagation="REQUIRED" rollback-for="Exception" />
  162.         </tx:attributes>
  163.     </tx:advice>
  164.     <aop:aspectj-autoproxy proxy-target-class="true"/>
  165.     <!-- 开启注解事务 只对当前配置文件有效 -->
  167.     <!-- 扫描注解Bean -->
  168.     <context:component-scan base-package="com.xinnet">
  169.         <context:include-filter type="annotation" expression="org.springframework.stereotype.Repository"/>
  170.         <context:include-filter type="annotation" expression="org.springframework.stereotype.Service"/>
  171.         <context:exclude-filter type="annotation" expression="org.springframework.stereotype.Controller"/>
  172.     </context:component-scan>
  173.      <!-- 隐式地向 Spring 容器注册 -->
  174.     <context:annotation-config/>
  176. </beans>

<3>这个时候就可以用两个数据源进行切换注入 从而使用不同数据源的service

这是service里面的方法 该怎么写就是怎么写 该怎么注解就怎么注解 不用做特殊的步骤

[java] view plain copy

  1. @Service("partyService")
  2. public class PartyServiceImpl implements PartyService {
  4.     @Autowired
  5.     private PartyDao partyDao;
  7.     @Override
  8.     public List<Emp> getAllEmp() throws SQLException {
  9.         return partyDao.getAllEmp();
  10.     }
  12. }

Dao层也是一样 该怎么写就怎么写 该怎么注解就怎么注解

然后可以写一个测试类试一下连接

[java] view plain copy

  1. @RunWith(SpringJUnit4ClassRunner.class)
  2. @ContextConfiguration(locations = { "classpath:spring.xml" })//这里的spring.xml加载了第一个数据源 spring-commons.xml 
  3. public class DataSourceTest extends AbstractTransactionalJUnit4SpringContextTests {
  4.     /**
  5.      * 
  6.      * 功能描述：xxxxx
  7.      *
  8.      * @throws SQLException
  9.      *
  10.      * @author xxx[973893384@163.com]
  11.      *
  12.      * @since 2014年3月12日
  13.      *
  14.      * @update:[变更日期YYYY-MM-DD][更改人姓名][变更描述]
  15.      */
  16.     @Test
  17.     @Rollback(true)
  18.     public void testGetAllEmp() throws SQLException {
  19.         ApplicationContext ac = new FileSystemXmlApplicationContext("classpath:config/hymanager/hymanager_spring.xml");//这里加载的是第二个数据源配置文件路径 使用的时候用application 读取第二个数据源的配置文件 就可以用getBean 获取注入的service 不用ac.getBean 用@Autowired自动注入的 则使用的是第一个数据源  
  20.         PartyService partyService = (PartyService) ac.getBean("partyService");
  21.         List<Emp> list = partyService.getAllEmp();
  22.         for (Emp emp : list) {
  23.             System.out.println(emp.getEmpno());
  24.         }
  25.     }

这样就可以封装一个父类

[java] view plain copy

  1. public class DataSourceChange {
  2.     //第二个数据源数据源
  3.     public ApplicationContext otherDataSource=new FileSystemXmlApplicationContext("classpath:config/hymanager/hymanager_spring.xml");
  4.     //默认数据源
  5.     public ApplicationContext defaultDataSource=new FileSystemXmlApplicationContext("classpath:config/spring_commons.xml");
  6.     /**
  7.      * 
  8.      * 功能描述：xxxx
  9.      *
  10.      * @param beanName
  11.      * @return
  12.      *
  13.      * @author xxx[973893384@163.com]
  14.      *
  15.      * @since 2014年3月12日
  16.      *
  17.      * @update:[变更日期YYYY-MM-DD][更改人姓名][变更描述]
  18.      */
  19.     public Object now(String beanName) {
  20.         return defaultDataSource.getBean(beanName);
  21.     }
  22.     public Object after(String beanName) {
  23.         return otherDataSource.getBean(beanName);
  24.     }
  25. }

要使用多个数据源的类就可以继承这个父类

[java] view plain copy

  1. public class HyMangerEmpDataHandle extends DataSourceChange {
  2.     //用父类的after方法更换配置切换第二套数据源获取注入partyService
  3.     private PartyService partyService=(PartyService) after("partyService");
  5.     //<span style="font-family:Arial, Helvetica, sans-serif;">用父类的now方法</span>更换配置切换第一套数据源获取注入empService
  6.     private EmpService empService=(EmpService) now("empService");
  8.     private static Logger log=LoggerFactory.getLogger(PartyService.class);
  9.     /**
  10.      * 
  11.      * 功能描述：xxxxx
  12.      *
  13.      * @throws SQLException
  14.      *
  15.      * @author xxx[973893384@163.com]
  16.      *
  17.      * @since 2014年3月12日
  18.      *
  19.      * @update:[变更日期YYYY-MM-DD][更改人姓名][变更描述]
  20.      */
  21.     public void leadingAllEmp() throws SQLException {
  22.         List<Emp> partyList=partyService.getAllEmp();//第二个数据源注入的service
  23.         for(Emp emp:partyList) {
  24.             empService.addEmp(emp);//第一个数据源注入的service
  25.         }
  26.     }
  27. }

 

文章标签：
云数据库 Redis 版
云数据库 RDS MySQL 版
日志服务
监控
Java
应用服务中间件
Dubbo
数据库连接
容器
关系型数据库
MySQL
Oracle
Spring
相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务，基于高可靠双机热备架构及可无缝扩展的集群架构，满足高读写性能场景及容量需弹性变配的业务需求。 产品详情：https://www.aliyun.com/product/kvstore &nbsp; &nbsp; ------------------------------------------------------------------------- 阿里云数据库体验：数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库&nbsp;ECS 实例和一台目标数据库&nbsp;RDS实例。跟着指引，您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接，领取免费ECS&amp;RDS资源，30分钟完成数据库上云实战！https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
优惠券发放
目录
相关文章
shark-chili
|
8天前
|
SQL 缓存 Java
仿MyBatis-Plus实现跨数据源事务
仿MyBatis-Plus实现跨数据源事务
shark-chili
21 0
java开发-郭老师
|
27天前
|
Java 关系型数据库 MySQL
【mybatis-plus】自定义多数据源，动态切换数据源事务失效问题
【mybatis-plus】自定义多数据源，动态切换数据源事务失效问题
java开发-郭老师
73 3
【mybatis-plus】自定义多数据源，动态切换数据源事务失效问题
一只牛博
|
3月前
|
存储 Java 关系型数据库
springboot整合多数据源的配置以及动态切换数据源，注解切换数据源
springboot整合多数据源的配置以及动态切换数据源，注解切换数据源
一只牛博
76 0
warmhearted
|
4月前
|
SQL Oracle 关系型数据库
dts跨表查询与事务处理
dts跨表查询与事务处理
warmhearted
18 1
朱季谦
|
6月前
|
SQL Java 关系型数据库
模仿Activiti工作流自动建表机制，实现Springboot项目启动后自动创建多表关联的数据库与表的方案
在一些本地化项目开发当中，存在这样一种需求，即开发完成的项目，在第一次部署启动时，需能自行构建系统需要的数据库及其对应的数据库表。
朱季谦
38 1
阿甘兄
|
7月前
|
Java Spring
119分布式电商项目 - 读写分离（使用Spring基于应用层实现（二））
119分布式电商项目 - 读写分离（使用Spring基于应用层实现（二））
阿甘兄
27 1
梁同学golang算法
|
10月前
|
XML Java 数据库连接
mybatis连接多源数据库
mybatis连接多源数据库
梁同学golang算法
58 0
禹迹
|
10月前
|
网络协议 测试技术 Apache
Tablestore-OTSClient连接池连接无法复用分析
某应用在压测过程中，发现OTSClient与OTS服务端之间的TCP连接有大量处于TIME_WAIT状态。
禹迹
114 0
小目标青年
|
Java 数据库
SSM 最简单的实现操作 多数据源&动态切换
SSM 最简单的实现操作 多数据源&动态切换
小目标青年
168 0
SSM 最简单的实现操作 多数据源&动态切换
石臻臻的杂货铺
|
存储 前端开发 Java
可路由计算引擎实现前置数据库
可路由计算引擎实现前置数据库
石臻臻的杂货铺
2417 0
可路由计算引擎实现前置数据库

热门文章

最新文章

  • 1
    《CMOS集成电路后端设计与实战》——3.3　标准单元设计流程
  • 2
    无人驾驶背后的技术 - PostGIS点云(pointcloud)应用
  • 3
    反垃圾邮件技术已转移到云计算中
  • 4
    MYSQL数据库主从复制(一)
  • 5
    Keepalived+MySQL主从切换演示【书里讲解】
  • 6
    数据库总结20160728
  • 7
    c++11新特性(4) lambda捕捉块
  • 8
    0225Snapshot Too Old Error ora-01555.txt
  • 9
    libvirtVirsh
  • 10
    What are TCHAR, WCHAR, LPSTR, LPWSTR, LPCTSTR (etc.)?
  • 1
    【大模型】讨论 LLM 在更广泛的通用人工智能 （AGI） 领域中的作用
    27
  • 2
    【大模型】在实际应用中大规模部署 LLM 会带来哪些挑战？
    22
  • 3
    【大模型】小样本学习的概念及其在微调 LLM 中的应用
    23
  • 4
    【大模型】LLM 如何处理域外或无意义的提示？
    18
  • 5
    【大模型】在使用大语言模型的过程中，我们需要考虑到哪些道德问题？
    18
  • 6
    【大模型】大语言模型存在的一些限制
    13
  • 7
    【大模型】描述一些评估 LLM 性能的技术
    9
  • 8
    【大模型】如何使用提示工程来改善 LLM 输出？
    8
  • 9
    【大模型】大语言模型训练数据中的偏差概念及其可能的影响？
    8
  • 10
    【大模型】在大语言模型的架构中，Transformer有何作用？
    12

    • 相关课程

    更多
  • 数据库核心概念
  • 实时数据接入：5分钟上手 Flink MySQL 连接器

    • 相关电子书

    更多
  • PostgresChina2018_权宗亮_基于odyssey连接池实现企业级PostgreSQL数据分布中间件
  • 阿里云分析引擎Spark On 多数据源介绍
  • PolarDB-PG：数据库“0”改造，提升企业级应用能力

    • 相关实验场景

    更多
  • 使用DAS实现数据库自动SQL优化
  • 使用DAS实现数据库自动SQL限流
  • 如何实现AnalyticDB MySQL多租户功能
    • 下一篇
    将Stable Diffusion模型文件转存到FC环境的NAS