hibernate与ssm多数据源配置

<?xml version=‘1.0‘ encoding=‘UTF-8‘?><!DOCTYPE hibernate-configuration PUBLIC ?????????"-//Hibernate/Hibernate Configuration DTD 3.0//EN" ?????????"http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd"><!-- Generated by MyEclipse Hibernate Tools. ??????????????????--><hibernate-configuration> ???<session-factory> ???????<property name="dialect">com.standsoft.dialect.DialectForInkfish</property> ???????<property name="connection.url">jdbc:sqlserver://localhost:1433;DatabaseName=zhangyanandb</property> ???????<property name="connection.username">sa</property> ???????<property name="connection.password">111111</property> ???????<property name="connection.driver_class">com.microsoft.sqlserver.jdbc.SQLServerDriver</property> ???????<property name="myeclipse.connection.profile">sql2008-4</property> ???????<property name="show_sql">true</property> ???????<property name="format_sql">true</property> ???????<mapping resource="com/standsoft/DictArea.hbm.xml" /> ???</session-factory></hibernate-configuration> 

package com.orm;import org.hibernate.HibernateException;import org.hibernate.Session;import org.hibernate.cfg.Configuration;/** * Configures and provides access to Hibernate sessions, tied to the current * thread of execution. Follows the Thread Local Session pattern, see * {@link http://hibernate.org/42.html }. */public class HibernateSessionFactory1{ ???/** ????* Location of hibernate.cfg.xml file. Location should be on the classpath ????* as Hibernate uses #resourceAsStream style lookup for its configuration ????* file. The default classpath location of the hibernate config file is in ????* the default package. Use #setConfigFile() to update the location of the ????* configuration file for the current session. ????*/ ???private static String CONFIG_FILE_LOCATION = "/hibernate.cfg1.xml"; ???private static final ThreadLocal<Session> threadLocal = new ThreadLocal<Session>(); ???private static Configuration configuration = new Configuration(); ???private static org.hibernate.SessionFactory sessionFactory; ???private static String configFile = CONFIG_FILE_LOCATION; ???static { ???????try { ???????????configuration.configure(configFile); ???????????sessionFactory = configuration.buildSessionFactory(); ???????} catch (Exception e) { ???????????System.err.println("%%%% Error Creating SessionFactory %%%%"); ???????????e.printStackTrace(); ???????} ???} ???private HibernateSessionFactory1() { ???} ???/** ????* Returns the ThreadLocal Session instance. Lazy initialize the ????* <code>SessionFactory</code> if needed. ????* ????* @return Session ????* @throws HibernateException ????*/ ???public static Session getSession() throws HibernateException { ???????Session session = threadLocal.get(); ???????if (session == null || !session.isOpen()) { ???????????if (sessionFactory == null) { ???????????????rebuildSessionFactory(); ???????????} ???????????session = (sessionFactory != null) ? sessionFactory.openSession() : null; ???????????threadLocal.set(session); ???????} ???????return session; ???} ???/** ????* Rebuild hibernate session factory ????* ????*/ ???public static void rebuildSessionFactory() { ???????try { ???????????configuration.configure(configFile); ???????????sessionFactory = configuration.buildSessionFactory(); ???????} catch (Exception e) { ???????????System.err.println("%%%% Error Creating SessionFactory %%%%"); ???????????e.printStackTrace(); ???????} ???} ???/** ????* Close the single hibernate session instance. ????* ????* @throws HibernateException ????*/ ???public static void closeSession() throws HibernateException { ???????Session session = threadLocal.get(); ???????threadLocal.set(null); ???????if (session != null) { ???????????session.close(); ???????} ???} ???/** ????* return session factory ????* ????*/ ???public static org.hibernate.SessionFactory getSessionFactory() { ???????return sessionFactory; ???} ???/** ????* return session factory ????* ????* session factory will be rebuilded in the next call ????*/ ???public static void setConfigFile(String configFile) { ???????HibernateSessionFactory1.configFile = configFile; ???????sessionFactory = null; ???} ???/** ????* return hibernate configuration ????* ????*/ ???public static Configuration getConfiguration() { ???????return configuration; ???}}

package com.orm;import org.hibernate.HibernateException;import org.hibernate.Session;/** * Configures and provides access to Hibernate sessions, tied to the current * thread of execution. Follows the Thread Local Session pattern, see * {@link http://hibernate.org/42.html }. */public class HibernateSessionFactory { ???public static Session currentSession; ???????public static Session getCurrentSession() { ???????return currentSession; ???} ???public static void setCurrentSession(Session currentSession) { ???????HibernateSessionFactory.currentSession = currentSession; ???} ???public static Session getSession() throws HibernateException { ???????return currentSession; ???}}

