/**
 * Created by xuliugen on 2016/5/4.
 */
@Controller
@RequestMapping(value = "/user", produces = {"application/json;charset=UTF-8"})
public class UserController {

 @Inject
 private IUserService userService;

 //http://localhost:8080/user/select.do
 @ResponseBody
 @RequestMapping(value = "/select.do", method = RequestMethod.GET)
 public String select() {
  User user = userService.selectUserById(123);
  return user.toString();
 }

 //http://localhost:8080/user/add.do
 @ResponseBody
 @RequestMapping(value = "/add.do", method = RequestMethod.GET)
 public String add() {
  boolean isOk = userService.addUser(new User("333", "444"));
  return isOk == true ? "shibai" : "chenggong";
 }
}

<?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"
  xsi:schemaLocation="http://www.springframework.org/schema/beans
      http://www.springframework.org/schema/beans/spring-beans-4.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">

 <bean id="statFilter" class="com.alibaba.druid.filter.stat.StatFilter" lazy-init="true">
  <property name="logSlowSql" value="true"/>
  <property name="mergeSql" value="true"/>
 </bean>

 <!-- 數(shù)據(jù)庫連接 -->
 <bean id="readDataSource" class="com.alibaba.druid.pool.DruidDataSource"
   destroy-method="close" init-method="init" lazy-init="true">
  <property name="driverClassName" value="${driver}"/>
  <property name="url" value="${url1}"/>
  <property name="username" value="root"/>
  <property name="password" value="${password}"/>
   <!-- 省略部分內(nèi)容 -->
 </bean>

 <bean id="writeDataSource" class="com.alibaba.druid.pool.DruidDataSource"
   destroy-method="close" init-method="init" lazy-init="true">
  <property name="driverClassName" value="${driver}"/>
  <property name="url" value="${url}"/>
  <property name="username" value="root"/>
  <property name="password" value="${password}"/>
  <!-- 省略部分內(nèi)容 -->
 </bean>

 <!-- 配置動態(tài)分配的讀寫 數(shù)據(jù)源 -->
 <bean id="dataSource" class="com.xuliugen.choosedb.demo.aspect.ChooseDataSource" lazy-init="true">
  <property name="targetDataSources">
   <map key-type="java.lang.String" value-type="javax.sql.DataSource">
    <!-- write -->
    <entry key="write" value-ref="writeDataSource"/>
    <!-- read -->
    <entry key="read" value-ref="readDataSource"/>
   </map>
  </property>
  <property name="defaultTargetDataSource" ref="writeDataSource"/>
  <property name="methodType">
   <map key-type="java.lang.String">
    <!-- read -->
    <entry key="read" value=",get,select,count,list,query"/>
    <!-- write -->
    <entry key="write" value=",add,create,update,delete,remove,"/>
   </map>
  </property>
 </bean>

</beans>

<property name="methodType">
 <map key-type="java.lang.String">
  <!-- read -->
  <entry key="read" value=",get,select,count,list,query"/>
  <!-- write -->
  <entry key="write" value=",add,create,update,delete,remove,"/>
  </map>
</property>

/**
 * 獲取數(shù)據(jù)源，用于動態(tài)切換數(shù)據(jù)源
 */
public class ChooseDataSource extends AbstractRoutingDataSource {

 public static Map<String, List<String>> METHOD_TYPE_MAP = new HashMap<String, List<String>>();

 /**
  * 實現(xiàn)父類中的抽象方法，獲取數(shù)據(jù)源名稱
  * @return
  */
 protected Object determineCurrentLookupKey() {
  return DataSourceHandler.getDataSource();
 }

 // 設(shè)置方法名前綴對應(yīng)的數(shù)據(jù)源
 public void setMethodType(Map<String, String> map) {
  for (String key : map.keySet()) {
   List<String> v = new ArrayList<String>();
   String[] types = map.get(key).split(",");
   for (String type : types) {
    if (StringUtils.isNotBlank(type)) {
     v.add(type);
    }
   }
   METHOD_TYPE_MAP.put(key, v);
  }
 }
}

/**
 * 切換數(shù)據(jù)源(不同方法調(diào)用不同數(shù)據(jù)源)
 */
@Aspect
@Component
@EnableAspectJAutoProxy(proxyTargetClass = true)
public class DataSourceAspect {

 protected Logger logger = LoggerFactory.getLogger(this.getClass());

 @Pointcut("execution(* com.xuliugen.choosedb.demo.mybatis.dao.*.*(..))")
 public void aspect() {
 }

 /**
  * 配置前置通知,使用在方法aspect()上注冊的切入點
  */
 @Before("aspect()")
 public void before(JoinPoint point) {
  String className = point.getTarget().getClass().getName();
  String method = point.getSignature().getName();
  logger.info(className + "." + method + "(" + StringUtils.join(point.getArgs(), ",") + ")");
  try {
   for (String key : ChooseDataSource.METHOD_TYPE_MAP.keySet()) {
    for (String type : ChooseDataSource.METHOD_TYPE_MAP.get(key)) {
     if (method.startsWith(type)) {
      DataSourceHandler.putDataSource(key);
     }
    }
   }
  } catch (Exception e) {
   e.printStackTrace();
  }
 }
}

package com.xuliugen.choosedb.demo.aspect;

/**
 * 數(shù)據(jù)源的Handler類
 */
public class DataSourceHandler {

 // 數(shù)據(jù)源名稱線程池
 public static final ThreadLocal<String> holder = new ThreadLocal<String>();

 /**
  * 在項目啟動的時候?qū)⑴渲玫淖x、寫數(shù)據(jù)源加到holder中
  */
 public static void putDataSource(String datasource) {
  holder.set(datasource);
 }

 /**
  * 從holer中獲取數(shù)據(jù)源字符串
  */
 public static String getDataSource() {
  return holder.get();
 }
}