【Java EE 学习第77天】【数据采集系统第九天】【使用spring实现答案水平分库】【未解决问题：分库查询问题】

 1 <!-- 配置数据源（主库） -->
 2 <bean id="dateSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
 3     <property name="driverClass" value="${jdbc.driverclass}"></property>
 4     <property name="jdbcUrl" value="${jdbc.url}"></property>
 5     <property name="user" value="${jdbc.username}"></property>
 6     <property name="password" value="${jdbc.password}"></property>
 7 
 8     <!-- 配置c3p0自身的参数 -->
 9     <property name="maxPoolSize" value="${c3p0.pool.maxsize}"></property>
10     <property name="minPoolSize" value="${c3p0.pool.minsize}"></property>
11     <property name="initialPoolSize" value="${c3p0.pool.initsieze}"></property>
12     <property name="acquireIncrement" value="${c3p0.pool.increment}"></property>
13 </bean>
14 <!-- （从库） 为了实现分库的功能，必须针对每个数据库配置一个数据源 这里使用了包的继承的特殊属性使用parent属性对dataSource进行了继承 -->
15 <bean id="dataSource1" class="com.mchange.v2.c3p0.ComboPooledDataSource"
16     parent="dateSource">
17     <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/lsn_surveypark1"></property>
18 </bean>

 1 <!-- 配置数据源路由器 -->
 2 <bean id="dataSource_router" class="com.kdyzm.datasource.SurveyparkDatasourceRouter">
 3     <property name="targetDataSources">
 4         <map>
 5             <!-- 如果id是偶数，保存到主库中 -->
 6             <entry key="even" value-ref="dateSource"></entry>
 7             <!-- 如果id是奇数，保存到从库中 -->
 8             <entry key="odd" value-ref="dataSource1"></entry>
 9         </map>
10     </property>
11     <!-- 如果不满足上述规则，则直接使用默认的数据源 -->
12     <property name="defaultTargetDataSource" ref="dateSource"></property>
13 </bean>

 1 package com.kdyzm.datasource;
 2 
 3 import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
 4 
 5 import com.kdyzm.domain.Survey;
 6 
 7 /**
 8  * 自定义数据源路由器
 9  *     有一个默认的实现类，该类是以传播属性来路由数据的。
10  * @author kdyzm
11  *
12  */
13 public class SurveyparkDatasourceRouter extends AbstractRoutingDataSource{
14 
15     /**
16      * 该方法实际上确定了一个数据向哪里存放的策略
17      * 在这里使用id的就属性来确定
18      * 如果答案id是偶数，就想lsn_surveypark数据库中的answer表（主表）中存放
19      * 如果答案的id是奇数，就向lsn_surveypark1数据库中的answer表（从表）中存放
20      */
21     @Override
22     protected Object determineCurrentLookupKey() {
23         SurveyToken surveyToken=SurveyToken.getSurveyToken();
24         if(surveyToken!=null){
25             Survey survey=surveyToken.getSurvey();
26             int surveyId=survey.getSurveyId();
27             System.out.println("Survey对象不为空，值为："+surveyId);
28             /**
29              * 在这里必须解除绑定
30              * 如果不在这里解除绑定的话就会将log日志写入到lsn_surveypark1数据库中。
31              * 由于lsn_surveypark1数据库中没有log表，所以一定会报错
32              */
33             SurveyToken.unbind();
34             return (surveyId%2)==0?"even":"odd";    //如果是偶数返回even字符串，如果是奇数返回odd字符串
35         }
36         System.out.println("survey对象为空");
37         return null;
38     }
39     
40 }