## 多庫多租戶 ? 如果每個庫一個租戶，則需要動態路由到指定的數據源，可以借助ConditionalConnectionSource類，類似ConditionalSQLManager，可以代理ConnectionSource，根據適當條件使用返回不同數據源的數據庫連接 > 參考S6MoreDatabase.multipleDataBaseAndTables ```java public class ConditionalConnectionSource implements ConnectionSource { Policy policy; Map<String,ConnectionSource> all; ConnectionSource defaultCs; /** * * @param policy 選擇數據源的策略 * @param all 所有備選的數據源表 */ public ConditionalConnectionSource( Policy policy,Map<String,ConnectionSource> all){ this.all = all; String defaultName = policy.getMasterName(); defaultCs = all.get(defaultName); if(defaultCs==null){ throw new IllegalArgumentException("根據 "+defaultName+" 找不到對應的ConnectionSource"); } this.policy = policy; } //忽略其他代碼 } ``` 構造ConditionalConnectionSource 需要一個策略類以及多個ConnectionSource構成的Map。策略類決定了使用哪個ConnectionSource。定義如下 ```java @Override public Connection getConn(ExecuteContext ctx, boolean isUpdate) { String name = policy.getConnectionSourceName(ctx,isUpdate); ConnectionSource cs = all.get(name); if(cs==null){ throw new IllegalArgumentException("根據 "+name+" 找不到對應的ConnectionSource"); } return cs.getConn(ctx,isUpdate); } ``` 策略類可以根據ThreadLocal，或者ExecuteContext提供的參數來決定返回哪一個ConnectionSouce，這個跟ThreadLocalSQLManager，ConditionalSQLManager原來類似。Policy定義如下 ```java public static interface Policy{ String getConnectionSourceName(ExecuteContext ctx, boolean isUpdate); String getMasterName(); } ``` 如下根據VipLocal的值來決定使用哪個數據源操作。 項目可以在Controller的Filter或者Service的AOP里設定這個值 ```java ConditionalConnectionSource.Policy policy = new ConditionalConnectionSource.Policy() { @Override public String getConnectionSourceName(ExecuteContext ctx, boolean isUpdate) { String name = VipLocal.get() if(name!=null){ return name; }else{ // 如果沒有設置，則返回一個默認庫 return "cs1"; } } @Override public String getMasterName() { return "cs1"; } }; ```