admin/mybatis-flex
1
0
Fork 0
mirror of https://gitee.com/mybatis-flex/mybatis-flex.git synced 2025-12-07 17:18:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

reset: 回滚 API 更改。

Browse Source
This commit is contained in:
Suomm 2024-01-19 19:31:23 +08:00
parent 98c555d451
commit 78ab827d42
1 changed files with 1 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
mybatis-flex-core/src/main/java/com/mybatisflex/core/audit/ConsoleMessageCollector.java
View File

@ -26,18 +26,6 @@ public class ConsoleMessageCollector implements MessageCollector {
} }
}; };
private SqlDebugExtPrinter extPrinter = (sql, dsName, tookTimeMillis) -> {
StringBuilder buffer = new StringBuilder();
buffer.append("Flex exec");
buffer.append("dsName >>> ").append(dsName);
if (tookTimeMillis != null) {
buffer.append(" sql took ").append(tookTimeMillis).append(" ms >>> ").append(sql);
} else {
buffer.append(" sql >>> ").append(sql);
}
System.out.println(buffer);
};
public ConsoleMessageCollector() { public ConsoleMessageCollector() {
} }
@ -45,18 +33,9 @@ public class ConsoleMessageCollector implements MessageCollector {
this.printer = printer; this.printer = printer;
} }
public ConsoleMessageCollector(SqlDebugExtPrinter printer) {
this.extPrinter = printer;
}
@Override @Override
public void collect(AuditMessage message) { public void collect(AuditMessage message) {
if (message.getDsName() == null) { printer.print(message.getFullSql(), message.getElapsedTime());
printer.print(message.getFullSql(), message.getElapsedTime());
} else {
extPrinter.print(message.getFullSql(), message.getDsName(), message.getElapsedTime());
}
} }
public interface SqlDebugPrinter { public interface SqlDebugPrinter {
@ -65,11 +44,4 @@ public class ConsoleMessageCollector implements MessageCollector {
} }
public interface SqlDebugExtPrinter {
void print(String sql, String dsName, Long tookTimeMillis);
}
} }