项目中我们经常会遇到多数据源的问题，尤其是数据同步或定时任务等项目更是如此。多数据源让人最头痛的，不是配置多个数据源，而是如何能灵活动态的切换数据源。例如在一个spring和hibernate的框架的项目中，我们在spring配置中往往是配置一个dataSource来连接数据库，然后绑定给sessionFactory，在dao层代码中再指定sessionFactory来进行数据库操作。
 
 
 
 
 正如上图所示，每一块都是指定绑死的，如果是多个数据源，也只能是下图中那种方式。
 
 
 
 可看出在Dao层代码中写死了两个SessionFactory，这样日后如果再多一个数据源，还要改代码添加一个SessionFactory，显然这并不符合开闭原则。
 
 那么正确的做法应该是
 
 
 
 先说一下我的思路：
 
 首先做一个创建数据源配置文件的类，专门用于创建数据源xml配置，叫ConfigFileCreator.java 
 
 其次，编写一个动态加载刚才创建的配置文件的类，叫 DynamicLoadBean.java。至此，创建的数据源到内存中已经完成。
 
 第三，重点编写这个DynamicDataSource.java，该类主要是用来实现动态切换数据源，并通知容器。在这一块我选择了修改，AbstractRoutingDataSource.java，编写一个支持添加数据源对象的方法public void addDataSource(Object key,Object dataSource)
 
 第四，写例子来测试
 
 实现过程如下：
 
 1.bean.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:tx="http://www.springframework.org/schema/tx"
	xmlns:context="http://www.springframework.org/schema/context"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
				http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd
				http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd">
	<!-- 自动扫描与装配bean -->
	<context:component-scan base-package="qilin"></context:component-scan>
	<!-- 使用外部的配置文件 -->
	<context:property-placeholder location="classpath:jdbc.properties" />
	<bean id="defaultDataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
				<!-- 数据库连接信息 -->
				<property name="jdbcUrl" value="${jdbcUrl}"></property>
				<property name="driverClass" value="${driverClass}"></property>
				<property name="user" value="${username}"></property>
				<property name="password" value="${password}"></property>
	</bean>
	
	<bean id="dataSourceA" class="com.mchange.v2.c3p0.ComboPooledDataSource">
				<!-- 数据库连接信息 -->
				<property name="jdbcUrl" value="jdbc:mysql:///dynamictest"></property>
				<property name="driverClass" value="${driverClass}"></property>
				<property name="user" value="${username}"></property>
				<property name="password" value="${password}"></property>
	</bean>
	<bean id="dynamicdatasource" class="qilin.utils.DynamicDataSource">
		<property name="targetDataSources">
			<map key-type="java.lang.String">
				 <entry key="defaultDataSource" value-ref="defaultDataSource" /> 
				 <entry key="dataSourceA" value-ref="dataSourceA" /> 
			</map>
		</property>
		<property name="defaultTargetDataSource" ref="defaultDataSource" />
	</bean>

	<!-- 配置SessionFactory -->
	<bean id="sessionFactory"
		class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
		<property name="dataSource" ref="dynamicdatasource" />
		<property name="hibernateProperties">
			<props>
				<prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>
				<prop key="hibernate.hbm2ddl.auto">none</prop>
				<prop key="hibernate.show_sql">true</prop>
				<prop key="hibernate.format_sql">false</prop>
				<prop key="hibernate.temp.use_jdbc_metadata_defaults">false</prop>
			</props>
		</property>
		<!-- 注解方式配置 -->
		<property name="annotatedClasses">
			<list>
				<value>qilin.entity.Student</value>
			</list>
		</property>
	</bean>


	<!-- 配置声明式事务管理，采用基于注解的方式 -->
	<bean id="transactionManager"
		class="org.springframework.orm.hibernate3.HibernateTransactionManager">
		<property name="sessionFactory" ref="sessionFactory"></property>
	</bean>
	<tx:annotation-driven transaction-manager="transactionManager" />
	<bean id="dynamicLoadBean" class="qilin.utils.DynamicLoadBean"></bean>
</beans>
2.AbstractRoutingDataSource.class 修改的部分 
 
 
 
/**@author qilin**/
	public void addDataSource(Object key,Object dataSource){
		
		this.targetDataSources.put(key, dataSource);
		
		setTargetDataSources(this.targetDataSources);
	}
3.DynamicDataSource.class  这个类中有一个地方需要注意，当我们添加数据，切换了数据源，要通知当前spring容器，需要调用父类的super.afterPropertiesSet();方法 
 
 
 
package qilin.utils;

import java.util.Map;

