Apache Commons DbUtils - 1.0

public class TransactionLogExecutor {

    private JdbcTransactionDataSource jdbcTransactionDataSource;

    private LogExecutor logExecutor;

    private QueryRunner queryRunner = new QueryRunner();

    public TransactionLogExecutor(LogExecutor logExecutor,JdbcTransactionDataSource jdbcTransactionDataSource) {
        this.logExecutor = logExecutor;
        this.jdbcTransactionDataSource = jdbcTransactionDataSource;
    }

    public void saveLog() throws SQLException {
        JdbcTransaction jdbcTransaction = JdbcTransaction.current();
        //todo insert all
        for(TransactionLog transactionLog:jdbcTransaction.getTransactionLogs()) {
            String sql = logExecutor.insert(transactionLog);
            Connection connection = jdbcTransactionDataSource.getConnection();
            int row = queryRunner.execute(connection, sql, transactionLog.params());
            log.debug("insert-sql=>{},row:{},connection:{}", sql, row,connection);
        }
    }

    public void init(Connection connection) throws SQLException{
        try {
            String createSql = logExecutor.create();
            queryRunner.execute(connection, createSql);
            log.info("transaction log init success .");
        }catch (SQLException exception){
            log.warn("init transaction-log");
        }
    }

    public void delete(Connection connection)throws SQLException{
        List<Long> ids =  JdbcTransaction.current().logIds();
        String sql = logExecutor.delete(ids);
        int row = queryRunner.execute(connection,sql);
        log.debug("delete-sql=>{},row:{}",sql,row);
    }
}

public class MysqlLogExecutor implements LogExecutor {

    @Override
    public String insert(TransactionLog transactionLog) {
        return "insert into `transaction_log`(`id`,`group_id`,`sql`,`time`,`flag`) values(?,?,?,?,?)";
    }

    @Override
    public String create() {
        return "\n" +
                "CREATE TABLE `transaction_log` (\n" +
                "  `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT ' ',\n" +
                "  `group_id` varchar(40) DEFAULT NULL,\n" +
                "  `sql` varchar(255) DEFAULT NULL,\n" +
                "  `time` bigint(20) DEFAULT NULL,\n" +
                "  `flag` int(1) DEFAULT NULL,\n" +
                "  PRIMARY KEY (`id`)\n" +
                ") ENGINE=InnoDB DEFAULT CHARSET=latin1;\n" +
                "\n" ;
    }

    @Override
    public String delete(List<Long> ids) {
        String id = Joiner.on(",").join(ids);
        return "delete from `transaction_log` where id in ("+id+")";
    }
}