package com.example;

import com.alibaba.druid.filter.FilterAdapter;
import com.alibaba.druid.filter.FilterChain;
import com.alibaba.druid.proxy.jdbc.StatementProxy;

import java.sql.SQLException;

public class LogFilter extends FilterAdapter {
    @Override
    public void statement_executeBefore(FilterChain chain, StatementProxy statement) throws SQLException {
        String sql = statement.getBatchSql();
        
        // 這里可以根據(jù)實(shí)際需求判斷是否需要記錄日志
        if (shouldLog(sql)) {
            logSql(sql);
        }
        chain.statement_executeBefore(statement);
    }

    private boolean shouldLog(String sql) {
        // 實(shí)現(xiàn)判斷邏輯，如檢查是否包含特定表名
        return sql.contains("sensitive_table");
    }

    private void logSql(String sql) {
        // 實(shí)際的日志記錄邏輯
        System.out.println("Executing SQL: " + sql);
    }
}

import com.alibaba.druid.filter.FilterEventAdapter;
import com.alibaba.druid.proxy.jdbc.StatementProxy;
import com.alibaba.druid.proxy.jdbc.ResultSetProxy;

public class CustomDruidFilter extends FilterEventAdapter {

    @Override
    protected void statementExecuteBefore(StatementProxy statement, String sql) {
        // 記錄SQL執(zhí)行前的日志
        logger.info("Before SQL Execute: " + sql);
    }

    @Override
    protected void statementExecuteAfter(StatementProxy statement, String sql, boolean result) {
        // 記錄SQL執(zhí)行后的日志
        logger.info("After SQL Execute: " + sql + " , result: " + result);
    }

    @Override
    protected void resultSetOpenAfter(ResultSetProxy resultSet) {
        // 當(dāng)結(jié)果集打開(kāi)后的處理
        logger.info("ResultSet Opened: " + resultSet.getRawObject());
    }

    @Override
    protected void resultSetCloseAfter(ResultSetProxy resultSet) {
        // 當(dāng)結(jié)果集關(guān)閉后的處理
        logger.info("ResultSet Closed: " + resultSet.getRawObject());
    }

    // ... 其他事件處理 ...
}

<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" ...>
    <property name="proxyFilters">
        <list>
            <ref bean="logFilter"/>
        </list>
    </property>
</bean>

<bean id="logFilter" class="com.example.LogFilter"/>

import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.Collections;

@Configuration
public class DruidConfig {

    @Bean
    public DruidDataSource dataSource() {
        DruidDataSource dataSource = new DruidDataSource();
        // 配置數(shù)據(jù)源參數(shù)
        // ...
        // 添加自定義過(guò)濾器
        dataSource.setProxyFilters(Collections.singletonList(new LogFilter()));
        return dataSource;
    }
}

spring.datasource.druid.url=jdbc:mysql://localhost:3306/yourdb
spring.datasource.druid.username=yourusername
spring.datasource.druid.password=yourpassword
# 啟用配置過(guò)濾器
spring.datasource.druid.filter.config.enabled=true
# 其他Druid配置...

spring:
  datasource:
    druid:
      url: jdbc:mysql://localhost:3306/yourdb
      username: yourusername
      password: yourpassword
      filter:
        config:
          enabled: true
      # 其他Druid配置...