PostgreSQL:Java使用CopyManager实现客户端文件COPY导入 .
在MySQL中,可以使用LOAD DATA INFILE和LOAD DATA LOCAL INFILE两种方式导入文本文件中的数据到数据库表中,速度非常快。其中LOAD DATA INFILE使用的文件要位于MySQL所在服务器上,LOAD DATA LOCAL INFILE则使用的是客户端的文件。 LOAD DATA INFILE 'data.txt' INTO TABLE table_name; 在PostgreSQL中也可以导入相同类型的文本文件,使用的是COPY命令: COPY table_name FROM 'data.txt'; 但是这个语句只能导入PostgreSQL所在服务器上的文件,要想导入客户端文件,就需要使用下面的语句: COPY table_name FROM STDIN; 在Java中,可以通过设置流的方式,设置需要导入的客户端本地文件。 public void copyFromFile(Connection connection,String filePath,String tableName) throws SQLException,IOException { FileInputStream fileInputStream = null; try { CopyManager copyManager = new CopyManager((BaseConnection)connection); fileInputStream = new FileInputStream(filePath); copyManager.copyIn("COPY " + tableName + " FROM STDIN",fileInputStream); } finally { if (fileInputStream != null) { try { fileInputStream.close(); } catch (IOException e) { e.printStackTrace(); } } } }
COPY (SELECT columns FROM table_name WHERE ……) TO STDOUT; Java代码如下: public void copyToFile(Connection connection,String tableOrQuery) throws SQLException,IOException { FileOutputStream fileOutputStream = null; try { CopyManager copyManager = new CopyManager((BaseConnection)connection); fileOutputStream = new FileOutputStream(filePath); copyManager.copyOut("COPY " + tableOrQuery + " TO STDOUT",fileOutputStream); } finally { if (fileOutputStream != null) { try { fileOutputStream.close(); } catch (IOException e) { e.printStackTrace(); } } } } 使用方式: // 将本地d:/data.txt文件中的数据导入到person_info表中 copyFromFile(connection,"d:/data.txt","person_info"); // 将person_info中的数据导出到本地文件d:/data.txt copyToFile(connection,"person_info"); // 将SELECT p_name,p_age FROM person_info查询结果导出到本地文件d:/data.txt copyToFile(connection,"(SELECT p_name,p_age FROM person_info)");
作者:叉叉哥 转载请注明出处:http://www.52php.cn/article/p-pjfgszzj-mb.html (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |