一套Spring+Hibernate的多个数据库切换的源码

package lhp.example.junit; import static org.junit.Assert.assertEquals; import java.sql.DatabaseMetaData; import lhp.example.context.ContextHolder; import lhp.example.context.DBType; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.junit.Before; import org.junit.Test; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; public class ServiceTest { private ApplicationContext context; //三个数据源的URL private String dataSource1_URL = "jdbc:mysql://127.0.0.1:3306/dec"; private String dataSource2_URL = "jdbc:mysql://127.0.0.1:3306/lms"; private String dataSource3_URL = "jdbc:odbc:accessTest"; private SessionFactory mysqlSessionFactory; private SessionFactory aceessSessionFactory; @Before public void setUp() throws Exception { // 选择数据源初始化spring ContextHolder.setDbType(DBType.dataSource1); // String[] xmlFiles = new String[] { "applicationContext-dataSource.xml", "applicationContext-hibernate.xml", "applicationContext-spring.xml" }; // context = new ClassPathXmlApplicationContext(xmlFiles); // mysqlSessionFactory = (SessionFactory) context.getBean("mysqlSessionFactory"); aceessSessionFactory = (SessionFactory) context.getBean("aceessSessionFactory"); } @SuppressWarnings("deprecation") @Test public void mysqlDataSourceTest() { try { Session mysqlSession = mysqlSessionFactory.openSession(); // 获得数据库元数据 DatabaseMetaData meatData = mysqlSession.connection().getMetaData(); // 默认启动数据源 dataSource1 //断言当前数据源URL是否是dataSource1的URL assertEquals(dataSource1_URL, meatData.getURL()); // 切换到数据源 dataSource2 ContextHolder.setDbType(DBType.dataSource2); mysqlSession = mysqlSessionFactory.openSession(); meatData = mysqlSession.connection().getMetaData(); //断言当前数据源URL是否是dataSource2的URL assertEquals(dataSource2_URL, meatData.getURL()); } catch (Exception e) { e.printStackTrace(); } } @SuppressWarnings("deprecation") @Test public void accessDataSourceTest() { try { Session accessSession = aceessSessionFactory.openSession(); // 获得数据库元数据 DatabaseMetaData meatData = accessSession.connection().getMetaData(); //断言当前数据源URL是否是dataSource3的URL assertEquals(dataSource3_URL, meatData.getURL()); } catch (Exception e) { e.printStackTrace(); } } }