import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
import org.springframework.jdbc.datasource.lookup.DataSourceLookup;

public class DynamicDataSource extends AbstractRoutingDataSource {

	/* 
	 * 该方法必须要重写  方法是为了根据数据库标示符取得当前的数据库
	 */
	@Override
	public Object determineCurrentLookupKey() {
		return DataSourceContextHolder.getDataSourceName();
	}

	@Override
	public void setDataSourceLookup(DataSourceLookup dataSourceLookup) {
		super.setDataSourceLookup(dataSourceLookup);
	}

	@Override
	public void setDefaultTargetDataSource(Object defaultTargetDataSource) {
		super.setDefaultTargetDataSource(defaultTargetDataSource);
	}

	@Override
	public void setTargetDataSources(Map targetDataSources) {
		super.setTargetDataSources(targetDataSources);
		//重点
		super.afterPropertiesSet();
	}

}
4.动态加载数据源配置文件DynamicLoadBean.class 
 
 
 
package qilin.utils;

import java.io.IOException;

import org.springframework.beans.BeansException;
import org.springframework.beans.factory.config.BeanDefinition;
import org.springframework.beans.factory.support.BeanDefinitionRegistry;
import org.springframework.beans.factory.support.ChildBeanDefinition;
import org.springframework.beans.factory.support.DefaultListableBeanFactory;
import org.springframework.beans.factory.xml.ResourceEntityResolver;
import org.springframework.beans.factory.xml.XmlBeanDefinitionReader;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.context.ConfigurableApplicationContext;

/**
 * 动�?�加载数据源
 * @author qilin
 *
 */
public class DynamicLoadBean implements ApplicationContextAware {

	private ConfigurableApplicationContext applicationContext = null;
	public void setApplicationContext(ApplicationContext applicationContext)
			throws BeansException {

			this.applicationContext = (ConfigurableApplicationContext) applicationContext;
	}

	public ConfigurableApplicationContext getApplicationContext() {  
        return applicationContext;  
    }
	
	/**
	 * 1.配置文件的位置固�?
	 * 2.配置文件中bean的名字已�?
	 * @param configLocationString
	 */
	 public void loadBean(String fileName)
	    {  
	        XmlBeanDefinitionReader beanDefinitionReader = new XmlBeanDefinitionReader((BeanDefinitionRegistry)getApplicationContext().getBeanFactory());  
	        beanDefinitionReader.setResourceLoader(getApplicationContext());  
	        beanDefinitionReader.setEntityResolver(new ResourceEntityResolver(getApplicationContext()));  
	        try
	        {  
	        	beanDefinitionReader.loadBeanDefinitions(getApplicationContext().getResources(fileName));  
	        } catch (BeansException e) {  
	            e.printStackTrace();  
	        } catch (IOException e) {  
	            e.printStackTrace();  
	        }  
	    }  

	 public void registBean(String beanName, String parentName) {
		 DefaultListableBeanFactory  fcy = (DefaultListableBeanFactory)applicationContext.getAutowireCapableBeanFactory();
		 BeanDefinition beanDefinition  = new ChildBeanDefinition(parentName);
		 fcy.registerBeanDefinition(beanName, beanDefinition);
	 }
}
5.DataSourceContextHolder.class 
 
 
 
package qilin.utils;


public class DataSourceContextHolder {

	private static final ThreadLocal contextHolder=new ThreadLocal();
	
	public static void setDataSourceType(String dataSourceName){
		contextHolder.set(dataSourceName);
	}
	
	public static String getDataSourceName(){
		return (String) contextHolder.get();
	}
	
	public static void clearDataSourceType(){
		contextHolder.remove();
	}
	
}
 
5.测试代码
 
 
package junit;

import java.util.HashMap;
import java.util.Map;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.mchange.v2.c3p0.ComboPooledDataSource;

import qilin.entity.Student;
import qilin.service.StuService;
import qilin.utils.DataSourceContextHolder;
import qilin.utils.DynamicDataSource;
import qilin.utils.DynamicLoadBean;

