root/wuHanXinRui
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

opt:优化sql日志打印

Browse Source
This commit is contained in:
zhangzq
2024-01-12 16:31:08 +08:00
parent 5040ca0b04
commit a4dee0902d
3 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
mes/hd/nladmin-system/src/main/java/org/nl/config/DruidFilter.java
View File

@@ -39,14 +39,14 @@ public class DruidFilter extends FilterEventAdapter {
@Override @Override
protected void statementExecuteAfter(StatementProxy statement, String sql, boolean result) { protected void statementExecuteAfter(StatementProxy statement, String sql, boolean result) {
String traceId = MDC.get("traceId"); // String traceId = MDC.get("traceId");
int size = statement.getParametersSize(); int size = statement.getParametersSize();
String executeSql = sql; String executeSql = sql;
int count = 0; int count = 0;
try { try {
count=statement.getUpdateCount(); count=statement.getUpdateCount();
}catch (Exception ex){ } }catch (Exception ex){ }
if (true) { if (size>0 && count>0) {
Collection<JdbcParameter> values = statement.getParameters().values(); Collection<JdbcParameter> values = statement.getParameters().values();
List<Object> params = new ArrayList<>(); List<Object> params = new ArrayList<>();
for (JdbcParameter value : values) { for (JdbcParameter value : values) {
@@ -61,8 +61,8 @@ public class DruidFilter extends FilterEventAdapter {
public ResultSetProxy statement_getResultSet(FilterChain chain, StatementProxy statement) throws SQLException { public ResultSetProxy statement_getResultSet(FilterChain chain, StatementProxy statement) throws SQLException {
ResultSetProxy rs = super.statement_getResultSet(chain, statement); ResultSetProxy rs = super.statement_getResultSet(chain, statement);
String executeSql = statement.getLastExecuteSql(); String executeSql = statement.getLastExecuteSql();
String traceId = MDC.get("traceId"); // String traceId = MDC.get("traceId");
if (StringUtils.isNotEmpty(traceId)){ if (true){
int result = 0; int result = 0;
if (rs != null) { if (rs != null) {
ResultSetImpl rss = rs.getResultSetRaw().unwrap(ResultSetImpl.class); ResultSetImpl rss = rs.getResultSetRaw().unwrap(ResultSetImpl.class);

1
mes/hd/nladmin-system/src/main/java/org/nl/config/lucene/AsyncLuceneAppender.java
View File

@@ -25,7 +25,6 @@ public class AsyncLuceneAppender extends AspectLogbackAsyncAppender {
if (mdcPropertyMap.getClass().getName().contains("SynchronizedMap")){ if (mdcPropertyMap.getClass().getName().contains("SynchronizedMap")){
mdcPropertyMap.put("traceId",traceId); mdcPropertyMap.put("traceId",traceId);
} }
MDC.clear();
} }
super.append(event); super.append(event);
} }

1
mes/hd/nladmin-system/src/main/java/org/nl/modules/security/config/SecurityConfig.java
View File

@@ -119,6 +119,7 @@ public class SecurityConfig extends WebSecurityConfigurerAdapter {
.antMatchers("/swagger-resources/**").permitAll() .antMatchers("/swagger-resources/**").permitAll()
.antMatchers("/webjars/**").permitAll() .antMatchers("/webjars/**").permitAll()
.antMatchers("/*/api-docs").permitAll() .antMatchers("/*/api-docs").permitAll()
.antMatchers("/metrics/**").permitAll()
// 文件 // 文件
.antMatchers("/avatar/**").permitAll() .antMatchers("/avatar/**").permitAll()
.antMatchers("/file/**").permitAll() .antMatchers("/file/**").permitAll()