0

iTunes EPF ファイルを読み取り、それらのレコードを mysql データベース テーブルに挿入するプロセスを完了しました。

レコードを挿入する前に指定されたレコードがデータベースに存在するかどうかを確認する必要があります。レコードが存在しない場合は、レコードを挿入します。ただし、レコードがデータベースに既に存在する場合は、mysql で対応するレコードを更新する必要があります。

mysql でレコードの存在を確認する方法。このチェックはMapperまたはReducerクラスで実行できるかどうか..?同様に、レコードが存在する場合、レコードを更新する方法。

4

2 に答える 2

0

ステージング テーブルを使用して異なるプラットフォームからのデータを統合することは、より堅牢なソリューションです。マップ ステージで各レコードのデータベースをクエリすることは、適切な方法ではなく、データ ロードの一貫性を提供しません。そう、

  1. mysql の STG スキーマ (または同様のもの) にターゲット テーブルのようなテーブルを作成します (2 つの追加フィールド: 'load_ts'、'update_ts')。
  2. MapRed Job (または Sqoop など) から入力し、
  3. merge節 (存在しない場合はアナログ) を使用して、ターゲットの mysql テーブルにデータを入力します
于 2014-07-28T09:56:20.370 に答える