So konfigurieren Sie zwei Datenquellen in MVC in Spring, um ein Java-Projekt zu realisieren, das gleichzeitig eine Verbindung zu zwei Datenbanken herstellt

Dieser Artikel führt Sie hauptsächlich in die relevanten Informationen darüber ein, wie Spring MVC zwei Datenquellen konfiguriert, um ein Java-Projekt zu implementieren, um zwei Datenbanken gleichzeitig zu verbinden. Der Artikel stellt es detailliert anhand von Beispielcode vor. Das ist eine große Hilfe für alle. Freunde, die es brauchen, können einen Blick darauf werfen.

Vorwort

In diesem Artikel wird hauptsächlich die Methode zur Konfiguration zweier Datenquellen mit Spring MVC vorgestellt, um ein Java-Projekt zu realisieren, das zwei Datenbanken gleichzeitig verbindet Schauen Sie sich die ausführliche Einführung an:

Die Datenquelle befindet sich in Konfiguration in der Konfigurationsdatei

DynamicDataSource.class

<pre name="code" class="java"><?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:aop="http://www.springframework.org/schema/aop" 
 xmlns:cache="http://www.springframework.org/schema/cache" 
 xmlns:context="http://www.springframework.org/schema/context" 
 xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:jee="http://www.springframework.org/schema/jee" 
 xmlns:jms="http://www.springframework.org/schema/jms" xmlns:lang="http://www.springframework.org/schema/lang" 
 xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:oxm="http://www.springframework.org/schema/oxm" 
 xmlns:p="http://www.springframework.org/schema/p" xmlns:task="http://www.springframework.org/schema/task" 
 xmlns:tx="http://www.springframework.org/schema/tx" xmlns:util="http://www.springframework.org/schema/util" 
 xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd 
 http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd 
 http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache-3.1.xsd 
 http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd 
 http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-3.1.xsd 
 http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.1.xsd 
 http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.1.xsd 
 http://www.springframework.org/schema/lang http://www.springframework.org/schema/lang/spring-lang-3.1.xsd 
 http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.1.xsd 
 http://www.springframework.org/schema/oxm http://www.springframework.org/schema/oxm/spring-oxm-3.1.xsd 
 http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.1.xsd 
 http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.1.xsd 
 http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.1.xsd"> 
 
 <context:annotation-config /> 
 
 <context:component-scan base-package="com"></context:component-scan> 
 
 <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> 
  <property name="locations"> 
   <list> 
    <value>classpath:com/resource/config.properties</value> 
   </list> 
  </property> 
 </bean> 
 
 <bean id="dataSourceOne" class="com.mchange.v2.c3p0.ComboPooledDataSource" 
  destroy-method="close"> 
  <property name="driverClass" value="${dbOne.jdbc.driverClass}" /> 
  <property name="jdbcUrl" value="${dbOne.jdbc.url}" /> 
  <property name="user" value="${dbOne.jdbc.user}" /> 
  <property name="password" value="${dbOne.jdbc.password}" /> 
  <property name="initialPoolSize" value="${dbOne.jdbc.initialPoolSize}" /> 
  <property name="minPoolSize" value="${dbOne.jdbc.minPoolSize}" /> 
  <property name="maxPoolSize" value="${dbOne.jdbc.maxPoolSize}" /> 
 </bean> 
 
 <bean id="dataSourceTwo" class="com.mchange.v2.c3p0.ComboPooledDataSource" 
  destroy-method="close"> 
  <property name="driverClass" value="${dbTwo.jdbc.driverClass}" /> 
  <property name="jdbcUrl" value="${dbTwo.jdbc.url}" /> 
  <property name="user" value="${dbTwo.jdbc.user}" /> 
  <property name="password" value="${dbTwo.jdbc.password}" /> 
  <property name="initialPoolSize" value="${dbTwo.jdbc.initialPoolSize}" /> 
  <property name="minPoolSize" value="${dbTwo.jdbc.minPoolSize}" /> 
  <property name="maxPoolSize" value="${dbTwo.jdbc.maxPoolSize}" /> 
 </bean> 
 
 <bean id="dynamicDataSource" class="com.core.DynamicDataSource"> 
  <property name="targetDataSources"> 
   <map key-type="java.lang.String"> 
    <entry value-ref="dataSourceOne" key="dataSourceOne"></entry> 
    <entry value-ref="dataSourceTwo" key="dataSourceTwo"></entry> 
   </map> 
  </property> 
  <property name="defaultTargetDataSource" ref="dataSourceOne"> 
  </property> 
 </bean> 
 
 <bean id="sessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean"> 
  <property name="dataSource" ref="dynamicDataSource" /> 
  <property name="hibernateProperties"> 
   <props> 
    <prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop> 
    <prop key="hibernate.current_session_context_class">org.springframework.orm.hibernate4.SpringSessionContext</prop> 
    <prop key="hibernate.show_sql">false</prop> 
    <prop key="hibernate.format_sql">true</prop> 
    <prop key="hbm2ddl.auto">create</prop> 
   </props> 
  </property> 
  <property name="packagesToScan"> 
   <list> 
    <value>com.po</value> 
   </list> 
  </property> 
 </bean> 
 
 <bean id="transactionManager" class="org.springframework.orm.hibernate4.HibernateTransactionManager"> 
  <property name="sessionFactory" ref="sessionFactory" /> 
 </bean> 
 
 <aop:config> 
  <aop:pointcut id="transactionPointCut" expression="execution(* com.dao..*.*(..))" /> 
  <aop:advisor advice-ref="txAdvice" pointcut-ref="transactionPointCut" /> 
 </aop:config> 
 
 <tx:advice id="txAdvice" transaction-manager="transactionManager"> 
  <tx:attributes> 
   <tx:method name="add*" propagation="REQUIRED" /> 
   <tx:method name="save*" propagation="REQUIRED" /> 
   <tx:method name="update*" propagation="REQUIRED" /> 
   <tx:method name="delete*" propagation="REQUIRED" /> 
   <tx:method name="*" read-only="true" /> 
  </tx:attributes> 
 </tx:advice> 
 
 <aop:config> 
  <aop:aspect id="dataSourceAspect" ref="dataSourceInterceptor"> 
   <aop:pointcut id="daoOne" expression="execution(* com.dao.one.*.*(..))" /> 
   <aop:pointcut id="daoTwo" expression="execution(* com.dao.two.*.*(..))" /> 
   <aop:before pointcut-ref="daoOne" method="setdataSourceOne" /> 
   <aop:before pointcut-ref="daoTwo" method="setdataSourceTwo" /> 
  </aop:aspect> 
 </aop:config> 
