Cassandra-テーブルの作成

テーブルを作成する

コマンド CREATE TABLE を使用してテーブルを作成できます。以下に、テーブルを作成するための構文を示します。

構文

CREATE (TABLE | COLUMNFAMILY) <tablename>
('<column-definition>' , '<column-definition>')
(WITH <option> AND <option>)

列の定義

以下に示すように列を定義できます。

column name1 data type,
column name2 data type,

example:

age int,
name text

主キー

主キーは、行を一意に識別するために使用される列です。したがって、テーブルの作成中は主キーの定義が必須です。主キーは、テーブルの1つ以上の列で構成されます。以下に示すように、テーブルの主キーを定義できます。

CREATE TABLE tablename(
   column1 name datatype PRIMARYKEY,
   column2 name data type,
   column3 name data type.
   )

or

CREATE TABLE tablename(
   column1 name datatype PRIMARYKEY,
   column2 name data type,
   column3 name data type,
   PRIMARY KEY (column1)
   )

例

以下は、cqlshを使用してCassandraでテーブルを作成する例です。ここにいる-

キースペースfinddevguidesの使用
emp という名前のテーブルを作成する

従業員の名前、ID、市、給与、電話番号などの詳細が含まれます。従業員IDは主キーです。

cqlsh> USE finddevguides;
cqlsh:finddevguides>; CREATE TABLE emp(
   emp_id int PRIMARY KEY,
   emp_name text,
   emp_city text,
   emp_sal varint,
   emp_phone varint
   );

検証

selectステートメントは、スキーマを提供します。次に示すように、selectステートメントを使用してテーブルを確認します。

cqlsh:finddevguides> select * from emp;

 emp_id | emp_city | emp_name | emp_phone | emp_sal
--------+----------+----------+-----------+---------

(0 rows)

ここで、指定された列で作成されたテーブルを観察できます。キースペースfinddevguidesを削除したため、キースペースリストに表示されません。

Java APIを使用したテーブルの作成

Sessionクラスのexecute（）メソッドを使用してテーブルを作成できます。以下の手順に従って、Java APIを使用してテーブルを作成します。

ステップ1：クラスターオブジェクトを作成する

まず、以下に示すように、 com.datastax.driver.core パッケージの Cluster.builder クラスのインスタンスを作成します。

//Creating Cluster.Builder object
Cluster.Builder builder1 = Cluster.builder();

*Cluster.Builder* オブジェクトの* addContactPoint（）*メソッドを使用して、接点（ノードのIPアドレス）を追加します。 このメソッドは *Cluster.Builder* を返します。

//Adding contact point to the Cluster.Builder object
Cluster.Builder builder2 = build.addContactPoint( "127.0.0.1" );

新しいビルダーオブジェクトを使用して、クラスターオブジェクトを作成します。そのためには、 Cluster.Builder クラスに* build（）*というメソッドがあります。次のコードは、クラスターオブジェクトを作成する方法を示しています。

//Building a cluster
Cluster cluster = builder.build();

以下に示すように、1行のコードを使用してクラスターオブジェクトを構築できます。

Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();

ステップ2：セッションオブジェクトを作成する

以下に示すように、 Cluster クラスの* connect（）*メソッドを使用してSessionオブジェクトのインスタンスを作成します。

Session session = cluster.connect( );

このメソッドは、新しいセッションを作成して初期化します。キースペースがすでにある場合は、以下に示すように、キースペース名を文字列形式でこのメソッドに渡すことにより、既存のキースペースに設定できます。

Session session = cluster.connect(“ Your keyspace name ” );

ここでは、 tp という名前のキースペースを使用しています。したがって、次のようにセッションオブジェクトを作成します。

Session session = cluster.connect(“ tp” );

ステップ3：クエリを実行する

Sessionクラスのexecute（）メソッドを使用して、CQLクエリを実行できます。クエリを文字列形式で、またはStatementクラスオブジェクトとしてexecute（）メソッドに渡します。文字列形式でこのメソッドに渡すものはすべて、cqlshで実行されます。

次の例では、* emp。*という名前のテーブルを作成しています。以下に示すように、クエリを文字列変数に保存し、execute（）メソッドに渡す必要があります。

//Query
String query = "CREATE TABLE emp(emp_id int PRIMARY KEY, "
   + "emp_name text, "
   + "emp_city text, "
   + "emp_sal varint, "
   + "emp_phone varint );";
session.execute(query);

以下は、Java APIを使用してCassandraでキースペースを作成および使用するための完全なプログラムです。

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Session;

public class Create_Table {

   public static void main(String args[]){

     //Query
      String query = "CREATE TABLE emp(emp_id int PRIMARY KEY, "
         + "emp_name text, "
         + "emp_city text, "
         + "emp_sal varint, "
         + "emp_phone varint );";

     //Creating Cluster object
      Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();

     //Creating Session object
      Session session = cluster.connect("tp");

     //Executing the query
      session.execute(query);

      System.out.println("Table created");
   }
}

クラス名の後に.javaを付けて上記のプログラムを保存し、保存されている場所を参照します。以下に示すように、プログラムをコンパイルして実行します。

$javac Create_Table.java
$java Create_Table

通常の状態では、次の出力を生成する必要があります-

Table created

Cassandra-create-table