@Scheduled(fixedDelay = 10000)
public void flushBuffer() {
    // ... 緩沖區(qū)處理邏輯
    jdbcTemplate.batchUpdate(sql, batch, batch.size(), (ps, entry) -> {
        ps.setString(1, entry.routingKey);
        ps.setString(2, entry.payload);
        ps.setString(3, entry.messageId);
        ps.setTimestamp(4, Timestamp.valueOf(entry.createdAt));
    });
}

@Component
public class LogService {
    @Scheduled(fixedDelay = 10000)
    @Transactional // 無(wú)效！
    public void flushBuffer() { ... } // 通過(guò)this.flushBuffer()調(diào)用
}

// 在flushBuffer()開(kāi)頭添加
log.info("事務(wù)是否激活: {}", TransactionSynchronizationManager.isActualTransactionActive());

# 錯(cuò)誤配置：未啟用事務(wù)管理
spring:
  jpa:
    properties:
      hibernate:
        hbm2ddl:
          auto: none

spring:
  jpa:
    properties:
      hibernate:
        hbm2ddl:
          auto: none
  transaction:
    enabled: true # 必須顯式啟用

# 錯(cuò)誤配置：內(nèi)存數(shù)據(jù)庫(kù)，重啟即失
spring:
  datasource:
    url: jdbc:h2:mem:testdb

try (Connection conn = jdbcTemplate.getDataSource().getConnection()) {
    log.info("當(dāng)前數(shù)據(jù)庫(kù)URL: {}", conn.getMetaData().getURL());
    log.info("數(shù)據(jù)庫(kù)類(lèi)型: {}", conn.getMetaData().getDatabaseProductName());
}

# 錯(cuò)誤配置：autoCommit=false
spring:
  datasource:
    hikari:
      auto-commit: false # 重大隱患！

private static final int BATCH_SIZE = -1; // 負(fù)數(shù)導(dǎo)致循環(huán)不執(zhí)行

log.info("BATCH_SIZE = {}, 實(shí)際處理數(shù)量: {}", BATCH_SIZE, batch.size());

LogEntry entry = new LogEntry(null, null, null, null); // 無(wú)效數(shù)據(jù)

log.debug("待插入數(shù)據(jù)樣本: {}", batch.get(0).toString());

private Queue<LogEntry> buffer = new LinkedList<>(); // 非線程安全！

private Queue<LogEntry> buffer = new ConcurrentLinkedQueue<>();

@Scheduled(fixedDelay = 10000)
public void flushBuffer() {
    log.info("線程: {} 正在執(zhí)行", Thread.currentThread().getName());
}

DataSource ds = jdbcTemplate.getDataSource();
try (Connection conn = ds.getConnection()) {
    log.info("? 數(shù)據(jù)庫(kù)連接驗(yàn)證: URL={}, 用戶(hù)={}, 產(chǎn)品={}",
        conn.getMetaData().getURL(),
        conn.getMetaData().getUserName(),
        conn.getMetaData().getDatabaseProductName());
}

jdbcTemplate.update(
    "INSERT INTO event_log (routing_key, payload, message_id, created_at) VALUES (?, ?, ?, ?)",
    "TEST_KEY", "{\"test\":1}", "TEST_MSG", Timestamp.from(Instant.now())
);

spring:
  datasource:
    hikari:
      auto-commit: true # 必須為true！

@Service
public class LogService {
    @Scheduled(fixedDelay = 10000)
    @Transactional(rollbackFor = Exception.class)
    public void flushBuffer() {
        // ... 業(yè)務(wù)邏輯
    }
}

// 創(chuàng)建獨(dú)立事務(wù)服務(wù)
@Service
public class LogTransactionService {
    @Autowired
    private LogService logService;

    @Transactional
    public void flushWithTransaction() {
        logService.flushBuffer(); // 通過(guò)代理調(diào)用
    }
}

// 在定時(shí)器中使用
@Component
public class Scheduler {
    @Autowired
    private LogTransactionService logTransactionService;

    @Scheduled(fixedDelay = 10000)
    public void scheduleFlush() {
        logTransactionService.flushWithTransaction();
    }
}

# MySQL持久化配置
spring:
  datasource:
    url: jdbc:mysql://localhost:3306/mydb?useSSL=false&serverTimezone=UTC
    username: root
    password: password
    hikari:
      auto-commit: true # 事務(wù)管理啟用時(shí)可忽略，但建議保持為true
      connection-timeout: 30000
      maximum-pool-size: 10

# 開(kāi)發(fā)環(huán)境使用內(nèi)存數(shù)據(jù)庫(kù)（需重啟清空）
spring:
  datasource:
    url: jdbc:h2:mem:testdb;DB_CLOSE_DELAY=-1
    driver-class-name: org.h2.Driver

log.info("批量寫(xiě)入 | 數(shù)據(jù)源: {}, 表: {}, 批次: {} | 耗時(shí): {}ms",
    ds.getConnection().getMetaData().getURL(),
    "event_log",
    batch.size(),
    duration
);

catch (DataAccessException e) {
    SQLException sqle = (SQLException) e.getRootCause();
    log.error("SQL執(zhí)行失敗 | 狀態(tài): {}, 錯(cuò)誤碼: {}, 語(yǔ)句: {}", 
        sqle.getSQLState(),
        sqle.getErrorCode(),
        sql
    );
}

private int batchSize = 100; // 可通過(guò)配置動(dòng)態(tài)調(diào)整

// 在配置文件中
log.batch.size=200

-- 添加唯一索引防止重復(fù)插入
ALTER TABLE event_log ADD UNIQUE (message_id);

// 在應(yīng)用啟動(dòng)時(shí)驗(yàn)證autoCommit
try (Connection conn = dataSource.getConnection()) {
    boolean autoCommit = conn.getAutoCommit();
    log.info("? 數(shù)據(jù)庫(kù)autoCommit狀態(tài): {}", autoCommit);
}

graph TD
    A[數(shù)據(jù)未持久化] --> B{是否啟用@Transaction}
    B -->|否| C[檢查autoCommit配置]
    C -->|autoCommit=false| D[手動(dòng)提交或啟用事務(wù)]
    B -->|是| E[檢查事務(wù)代理]
    E -->|內(nèi)部調(diào)用| F[使用獨(dú)立服務(wù)類(lèi)]
    E -->|配置錯(cuò)誤| G[啟用spring.transaction.enabled=true]

# application.yml - 數(shù)據(jù)庫(kù)與事務(wù)配置
spring:
  datasource:
    url: jdbc:mysql://localhost:3306/your_db?useSSL=false&serverTimezone=UTC
    username: your_user
    password: your_password
    driver-class-name: com.mysql.cj.jdbc.Driver
    hikari:
      auto-commit: true # 事務(wù)啟用時(shí)可忽略，但建議保持
      connection-timeout: 30000
      maximum-pool-size: 10
  jpa:
    properties:
      hibernate:
        dialect: org.hibernate.dialect.MySQL8Dialect
        show_sql: true
        format_sql: true
  transaction:
    enabled: true # 確保事務(wù)管理已啟用

# 業(yè)務(wù)類(lèi)示例
@Service
public class LogService {
    @Transactional(rollbackFor = Exception.class)
    public void flushBuffer() {
        // ... 業(yè)務(wù)邏輯
    }
}

@Component
public class Scheduler {
    @Autowired
    private LogService logService;

    @Scheduled(fixedDelay = 10000)
    public void scheduleFlush() {
        logService.flushBuffer();
    }
}