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; 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;
자바 코드 는 다음 과 같 습 니 다:

	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)");

 
작자  전재 출처 를 밝 혀 주 십시오:http://blog.csdn.net/xiao__gui/article/details/12090341