文档章节

Spring 多数据源动态切换

无知的小孩
 无知的小孩
发布于 2015/07/14 18:04
字数 581
阅读 25
收藏 0

beans.xml

<bean id="dataSource2" class="com.alibaba.druid.pool.DruidDataSource"
  init-method="init" destroy-method="close">
  <property name="url" value="${jdbc_url2}" />
  <property name="username" value="${jdbc_user2}" />
  <property name="password" value="${jdbc_password2}" />
  <property name="maxActive" value="20" />
  <property name="initialSize" value="1" />
  <property name="maxWait" value="60000" />
  <property name="minIdle" value="1" />
  <property name="timeBetweenEvictionRunsMillis" value="60000" />
  <property name="minEvictableIdleTimeMillis" value="300000" />
  <property name="testWhileIdle" value="true" />
  <property name="testOnBorrow" value="false" />
  <property name="testOnReturn" value="false" />
  <property name="poolPreparedStatements" value="true" />
  <property name="maxPoolPreparedStatementPerConnectionSize"
   value="50" />
  <property name="filters" value="stat,log4j" />
  <property name="proxyFilters" ref="log-filter" />

 </bean>
 <bean id="log-filter" class="com.alibaba.druid.filter.logging.Log4jFilter">
  <property name="resultSetLogEnabled" value="false" />
  <property name="statementExecutableSqlLogEnable" value="true" />
  <property name="statementLoggerName" value="sqlLogger" />
 </bean>
 <!-- ibatis配置 -->
 <bean id="sqlMapClient" class="org.springframework.orm.ibatis.SqlMapClientFactoryBean">
  <property name="configLocation" value="classpath:ibatis.xml" />
  <property name="dataSource" ref="dataSource" />
 </bean>
 <bean id="dataSource" class="zh.dbcenter.DynamicDataSource">
  <property name="targetDataSources">
   <map key-type="java.lang.String">
    <entry key="dataSource1" value-ref="dataSource1" />
    
    <!--<entry key="dataSource2" value-ref="dataSource2" />  -->
   </map>
  </property>
  <property name="defaultTargetDataSource" ref="dataSource1" />
 </bean>

DynamicDataSource.java

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;
import org.apache.commons.dbcp.BasicDataSource;
import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
public class DynamicDataSource extends AbstractRoutingDataSource {
 Logger log = Logger.getLogger("DynamicDataSource");
 private Map<Object, Object> _targetDataSources;
 @Override
 protected Object determineCurrentLookupKey() {
  String dataSourceName = DbContextHolder.getDBType();
  if (dataSourceName == null) {
   dataSourceName = "dataSource";
  } else {
   this.selectDataSource(dataSourceName);
   if (dataSourceName.equals("0"))
    dataSourceName = "dataSource";
  }
  log.debug("--------> use datasource " + dataSourceName);
  return dataSourceName;
 }
 public void setTargetDataSources(Map<Object, Object> targetDataSources) {
  this._targetDataSources = targetDataSources;
  super.setTargetDataSources(this._targetDataSources);
  afterPropertiesSet();
 }
 public void addTargetDataSource(String key, BasicDataSource dataSource) {
  this._targetDataSources.put(key, dataSource);
  this.setTargetDataSources(this._targetDataSources);
 }
 public BasicDataSource createDataSource(String driverClassName, String url,
   String username, String password) {
  BasicDataSource dataSource = new BasicDataSource();
  dataSource.setDriverClassName(driverClassName);
  dataSource.setUrl(url);
  dataSource.setUsername(username);
  dataSource.setPassword(password);
  dataSource.setTestWhileIdle(true);
  dataSource.setInitialSize(1);
  dataSource.setMaxActive(5);
  dataSource.setMaxWait(30000);
  return dataSource;
 }
 
 public BasicDataSource createDataSource(Map<String,String> jdbc) {
  String dcn = jdbc.get("driverClassName");
  if(StringUtils.isBlank(dcn)
    ||StringUtils.isEmpty(dcn)
    ||dcn.equals("null"))
  {
   dcn = "oracle.jdbc.driver.OracleDriver";
  }
  BasicDataSource dataSource = new BasicDataSource();
  dataSource.setDriverClassName(jdbc.get("driverClassName"));
  dataSource.setUrl(jdbc.get("url"));
  dataSource.setUsername(jdbc.get("username"));
  dataSource.setPassword(jdbc.get("password"));
  dataSource.setTestWhileIdle(true);
  dataSource.setInitialSize(1);
  dataSource.setMaxActive(5);
  dataSource.setMaxWait(30000);
  return dataSource;
 }
 /**
  * @param dataSourceName
  * @describe 数据源存在时不做处理,不存在时创建新的数据源链接,并将新数据链接添加至缓存
  */
 public void selectDataSource(String dataSourceName) {
  Object sid = DbContextHolder.getDBType();
  if ("0".equals(dataSourceName)) {
   DbContextHolder.setDBType("0");
   return;
  }
  Object obj = this._targetDataSources.get(dataSourceName);
  if (obj != null && sid.equals(dataSourceName)) {
   DbContextHolder.setDBType(dataSourceName);
   return;
  } else {
   
   this.selectDataSource("0");
   Connection conn = null;
   try {
    conn = this.getConnection();
    System.out.println(conn == null);
    
   } catch (SQLException e) {
    e.printStackTrace();
   }
   
   if(conn != null)
   {
    try {
       Map<String,String> jdbc = new HashMap<String, String>();
       PreparedStatement ps = conn
                      .prepareStatement("SELECT * FROM bas_datasource WHERE DBS_ID = ?");
              ps.setString(1, dataSourceName);
              ResultSet rs = ps.executeQuery();
              if (rs.next()) {
               jdbc.put("DBS_ID", rs.getString("DBS_ID"));
               jdbc.put("driverClassName","oracle.jdbc.driver.OracleDriver");
               jdbc.put("url", rs.getString("URL"));
               jdbc.put("username", rs.getString("USERNAME"));
               jdbc.put("password", rs.getString("PASSWORD"));
              }
              rs.close();
              ps.close();
              
              BasicDataSource dataSource = this.createDataSource(jdbc);
     this.setDataSource(dataSourceName, dataSource);
              
          } catch (SQLException e) {
              log.error(e);
          } finally {
              try {
                  conn.close();
              } catch (SQLException e) {
                  log.error(e);
              }
          }
   } 
  }
 }
 /**
  * @param serverId
  * @param dataSource
  */
 public void setDataSource(String dataSourceName, BasicDataSource dataSource) {
  this.addTargetDataSource(dataSourceName, dataSource);
  DbContextHolder.setDBType(dataSourceName);
 }
}

