如何基于用户名提取Hibernate日志中的查询语句及绑定参数？

针对你的技术栈（Java 8 + Log4j2 + Spring Boot + Hibernate），提供四种可行方案：

一、临时快速处理：命令行文本过滤 #

直接用Linux/Unix工具从现有日志文件中提取目标内容，适合临时排查：

# 提取USER_B相关的完整SQL及参数上下文
grep -A 10 -B 2 "APP-NAME#USER_B" your-app.log

# 精准过滤SQL语句和参数行
grep -E "(APP-NAME#USER_B|select.*from|binding parameter)" your-app.log | grep -B 3 -A 3 "USER_B"

• -A n：显示匹配行后n行内容
• -B n：显示匹配行前n行内容

二、长期规范方案：Log4j2配置专属日志 #

通过Log4j2的过滤器，将USER_B的Hibernate日志单独输出到指定文件，避免混在主日志中：

1. 修改log4j2.xml配置 #

添加专属Appender和Logger：

<Appenders>
    <!-- 专门存储USER_B的Hibernate日志 -->
    <File name="UserBHibernateLog" fileName="logs/user-b-hibernate.log">
        <PatternLayout pattern="%d{yyyy-MM-dd HH:mm:ss,SSS} [%msg]%n"/>
        <Filters>
            <!-- 正则匹配日志中的USER_B标识 -->
            <RegexFilter regex=".*APP-NAME#USER_B.*" onMatch="ACCEPT" onMismatch="DENY"/>
        </Filters>
    </File>
</Appenders>

<Loggers>
    <!-- 输出Hibernate SQL日志 -->
    <Logger name="org.hibernate.SQL" level="DEBUG" additivity="false">
        <AppenderRef ref="UserBHibernateLog"/>
    </Logger>
    <!-- 输出参数绑定日志 -->
    <Logger name="org.hibernate.type.descriptor.sql.BasicBinder" level="TRACE" additivity="false">
        <AppenderRef ref="UserBHibernateLog"/>
    </Logger>
</Loggers>

2. 补充MDC上下文（可选） #

如果日志中的USER_B是通过MDC传递的，确保在请求入口设置MDC：

// 在Spring Security拦截器或ControllerAdvice中添加
@Component
public class MdcFilter implements Filter {
    @Override
    public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
        Authentication auth = SecurityContextHolder.getContext().getAuthentication();
        if (auth != null) {
            MDC.put("username", auth.getName());
        }
        try {
            chain.doFilter(request, response);
        } finally {
            MDC.remove("username");
        }
    }
}

三、代码层面拦截：Hibernate监听器/Inspector #

通过Hibernate提供的扩展点，直接在SQL执行和参数绑定阶段捕获USER_B的相关信息：

1. SQL语句捕获（StatementInspector） #

public class UserBSqlInspector implements StatementInspector {
    private static final Logger LOGGER = LoggerFactory.getLogger(UserBSqlInspector.class);

    @Override
    public String inspect(String sql) {
        String username = MDC.get("username");
        if ("USER_B".equals(username)) {
            LOGGER.debug("USER_B EXECUTE SQL: {}", sql);
        }
        return sql;
    }
}

在application.properties中配置：

spring.jpa.properties.hibernate.session_factory.statement_inspector=com.yourpackage.UserBSqlInspector

2. 参数绑定捕获（ParameterBindListener） #

public class UserBParameterListener implements ParameterBindListener {
    private static final Logger LOGGER = LoggerFactory.getLogger(UserBParameterListener.class);

    @Override
    public void parameterBind(ParameterBindEvent event) {
        String username = MDC.get("username");
        if ("USER_B".equals(username)) {
            LOGGER.trace(
                "USER_B BIND PARAMETER [{}] AS [{}] - [{}]",
                event.getParameterPosition(),
                event.getBindType().getName(),
                event.getBindValue()
            );
        }
    }
}

注册监听器：

@Configuration
public class HibernateConfig {
    @Bean
    public SessionFactory sessionFactory(EntityManagerFactory emf) {
        HibernateEntityManagerFactory hibernateEmf = (HibernateEntityManagerFactory) emf;
        SessionFactory sessionFactory = hibernateEmf.getSessionFactory();
        EventListenerRegistry registry = sessionFactory.getServiceRegistry().getService(EventListenerRegistry.class);
        registry.appendListeners(EventType.PRE_BIND_PARAMETER, new UserBParameterListener());
        return sessionFactory;
    }
}

四、日志平台分析：ELK Stack（如果已部署） #

如果你的日志已收集到ELK（Elasticsearch + Logstash + Kibana），可以直接在Kibana中：

• 添加过滤条件：message: *APP-NAME#USER_B*
• 通过Thread字段关联同一请求的SQL和参数日志
• 自定义可视化面板，快速查看USER_B的所有数据库操作

内容的提问来源于stack exchange，提问作者Usha