阿西河

所有教程

公众号
🌙
阿西河前端的公众号

我的收藏

    最近访问  (文章)

      教程列表

      抓包专区
      测试专区

      Cassandra 读取数据

      使用选择子句读取数据

      SELECT 子句用于从 Cassandra 中的表读取数据。使用此子句,您可以读取整个表,单个列或特定单元格。下面给出了 SELECT 子句的语法。

      SELECT FROM
      
      

      示例

      假设在名为 emp 的键空间中有一个具有以下详细信息的表:

      emp_idemp_nameemp_cityemp_phoneemp_sal
      1ramHyderabad984802233850000
      2robinnull984802233950000
      3rahmanChennai984802233050000
      4rajeevPune984802233130000

      以下示例显示如何使用 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 子句,可以对必需的列设置约束。其语法如下:

      SELECT FROM  WHERE ;
       注意:WHERE子句只能用于作为主键的一部分或在其上具有辅助索引的列。 在以下示例中,我们正在读取薪水为50000的员工的详细信息。首先,将辅助索引设置为列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读取数据您可以使用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();
      您可以使用单行代码构建集群对象,如下所示。Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();
      第2步:创建会话对象使用Cluster类的connect()方法创建一个Session对象的实例,如下所示。Session session = cluster.connect( );
      此方法创建一个新会话并初始化它。如果您已经有一个键空间,那么您可以通过将KeySpace名称以字符串格式设置为现有键空间,此方法如下所示。Session session = cluster.connect(“Your keyspace name”);
      这里我们使用KeySpace称为tp。因此,创建会话对象如下所示。Session session = cluster.connect(“tp”);
      第3步:执行查询您可以使用Session类的execute()方法执行CQL查询。将查询以字符串格式或Statement类对象传递给execute()方法。无论您以字符串格式传递给此方法将在cqlsh上执行。 在这个例子中,我们从emp表中检索数据。将查询存储在字符串中,并将其传递给会话类的execute()方法,如下所示。String query = ”SELECT 8 FROM emp”;
      session.execute(query);
      使用Session类的execute()方法执行查询。第4步:获取ResultSet对象select查询将以ResultSet对象的形式返回结果,因此将结果存储在RESULTSET类的对象中,如下所示。ResultSet result = session.execute( );
      下面给出的是从表中读取数据的完整程序。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保存上述程序,浏览到保存位置。编译并执行程序如下图所示。$javac Read_Data.java
      $java Read_Data
      在正常条件下,它应该产生以下输出:[Row[1, Hyderabad, ram, 9848022338, 50000], Row[2, Delhi, robin,
      9848022339, 50000], Row[4, Pune, rajeev, 9848022331, 30000], Row[3,
      Chennai, rahman, 9848022330, 50000]]
      
      
      
      
      卖前端学习教程

      只需几十元,就能买到培训班的内部教程!开启高薪之路!

      零基础小白阿里P7的教程都有!

      同时长期收购所有培训班的前端教程

      目录
      目录