SELECT

データの場所の特定とクラスター化カラムによるフィルター

partition_conditions

データベースでは、セカンダリ・インデックスまたは検索インデックスをクエリーする場合を除き、すべてのパーティションを制限する必要があります。次の演算子でパーティション・キー・カラムを特定するロジック文を使用します。

• 等号（=）：任意のパーティション・キー・カラム。
• IN：複数のパーティションを検索するには、パーティション・キーの最後のカラムに制限します。
• トークンの範囲（>=、<=、>および<）：完全にトークン化されたパーティション・キー（TOKEN関数の引数として順番に指定されたすべてのPKカラム）。トークン範囲を使用して特定のノードに格納したデータをスキャンします。

注: セカンダリ・インデックス・クエリーでは、パーティション・キー・ロジック文で使用できる演算子は等価のみです。

使用例と手順については、「パーティション・キー」を参照してください。

clustering_conditions

クラスター化セグメントを特定するロジック文を使用します。クラスター化カラムは、複数のクラスター化カラムがある場合はネストされる、格納データのソート順を設定します。パーティション・キーの評価後、データベースは、1番目（最上位）、2番目、3番目などネストされた順序でクラスター化した文を評価します。

テーブルにクラスター化カラムが1つしかない場合、ロジック文ではすべての演算子がサポートされます。テーブルに複数のクラスター化カラムがある場合にテーブルのパーティション内のデータを効率よく見つけるには、次の制限を適用します。

• 最上位のクラスター化カラム：
  • 等号（=）
  • IN
• 最後のクラスター化カラムの文：すべての演算子および複数のカラムの比較

クラスター化カラムのロジック文では、複数のクラスター化セグメントに及ぶスライスを返すこともできます。

(column1, column2, ...) operator (value1, value2, ...)
[ AND (column1, column2, ...) operator (value1, value2, ...)]

スライスを使用すると、対応する値のある行を特定し、その前、後および間にあるすべての行を返すことができます（2つのスライス文が含まれている場合）。

使用例と手順については、「クラスター化カラム」を参照してください。

カラム別名の使用

選択項目リストに関数やその他の複雑な式が含まれている場合、別名を使用すると出力が読みやすくなります。次の例では、dateOf(created_at)関数とblobAsText(content)関数に別名を適用します。

SELECT event_id, 
  dateOf(created_at) AS creation_date,
  blobAsText(content) AS content 
  FROM timeline;

出力では、これらのカラムにわかりやすい名前のラベルを付けます。

event_id                | creation_date            | content
-------------------------+--------------------------+----------------
 550e8400-e29b-41d4-a716 | 2013-07-26 10:44:33+0200 | Some stuff

FROMを使用したソース・テーブルの指定

次のSELECT文の例では、systemキースペースのIndexInfoテーブルの行数が返されます

SELECT COUNT(*) 
FROM system.IndexInfo;

LIMITを使用した、返される行数の制御

LIMITオプションは、クエリーが返す最大行数を設定します。

SELECT lastname 
FROM cycling.cyclist_name 
LIMIT 50000;

たとえば、クエリーが105,291行と一致しても、データベースは最初の50,000行のみを返します。

cqlshシェルのデフォルトの行数は10,000に制限されています。DataStax Enterpriseサーバーとネイティブ・プロトコルでは、返される行の数は制限されませんが、誤った形式のクエリーによってシステムが不安定になるのを防ぐためにタイムアウトが適用されます。

パーティションの選択

partition_column = value

partition_column IN(value1,value2[,...])

partition_column1 = value1 
AND partition_column2 = value2 [AND ...])

PER PARTITION LIMITを使用した、返される行数の制御

DataStax Enterprise 5.1以降では、PER PARTITION LIMITオプションを使用して、クエリーで各パーティションから返される行数の最大数を設定します。たとえば、複数のパーティションにデータをソートするテーブルを作成します。

CREATE TABLE cycling.rank_by_year_and_name ( 
     race_year int, 
     race_name text, 
     cyclist_name text, 
     rank int, 
     PRIMARY KEY ((race_year, race_name), rank) );

データを挿入した後、テーブルには以下の値が格納されます。

