diff options
Diffstat (limited to 'sm-mqtt-consumer.cpp')
-rw-r--r-- | sm-mqtt-consumer.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
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)); } |