jdbc.driver=com.microsoft.sqlserver.jdbc.SQLServerDriverjdbc.url=jdbc:sqlserver://localhost:1433; DatabaseName=zhangyanandbjdbc.username=sajdbc.password=11111jdbc2.url=jdbc:sqlserver://localhost:1433; DatabaseName=zhangyanandb2jdbc2.username=sajdbc2.password=11111

 ???<!-- 数据库连接池 --> ???<!-- 加载配置文件 --> ???<context:property-placeholder location="classpath:resource/db.properties" /> ???<!-- 数据库连接池 --> ???<bean id="dataSource1" class="com.alibaba.druid.pool.DruidDataSource" ???????destroy-method="close"> ???????<property name="url" value="${jdbc.url}" /> ???????<property name="username" value="${jdbc.username}" /> ???????<property name="password" value="${jdbc.password}" /> ???????<property name="driverClassName" value="${jdbc.driver}" /> ???????<property name="maxActive" value="10" /> ???????<property name="minIdle" value="5" /> ???</bean> ???????<!-- 数据库连接池 --> ???<bean id="dataSource2" class="com.alibaba.druid.pool.DruidDataSource" ???????destroy-method="close"> ???????<property name="url" value="${jdbc2.url}" /> ???????<property name="username" value="${jdbc2.username}" /> ???????<property name="password" value="${jdbc2.password}" /> ???????<property name="driverClassName" value="${jdbc.driver}" /> ???????<property name="maxActive" value="10" /> ???????<property name="minIdle" value="5" /> ???</bean> ????????<!-- 动态数据源 --><bean id="dynamicDataSource" class="util.DynamicDataSource"> ???<property name="targetDataSources"> ?????????<map key-type="java.lang.String"> ???????????<!-- 指定lookupKey和与之对应的数据源 --> ???????????<entry key="dataSource1" value-ref="dataSource1"></entry> ?????????????<entry key="dataSource2" value-ref="dataSource2"></entry> ???????</map> ?????</property> ?????<!-- 这里可以指定默认的数据源 --> ???<property name="defaultTargetDataSource" ref="dataSource1" /> ?</bean>

 ???<!-- 配置sqlsessionFactory --> ???<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean" > ???????<property name="configLocation" value="classpath:resource/SqlMapConfig.xml"></property> ???????<property name="dataSource" ref="dynamicDataSource"></property> ???</bean> ???

<!-- 事务管理器 --> ???<bean id="transactionManager" ???????class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> ???????<!-- 数据源 --> ???????<property name="dataSource" ref="dynamicDataSource" /> ???</bean> ???<!-- 通知 --> ???<tx:advice id="txAdvice" transaction-manager="transactionManager"> ???????<tx:attributes> ???????????<!-- 传播行为 --> ???????????<tx:method name="save*" propagation="REQUIRED" /> ???????????<tx:method name="insert*" propagation="REQUIRED" /> ???????????<tx:method name="add*" propagation="REQUIRED" /> ???????????<tx:method name="create*" propagation="REQUIRED" /> ???????????<tx:method name="delete*" propagation="REQUIRED" /> ???????????<tx:method name="update*" propagation="REQUIRED" /> ???????????<tx:method name="find*" propagation="SUPPORTS" read-only="true" /> ???????????<tx:method name="select*" propagation="SUPPORTS" read-only="true" /> ???????????<tx:method name="get*" propagation="SUPPORTS" read-only="true" /> ???????</tx:attributes> ???</tx:advice>

import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;public class DynamicDataSource extends AbstractRoutingDataSource { ???/** ????* ?该方法返回需要使用的DataSource的key值， ????* ?然后根据这个key从resolvedDataSources这个map里取出对应的DataSource， ????* ?如果找不到，则用默认的resolvedDefaultDataSource。 ????*/ ???@Override ???protected Object determineCurrentLookupKey() { ???????// 从自定义的位置获取数据源标识 ???????return DynamicDataSourceHolder.getDataSource(); ???}}

public class DynamicDataSourceHolder { ???/** ????* 注意：数据源标识保存在线程变量中，避免多线程操作数据源时互相干扰 ????*/ ???private static final ThreadLocal<String> THREAD_DATA_SOURCE = new ThreadLocal<String>(); ???public static String getDataSource() { ???????return THREAD_DATA_SOURCE.get(); ???} ???public static void setDataSource(String dataSource) { ???????THREAD_DATA_SOURCE.set(dataSource); ???} ???public static void clearDataSource() { ???????THREAD_DATA_SOURCE.remove(); ???}}