0

我有以下代码用于插入 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 驱动程序。

4

1 回答 1

1

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

CassError rc = cass_future_error_code(connect_future);

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

否则，您触发 2 个异步操作并且不等待结果，并且您的程序完成 - C/C++ 驱动程序在设计上是异步的。请参阅介绍如何正确使用它的入门文档。

于 2019-09-06T11:45:23.087 回答