COPY FROM

カンマ区切り値（CSV）ファイルまたは区切りテキスト・ファイルのデータを既存のテーブルにインポートします。ソース・ファイル内の各行が行としてインポートされます。データセット内のすべての行に同じ数のフィールドが含まれており、PRIMARY KEYフィールドに値が存在する必要があります。

このプロセスはPRIMARY KEYを確認し、既存のレコードを更新します。HEADER = falseで、カラム名が指定されていない場合は、フィールドが決定論的な順番でインポートされます。HEADER = trueの場合、ファイルの最初の行がヘッダー行になります。

構文

COPY table_name [ ( column_list ) ]
  FROM 'file_name'[ , 'file2_name', ... ] | STDIN
  [ WITH option = 'value' [ AND ... ] ]      

コピー・オプションの設定

COPY文で設定されているコピー・オプションは、cqlshrcファイルとデフォルト設定よりも優先されます。オプションがコマンドラインで設定されていない場合は、cqlshrcファイルがデフォルト設定よりも優先されます。

例

サンプル・データセットの作成

COPYコマンドの例に使用する環境を設定します。

1. CQLを使用して、cyclingキースペースを作成します。

   CREATE KEYSPACE cycling
   WITH REPLICATION = { 
     'class' : 'NetworkTopologyStrategy', 
     'datacenter1' : 1 
   };

2. cycling.cyclist_nameテーブルを作成します。

   CREATE TABLE cycling.cyclist_name ( 
     id UUID PRIMARY KEY, 
     lastname text, 
     firstname text 
   );

3. データをcycling.cyclist_nameに挿入します。

   INSERT INTO cycling.cyclist_name (id, lastname, firstname) 
   VALUES (5b6962dd-3f90-4c93-8f61-eabfa4a803e2, 'VOS','Marianne');
   
   INSERT INTO cycling.cyclist_name (id, lastname, firstname) 
   VALUES (e7cd5752-bc0d-4157-a80f-7523add8dbcd, 'VAN DER BREGGEN','Anna');
   
   INSERT INTO cycling.cyclist_name (id, lastname, firstname) 
   VALUES (e7ae5cf3-d358-4d99-b900-85902fda9bb0, 'FRAME','Alex');
   
   INSERT INTO cycling.cyclist_name (id, lastname, firstname) 
   VALUES (220844bf-4860-49d6-9a4b-6b5d3a79cbfb, 'TIRALONGO','Paolo');
   
   INSERT INTO cycling.cyclist_name (id, lastname, firstname)   
   VALUES (6ab09bec-e68e-48d9-a5f8-97e6fb4c9b47, 'KRUIKSWIJK','Steven');
   
   INSERT INTO cycling.cyclist_name (id, lastname, firstname) 
   VALUES (fb372533-eb95-4bb4-8685-6ef61e994caa, 'MATTHEWS', 'Michael');

cyclist_nameテーブルに対するデータのエクスポートおよびインポート

1. cyclist_nameテーブルのidおよびlastnameカラムのみをCSVファイルにエクスポートします。

   COPY cycling.cyclist_name (id,lastname) 
   TO '../cyclist_lastname.csv' WITH HEADER = TRUE;

   cyclist_lastname.csvファイルが現在の作業ディレクトリー（../で示されています）の上のディレクトリーに作成されます。CSVファイルが既に存在する場合は上書きされます。

   Using 7 child processes
       
   Starting copy of cycling.cyclist_name with columns [id, lastname].
   Processed: 6 rows; Rate:      29 rows/s; Avg. rate:      29 rows/s
   6 rows exported to 1 files in 0.223 seconds.

2. idとfirstnameを、cyclist_firstname.csvという名前の別のCSVファイルにコピーします。

   COPY cycling.cyclist_name (id,firstname) 
   TO '../cyclist_firstname.csv' WITH HEADER = TRUE;

   CSVファイルが作成されます。

   Using 7 child processes
       
   Starting copy of cycling.cyclist_name with columns [id, firstname].
   Processed: 6 rows; Rate:      30 rows/s; Avg. rate:      30 rows/s
   6 rows exported to 1 files in 0.213 seconds.

3. すべてのレコードをサイクリスト名テーブルから削除します。

   TRUNCATE cycling.cyclist_name;