public class Test {
	public static void main(String[] args) {
		ApplicationContext ac = new ClassPathXmlApplicationContext("bean.xml");
		
		StuService stuService = (StuService) ac.getBean("stuServiceImpl");
		
		Student stu = new Student();
		
		stu.setStuName("qilin");
		
		stuService.save(stu);
		
		DataSourceContextHolder.setDataSourceType("dataSourceA");
		
		
		Student _stu = new Student();
		
		_stu.setStuName("_qilin1");
		
		stuService.save(_stu);
		
		//创建一个数据源
		DynamicLoadBean dynamicBeanLoad =(DynamicLoadBean)ac.getBean("dynamicLoadBean");   
        dynamicBeanLoad.loadBean("classpath:mos/qqq.xml"); 
        ComboPooledDataSource dataSource = (ComboPooledDataSource) ac.getBean("qqq");
        System.err.println(dataSource.getDriverClass());
        
        
        
        DynamicDataSource dynamicDataSource = (DynamicDataSource) ac.getBean("dynamicdatasource");
       
//        Map<String, ComboPooledDataSource> targetDataSources = new HashMap<String, ComboPooledDataSource>();
        
//        targetDataSources.put("qqq", dataSource);
        
//        Map<Object, Object> targetDataSources = dynamicDataSource.getTargetDataSources();
        
//        targetDataSources.put("qqq", dataSource);
        
//        dynamicDataSource.setTargetDataSources(targetDataSources);
        
//        dynamicDataSource.setDefaultTargetDataSource(dataSource);
        
        dynamicDataSource.addDataSource("qqq", dataSource);
        
        DataSourceContextHolder.setDataSourceType("qqq");
		
        Student __stu = new Student();
		
		__stu.setStuName("qilin2");
		
		stuService.save(__stu);
		
	}
}


 

 
 
切换数据源就一句话搞定  DataSourceContextHolder.setDataSourceType("qqq");
 
下载链接http://download.csdn.net/detail/qi_lin70/6778247
 

 
 
 
 有什么不妥之处，还望指教。共同学习，共同进步！
 
 
 
 
 
 
 
 
 
 
 
 

软件环境
 数据库：SQL Server 2005
 桌面产品：SuperMap Deskpro .NET 6R (2012)
 实现内容
 使用 SuperMap Deskpro .NET 6R (2012)创建数据库型数据源，数据库类型为 SQLServer 2005。
 实现思路
 连接到 SQL Server 2005 数据库，新建一个数据库登录名，再打开 SuperMap Deskpro .NET 6R (2012)，用这个新建的数据库登录名，创建一个 SQL Server 数
 据库，也就是 SQL Server 数据源。
 实现步骤
 新建数据库的登录名（ 图一 ），设置服务器角色为 dbcreator（ 有关服务器角色的概念，请参见附录一 ）（ 图二 ）。不需要设置用户映射，当在 Deskpro .NET 中创建了 SQL Server 数据源后会自动将新创建的数据库映射到新建的这个登录名中。
 
 
 
打开Deskpro .NET 6R (2012)，新建SQL Server数据源，在弹出的新建SQL Server Plus 数据源对话框中，输入数据库服务器名称，或 IP\实例名，数据库名称为用户自定义的名称，例中为 supermap，用户名称和用户密码为在 SQL Server中新建的登录名及其相应的密码（图三 ），点击新建，即可新建成功（图四 ）。
 
 
可以再回到 SQL Server 2005 中验证一下是否生成了相应的数据库，刷新数据库，会看到生成了一个名为 supermap 的数据库，再查看之前新建的登录名，会看到默认映射到 supermap 数据库中，并设置了数据库角色身份为db_owner（ 执行所有数据库角色活动 ）和 public（ 维护所有默认权限 ）。
 
 附录一：
 
服务器角色：服务器角色限制在发布 SQL Server 时就已经建立于其中的角色，并且，它在这里主要是为了进行系统的维护以及授予完成非数据库特有的事情的能力，如登录账户和创建连接服务器。
 SQL Server 服务器角色是指根据 SQL Server 的管理任务，以及这些任务相对的重要性等级来把具有 SQL Server 管理职能的用户划分为不同的用户组，每一组所具有的管理 SQL Server 的权限都是系统内置的，即不能对其进行添加、修改和删除，只能向其中加入用户或者其他角色。
 SQL Server 服务器角色存在于各个数据库之中，要想加入用户，该用户必须有登录账号以便加入到角色中。SQL Server 提供了七种常用的固定 SQL Server 服务器角色，其具体含义如下：
  系统管理员(sysadmin)：拥有 SQL Server 所有的权限许可；
  服务器管理员(serveradmin)：管理 SQL Server 服务器端的设置；
  磁盘管理员(diskadmin)：管理磁盘文件；
  进程管理员(processadmin)：管理 SQL Server 系统进程；
  安全管理员(securityadmin)：管理和审核 SQL Server 系统登录；
  安装管理员(setupadmin)：增加、删除连接服务器，建立数据库复制以及管理扩展存储过程；
  数据库创建者(dbcreator)：创建数据库，并对数据库进行修改。
  Bulkadmin：用于执行 bulk insert 语句的权限，否则的话，只能由具有 sysadmin权限的人来执行 bulk insert 语句。
