逻辑调整
This commit is contained in:
@@ -39,15 +39,14 @@ public class OrderServiceStaticProxy {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private void beforeMethod(Order order) {
|
private void beforeMethod(Order order) {
|
||||||
|
log.info("静态代理before code");
|
||||||
// 通过用户ID对2取模分库
|
// 通过用户ID对2取模分库
|
||||||
Integer userId = order.getUserId();
|
Integer userId = order.getUserId();
|
||||||
int dbRouter = userId % 2;
|
int dbRouter = userId % 2;
|
||||||
log.info("静态代理分配到【db{}】处理数据", dbRouter);
|
log.info("静态代理分配到【db{}】处理数据", dbRouter);
|
||||||
|
|
||||||
// 设置DataSource
|
// 设置DataSource
|
||||||
DataSourceContextHolder.setDBType(DB + String.valueOf(dbRouter));
|
DataSourceContextHolder.setDBType(DB + dbRouter);
|
||||||
|
|
||||||
log.info("静态代理before code");
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private void afterMethod() {
|
private void afterMethod() {
|
||||||
|
|||||||
Reference in New Issue
Block a user