DBCenter.java

import java.util.HashMap;
import java.util.Map;
import org.apache.commons.dbcp.BasicDataSource;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import zh.Dao.CampusDao;
 
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations={"classpath*:beans.xml"}) 
public class DBCenter { 
 
 @Autowired
 private CampusDao campusDao;
  
 @Test 
 public void testCampusAll() { 
  
  System.out.println("傻逼");
  System.out.println(campusDao.findAll().get(0));
  DbContextHolder.setDBType("dataSource2");
  System.out.println(campusDao.findAll().get(0));
  DbContextHolder.setDBType("dataSource1");
  System.out.println(campusDao.findAll().get(0));
  
 }

© 著作权归作者所有

共有 人打赏支持
无知的小孩
粉丝 1
博文 70
码字总数 19034
作品 0
贵阳
后端工程师
私信 提问
spring管理多数据源 现在需要通过zookeeper动态控制切换数据源

需求来源: 上次从库宕机了,导致几个同事都在修改配置文件中的IP把从库ip换成主库IP做查询 ,这样从监控通知到修改再到上线发布至少要30分钟。 现在要求通过一个配置页面轻轻松松点击一下就...

Elijah
2016/04/29
812
2
spring+mybitas 实现多数据源动态切换

1 由于项目需要,需要将不同来源的数据存入不同的数据库,所以需要根据入参的信息动态切换数据源 项目core层采用了spring+mybitas 方式进行架构 1 在spring的配置中定义两个数据源 2创建一个...

black_c
2018/05/15
0
0
Spring动态创建,加载,使用多数据源

项目中我们经常会遇到多数据源的问题,尤其是数据同步或定时任务等项目更是如此。多数据源让人最头痛的,不是配置多个数据源,而是如何能灵活动态的切换数据源。例如在一个spring和hibernate...

Java编程思想
2014/02/26
0
3
JAVA中使用代码创建多数据源,并实现动态切换(一)

2017-06-06 11:31:57补充:近日,在本文的基础之上,扩展了下,使用atomikos来管理事务,保证多数据源操作时,事务一致性。(https://my.oschina.net/simpleton/blog/916108) 另外,感谢朋友...

十月阳光
2017/03/27
0
0
Spring Boot MyBatis 动态数据源切换、多数据源,读写分离

项目地址 https://github.com/helloworlde/SpringBoot-DynamicDataSource 本项目使用 Spring Boot 和 MyBatis 实现多数据源,动态数据源的切换;有多种不同的实现方式,在学习的过程中发现没...

呜呜呜啦啦啦
2017/12/21
0
0

没有更多内容

加载失败,请刷新页面

加载更多

开启genelog

打开genelog genelog 可以记录数据库的操作语句。 首先进入mysql, mysql -u root -p 设置日志位置 set global general_log_file = "/tmp/general.log"; 设置全局global模式 set global gen......

狼王黄师傅
15分钟前
0
0
Java 帝国对 Python 的渗透能成功吗?哈哈

引子 Java 帝国已经成立20多年,经过历代国王的励精图治,可以说是地大物博,码农众多。 可是国王依然不满足,整天想着如何继续开拓疆土, 这一天晚上他又把几个重臣招来商议了。 IO大臣说:...

边鹏_尛爺鑫
今天
7
0
分布式事务解决方案框架(LCN)

什么是XA接口 XA是一个分布式事务协议,由Tuxedo提出。XA中大致分为两部分:事务管理器和本地资源管理器。其中本地资源管理器往往由数据库实现,比如Oracle、DB2这些商业数据库都实现了XA接口...

群星纪元
今天
7
0
linux 操作系统 常用命令和软件安装

1.系统时间更新 ntpdate time.windows.com 2.传送文件 rsync -av /home/data/a.dat -e ssh root@192.168.0.100:/home 3.传送文件夹 scp -r /home/data root@192.168.0.100:/home 4.JDK安装 ......

WJtiny
今天
3
0
pg_lightool基于basebackup的单表恢复和块恢复

开源软件pg_lightool,实现了基于wal日志的块恢复。详情参见博客:https://my.oschina.net/lcc1990/blog/1931485。由于wal日志中FPW的不确定性,它不能作为一个数据库恢复的解决方案。目前对...

movead
今天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部