seperate quorum

Author: PeterChen13579

src/data/cassandra/impl/Cluster.cpp

@@ -61,8 +61,12 @@ Cluster::Cluster(Settings const& settings) : ManagedObject{cass_cluster_new(), k
     cass_cluster_set_request_timeout(*this, settings.requestTimeout.count());
 
     // TODO: AWS keyspace reads should be local_one to save cost
-    if (settings.provider == "aws_keyspace") {
+    if (settings.provider == toString(cassandra::impl::Provider::Keyspace)) {
         if (auto const rc = cass_cluster_set_consistency(*this, CASS_CONSISTENCY_LOCAL_QUORUM); rc != CASS_OK) {
+            throw std::runtime_error(fmt::format("Error setting keyspace consistency: {}", cass_error_desc(rc)));
+        }
+    } else {
+        if (auto const rc = cass_cluster_set_consistency(*this, CASS_CONSISTENCY_QUORUM); rc != CASS_OK) {
             throw std::runtime_error(fmt::format("Error setting cassandra consistency: {}", cass_error_desc(rc)));
         }
     }

src/data/cassandra/impl/Statement.hpp

@@ -58,15 +58,17 @@ class Statement : public ManagedObject<CassStatement> {
     explicit Statement(std::string_view query, Args&&... args)
         : ManagedObject{cass_statement_new_n(query.data(), query.size(), sizeof...(args)), kDELETER}
     {
-        cass_statement_set_consistency(*this, CASS_CONSISTENCY_LOCAL_QUORUM);
-        cass_statement_set_is_idempotent(*this, cass_true);
+        // TODO: figure out how to set consistency level in config
+        // NOTE: Keyspace doesn't support QUORUM at write level
+        // cass_statement_set_consistency(*this, CASS_CONSISTENCY_LOCAL_QUORUM);
+        // cass_statement_set_is_idempotent(*this, cass_true);
         bind<Args...>(std::forward<Args>(args)...);
     }
 
     /* implicit */ Statement(CassStatement* ptr) : ManagedObject{ptr, kDELETER}
     {
-        cass_statement_set_consistency(*this, CASS_CONSISTENCY_LOCAL_QUORUM);
-        cass_statement_set_is_idempotent(*this, cass_true);
+        // cass_statement_set_consistency(*this, CASS_CONSISTENCY_LOCAL_QUORUM);
+        // cass_statement_set_is_idempotent(*this, cass_true);
     }
 
     /**