copyを使用する正しい方法Postgres jdbc

Question

jdbc Postgresでcopyコマンドを使用することができません。以下のコードスニペットサンプルで何が間違っていますか。

public boolean loadReportToDB(String date) { 
     // TODO Auto-generated method stub 
     Connection connection = DBUtil.getConnection("POSTGRESS"); 
     String fileName = "C:/_0STUFF/NSE_DATA/nseoi_" + date + ".csv"; 
     String sql = "\\copy fno_oi FROM 'C:\\_0STUFF\\NSE_DATA\\nseoi_27102017.csv' DELIMITER ',' CSV header"; 
     try { 
      PreparedStatement ps = connection.prepareStatement(sql); 
      System.out.println("query"+ps.toString()); 
      int rowsaffected = ps.executeUpdate(); 
      System.out.println("INT+" + rowsaffected); 
      return true; 
     } catch (SQLException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 

     return false; 
    } 

org.postgresql.util.PSQLException: ERROR: syntax error at or near "\" 
    Position: 1 
    at org. 

我々は

String sql = "copy fno_oi FROM 'C:\\_0STUFF\\NSE_DATA\\nseoi_27102017.csv' DELIMITER ',' CSV header"; 

を使用する場合は、入力ファイルが格納されている通り、その後何の行は

Postgresのバージョンのpostgresql-10.0から1-Windowsのx64の

Answer 1

更新されませんあなたのJavaプログラムを実行しているコンピュータで私たちに必要なものcopyはサーバ（Postgresが実行されている場所）のファイルにしかアクセスできないため、JDBCのcopy ... from stdinに相当します。

これを行うには、JDBCドライバが提供するCopyManager APIを使用します。線に沿って

何か：

Connection connection = DBUtil.getConnection("POSTGRES"); 

String fileName = "C:/_0STUFF/NSE_DATA/nseoi_" + date + ".csv"; 
String sql = "copy fno_oi FROM stdin DELIMITER ',' CSV header"; 

BaseConnection pgcon = (BaseConnection)conection; 
CopyManager mgr = new CopyManager(pgcon); 

try { 

    Reader in = new BufferedReader(new FileReader(new File(fileName))); 
    long rowsaffected = mgr.copyIn(sql, in); 

    System.out.println("Rows copied: " + rowsaffected); 

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

Answer 2

これは私の作品：copyIn(String sql, Reader from)を使用して

try (Connection conn = DriverManager.getConnection(connUrl, myUid, myPwd)) { 
    long rowsInserted = new CopyManager((BaseConnection) conn) 
      .copyIn(
       "COPY table1 FROM STDIN (FORMAT csv, HEADER)", 
       new BufferedReader(new FileReader("C:/Users/gord/Desktop/testdata.csv")) 
       ); 
    System.out.printf("%d row(s) inserted%n", rowsInserted); 
} 

はどちらか、PostgreSQLサーバプロセスがファイルを直接読み取ることができません問題を回避するという利点を持っています（デスクトップ上のファイルの読み込みのような）権限がないか、PostgreSQLサーバが動作しているマシンのローカルファイルではないためです。