PostgreSQL:Java使用CopyManager实现客户端文件COPY导入
2024-10-19 03:32:53
在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;
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)");
https://blog.csdn.net/xiao__gui/article/details/12090341
最新文章
- 《UML大战需求分析》阅读随笔(六)
- NPOI 教程 - 2.1单元格合并
- mysql relay log参数汇总
- wpf listbox 内的内容显示问题,需要设置里面的itemsPresenter
- 数据库中MyISAM与InnoDB区别
- 窥探JVM内存分配和回收的过程
- 【UVALive - 5131】Chips Challenge(上下界循环费用流)
- Powershell调用静态方法
- 关于tableView的简单实例
- Ubuntu 使用中的问题总结
- 【笔记】归纳js getcomputedStyle, currentStyle 以及其相关用法
- (转)HTTP1.0和HTTP1.1的区别
- Java与算法之(5) - 老鼠走迷宫(深度优先算法)
- 【转】监听器(Listener)学习
- 不要使用Resource Owner Password Credentials
- Leetcode Articles: Insert into a Cyclic Sorted List
- github 遇到Permanently added the RSA host key for IP address '192.30.252.128' to the list of known hosts问题解决
- python学习快人一步,从19个语法开始!
- SQL语句及5.7.2 mysql 用户管理
- Delphi:MSBuild编译dproj工程