</beans>

DatabaseContextHolder .class legt die Klasse der Datenquelle fest

package com.core; 
 
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource; 
 
public class DynamicDataSource extends AbstractRoutingDataSource{ 
 
 @Override 
 protected Object determineCurrentLookupKey() { 
  return DatabaseContextHolder.getCustomerType(); 
 } 
 
}

DataSourceInterceptor.class

package com.core; 
 
public class DatabaseContextHolder { 
 
 private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>(); 
<span style="white-space:pre"> </span>//设置要使用的数据源 
 public static void setCustomerType(String customerType) { 
  contextHolder.set(customerType); 
 } 
<span style="white-space:pre"> </span>//获取数据源 
 public static String getCustomerType() { 
  return contextHolder.get(); 
 } 
<span style="white-space:pre"> </span>//清除数据源，使用默认的数据源 
 public static void clearCustomerType() { 
  contextHolder.remove(); 
 } 
}

springMVC-Datenquelle

package com.core; 
 
import org.aspectj.lang.JoinPoint; 
import org.springframework.stereotype.Component; 
 
@Component 
public class DataSourceInterceptor { 
<span style="white-space:pre"> </span>//数据源1 
 public static final String SOURCE_PLAN = "<span style="font-family: Arial, Helvetica, sans-serif;">dataSourceOne</span><span style="font-family: Arial, Helvetica, sans-serif;">";</span> 
 //数据源2 
<pre name="code" class="java"><span style="white-space:pre"> </span>public static final String SOURCE_FUND = "<span style="font-family: Arial, Helvetica, sans-serif;">dataSourceTwo</span>"; 
}

jdbc_username=**jdbc_password=**

jdbc_driverClassName=com.microsoft.sqlserver.jdbc.SQLServerDriver 
<pre name="code" class="java">dataSourceOne<span style="font-family: Arial, Helvetica, sans-serif;">=jdbc:sqlserver://115.29.***.**;DatabaseName=DB_GuiHua</span>

Spring MVC verfügt standardmäßig über eine Datenquelle Wenn Sie die Datenquelle ändern müssen, müssen Sie dies tun, bevor Sie die Transaktion aufrufen

dataSourceTwo<span style="font-family: Arial, Helvetica, sans-serif;">=jdbc:sqlserver://115.29.***.*;DatabaseName=DB_Fund</span>

DataSourceContextHolder.setDbType(DataSourceType.SOURCE_FUND);//更换数据源

Zusammenfassung

/** 
 * @ClassName: DataSourceContextHolder 
 * @Description: 数据库切换工具类 
 * @author: wzx 
 * @date: 2016-07-27 上午10:26:01 
 */ 
public class DataSourceContextHolder { 
 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(); 
 } 
}

Das obige ist der detaillierte Inhalt vonSo konfigurieren Sie zwei Datenquellen in MVC in Spring, um ein Java-Projekt zu realisieren, das gleichzeitig eine Verbindung zu zwei Datenbanken herstellt. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!