zhuyifan

fix

......@@ -56,7 +56,9 @@ public class MysqlZipkinInterceptor implements StatementInterceptorV2 {
private Tracing getTracing() {
if (tracing == null) {
tracing = AppConfig.APP_CONTEXT.getBean(Tracing.class);
tracing = AppConfig.APP_CONTEXT != null
? AppConfig.APP_CONTEXT.getBean(Tracing.class)
: null;
}
return tracing;
}
......@@ -70,6 +72,9 @@ public class MysqlZipkinInterceptor implements StatementInterceptorV2 {
final Statement interceptedStatement,
final Connection connection) throws SQLException {
final var tracing = getTracing();
if (tracing == null) {
return null;
}
final var context = tracing.currentTraceContext().get();
final var sqlStr = sql != null ? sql : interceptedStatement.toString();
log.info("sql exec: {}", sqlStr.replace("\n", ""));
......@@ -110,6 +115,9 @@ public class MysqlZipkinInterceptor implements StatementInterceptorV2 {
final boolean noGoodIndexUsed,
final SQLException statementException) throws SQLException {
final var tracing = getTracing();
if (tracing == null) {
return null;
}
final var span = ThreadLocalSpan.CURRENT_TRACER.remove();
if (statementException != null) {
log.error("sql exec failed", statementException);
......