数据库角色。数据库角色限制在单个数据库的范围之----用户属于一个数据库中的db_datareader 角色并不意味着他属于另一个数据库中的那个角色。数据库的角色分为两个子类：固定数据库角色和用户自定义数据库角色。这里主要为大家介绍固定数据库角色。固定数据库角色有预先定义好的专门的用途，这是不能使用常规的语句复制出来的。包括以下的内容：
  db_owner ：执行数据库中的所有维护和配置活动。
  db_accessadmin ：添加或删除 windows 用户、组和 SQL Server 登录的访问权限。
  db_datareader ：读取所有用户表中的所有数据。
  db_datawriter： 添加、删除或更改所有用户表中的数据。
  db_ddladmin ：在数据库中运行任何数据定义语言 (ddl) 命令。
  db_securityadmin ：修改角色成员身份并管理权限。
  db_backupoperator ：备份数据库。
  db_denydatareader ：无法读取数据库用户表中的任何数据。
  db_denydatawriter ：无法添加、修改或删除任何用户表或视图中的数据。

        上一篇中有讲到数据源的使用方式有多种，这里来简单介绍下。首先，给大家看一张图：
 

 
 
        PB提供5种数据源：Quick Select(快速选择类型)、SQL Select(SQL选择类型)、Query(查询类型)、External(外部类型)和Stored Procedure(存储过程类型)
 
 
Quick Select
 
       快速选择类型，只能从一个数据表或者视图中选取数据(无关联的表或者视图)
 

 
 
SQL Select
 
       SQL选择类型，可以实现多表查询
 
选择表
 

 
 

 
 
选择字段
 
       选择需要查询的数据字段
 

 
 
指定检索条件
 
       还可以根据条件进行查询等等
 

 
 
Query
 
       查询类型，PB可以将特定的SQL语句保存为Query对象，不同的Query数据源的数据窗口都可以使用这些已经保存好的SQL语句来提取数据
 
 

 
 
External
 
       外部类型，添加外部数据源，当和不存在于数据库中的数据打交道或者要利用数据窗口的某些特性但不进行数据处理时，使用此数据源。无SQL语句。
 

 
 
Stored Procedure
 
        存储过程类型，使用已经定义好的存储过程来做数据源。
 

 
 

 
 
       使用PB软件开发程序的小伙伴们一定要好好了解这五种数据源方式哦！

 
 
作者：12058
 
 
本文主要介绍如何如何创建达梦数据库型的数据源，目前我们的iDesktop产品支持达梦数据库的版本为7.1.4和7.1.5，我们就以64位的达梦数据库7.1.5版本和64位的iDesktop7.1.2版本为示例。
 
 
安装数据库：达梦数据库的安装过程很简单，按安装向导流程化的安装即可。如图一至图三。
 
 
 注：达梦数据库的服务器和客户端是在同一个安装程序里，如果只需要服务器的话，就不勾选客户端，如果只需要客户端的话，就不勾选服务器和数据库服务即可。
 
 安装完成后就初始化数据库。
 
 
配置数据库：达梦数据库的实例化也比较简单，因为它的组织和 Oracle 数据库类似，它的参数配置、创建数据库等过程都和 Oracle 数据库类似，它的实例、表空间、用户、数据文件等概念都和 oracle 数据库的类似。如图四至图十二。
 
 
 
 
 注：安装到这一步，会提示防火墙阻止，勾选上所有网络，然后点击允许访问。
 
 注：这里的字符集设置的是GB18030。如果使用过程中遇到数据表里有产生乱码现象，那基本都是字符集不一致导致的，这时请修改字符集类型。
 
 注：设置用户名密码，这个需要记住。
 
 
 注：数据库创建完成后。打开DM服务查看器，我们可以看到达梦数据库的实例服务已经在运行了，那么我们接下来就可以创建达梦数据库用户了。
 
 
创建DM数据库用户，创建DM的用户也很简单，选择变空间为MAIN，然后赋予角色所有的权限，如图，然后下一步完成创建。
 
 
 
 
创建DM数据源，在创建前将DM数据库安装目录的bin文件夹的整个路径添加到系统环境Path变量里。
 
 注：如果DM数据库安装在本机，那么服务器名称就填“localhost”，如果DM数据库不在本机，那么就填服务器的IP地址。带有DM数据库引擎的iDesktop需要单独申请，或者通过扩展开发写这个功能（组件已提供该引擎接口）。