Cassandra - 建立資料

---

---

在表中建立資料

您可以使用INSERT命令將資料插入表的行列中。以下是建立表中資料的語法。

INSERT INTO <tablename>
(<column1 name>, <column2 name>....)
VALUES (<value1>, <value2>....)
USING <option>

示例

讓我們假設有一個名為emp的表，其列為(emp_id, emp_name, emp_city, emp_phone, emp_sal)，您需要將以下資料插入emp表。

使用以下命令將資料填充到表中。

cqlsh:tutorialspoint> INSERT INTO emp (emp_id, emp_name, emp_city,
   emp_phone, emp_sal) VALUES(1,'ram', 'Hyderabad', 9848022338, 50000);

cqlsh:tutorialspoint> INSERT INTO emp (emp_id, emp_name, emp_city,
   emp_phone, emp_sal) VALUES(2,'robin', 'Hyderabad', 9848022339, 40000);

cqlsh:tutorialspoint> INSERT INTO emp (emp_id, emp_name, emp_city,
   emp_phone, emp_sal) VALUES(3,'rahman', 'Chennai', 9848022330, 45000);

驗證

插入資料後，使用SELECT語句驗證資料是否已插入。如果您使用SELECT語句驗證emp表，則會得到以下輸出。

cqlsh:tutorialspoint> SELECT * FROM emp;

 emp_id |  emp_city | emp_name |  emp_phone | emp_sal
--------+-----------+----------+------------+---------
      1 | Hyderabad |      ram | 9848022338 | 50000
      2 | Hyderabad |    robin | 9848022339 | 40000
      3 |   Chennai |   rahman | 9848022330 | 45000
 
(3 rows)

在這裡您可以看到表已填充我們插入的資料。

使用Java API建立資料

您可以使用Session類的execute()方法在表中建立資料。請按照以下步驟使用java API在表中建立資料。

步驟1：建立Cluster物件

建立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");

使用新的builder物件，建立一個叢集物件。為此，您在Cluster.Builder類中有一個名為build()的方法。以下程式碼顯示瞭如何建立一個叢集物件。

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

您可以使用一行程式碼構建叢集物件，如下所示。

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

步驟2：建立Session物件

使用Cluster類的connect()方法建立Session物件的例項，如下所示。

Session session = cluster.connect( );

此方法建立一個新的會話並對其進行初始化。如果您已經有keyspace，則可以透過將KeySpace名稱以字串格式傳遞給此方法來將其設定為現有keyspace，如下所示。

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

這裡我們使用名為tp的KeySpace。因此，建立會話物件如下所示。

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

步驟3：執行查詢

您可以使用Session類的execute()方法執行CQL查詢。將查詢以字串格式或作為Statement類物件傳遞給execute()方法。您以字串格式傳遞給此方法的任何內容都將在cqlsh上執行。

在以下示例中，我們正在將資料插入名為emp的表中。您必須將查詢儲存在一個字串變數中，然後將其傳遞給execute()方法，如下所示。

String query1 = “INSERT INTO emp (emp_id, emp_name, emp_city, emp_phone, emp_sal)
   VALUES(1,'ram', 'Hyderabad', 9848022338, 50000);” ;
 
String query2 = “INSERT INTO emp (emp_id, emp_name, emp_city, emp_phone, emp_sal)
   VALUES(2,'robin', 'Hyderabad', 9848022339, 40000);” ;
 
String query3 = “INSERT INTO emp (emp_id, emp_name, emp_city, emp_phone, emp_sal)
   VALUES(3,'rahman', 'Chennai', 9848022330, 45000);” ;
 
session.execute(query1);
session.execute(query2);
session.execute(query3); 

以下是使用Java API在Cassandra中將資料插入表的完整程式。

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

public class Create_Data {

   public static void main(String args[]){

      //queries
      String query1 = "INSERT INTO emp (emp_id, emp_name, emp_city, emp_phone,  emp_sal)"
		
         + " VALUES(1,'ram', 'Hyderabad', 9848022338, 50000);" ;
                             
      String query2 = "INSERT INTO emp (emp_id, emp_name, emp_city,
         emp_phone, emp_sal)"
      
         + " VALUES(2,'robin', 'Hyderabad', 9848022339, 40000);" ;
                             
      String query3 = "INSERT INTO emp (emp_id, emp_name, emp_city, emp_phone, emp_sal)"
       
         + " VALUES(3,'rahman', 'Chennai', 9848022330, 45000);" ;

      //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(query1);
        
      session.execute(query2);
        
      session.execute(query3);
        
      System.out.println("Data created");
   }
}

使用類名後跟.java儲存上述程式，瀏覽到儲存它的位置。編譯並執行程式，如下所示。

$javac Create_Data.java
$java Create_Data

在正常情況下，它應該產生以下輸出：

Data created