PostgreSQL:Java使用CopyManager实现客户端文件COPY导入 .
2015-09-29 17:36
537 查看
在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;
LOAD DATA LOCAL INFILE 'data.txt' INTO TABLE table_name;
在PostgreSQL中也可以导入相同类型的文本文件,使用的是COPY命令:
COPY table_name FROM 'data.txt';
但是这个语句只能导入PostgreSQL所在服务器上的文件,要想导入客户端文件,就需要使用下面的语句:
COPY table_name FROM STDIN;
在Java中,可以通过设置流的方式,设置需要导入的客户端本地文件。
另外,还可以使用COPY table_name TO STDOUT来导出数据文件到本地,和上面的导入相反,可以用于数据库备份。此外,还支持导出一个SQL查询结果:
COPY (SELECT columns FROM table_name WHERE ……) TO STDOUT;
Java代码如下:
使用方式:
作者:叉叉哥 转载请注明出处:/article/1557565.html
LOAD DATA INFILE 'data.txt' INTO TABLE table_name;
LOAD DATA LOCAL 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 table_name TO STDOUT来导出数据文件到本地,和上面的导入相反,可以用于数据库备份。此外,还支持导出一个SQL查询结果:
COPY (SELECT columns FROM table_name WHERE ……) TO STDOUT;
Java代码如下:
public void copyToFile(Connection connection, String filePath, 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, "d:/data.txt", "person_info"); // 将SELECT p_name,p_age FROM person_info查询结果导出到本地文件d:/data.txt copyToFile(connection, "d:/data.txt", "(SELECT p_name,p_age FROM person_info)");
作者:叉叉哥 转载请注明出处:/article/1557565.html
相关文章推荐
- test8.15
- 跟踪Spring MVC的请求
- java中常用的包
- Java.math包中常用的类
- Java.io包中常用的类
- Java.util包中常用的类
- Eclipse 使用Butter Knife注解工具
- 讲解Java中的基础类库和语言包的使用
- java.lang包中的常用类
- java中static关键字的用法
- spring配置druid
- Java垃圾回收机制
- java 文件读写操作
- QuartzJobBean实现定时器功能
- java取奇偶数的基本练习
- Java文件读取
- java基础:基本程序设计结构-1
- Java APNS使用填坑
- java--SAX解析xml
- java 状态码详解