Spring与Mybatis相结合实现多数据源切换功能
发布时间:2020-12-14 20:00:06 所属栏目:Java 来源:网络整理
导读:废话不多说,关键代码如下所示: 1. 代码: DbContextHolder public class DbContextHolder {//线程安全的ThreadLocalprivate static final ThreadLocalString contextHolder = new ThreadLocalString();public static void setDbType(String dbType) {contex
废话不多说,关键代码如下所示: 1. 代码: DbContextHolder public class DbContextHolder { //线程安全的ThreadLocal private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>(); public static void setDbType(String dbType) { contextHolder.set(dbType); } public static String getDbType() { return ((String)contextHolder.get()); } public static void clearDbType() { contextHolder.remove(); } } 2. 代码 : DynamicDataSource import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource; public class DynamicDataSource extends AbstractRoutingDataSource { @Override public Object determineCurrentLookupKey() { return DbContextHolder.getDbType(); } } 3.代码: spring.xml <!-- 数据源属性配置文件 --> <context:property-placeholder location="classpath:ibatis.properties" /> <bean id="jksh" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <!-- Connection Info --> <property name="driverClassName" value="${driver.jksh}" /> <property name="url" value="${url.jksh}" /> <property name="username" value="${username.jksh}" /> <property name="password" value="${password.jksh}" /> <!-- Connection Pooling Info --> <property name="maxIdle" value="${maxIdle.jksh}" /> <property name="maxActive" value="${maxActive.jksh}" /> <property name="defaultAutoCommit" value="false" /> <property name="timeBetweenEvictionRunsMillis" value="${timeBetweenEvictionRunsMillis.jksh}" /> <property name="minEvictableIdleTimeMillis" value="${minEvictableIdleTimeMillis.jksh}" /> </bean> <bean id="jclt" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <!-- Connection Info --> <property name="driverClassName" value="${driver.jclt}" /> <property name="url" value="${url.jclt}" /> <property name="username" value="${username.jclt}" /> <property name="password" value="${password.jclt}" /> <!-- Connection Pooling Info --> <property name="maxIdle" value="${maxIdle.jclt}" /> <property name="maxActive" value="${maxActive.jclt}" /> <property name="defaultAutoCommit" value="false" /> <property name="timeBetweenEvictionRunsMillis" value="${timeBetweenEvictionRunsMillis.jclt}" /> <property name="minEvictableIdleTimeMillis" value="${minEvictableIdleTimeMillis.jclt}" /> </bean> <bean id="dataSource" class="com.jclt.service.commons.DynamicDataSource"> <property name="targetDataSources"> <map key-type="java.lang.String"> <entry key="jksh" value-ref="jksh" /> <entry key="jclt" value-ref="jclt" /> </map> </property> <property name="defaultTargetDataSource" ref="jksh" /> </bean> 4. 代码:main方法 import javax.sql.DataSource; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; import org.springframework.core.io.FileSystemResource; import org.springframework.core.io.Resource; import com.jclt.service.commons.DbContextHolder; import com.jclt.service.model.User; import org.apache.ibatis.session.SqlSession; import org.apache.ibatis.session.SqlSessionFactory; import org.mybatis.spring.SqlSessionFactoryBean; public class Text { /** * @param args */ public static void main(String[] args) { ApplicationContext appContext = new ClassPathXmlApplicationContext("client-beans.xml"); DbContextHolder.setDbType("jclt"); String res="src/main/resources/ibatis-config.xml"; DataSource datasource=(DataSource) appContext.getBean("dataSource"); SqlSessionFactoryBean bean=new SqlSessionFactoryBean(); bean.setDataSource(datasource); Resource resource=new FileSystemResource(res); bean.setConfigLocation(resource); try { SqlSessionFactory sessionfactory = bean.getObject(); SqlSession session=sessionfactory.openSession(); User user=session.selectOne("com.jclt.service.Dao.readJKSH.findOne"); System.out.println(user.getName()); } catch (Exception e) { e.printStackTrace(); } DbContextHolder.setDbType("jksh"); String res1="src/main/resources/ibatis-config.xml"; DataSource datasource1=(DataSource) appContext.getBean("dataSource"); SqlSessionFactoryBean bean1=new SqlSessionFactoryBean(); bean1.setDataSource(datasource1); Resource resource1=new FileSystemResource(res1); bean1.setConfigLocation(resource1); try { SqlSessionFactory sessionfactory = bean.getObject(); SqlSession session=sessionfactory.openSession(); User user=session.selectOne("com.jclt.service.Dao.readJKSH.findOne"); System.out.println(user.getName()); } catch (Exception e) { e.printStackTrace(); } } } 以上所述是小编给大家介绍的Spring与Mybatis相结合实现多数据源切换功能,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对编程小技巧网站的支持! 您可能感兴趣的文章:
(编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |
推荐文章
站长推荐
- java – 如何在更改某些JButton上的背景颜色而不
- java – HSQLDB – 更改表模式
- java – 尝试使用Google Blogger API OAuth2创建
- 如何在Java代码中使用scala.collection.immutabl
- Mybatis传递多个参数的解决办法(三种)
- java – 使用Hibernate 4和Postgres的“SELECT F
- java – 在Spring中,@ RequestParameter注释不接
- java – 使用带子元素的ClickHandler
- java – 如何将EclipseLink对象导出到XML
- java – Null对象设计模式Vs null对象检查
热点阅读