使用Java从Cassandra读取数据

问题描述

 My sample  cassandra table looks like

id | article_read | last_hours | name
----+-----------------------------------
5  |    [4, 5, 6]  |          5  | shashank
10 | [12, 88, 32]  |          1  |      sam
8  |    [4, 5, 6]  |          8  |     aman
7  |       [5, 6]  |          7  |    ashif
6  |    [4, 5, 6]  |          6  |     amit
9  |    [4, 5, 6]  |          9  |  shekhar

我的Java代码使用cql查询从Cassandra表读取数据，

My java code to read data from Cassandra table using cql queries,

     Scanner sc = new Scanner(System.in);
     System.out.println("enter name1 ");
     String name1 = sc.nextLine();
     System.out.println("enter name2");
     String name2 = sc.nextLine();

     Cluster cluster =    Cluster.builder().addContactPoint("127.0.0.1").build();
     Session session = cluster.connect("tp");

     PreparedStatement queryStmt = session.prepare("select article_read  from bat where name = ?");
     ResultSet result1 = session.execute(queryStmt.bind(name1));

     ResultSet result2 = session.execute(queryStmt.bind(name2));
      System.out.println(result1.all());
      System.out.println(result2.all());

       if(result1.equals(result2))
      {
      System.out.println("100% sentiment ");
      }
      else
      {
       System.out.println("no sentiment ");
    }
}

看看我的代码，它正在运行，但是当我在将name1，name2 shashank和aman赋予其100％，但是给shashank和ashif时，结果再次达到100％匹配。

look at my code ,its running but when i am putting name1,name2 shashank and aman its giving 100 % but when giving shashank and ashif result is again 100% match..

推荐答案

使用

Use PreparedStatement

首先仅如下一次准备查询：

First prepared the query only once like below :

//Prepared only once.
PreparedStatement queryStmt = session.prepare("select * from bat where name = ?");

然后您可以在任意时间使用它，如下所示：

Then you can use it any number of time like below :

ResultSet result1 = session.execute(queryStmt.bind("shashank"));
ResultSet result2 = session.execute(queryStmt.bind("aman"));

---

已编辑

---

Edited

try (Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build(); Session session = cluster.connect("test")) {
    Scanner sc = new Scanner(System.in);
    System.out.println("enter name1 ");
    String name1 = sc.nextLine();
    System.out.println("enter name2");
    String name2 = sc.nextLine();

    PreparedStatement queryStmt = session.prepare("select article_read from bat where name = ?");
    ResultSet result1 = session.execute(queryStmt.bind(name1));
    ResultSet result2 = session.execute(queryStmt.bind(name2));


    if (result1.one().getList("article_read", Integer.class).equals(result2.one().getList("article_read", Integer.class))) {
        System.out.println("100% sentiment ");
    } else {
        System.out.println("no sentiment ");
    }
}

这篇关于使用Java从Cassandra读取数据的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！