From d2caf82ad16f8d31db6afdd69383ba1c04e02c32 Mon Sep 17 00:00:00 2001 From: Trygve Laugstøl Date: Fri, 7 Aug 2015 17:39:23 +0200 Subject: o More explicit bind functions, it is useful because Cassandra is touchy with its types. o Saving the topic and message id in the raw record table. o Dropping the mosquittopp, it is not very useful. --- cassandra_support.h | 17 +++++++++++------ 1 file changed, 11 insertions(+), 6 deletions(-) (limited to 'cassandra_support.h') diff --git a/cassandra_support.h b/cassandra_support.h index 3f49be2..2e3ea19 100644 --- a/cassandra_support.h +++ b/cassandra_support.h @@ -395,32 +395,37 @@ public: cassandra_statement &operator=(const cassandra_statement &) = delete; - void bind(size_t i, const string &value) { + void bind_string(size_t i, const string &value) { auto err = cass_statement_bind_string(statement, i, value.c_str()); assert_ok("cass_statement_bind_string", err); } - void bind(size_t i, const char *value) { + void bind_string(size_t i, const char *value) { auto err = cass_statement_bind_string(statement, i, value); assert_ok("cass_statement_bind_string", err); } - void bind(size_t i, const cass_int64_t value) { + void bind_int32(size_t i, const cass_int32_t value) { + auto err = cass_statement_bind_int32(statement, i, value); + assert_ok("cass_statement_bind_int32", err); + } + + void bind_int64(size_t i, const cass_int64_t value) { auto err = cass_statement_bind_int64(statement, i, value); assert_ok("cass_statement_bind_int64", err); } - void bind(size_t i, const CassCollection *value) { + void bind_collection(size_t i, const CassCollection *value) { auto err = cass_statement_bind_collection(statement, i, value); assert_ok("cass_statement_bind_collection", err); } - void bind(size_t i, const cassandra_collection &value) { + void bind_collection(size_t i, const cassandra_collection &value) { auto err = cass_statement_bind_collection(statement, i, value); assert_ok("cass_statement_bind_collection", err); } - void bind(size_t i, const std::vector &&values) { + void bind_list(size_t i, const std::vector &&values) { cassandra_collection c(CassCollectionType::CASS_COLLECTION_TYPE_LIST, values.size()); for (const auto &value : values) { -- cgit v1.2.3