如何将“COPY”命令与 JDBC 结合使用

Question

所以我一直在使用 postgre 数据库，我注意到当我尝试读取 csv 文件并远程复制到表时，它有时会抛出错误。当我使用缓冲阅读器时它工作得很好，但我试图看看是否有办法让我使用数据库 COPY FROM 方法来工作。它在数据库所在的计算机上运行良好，但我的另一台计算机出现错误。

这一行出现错误：

st.execute("COPY inputdata FROM 'C:\\Users\\JAMES\\Downloads\\V24_Mike_110217_RemovedReturnTrips\\RyderCombiner\\AllNonMatchingWithColNames.csv' CSV HEADER DELIMITER ',';");

这是我连接到数据库的地方：

Class.forName("org.postgresql.Driver");
Connection conn = DriverManager.getConnection("jdbc:postgresql://192.168.1.15:5432/postgres", "postgres", "pass");

我在网上读到也许 STDIN 可以帮助我，但我无法让它工作，并且大多数在线示例都使用 pqsl。有没有办法让它工作或者我需要返回缓冲读者？

更新：

因此，我尝试使用 CopyManager API，但在尝试使用 DBUtil 建立连接时出现错误，因为即使我从以下网站下载了 jar 文件，它也无法识别：http ://commons.apache.org/proper/ commons-dbutils/download_dbutils.cgi

代码：

    Connection connection = DBUtil.getConnection("POSTGRES");
    String sql = "COPY inputdata FROM 'C:\\Users\\JAMES\\Downloads\\V24_Mike_110217_RemovedReturnTrips\\RyderCombiner\\AllNonMatchingWithColNames.csv' CSV HEADER DELIMITER ','";
    CopyManager copyManager = new CopyManager((BaseConnection)connection); 
    copyManager.copyIn(sql);

我在 DBUtil 的第一行收到错误...导入 jar 文件是使 jdbc 识别此变​​量的唯一方法吗？

更新2：

再次感谢大家，我最终通过遵循给定的链接和一些调整使复制工作正常。

public static void readInputData(String inputDataFile, Statement st) throws FileNotFoundException, IOException, SQLException {
    Connection connection = DriverManager.getConnection("jdbc:postgresql://192.168.1.15:5432/postgres", "postgres", "pass");
    String sql = "COPY INPUTDATA FROM stdin CSV HEADER DELIMITER ','";
    BaseConnection pgcon = (BaseConnection)connection;
    CopyManager mgr = new CopyManager(pgcon);
    try {
        Reader in = new BufferedReader(new FileReader(new File(inputDataFile)));
        long rowsaffected  = mgr.copyIn(sql, in);
    } catch (SQLException ex) {
        System.err.println(ex.getClass().getName() + ": " + ex.getMessage());
        System.exit(0);
    }
}

Answer 1

当我使用缓冲阅读器时它工作得很好，但我试图看看是否有办法让我使用数据库 COPY FROM 方法来工作。它在数据库所在的计算机上运行良好，但我的另一台计算机出现错误。

不，你必须使用BufferedReader, 或InputStream

1. COPY在服务器上打开文件句柄。它只需要一个路径，因为它可以打开和管理自己的文件句柄，而且效率更高。
2. 对于客户端COPY，您必须使用libpqPQputCopyData。在内部，客户端COPY是COPY FROM STDIN. 客户端必须发送数据。这就是 psql\COPY内部所做的事情。在 Java 中，调用的函数PQputCopyData是copyInwhich 需要BufferedReader, 或InputStream。