COPY

CSV（コンマ区切り値またはコンマ区切りテキスト・ファイル）をインポートおよびエクスポートするCQLシェル・コマンド。

• COPY TOは、テーブルのデータをCSVファイルにエクスポートします。各行は区切り文字で区切られたフィールドを含むターゲット・ファイル内の行に書き込まれます。カラム名が指定されていない場合は、すべてのフィールドがエクスポートされます。カラムを削除するには、カラム・リストを指定します。
• COPY FROMは、CSVファイルのデータを既存のテーブルにインポートします。ソース・ファイル内の各行が行としてインポートされます。データセット内のすべての行に同じ数のフィールドが含まれており、PRIMARY KEYフィールドに値が存在する必要があります。このプロセスはPRIMARY KEYを確認し、既存のレコードを更新します。HEADER = falseで、カラム名が指定されていない場合は、フィールドが決定論的な順番でインポートされます。カラム名が指定されている場合、フィールドはその順番でインポートされます。欠落しているフィールドや空のフィールドはnullに設定されます。ソースのフィールド数がターゲット・テーブルのフィールド数を超えることはできませんが、少なくてもかまいません。

構文

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

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

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

文で設定されているコピー・オプションは、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ファイルが現在の作業ディレクトリーの上のディレクトリーに作成されます。ファイルが既に存在する場合は、上書きされます。

   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を別のCSVファイルにコピーします。

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

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

   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 ;

   行がインポートされます。姓がデータセットに含まれていなかったため、すべての行がnullに設定されます。

   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 ;

   姓のフィールドがインポートしたデータ・セットに含まれていなかったため、姓には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がすべてのレコードについて照合され、姓が更新されます。

   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. 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] e7cd5752-bc0d-4157-a80f-7523add8dbcd,Anna,VAN DER BREGGEN
   [copy] .

4. 最終行にピリオドを挿入した後、Return（または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)