cómo copiar datos de un archivo a PostgreSQL usando JDBC?

Question

Quiero copiar datos del archivo a DB de PostgreSQL usando JDBC. Estaba usando el objeto de declaración JDBC para copiar el archivo en DB. Es muy lento.

Llegué a saber que también podemos usar el comando de copiado para copiar el archivo a DB. Pero, ¿cómo hago con JDBC? Incluso un buen material de referencia con un ejemplo de copia en JDBC ayudaría.

PD: gracias de antemano

Answer 1

Esto funciona ...

import java.io.FileReader; 
import java.sql.Connection; 
import java.sql.DriverManager; 

import org.postgresql.copy.CopyManager; 
import org.postgresql.core.BaseConnection; 

public class PgSqlJdbcCopyStreamsExample { 

    public static void main(String[] args) throws Exception { 

     if(args.length!=4) { 
      System.out.println("Please specify database URL, user, password and file on the command line."); 
      System.out.println("Like this: jdbc:postgresql://localhost:5432/test test password file"); 
     } else { 

      System.err.println("Loading driver"); 
      Class.forName("org.postgresql.Driver"); 

      System.err.println("Connecting to " + args[0]); 
      Connection con = DriverManager.getConnection(args[0],args[1],args[2]); 

      System.err.println("Copying text data rows from stdin"); 

      CopyManager copyManager = new CopyManager((BaseConnection) con); 

      FileReader fileReader = new FileReader(args[3]); 
      copyManager.copyIn("COPY t FROM STDIN", fileReader); 

      System.err.println("Done."); 
     } 
    } 
} 

Answer 2

(basado en aliasmrchips' respuesta :) si usted tiene un maravilloso entorno (como yo usarlo dentro ANT) podría hacerlo así (sustituyendo los detalles de Oracle con Postgres):

// exec.groovy 
this.class.classLoader.rootLoader.addURL('${postgres-jdbc-driver-path}') 
PgScript.load() 

// PgScript.groovy 
// (we cannot use the org.postgres.* classes in exec.groovy already!) 
import java.io.FileReader 
import java.sql.DriverManager 
import org.postgresql.copy.CopyManager 
import org.postgresql.core.BaseConnection 

class PgScript { 
    public static void load() {  
     new CopyManager((BaseConnection) DriverManager.getConnection( 
      '${jdbc-db-url}', '${db-usr}', '${db-usr-pass}') 
     ).copyIn('COPY t FROM STDIN', new FileReader('${sqlfile}')) 
    } 
} 

Basado también en este javaworld.com article.