为了减轻数据库的压力，同时也为了提高数据库的效率。我们在开发时都需要配置多个数据库，将 查询等读操作 和 增删改等写操作 分开来。这时候我们就需要对数据库的切换进行一些配置。

     AOP切面很好的实现了动态切换数据源。AbstractRoutingDataSource类是实现的关键，我们需要自己定义一个类继承路由类去实现determineCurrentLookupKey()方法。

1. DynamicDataSource 类

import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;public class DynamicDataSource extends AbstractRoutingDataSource{	    @Override    protected Object determineCurrentLookupKey() {    	return  DataBaseContextHolder.getDataSouce();    }    }

 2. 多线程辅助类

package com.common.readwriteseparate;public class  DataBaseContextHolder {        public static final ThreadLocal
     
       contextHolder = new ThreadLocal
      
       ();    public static void setDbType(String name) {        contextHolder.set(name);    }    public static String getDataSouce() {        return contextHolder.get();    }　  public static void clearDBType() {　     contextHolder.remove();    }}
      
     

 

 3.DataSource 类

import java.lang.annotation.ElementType;  import java.lang.annotation.Retention;  import java.lang.annotation.RetentionPolicy;  import java.lang.annotation.Target;    @Retention(RetentionPolicy.RUNTIME)  @Target(ElementType.METHOD)  public @interface DataSource {      String value();  }

 4. AOP 切面类

public class DataSourceAspect {    //log     private static final Logger logger = Logger.getLogger(DataSourceAspect.class);    public void pointcut(){    }    public void before(JoinPoint point) {        Object target = point.getTarget();        String method = point.getSignature().getName();	logger.debug("当前执行方法" + method);        Class
     [] classz = target.getClass().getInterfaces();	//拦截的方法参数类型        Class
     [] parameterTypes = ((MethodSignature) point.getSignature()).getMethod().getParameterTypes();        try {            //通过反射获得拦截的方法            Method m = classz[0].getMethod(method, parameterTypes);            if (m != null && m.isAnnotationPresent(DataSource.class)) {                DataSource data = m.getAnnotation(DataSource.class);                DynamicDataSourceHolder.setDbType(data.value());                            }        }         catch (Exception e) {            logger.error("数据源失败切面获取异常:", e);        }    }}

 接下来及时数据源的配置了。

5.我们在spring 的配置文件中对数据库进行配置：

5.1 spring-mybatis.xml（spring + mybatis 配置）

 

     
     	
      
       MyBatis的数据库持久层配置/配置主-从数据源
      	
      		
       		
       		
       		
       	
      	
      	
      		
       		
       	
             
              
                
                 
                 
                 
                 
                 
                 
                 
                 
                 
                   
                 
                 
                 
                 
                 
                 
                 
                 
                 
                 
                 
                      
      	 
            
                         
                 
                 
                   
            
            
                
                 
                 
             
        	
      	
              
                       
                  
                 
             
      
      	
      	
      	
      		
       			
        			
        		
       	
         
            
            
            
                
             
            
                
                 
             
            
            
                
                     
                      
                      
                      
                      
                      
                      
                      
                      
                                    
                      
                      
                  
             
        
     

 5.2 database.properties

validationQuery=SELECT 1jdbc.initialSize=5jdbc.maxActive=20jdbc.maxWait=60000jdbc.poolPreparedStatements=falsejdbc.poolMaximumIdleConnections=0jdbc.driverClassName=org.gjt.mm.mysql.Drivermaster.jdbc.url=jdbc:mysql://your ip:3306/masterslave.jdbc.url=jdbc:mysql://your ip:3306/slavejdbc.username=usernamejdbc.password=password

 6. 最后，我们需要在业务接口层进行注解来实现对数据库的切换

public interface UserService{              @DataSource("master")      int updateByPrimaryKey(int id);        @DataSource("slave")      User selectByPrimaryKey(int id);  }