race_year | race_name                                  | rank | cyclist_name
-----------+--------------------------------------------+------+----------------------
      2014 |                        4th Tour of Beijing |    1 |    Phillippe GILBERT
      2014 |                        4th Tour of Beijing |    2 |        Daniel MARTIN
      2014 |                        4th Tour of Beijing |    3 | Johan Esteban CHAVES
      2015 |   Giro d'Italia - Stage 11 - Forli > Imola |    1 |        Ilnur ZAKARIN
      2015 |   Giro d'Italia - Stage 11 - Forli > Imola |    2 |      Carlos BETANCUR
      2015 | Tour of Japan - Stage 4 - Minami > Shinshu |    1 |      Benjamin PRADES
      2015 | Tour of Japan - Stage 4 - Minami > Shinshu |    2 |          Adam PHELAN
      2015 | Tour of Japan - Stage 4 - Minami > Shinshu |    3 |         Thomas LEBAS

レースの年度と名前ごとに上位2名のレーサーを取得するには、SELECT文とPER PARTITION LIMIT 2を使用します。

SELECT * 
FROM cycling.rank_by_year_and_name 
PER PARTITION LIMIT 2;

出力：

race_year | race_name                                  | rank | cyclist_name
-----------+--------------------------------------------+------+-------------------
      2014 |                        4th Tour of Beijing |    1 | Phillippe GILBERT
      2014 |                        4th Tour of Beijing |    2 |     Daniel MARTIN
      2015 |   Giro d'Italia - Stage 11 - Forli > Imola |    1 |     Ilnur ZAKARIN
      2015 |   Giro d'Italia - Stage 11 - Forli > Imola |    2 |   Carlos BETANCUR
      2015 | Tour of Japan - Stage 4 - Minami > Shinshu |    1 |   Benjamin PRADES
      2015 | Tour of Japan - Stage 4 - Minami > Shinshu |    2 |       Adam PHELAN

WHEREを使用したデータのフィルター

WHERE句は、SELECTで返された行をフィルター処理する1つまたは複数の関係を示します。

カラム指定

パーティション・キーでのフィルター

CREATE TABLE cycling.cyclist_career_teams ( id UUID PRIMARY KEY, lastname text, teams set<text> );

SELECT id, lastname, teams 
FROM cycling.cyclist_career_teams 
WHERE id=5b6962dd-3f90-4c93-8f61-eabfa4a803e2;

制限：パーティション・キーを参照する関係は、等価演算子=またはINしか使用できません。IN演算子の詳細については、以下の「例」を参照してください。

クラスター化カラムでのフィルター

パーティション・キーのすべての要素を参照する関係がその前にある場合のみ、クラスター化カラムに対して関係を使用します。

例：

CREATE TABLE cycling.cyclist_points (
   id UUID, 
   firstname text, 
   lastname text, 
   race_title text, 
   race_points int, 
   PRIMARY KEY (id, race_points ));

SELECT sum(race_points) 
FROM cycling.cyclist_points 
WHERE id=e3b19ec4-774a-4d1c-9e5a-decec1e30aac 
      AND race_points > 7;

出力：

 system.sum(race_points)
-------------------------
                     195

(1 rows)

DataStax Enteprise 5.1以降では、インデックスなしのクラスター化カラムでのみフィルター処理するにはALLOW FILTERINGを追加します。次の例ではテーブル定義を含めて、race_start_dateがセカンダリ・インデックスのないクラスター化カラムであることを示しています。

例：

CREATE TABLE cycling.calendar (
   race_id int, 
   race_name text, 
   race_start_date timestamp, 
   race_end_date timestamp, 
   PRIMARY KEY (race_id, race_start_date, race_end_date));

SELECT * 
FROM cycling.calendar 
WHERE race_start_date='2015-06-13' 
ALLOW FILTERING;

出力：

race_id | race_start_date                 | race_end_date                   | race_name
---------+---------------------------------+---------------------------------+----------------
     102 | 2015-06-13 07:00:00.000000+0000 | 2015-06-13 07:00:00.000000+0000 | Tour de Suisse
     103 | 2015-06-13 07:00:00.000000+0000 | 2015-06-17 07:00:00.000000+0000 | Tour de France

パーティション・キーとクラスター化カラムを組み合わせて1つの関係にすることができます。 詳細については、「クラスター化カラムの比較」を参照してください。

インデックス付きカラムでのフィルター

インデックス付きテーブルのSELECTのWHERE句には、インデックス付きカラムに対する等価関係を少なくとも1つ含める必要があります。詳細については、「カラムのインデックスの作成」を参照してください。

IN演算子の使用

