Cassandra 讀取數(shù)據(jù)

使用選擇子句讀取數(shù)據(jù)

SELECT子句用于從Cassandra中的表讀取數(shù)據(jù)。使用此子句，您可以讀取整個表，單個列或特定單元格。下面給出了SELECT子句的語法。

SELECT FROM <tablename>

示例

假設(shè)在名為emp的鍵空間中有一個具有以下詳細(xì)信息的表：

以下示例顯示如何使用SELECT子句讀取整個表。這里我們讀一個表emp。

cqlsh:tutorialspoint> select * from emp;

 emp_id |  emp_city | emp_name |  emp_phone | emp_sal
--------+-----------+----------+------------+---------
      1 | Hyderabad |   ram    | 9848022338 | 50000
      2 | null      |   robin  | 9848022339 | 50000
      3 | Chennai   |   rahman | 9848022330 | 50000
      4 | Pune      |   rajeev | 9848022331 | 30000
		
(4 rows)

讀取必需的列

以下示例顯示如何讀取表中的特定列。

cqlsh:tutorialspoint> SELECT emp_name, emp_sal from emp;

 emp_name | emp_sal
----------+---------
      ram | 50000
    robin | 50000
   rajeev | 30000
   rahman | 50000 
	
(4 rows)

Where子句

使用WHERE子句，可以對必需的列設(shè)置約束。其語法如下：

SELECT FROM <table name> WHERE <condition>;

注意：WHERE子句只能用于作為主鍵的一部分或在其上具有輔助索引的列。

在以下示例中，我們正在讀取薪水為50000的員工的詳細(xì)信息。首先，將輔助索引設(shè)置為列emp_sal。

cqlsh:tutorialspoint> CREATE INDEX ON emp(emp_sal);
cqlsh:tutorialspoint> SELECT * FROM emp WHERE emp_sal=50000;

 emp_id |  emp_city | emp_name |  emp_phone | emp_sal
--------+-----------+----------+------------+---------
      1 | Hyderabad |      ram | 9848022338 | 50000
      2 |      null |    robin | 9848022339 | 50000
      3 |   Chennai |   rahman | 9848022330 | 50000

使用Java API讀取數(shù)據(jù)

您可以使用Session類的execute（）方法從表中讀取數(shù)據(jù)。按照下面給出的步驟在Java API的幫助下使用批處理語句執(zhí)行多個語句。

第1步：創(chuàng)建集群對象

創(chuàng)建一個名為com.datastax.driver.core的Cluster.builder類的實(shí)例，如下所示。

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

使用Cluster.Builder對象的addContactPoint（）方法添加聯(lián)系點(diǎn)（節(jié)點(diǎn)的IP地址）。此方法返回Cluster.Builder。

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

使用新的構(gòu)建器對象，創(chuàng)建一個集群對象。為此，在Cluster.Builder類中有一個名為build（）的方法。使用以下代碼創(chuàng)建集群對象。

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

您可以使用單行代碼構(gòu)建集群對象，如下所示。

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

第2步：創(chuàng)建會話對象

使用Cluster類的connect（）方法創(chuàng)建一個Session對象的實(shí)例，如下所示。

Session session = cluster.connect( );

此方法創(chuàng)建一個新會話并初始化它。如果您已經(jīng)有一個鍵空間，那么您可以通過將KeySpace名稱以字符串格式設(shè)置為現(xiàn)有鍵空間，此方法如下所示。

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

這里我們使用KeySpace稱為tp。因此，創(chuàng)建會話對象如下所示。

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

第3步：執(zhí)行查詢

您可以使用Session類的execute（）方法執(zhí)行CQL查詢。將查詢以字符串格式或Statement類對象傳遞給execute（）方法。無論您以字符串格式傳遞給此方法將在cqlsh上執(zhí)行。

在這個例子中，我們從emp表中檢索數(shù)據(jù)。將查詢存儲在字符串中，并將其傳遞給會話類的execute（）方法，如下所示。

String query = ”SELECT 8 FROM emp”;
session.execute(query);

使用Session類的execute（）方法執(zhí)行查詢。

第4步：獲取ResultSet對象

select查詢將以ResultSet對象的形式返回結(jié)果，因此將結(jié)果存儲在RESULTSET類的對象中，如下所示。

ResultSet result = session.execute( );

下面給出的是從表中讀取數(shù)據(jù)的完整程序。

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

public class Read_Data {

   public static void main(String args[])throws Exception{
    
      //queries
      String query = "SELECT * FROM emp";

      //Creating Cluster object
      Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();
    
      //Creating Session object
      Session session = cluster.connect("tutorialspoint");
    
      //Getting the ResultSet
      ResultSet result = session.execute(query);
    
      System.out.println(result.all());
   }
}

使用類名稱和.java保存上述程序，瀏覽到保存位置。編譯并執(zhí)行程序如下圖所示。

$javac Read_Data.java
$java Read_Data

在正常條件下，它應(yīng)該產(chǎn)生以下輸出：

[Row[1, Hyderabad, ram, 9848022338, 50000], Row[2, Delhi, robin,
9848022339, 50000], Row[4, Pune, rajeev, 9848022331, 30000], Row[3,
Chennai, rahman, 9848022330, 50000]]