Javaがsqoopを使用してPostgreライブラリに接続するパラメータの注意事項

sqoopのjarパッケージ接続Postgreライブラリのパラメータ注意事項

フルネットはこの1軒だけ

パラメータ:schemaの使用

Postgreライブラリに接続するコード例

また、sqoop-1.4.5のjarパケットソースコード

を自分で修正しました.
ネットワーク全体はこの1社のみ
パラメータぱらめーた:schemaの使用schemaのしよう
JAvaはsqoopを呼び出す時、いくつかの共通パラメータはここで紹介しないで、多くの地方はすべて詳しく紹介して、本文はただいくつかの私個人がsqoopツールパッケージを使って出会った問題を紹介します:Postgreライブラリにアクセスする時どのようにschemaパラメータをプラスします

1 schemaパラメータを追加する場合は、-schemaの前に「-」

を追加します.

2 schemaパラメータは、すべてのパラメータの最後の

に加算されます.
Postgreライブラリに接続するコードの例

//  HDFS     Postgre 
/**
*@param conf   Hadoop conf
*@param pg_tablename pg    
*@param table_columns     
*@param schema_name schema  
*@param hdfsDir HDFS     
*@param pg_con_info_map pg      
*/
public static void ExportCmd(Configration conf,
String pg_tablename,String schema_name,List<String> table_columns,
String hdfsDir,Map<String,String> pg_con_info_map){
     
	list<String> list = new ArryList<>();
	//pg     
	list.add("--connect");
	list.add(pg_con_info_map.get("DRIVERURL"));
	list.add("--username");
	list.add(pg_con_info_map.get("USER"));
	list.add("--password");
	list.add(pg_con_info_map.get("PASSWORD"));
	list.add("--table");
	list.add(pg_tablename);
	list.add("--colnumns");
	list.add(StringUtils.join(table_columns));
	list.add("--fields-terminated-by");
	list.add("\t");
	list.add("--export-dir");
	list.add(hdfsDir);
	list.add("-m");
	list.add("1");
	//    schema
	//         
	list.add("--");
	list.add("--schema");
	list.add(schema_name);
	
	Exporter exporter = new Exporter();
	....
}

また、sqoop-1.4.5のjarパッケージソースコードを自分で修正しました.
jarパッケージのソースコードが変更され、scheme.tableNameのテーブル名フォーマットがサポートされています.たとえば、テーブル名:hero.zero_test_pgは、自動的に処理され、Postgreライブラリで「hero」.zero_を探します.test_pgのテーブル名、元のschemaパラメータは依然として使用することができて、jarパケットは後でアップロードします