4. 行が存在しないことを確認します。

   SELECT *
   FROM cycling.cyclist_name;

   クエリー結果は空です。

    id | firstname | lastname
   ----+-----------+----------
       
   (0 rows)

5. サイクリストの名をインポートします。

   COPY cycling.cyclist_name (id,firstname)
   FROM '../cyclist_firstname.csv' WITH HEADER = TRUE;

   行がインポートされます。

   Using 7 child processes
       
   Starting copy of cycling.cyclist_name with columns [id, firstname].
   Processed: 6 rows; Rate:      10 rows/s; Avg. rate:      14 rows/s
   6 rows imported from 1 files in 0.423 seconds (0 skipped).

6. 新しい行を確認します。

   SELECT *
   FROM cycling.cyclist_name;

   lastnameフィールドがインポートしたデータ・セットに含まれていなかったため、姓にはnullが指定されて行が作成されました。

    id                                   | firstname | lastname
   --------------------------------------+-----------+----------
    e7ae5cf3-d358-4d99-b900-85902fda9bb0 |      Alex |     null
    fb372533-eb95-4bb4-8685-6ef61e994caa |   Michael |     null
    5b6962dd-3f90-4c93-8f61-eabfa4a803e2 |  Marianne |     null
    220844bf-4860-49d6-9a4b-6b5d3a79cbfb |     Paolo |     null
    6ab09bec-e68e-48d9-a5f8-97e6fb4c9b47 |    Steven |     null
    e7cd5752-bc0d-4157-a80f-7523add8dbcd |      Anna |     null
       
   (6 rows)

7. 姓をインポートします。

   COPY cycling.cyclist_name (id,lastname)
   FROM '../cyclist_lastname.csv' WITH HEADER = TRUE;

   レコードがインポートされますが、新しいレコードは作成されません。

   Using 7 child processes
       
   Starting copy of cycling.cyclist_name with columns [id, lastname].
   Processed: 6 rows; Rate:      10 rows/s; Avg. rate:      14 rows/s
   6 rows imported from 1 files in 0.422 seconds (0 skipped).

8. レコードが更新されたことを確認します。

   SELECT *
   FROM cycling.cyclist_name;

   PRIMARY KEYであるidがすべてのレコードについて照合され、lastnameが自動入力されます。

    id                                   | firstname | lastname
   --------------------------------------+-----------+-----------------
    e7ae5cf3-d358-4d99-b900-85902fda9bb0 |      Alex |           FRAME
    fb372533-eb95-4bb4-8685-6ef61e994caa |   Michael |        MATTHEWS
    5b6962dd-3f90-4c93-8f61-eabfa4a803e2 |  Marianne |             VOS
    220844bf-4860-49d6-9a4b-6b5d3a79cbfb |     Paolo |       TIRALONGO
    6ab09bec-e68e-48d9-a5f8-97e6fb4c9b47 |    Steven |      KRUIKSWIJK
    e7cd5752-bc0d-4157-a80f-7523add8dbcd |      Anna | VAN DER BREGGEN

標準入力からテーブルにデータをコピーします。

1. cyclist_nameテーブルからデータを消去します。

   TRUNCATE cycling.cyclist_name;

2. FROM STDINオプションを使用してコピー入力操作を開始します。

   COPY cycling.cyclist_name FROM STDIN;

   行のプロンプトが[copy]に変わります。

   Using 7 child processes
                 
   Starting copy of cycling.cyclist_name with columns [id, firstname, lastname].
   [Use . on a line by itself to end input]
   [copy] 

3. [copy]プロンプトの次にフィールド値のコンマ区切りリストを入力します。データの最終行にはピリオドを入力します。

   [copy] e7cd5752-bc0d-4157-a80f-7523add8dbcd,Anna,VAN DER BREGGEN
   [copy] .

4. Enterキーを押してレコードの処理を開始します。

   Processed: 1 rows; Rate:       0 rows/s; Avg. rate:       0 rows/s
   1 rows imported from 1 files in 36.991 seconds (0 skipped).

5. レコードがインポートされたことを確認します。

   SELECT *
   FROM cycling.cyclist_name;

    id                                   | firstname | lastname
   --------------------------------------+-----------+-----------------
    e7cd5752-bc0d-4157-a80f-7523add8dbcd |      Anna | VAN DER BREGGEN
     
   (1 rows)