参考网站：https://support.huaweicloud.com/devg-dws/dws_04_0855.html
http://www.postgres.cn/docs/9.3/sql-copy.html
https://easypoi.mydoc.io/#text_197817
在MysqL中，可以使用LOAD DATA INFILE和LOAD DATA LOCAL INFILE两种方式导入文本文件中的数据到数据库表中，速度非常快。其中LOAD DATA INFILE使用的文件要位于MysqL所在服务器上，LOAD DATA LOCAL INFILE则使用的是客户端的文件。
1
2
|
LOAD DATA INFILE 'data.txt' INTO TABLE table_name;
LOAD DATA LOCAL INFILE 'data.txt' INTO TABLE table_name;
|
在Postgresql中也可以导入相同类型的文本文件，使用的是copY命令：
1
|
copY table_name FROM 'data.txt';
|
但是这个语句只能导入Postgresql所在服务器上的文件，要想导入客户端文件，就需要使用下面的语句：
1
|
copY table_name FROM STDIN;
|
在Java中，可以通过设置流的方式，设置需要导入的客户端本地文件。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
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查询结果：
1
|
copY (SELECT columns FROM table_name WHERE ……) TO STDOUT;
|
Java代码如下：
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
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();
}
}
}
}
|
使用方式：
1
2
3
4
5
6
|
// 将本地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)");
|
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。
