テーブルデータをCSV出力しても中身が空になる

Question

java初心者です、不備があったらご指摘ください。
※当初質問文から、一歩進んだため、ソースを修正しています。
(当初質問：copyManagerを利用してpsqlコマンドを実行したい)

前提・実現したいこと

テーブルの全データをCSVに出力したいです。
javaを使ってPostgreSQLにアクセスしようと思っています。

PostgreSQLからデータを出力する際は、下記のようなCOPYコマンドを利用したいと思っています。

COPY driver_message TO STDOUT WITH (FORMAT csv ,HEADER ,NULL 'null' ,DELIMITER E'\t');

上記コマンドをjava上で実行するためには、copyManagerを使うことで実行できると見つけて実装していますが、実行してもファイルを出力しますがファイルの中身が空となり正しく出力できません。
copyManagerの使い方が違う・コマンドがおかしい、などご指摘ありましたら頂けると幸いです。

public class OutputDbDao {
	
	/**
	 * TSV出力処理
	 * 
	 * @throws SQLException
	 * @throws ClassNotFoundException
	 * @throws IOException 
	 */
	public void exportTsv() throws SQLException, ClassNotFoundException, IOException {

		System.out.println("OutputDao 開始");
		
		// PostgreSQLへ接続
		Class.forName("org.postgresql.Driver");
		
		
		// 接続情報取得
		String jdbcUrl = "jdbc:postgresql://xxx.xxx.xxx.xxx:5432/abc_cde";
		String DbUser = "user";
		String DbPassword = "pass";
		
		Connection conn = null;
		conn = DriverManager.getConnection(jdbcUrl, DbUser, DbPassword);
		
		// PostgreSQLコマンド実行クラス				
		// copyManager準備
		FileOutputStream file = new FileOutputStream("/tmp/table.tsv");
		CopyManager copyManager = new CopyManager((BaseConnection) conn);
		Writer writer = new OutputStreamWriter(file, "UTF8");
		
		// PostgreSQLコマンド呼び出し実行
		String command = "COPY driver_message TO STDOUT WITH (FORMAT csv ,HEADER ,NULL 'null' ,DELIMITER E'\t');";
		
		// PostgreSQLコマンド実行		
		copyManager.copyOut(command,writer);	
		
		System.out.println("OutputDao 完了");
		
	}
}

Comments

[jimbe]

exportTsv メソッドでは例外の処理が何もありませんが, 呼び出し側で表示する等で, 例外が発生していないことは確認されていますでしょうか.

[inu_inu]

呼び出し側でtry-catchをしておりますが、例外の発生はありませんでした。
記述不足です、申し訳ございません。

Answer 1

copyOut の後に writer.close(); ではどうなりますか?

Comments

[inu_inu]

ご指摘の通り、writer.close();をcopyOutの後につけたら出力できました！
writerをcloseしていない場合、書き込みの処理が完了せず反映されないということでしょうか。
大変勉強になりました、ありがとうございます！

[jimbe]

java に限らず ファイル入出力や通信等 連続するデータ(stream) を扱う場合, (処理の関係上や効率化, スピードアップ等のために)内部にバッファを持っている場合が多いです. その場合, 処理途中のデータがバッファに残ることがあります.
java では java.io.Flushable というインターフェースがありまして, これを実装しているクラスは, flush() を実装してそのバッファの中身を全て書き出すという動作が定義されます.
逆に言うと, java.io.Flushable を実装しているクラスは内部にバッファを持っているので, flash() を呼ばないとデータが出て行かないことがあるということです.
また, そういうクラスの場合は close() でも内部で flash() を呼び出していますので, flash()→close() と書かなくても close() だけでフラッシュされます.

理由は上記のようになりますが, 詳細はともかく, 「openしたら (例外はありますが new した時点で open されます) close する」という原則でコードを書くようにしますと, 今後も同様の問題にあうことは少なくなると思います.

[inu_inu]

根幹のご提示・ご教授ありがとうございます、大変わかりやすかったです。
「openしたら (例外はありますが new した時点で open されます) close する」
の原則を念頭に入れて、今後も勉強などさせていただきます。