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. --- sm-mqtt-consumer.cpp | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'sm-mqtt-consumer.cpp') diff --git a/sm-mqtt-consumer.cpp b/sm-mqtt-consumer.cpp index 5a0a23e..778eddf 100644 --- a/sm-mqtt-consumer.cpp +++ b/sm-mqtt-consumer.cpp @@ -137,14 +137,14 @@ private: cassandra_future2* insert_into_sm_by_day(cassandra_session *session, device_measurement &&measurement) { cassandra_statement stmt("INSERT INTO sm_by_day(device, day, timestamp, sensors) VALUES (?, ?, ?, ?);", 4); - stmt.bind(0, measurement.device); + stmt.bind_string(0, measurement.device); std::time_t t = system_clock::to_time_t(measurement.timestamp); char day[100]; std::strftime(day, sizeof(day), "%Y-%m-%d", std::localtime(&t)); - stmt.bind(1, day); + stmt.bind_string(1, day); - stmt.bind(2, measurement.timestamp.time_since_epoch().count()); + stmt.bind_int64(2, measurement.timestamp.time_since_epoch().count()); cassandra_collection sensors(CASS_COLLECTION_TYPE_LIST, measurement.sensors.size()); for_each(measurement.sensors.cbegin(), measurement.sensors.cend(), [&](auto sensor) { @@ -154,7 +154,7 @@ cassandra_future2* insert_into_sm_by_day(cassandra_session *session, device_meas sensors.append(std::move(tuple)); }); - stmt.bind(3, sensors); + stmt.bind_collection(3, sensors); return session->execute2(std::move(stmt)); } -- cgit v1.2.3