Windows环境下自动导出DB2数据库表为.csv的Java实现求助

一、Java连接DB2并导出CSV的核心实现 #

首先确认项目中已引入DB2 JDBC驱动（db2jcc.jar或db2jcc4.jar），可从DB2安装目录获取，放入Eclipse项目的lib文件夹并添加到构建路径。

1. 核心代码示例 #

import java.io.FileWriter;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.Statement;

public class DB2ToCSVExporter {
    public static void main(String[] args) {
        // DB2连接配置
        String dbUrl = "jdbc:db2://你的DB2服务器地址:端口/数据库名";
        String dbUser = "用户名";
        String dbPwd = "密码";
        String exportQuery = "SELECT * FROM 目标表名"; // 替换为你的导出SQL
        String csvSavePath = "D:/export/data.csv"; // 本地CSV保存路径

        try (Connection conn = DriverManager.getConnection(dbUrl, dbUser, dbPwd);
             Statement stmt = conn.createStatement();
             ResultSet rs = stmt.executeQuery(exportQuery);
             FileWriter writer = new FileWriter(csvSavePath, StandardCharsets.UTF_8)) {

            // 写入CSV表头
            ResultSetMetaData metaData = rs.getMetaData();
            int columnNum = metaData.getColumnCount();
            for (int i = 1; i <= columnNum; i++) {
                writer.write(metaData.getColumnName(i));
                if (i < columnNum) writer.write(",");
            }
            writer.write("\n");

            // 写入数据行，处理特殊字符
            while (rs.next()) {
                for (int i = 1; i <= columnNum; i++) {
                    String cellValue = rs.getString(i);
                    // 对含逗号、双引号的字段做转义处理
                    if (cellValue != null && (cellValue.contains(",") || cellValue.contains("\""))) {
                        cellValue = "\"" + cellValue.replace("\"", "\"\"") + "\"";
                    }
                    writer.write(cellValue != null ? cellValue : "");
                    if (i < columnNum) writer.write(",");
                }
                writer.write("\n");
            }

            System.out.println("CSV导出完成");

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

2. 关键注意事项 #

• 驱动加载：JDBC4.0+版本无需手动加载驱动，旧版本需添加Class.forName("com.ibm.db2.jcc.DB2Driver");
• 编码处理：如果导出中文乱码，直接用FileWriter指定UTF-8编码（如上述代码）
• 大数据量优化：添加stmt.setFetchSize(1000)设置批量读取行数，避免内存溢出

二、实现每日自动更新 #

1. Java内部定时方案（轻量） #

用ScheduledExecutorService实现后台定时执行，比如每天凌晨2点触发：

import java.util.Calendar;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class ScheduledCSVUpdate {
    public static void main(String[] args) {
        ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
        
        // 计算首次执行延迟：当前时间到次日凌晨2点的毫秒数
        long firstDelay = getDelayToTargetTime(2, 0);
        // 每24小时执行一次导出逻辑
        scheduler.scheduleAtFixedRate(() -> DB2ToCSVExporter.main(null), 
                                      firstDelay, 24, TimeUnit.HOURS);
    }

    private static long getDelayToTargetTime(int targetHour, int targetMinute) {
        Calendar now = Calendar.getInstance();
        Calendar target = Calendar.getInstance();
        target.set(Calendar.HOUR_OF_DAY, targetHour);
        target.set(Calendar.MINUTE, targetMinute);
        target.set(Calendar.SECOND, 0);
        target.set(Calendar.MILLISECOND, 0);

        if (now.after(target)) {
            target.add(Calendar.DAY_OF_MONTH, 1);
        }
        return target.getTimeInMillis() - now.getTimeInMillis();
    }
}

2. 操作系统计划任务（更稳定） #

将导出程序打包为可执行JAR，用系统自带定时工具触发：

• Windows：打开「任务计划程序」→ 创建基本任务，设置每日触发时间，操作选择启动java.exe，参数填-jar 你的导出程序.jar
• Linux：编辑crontab定时任务，添加0 2 * * * java -jar /opt/export/db2-exporter.jar（每天凌晨2点执行）

三、常见问题排查 #

• 连接失败：检查DB2服务器地址、端口、账号权限，用telnet 服务器地址 端口测试网络连通性
• 写入失败：确认CSV保存路径有写入权限，避免写入系统保护目录（如Windows C盘根目录）
• 数据格式错误：重点检查含特殊字符的字段是否正确转义，避免CSV列错位

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