From a0ad14b0a0fb60604b0a9cf978a537e64479a8d4 Mon Sep 17 00:00:00 2001
From: chenjiahe <763432473@qq.com>
Date: 星期一, 27 六月 2022 19:05:01 +0800
Subject: [PATCH] 新增Redis可以切换数据库
---
src/main/java/com/hx/mybatis/aes/springbean/MySqlInterceptor.java | 23 ++++++++---------------
1 files changed, 8 insertions(+), 15 deletions(-)
diff --git a/src/main/java/com/hx/mybatis/aes/springbean/MySqlInterceptor.java b/src/main/java/com/hx/mybatis/aes/springbean/MySqlInterceptor.java
index cb06b46..cff0067 100644
--- a/src/main/java/com/hx/mybatis/aes/springbean/MySqlInterceptor.java
+++ b/src/main/java/com/hx/mybatis/aes/springbean/MySqlInterceptor.java
@@ -62,30 +62,23 @@
//杩欓噷鍙互杩涜sql淇敼
//鑾峰彇鍒板師濮媠ql璇彞
String sql = boundSql.getSql();
- String sql2 = null;
//鏂板
if(sqlCommandType == SqlCommandType.INSERT){
- sql2 = SqlUtils.insertSql(sql, VariableAesKey.aesKeysTable);
+ sql = SqlUtils.insertSql(sql, VariableAesKey.aesKeysTable);
}else if(sqlCommandType == SqlCommandType.UPDATE){
- sql2 = SqlUtils.updateSql(sql, VariableAesKey.aesKeysTable);
+ sql = SqlUtils.updateSql(sql, VariableAesKey.aesKeysTable);
}else if(sqlCommandType == SqlCommandType.SELECT){
if(VariableAesKey.isRun == 1){
- sql2 = SqlUtils.selectSql(sql, VariableAesKey.aesKeysTable);
- }else{
- sql2 = sql;
+ sql = SqlUtils.selectSql(sql, VariableAesKey.aesKeysTable);
}
}else if(sqlCommandType == SqlCommandType.DELETE){
- sql2 = SqlUtils.deleteSql(sql, VariableAesKey.aesKeysTable);
- }else{
- sql2 = sql;
+ sql = SqlUtils.deleteSql(sql, VariableAesKey.aesKeysTable);
}
- if(!"err".equals(sql2)){
- //閫氳繃鍙嶅皠淇敼sql璇彞
- Field field = boundSql.getClass().getDeclaredField("sql");
- field.setAccessible(true);
- field.set(boundSql, sql2);
- }
+ //閫氳繃鍙嶅皠淇敼sql璇彞
+ Field field = boundSql.getClass().getDeclaredField("sql");
+ field.setAccessible(true);
+ field.set(boundSql, sql);
return invocation.proceed();
--
Gitblit v1.8.0