加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 百科 > 正文

PostgreSQL:Java使用CopyManager实现客户端文件COPY导入 .

发布时间:2020-12-13 17:14:21 所属栏目:百科 来源:网络整理
导读:在MySQL中,可以使用LOAD DATA INFILE和LOAD DATA LOCAL INFILE两种方式导入文本文件中的数据到数据库表中,速度非常快。其中LOAD DATA INFILE使用的文件要位于MySQL所在服务器上,LOAD DATA LOCAL INFILE则使用的是客户端的文件。 LOAD DATA INFILE 'data.t

在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中,可以通过设置流的方式,设置需要导入的客户端本地文件。

	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 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

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读