时间戳

首页 > 解决方案 > Log4J2 JdbcAppender 没有编写正确的 INSERT 语句

java - Log4J2 JdbcAppender 没有编写正确的 INSERT 语句

问题描述

我正在尝试在我的 Spring 应用程序中使用这个池化 JDBC 记录器登录 PostgreSQL 数据库。

主要思想来自这里：如何使用 Spring Boot 应用程序初始化 log4j？

@Component
public class JdbcAppenderConfiguration implements 
                     ApplicationListener<ContextRefreshedEvent> {

  private static Logger LOGGER = 
      LogManager.getLogger(JdbcAppenderConfiguration.class);

  private final DataSource dataSource;

  public JdbcAppenderConfiguration(DataSource dataSource) {
      this.dataSource = dataSource;
  }

  @Override
  public void onApplicationEvent(ContextRefreshedEvent event) {

    final LoggerContext ctx = (LoggerContext) LogManager.getContext(false);
    final ColumnConfig[] cc = {
        ColumnConfig.newBuilder()
            .setConfiguration(ctx.getConfiguration())
            .setName("level")
            .setPattern("%level")
            .setUnicode(false)
            .build()
    };

    final Appender appender = JdbcAppender
        .newBuilder()
        .setName("databaseAppender")
        .setIgnoreExceptions(false)
        .setConnectionSource(new ConnectionFactory(dataSource))
        .setTableName("logs2")
        .setColumnConfigs(cc)
        .build();

    appender.start();

    ctx.getConfiguration().addAppender(appender);

    final LoggerConfig loggerConfig =
        ctx.getConfiguration()
           .getLoggerConfig(LogManager.ROOT_LOGGER_NAME);
    loggerConfig.addAppender(appender, null, null);

    ctx.updateLoggers();

  }

}

和连接工厂：

public class ConnectionFactory extends AbstractConnectionSource {

  private final DataSource dataSource;

  public ConnectionFactory(DataSource dataSource) {
    AssertUtils.notNull(dataSource, "dataSource");
    this.dataSource = dataSource;
  }

  @Override
  public Connection getConnection() throws SQLException {
    return dataSource.getConnection();
  }

}

但是在记录时我得到这个错误：

2020-12-12 08:03:05,860 restartedMain 错误无法写入数据库 [JdbcManager{name=databaseAppender, bufferSize=0, tableName=logs2, columnConfigs=[{ name=level, layout=%level, literal=null, timestamp =false }], columnMappings=null}] 用于附加程序 [databaseAppender]。org.apache.logging.log4j.core.appender.db.DbAppenderLoggingException：无法在 JDBC 管理器中插入日志事件记录：org.postgresql.util.PSQLException：错误：“）”或附近的语法错误 Pozice：20 [columnConfigs =[{ name=level, layout=%level, literal=null, timestamp=false }], sqlStatement=insert into logs2 () values (?), factoryData=FactoryData [connectionSource=ConnectionFactory@ca2c455, tableName=logs2, columnConfigs= [{ name=level, layout=%level, literal=null, timestamp=false }], columnMappings=null, immediateFail=false, retry=true, reconnectIntervalMillis=5000,

无效的 SQL INSERT 语句存在问题：

sqlStatement=insert into logs2 () values (?),

问题：您知道为什么 log4J 不能正确/完整地编写命令吗？我的代码有什么问题？

标签： javaspring-bootlog4j2

解决方案

这是 Log4j2 中的一个错误。

我在 IntelliJ 中建立了一个快速项目，添加了 log4j2 2.14 api 和核心 JAR 以及一个数据库驱动程序 JAR 并运行了您的代码，我能够INSERT在您的错误消息中重现格式不正确的语句。

INSERT我使用 IntelliJ 下载了 log4j2 源 JAR 并将其附加，并逐步执行了将语句组合在一起的代码。将列名添加到 SQL 字符串的方法被调用appendColumnNames并且在类中JdbcDatabaseManager。它包含以下代码，为了清楚起见，我对其进行了缩写：

        if (data.columnMappings != null) {
            for (final ColumnMapping colMapping : data.columnMappings) {
                // append column from colMapping
            }
            if (data.columnConfigs != null) {
                for (final ColumnConfig colConfig : data.columnConfigs) {
                    // append column from colConfig
                }
            }
        }

在这种情况下，我们可以看到，如果sColumnConfig是 ，则不使用 s 中的列名。这种行为是不正确的：您应该只能指定s。第二个不应该嵌套在第一个里面。ColumnMappingnullColumnConfigif

Log4j2 支持使用ColumnMappings 以及ColumnConfigs 来指定要在日志表中写入的列，因此一种解决方法是改用它们。另一种解决方法是添加该行

        .setColumnMappings(new ColumnMapping[0])

来建设你的JdbcAppender。我对您的代码进行了此更改，Log4j2 生成了正确的 SQL 字符串。

推荐阅读