From 8ab2ad5580212b91df848e4c127f2a682485fde3 Mon Sep 17 00:00:00 2001
From: zhouxiang <zhouxiang>
Date: 星期一, 25 四月 2022 01:49:15 +0800
Subject: [PATCH] 修改common
---
src/main/java/com/hx/mybatis/aes/springbean/SqlUtils.java | 2 +-
src/main/java/com/hx/mybatis/aes/springbean/MySqlInterceptor.java | 24 +++++++++++++++---------
2 files changed, 16 insertions(+), 10 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 2d94032..cb06b46 100644
--- a/src/main/java/com/hx/mybatis/aes/springbean/MySqlInterceptor.java
+++ b/src/main/java/com/hx/mybatis/aes/springbean/MySqlInterceptor.java
@@ -10,6 +10,8 @@
import org.apache.ibatis.reflection.MetaObject;
import org.apache.ibatis.reflection.SystemMetaObject;
import org.apache.ibatis.session.Configuration;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
import java.lang.reflect.Field;
@@ -25,6 +27,8 @@
})
})
public class MySqlInterceptor implements Interceptor {
+
+ private static Logger logger = LoggerFactory.getLogger(MySqlInterceptor.class.getName());
@Override
public Object intercept(Invocation invocation) throws Throwable {
@@ -58,27 +62,29 @@
//杩欓噷鍙互杩涜sql淇敼
//鑾峰彇鍒板師濮媠ql璇彞
String sql = boundSql.getSql();
-
+ String sql2 = null;
//鏂板
if(sqlCommandType == SqlCommandType.INSERT){
- sql = SqlUtils.insertSql(sql, VariableAesKey.aesKeysTable);
+ sql2 = SqlUtils.insertSql(sql, VariableAesKey.aesKeysTable);
}else if(sqlCommandType == SqlCommandType.UPDATE){
- sql = SqlUtils.updateSql(sql, VariableAesKey.aesKeysTable);
+ sql2 = SqlUtils.updateSql(sql, VariableAesKey.aesKeysTable);
}else if(sqlCommandType == SqlCommandType.SELECT){
if(VariableAesKey.isRun == 1){
- sql = SqlUtils.selectSql(sql, VariableAesKey.aesKeysTable);
+ sql2 = SqlUtils.selectSql(sql, VariableAesKey.aesKeysTable);
+ }else{
+ sql2 = sql;
}
}else if(sqlCommandType == SqlCommandType.DELETE){
- sql = SqlUtils.deleteSql(sql, VariableAesKey.aesKeysTable);
+ sql2 = SqlUtils.deleteSql(sql, VariableAesKey.aesKeysTable);
+ }else{
+ sql2 = sql;
}
-
-
- if(!"err".equals(sql)){
+ if(!"err".equals(sql2)){
//閫氳繃鍙嶅皠淇敼sql璇彞
Field field = boundSql.getClass().getDeclaredField("sql");
field.setAccessible(true);
- field.set(boundSql, sql);
+ field.set(boundSql, sql2);
}
return invocation.proceed();
diff --git a/src/main/java/com/hx/mybatis/aes/springbean/SqlUtils.java b/src/main/java/com/hx/mybatis/aes/springbean/SqlUtils.java
index 015815f..e92cd8c 100644
--- a/src/main/java/com/hx/mybatis/aes/springbean/SqlUtils.java
+++ b/src/main/java/com/hx/mybatis/aes/springbean/SqlUtils.java
@@ -55,7 +55,7 @@
sqlSelectQuery = (SQLSelectQueryBlock)sqlStatement.getSelect().getQuery() ;
}catch (Exception e){
b = false;
- logger.error("瑙ｆ瀽sql鎶ラ敊锛�",e.getMessage());
+ logger.error("瑙ｆ瀽sql鎶ラ敊锛�"+e.getMessage());
}
if(!b){
--
Gitblit v1.8.0