diff --git a/mongo-plus-core/src/main/java/com/anwen/mongo/interceptor/business/LogInterceptor.java b/mongo-plus-core/src/main/java/com/anwen/mongo/interceptor/business/LogInterceptor.java index 1339f05e2534477f2ed6d54130459c1298d369c0..220910510531d4f00c6199ffeca60023fa279955 100644 --- a/mongo-plus-core/src/main/java/com/anwen/mongo/interceptor/business/LogInterceptor.java +++ b/mongo-plus-core/src/main/java/com/anwen/mongo/interceptor/business/LogInterceptor.java @@ -9,6 +9,8 @@ import com.anwen.mongo.interceptor.Interceptor; import com.anwen.mongo.model.command.CommandFailed; import com.anwen.mongo.model.command.CommandStarted; import com.anwen.mongo.model.command.CommandSucceeded; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import java.util.Objects; @@ -19,6 +21,8 @@ import java.util.Objects; */ public class LogInterceptor implements Interceptor { + Logger logger = LoggerFactory.getLogger(LogInterceptor.class); + private String formattingStatement(String statement){ return PropertyCache.format ? JSON.toJSONString(JSONObject.parse(statement), SerializerFeature.PrettyFormat, SerializerFeature.WriteMapNullValue, SerializerFeature.WriteDateUseDateFormat) : statement; @@ -26,19 +30,17 @@ public class LogInterceptor implements Interceptor { @Override public void commandStarted(CommandStarted commandStarted) { - System.out.println(commandStarted.getCommandName()+" Statement Execution ==> "); - System.out.println(formattingStatement(commandStarted.getCommand())); + logger.info("{} Statement Execution ==> {}",commandStarted.getCommandName(),formattingStatement(commandStarted.getCommand())); } @Override public void commandSucceeded(CommandSucceeded commandSucceeded) { - System.out.println(commandSucceeded.getCommandName()+" results of execution ==> "); if (Objects.equals(commandSucceeded.getCommandName(), "find") || Objects.equals(commandSucceeded.getCommandName(), "aggregate")){ - System.out.println(commandSucceeded.getResponse().getDocument("cursor").get("firstBatch").asArray().getValues().size()); + logger.info("{} results of execution ==> {}",commandSucceeded.getCommandName(),commandSucceeded.getResponse().getDocument("cursor").get("firstBatch").asArray().getValues().size()); } else if (Objects.equals(commandSucceeded.getCommandName(), "update")) { - System.out.println(commandSucceeded.getResponse().get("nModified").asInt32().getValue()); + logger.info("{} results of execution ==> {}",commandSucceeded.getCommandName(),commandSucceeded.getResponse().get("nModified").asInt32().getValue()); } else if (Objects.equals(commandSucceeded.getCommandName(), "insert") || Objects.equals(commandSucceeded.getCommandName(), "delete")) { - System.out.println(commandSucceeded.getResponse().get("n").asInt32().getValue()); + logger.info("{} results of execution ==> {}",commandSucceeded.getCommandName(),commandSucceeded.getResponse().get("n").asInt32().getValue()); } } @@ -46,7 +48,7 @@ public class LogInterceptor implements Interceptor { public void commandFailed(CommandFailed commandFailed) { String commandName = commandFailed.getCommandName(); Throwable throwable = commandFailed.getThrowable(); - System.out.println("error ==> : " + commandName + ", " + throwable.getMessage()); + logger.error("error ==> : {} , {}", commandName, throwable.getMessage()); } @Override