等価条件演算子であるINは、可能性のある複数のカラム値をリストするために使用します。次の例では、従業員ID（プライマリ・キー）が105、107、または104である3つの行から、first_nameとlast_nameという2つのカラムを選択します。

SELECT first_name, last_name 
FROM emp 
WHERE empID IN (105, 107, 104);

リストは特定の範囲のコンマ区切りのカラム値で構成できます。

INを使用した、複合プライマリ・キーでのフィルター

CREATE TABLE parts (
   part_type text, 
   part_name text, 
   part_num int, 
   part_year text, 
   serial_num text, 
   PRIMARY KEY ((part_type, part_name), part_num, part_year));

SELECT * 
FROM parts 
WHERE part_type='alloy' AND part_name='hubcap' 
AND part_num=1249 AND part_year IN ('2010', '2015');

SELECT * 
FROM parts 
WHERE part_num=123456 AND part_year IN ('2010', '2015') 
ALLOW FILTERING;

CQLでは、IN句内に空の値リストを使用できるため、Javaドライバー・アプリケーションで空の配列を引数としてIN句に渡す場合に役立ちます。

INを使用すべきでない場合

ほとんどの条件下では、パーティション・キーの関係にINを使用することは推奨されません。値のリストを処理するには、SELECTで多数のノードをクエリーする必要がある場合があり、それによってパフォーマンスが低下します。たとえば、ノードが30、レプリケーション係数が3、整合性レベルがLOCAL_QUORUMの1つのローカル・データ・センター・クラスターがあるとします。パーティション・キーを1つ指定したクエリーは2つのノードに送られます。しかし、SELECTでIN条件が使用されている場合、キーがトークン範囲のどこに位置するかにより、演算には最大で20のノードが含まれる可能性があります。

クラスター化カラムでINを使用する方が安全です。「Cassandra Query Patterns: Not using the “in” query for multiple partitions」でINの使用に関するその他のロジックの詳細を参照してください。

コレクションでのフィルター

クエリーはコレクション全体を取得できます。また、コレクション・カラムを対象としてインデックスを作成してから、WHERE句にCONTAINS条件を指定してコレクションに属する特定の値のデータをフィルター処理することも、CONTAINS KEYを使用してキーでフィルター処理することもできます。次の例では、playlistsテーブルのタグのコレクションを示します。クエリーによってタグのインデックスを作成し、次にタグ・セットの'blues'でフィルター処理できます。

SELECT album, tags 
FROM playlists 
WHERE tags CONTAINS 'blues';

SELECT * 
FROM playlists 
WHERE venue 
CONTAINS 'The Fillmore';

SELECT * 
FROM playlists 
WHERE venue CONTAINS KEY '2014-09-22 22:00:00-0700';

マップのエントリーのフィルター

CREATE INDEX blist_idx 
ON cycling.birthday_list (ENTRIES(blist));

SELECT * 
FROM cycling.birthday_list 
WHERE blist['age'] = '23';

frozenのフル・コレクションのフィルター

CREATE INDEX rnumbers_idx 
ON cycling.race_starts (FULL(rnumbers));

SELECT * 
FROM cycling.race_starts 
WHERE rnumbers = [39,7,14];

範囲関係

DataStax Enterpriseは&gt;または&lt;比較をサポートしていますが、指定されたパーティション・キーのクラスター化カラムに対する条件は、連続した行のセットを選択できるフィルターに制限されます。

CREATE TABLE ruling_stewards (
  steward_name text,
  king text,
  reign_start int,
  event text,
  PRIMARY KEY (steward_name, king, reign_start)
); 

SELECT * FROM ruling_stewards
WHERE king = 'Brego'
  AND reign_start >= 2450
  AND reign_start < 2500 
ALLOW FILTERING;

 steward_name | king  | reign_start | event
--------------+-------+-------------+--------------------
      Boromir | Brego |        2477 |   Attacks continue
       Cirion | Brego |        2489 | Defeat of Balchoth
       
(2 rows)

連続した行のセットを選択できるようにするには、WHERE句でプライマリ・キーのkingコンポーネントに等価条件を適用する必要があります。ALLOW FILTERING句も必要です。 ALLOW FILTERINGを使用すると、任意の条件を使用してクラスター化カラムをクエリーできます。

Bad Request: Cannot execute this query as it might involve data filtering and thus may have unpredictable performance. If you want to execute this query despite the performance unpredictability, use ALLOW FILTERING.

