多数据源

多数据源配置，当时不能达到动态数据源。自己想要的是动态的，搞错，不过还是写下博客吧。也是知识。

 

实体类：

public class DataEntity implements java.io.Serializable {
	private Integer id;
	private String name;
	private int age;
	
其他的get，set省略了！

 

 

映射文件：

<?xml version="1.0" encoding="utf-8"?>
<!DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
<hibernate-mapping>
	<class name="com.mul.entity.DataEntity" table="dataentity"
		mutable="false">
		<id name="id" type="java.lang.Integer">
			<column name="id" />
			<generator class="native"></generator>
		</id>
		<property name="name" type="java.lang.String">
			<column name="name" length="128" />
		</property>
		<property name="age">
			<column name="age" />
		</property>
	</class>
</hibernate-mapping>

 

 

一个标识类，可以要可以不要的。

package com.mul.spring;
public class DataSourceTypeKey {
	public static String ADMIN = "admin1";//标识一个数据源
	public static String GUEST = "guest1";//标识另一个数据源
}

 

 

选择一个标识，一定要是线程安全的所以才特意的写了个类来存放

package com.mul.spring;

public class DataSourceTypeChoose {
	private static final ThreadLocal  threadLocal = new ThreadLocal();
	
	public static void setThreadLocal(String value) {//value就是DataSourceTypeKey 中的一个
		threadLocal.set(value);
	}
	
	public static ThreadLocal getThreadLocal() {
		return threadLocal;
	}
	
	public static void clearDataSourceType () { 
		threadLocal.remove();
	} 
	
}

 

真正提供给spring文件读取的类      必须继承AbstractRoutingDataSource

package com.mul.spring;

import java.sql.SQLException;

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

public class MyAbstractRoutingDataSource extends AbstractRoutingDataSource {

	@Override
	protected Object determineCurrentLookupKey() {
		// spring调用方法得到产生sessionfacroty时用哪个数据源，还得在文件中配
		return DataSourceTypeChoose.getThreadLocal();
	}
}

 

spring配置文件

<?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:context="http://www.springframework.org/schema/context"
	xmlns:aop="http://www.springframework.org/schema/aop"
	xmlns:tx="http://www.springframework.org/schema/tx"
	xsi:schemaLocation="
	   http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
       http://www.springframework.org/schema/context
       http://www.springframework.org/schema/context/spring-context-2.5.xsd
       http://www.springframework.org/schema/tx 
       http://www.springframework.org/schema/tx/spring-tx-2.5.xsd
       http://www.springframework.org/schema/aop 
       http://www.springframework.org/schema/aop/spring-aop-2.5.xsd"
	default-autowire="byName">
	
	
	<context:annotation-config />
	<bean id="parentDataSource"
		class="org.springframework.jdbc.datasource.DriverManagerDataSource">
		<property name="driverClassName">
			<value>com.mysql.jdbc.Driver</value>
		</property>
		<property name="username" value="root"></property>
		<property name="password" value="hejie"></property>
	</bean>

	<bean id="primaryDataSource" parent="parentDataSource">
		<property name="url">
			<value>jdbc:mysql://localhost:3306/test1</value>
		</property>
	</bean>

	<bean id="backupDataSource" parent="parentDataSource">
		<property name="url">
			<value>jdbc:mysql://localhost:3306/test2</value>
		</property>
	</bean>
               <!-- 数据源 里面有两个不同的数据源，key就是我们之前的标识，对应了一个数据源。还有一个默认的-->
	<bean id="dataSource" scope="prototype"
		class="com.mul.spring.MyAbstractRoutingDataSource">
		<property name="targetDataSources">
			<map key-type="java.lang.String">
			        <entry key="admin1" value-ref="primaryDataSource" />
			        <entry key="guest1" value-ref="backupDataSource" />
			</map>
		</property>
		<property name="defaultTargetDataSource" ref="primaryDataSource" />
	</bean>


	<bean id="sessionFactory"
		class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
		<property name="dataSource">
			<ref bean="dataSource" />
		</property>
		<property name="hibernateProperties">
			<props>
				<prop key="hibernate.dialect">
					org.hibernate.dialect.MySQLDialect
				</prop>
				<prop key="hibernate.show_sql">true</prop>
				<prop key="hibernate.format_sql">true</prop>
				<prop key="hibernate.hbm2ddl.auto">update</prop>
				<prop key="hibernate.current_session_context_class">
					thread
				</prop>
				<prop key="hibernate.show_sql">false</prop>
			</props>
		</property>

		<property name="mappingResources">
			<list>
				<value>
					com/mul/entity/DataEntity.hbm.xml
				</value>
			</list>
		</property>

		<property name="exposeTransactionAwareSessionFactory">
			<value>false</value>
		</property>

	</bean>
	
	
	<bean id="transactionManager"
		class="org.springframework.orm.hibernate3.HibernateTransactionManager">
		<property name="sessionFactory" ref="sessionFactory" />
<!--		<property name="hibernateManagedSession" value="false"/>-->
	</bean>
	<tx:annotation-driven transaction-manager="transactionManager" />
	<context:component-scan base-package="com.mul" />

		<aop:config>
	
			<aop:pointcut id="testservice"
				expression="execution(* com.mul.service.*Service.*(..))" />
			
				
			<aop:advisor id="testServiceAd" advice-ref="txAdvice" pointcut-ref="testservice" />		
		</aop:config>
		<tx:advice id="txAdvice" transaction-manager="transactionManager">
			<tx:attributes>
				<tx:method name="*" propagation="REQUIRED" rollback-for="java.lang.Exception"/>
<!--				<tx:method name="*" propagation="REQUIRED"/>-->
			</tx:attributes>
		</tx:advice>
<!-- dao -->
	<bean id="dataEntityDao" class="com.mul.dao.DataEntityDao">

	</bean>
	<!-- service -->
	<bean id="dataEntityService" class="com.mul.service.DataEntityService">

	</bean>
	
</beans>