无法使用 Cassandra 的 C 驱动程序连接到键空间

Question

我有以下代码用于插入 Cassandra 的简单查询。我在这里尝试使用准备好的语句，因为常规语句无法在表time_demo 的时间戳列中插入时间戳。

      CassFuture* connect_future = NULL;
      CassCluster* cluster = cass_cluster_new();
      CassSession* session = cass_session_new();
      char* hosts = "127.0.0.1";

      time_t rt= time(NULL);
      struct tm * timeinfo;

      timeinfo = localtime ( &rt );
      char lt[20];
      strftime(lt, sizeof(lt), "%Y-%m-%d %T", timeinfo);

      /* Add contact points */
      cass_cluster_set_contact_points(cluster, hosts);

      /* Provide the cluster object as configuration to connect the session  with a specified keyspace*/
      connect_future = cass_session_connect_keyspace(session, cluster,"test_keyspace");

      //After this line program exits
      CassFuture* prepare_future
          = cass_session_prepare(session, "INSERT INTO time_demo(id,time) VALUES(now(),?);");

在最后一行之后，我的程序突然结束。我想连接到键空间test_keyspace，同时还使用准备好的语句。我猜该程序因此而被终止，因为我没有为它正确编写代码。

谁能指出我在这里犯的错误？我正在为 C 使用 Cassandra 2.13 驱动程序。

Answer 1

您需要等到连接建立 - 最简单的方法是使用类似的东西：

CassError rc = cass_future_error_code(connect_future);

在你得到驱动程序的OK后，你可以开始准备查询，但你还需要等待准备的结果，可能也是cass_future_error_code，或者其他方式。

否则，您会触发 2 个异步操作而不等待结果，然后您的程序就会完成 - C/C++ 驱动程序在设计上是异步的。正确使用方法请参考Getting Started文档。