Select * 
FROM ruling_stewards
WHERE king = 'none'
  AND reign_start >= 1500
  AND reign_start < 3000 
LIMIT 10 
ALLOW FILTERING;

複合プライマリ・キーの使用と結果のソート

ORDER BY句は単一のカラムにのみ使用できます。そのカラムは、複合PRIMARY KEYの2番目のカラムである必要があります。これは、プライマリ・キーに複数のカラム・コンポーネントがあるテーブルにも当てはまります。順序はASCキーワードまたはDESCキーワードを使用して昇順または降順に指定できます（デフォルトは昇順）。

ORDER BY句では、別名ではなく実際の名前を使用してカラムを参照してください。

たとえば、複合プライマリ・キーを使用するplaylistsテーブルを設定し、以下のクエリーを使用してsong_orderで順序が指定された特定のプレイリストに関する情報を取得します。select式にORDER BYカラムを含める必要はありません。

SELECT * FROM playlists 
WHERE id = 62c36092-82a1-3a00-93d1-46196ee77204
ORDER BY song_order DESC 
LIMIT 50;

出力：

または、プレイリストのアーティストにインデックスを作成し、以下のクエリーを使用してそのプレイリストでFu Manchuの曲のタイトルを取得します。

CREATE INDEX ON playlists(artist);

SELECT album, title 
FROM playlists 
WHERE artist = 'Fu Manchu';

出力：

集計の計算

DataStax Enterpriseは、SELECT文に集計値を返す標準の組み込み関数を備えています。

COUNT()を使用した、カラムのNULL以外の値のカウントの取得

SELECT式でCOUNT(column_name)を使用すると、カラムに含まれるNULL以外の値の数を返します。

たとえば、cyclist_nameテーブル内の姓の数をカウントします。

SELECT COUNT(lastname) 
FROM cycling.cyclist_name;

COUNT()を使用した、条件に一致する行と集計値の取得

SELECT式でCOUNT(*)を使用すると、クエリーに一致した行の数を返します。COUNT(1)を使用しても同じ結果を得ることができます。他の集計関数またはカラムと組み合わせてCOUNT(*)またはCOUNT(1)を使用できます。

次の例は、usersテーブルの行数を返します。

SELECT COUNT(*) 
FROM users;

次の例は、usersテーブルの行数をカウントし、pointsの最大値を計算します。

SELECT name, max(points), COUNT(*) 
FROM users; 

カラムの最大値および最小値の取得

SELECT MAX(points) 
FROM cycling.cyclist_category;

出力：

SELECT category, MIN(points) 
FROM cycling.cyclist_category 
WHERE category = 'GC';

出力：

数値のカラムの合計または平均の取得

SELECT文でSUMまたはAVGを使用した場合、DataStax Enterpriseではカラム内のすべての値の合計または平均が計算されます。

注: 返された行にAVG集計で参照されるカラムのNull値が含まれている場合、その行は行数に含まれますが、平均の計算には0値が使用されます。

注: sum関数とavg関数はtext型、uuid型またはdate型のフィールドには使用できません。

書き込みが発生した日時の取得

カラムにWRITETIME関数が適用されると、カラムがデータベースに書き込まれた日時がマイクロ秒単位で返されます。

たとえば、姓がJonesというユーザーのfirst_nameカラムに書き込みが発生した日時を取得するには、次のように入力します。

SELECT WRITETIME (first_name) 
FROM users 
WHERE last_name = 'Jones';

 writetime(first_name)
-----------------------
 1353010594789000

マイクロ秒単位のWRITETIME出力を変換すると、「November 15, 2012 at 12:16:34 GMT-8」になります。

カラムのTime To Liveの取得

INSERT INTO cycling.calendar (race_id, race_name, race_start_date, race_end_date) 
VALUES (200, 'placeholder', '2015-05-27', '2015-05-27') 
USING TTL;

UPDATE cycling.calendar 
USING TTL 300 
SET race_name = 'dummy' 
WHERE race_id = 200 
  AND race_start_date = '2015-05-27' 
  AND race_end_date = '2015-05-27';

SELECT TTL(race_name) 
FROM cycling.calendar 
WHERE race_id=200;

 ttl(race_name)
----------------
            276

(1 rows)

JSON形式の値の取得

このオプションは、DataStax Enterprise 5.0以降で使用できます。詳細については、「JSONを使用した取得」を参照してください。