void
CqlConnection::prepareStatements(CqlTaggedStatement *statements) {
CassError rc = CASS_OK;
- CassFuture* future = NULL;
uint32_t size = 0;
tagged_statements_ = statements;
for (; tagged_statements_[size].params_; size++);
for (uint32_t i = 0; i < size; i++) {
const char* query = tagged_statements_[i].text_;
- future = cass_session_prepare(session_, query);
+ CassFuture* future = cass_session_prepare(session_, query);
cass_future_wait(future);
std::string error;
checkStatementError(error, future, i, "could not prepare statement");
void
CqlLeaseMgr::getData(const CassRow* row, const int pindex, CqlDataArray& data,
CqlDataArray& size, const int dindex, const SqlExchange& exchange) {
- const CassValue* value;
if (pindex >= exchange.parameters_.size()) {
return;
}
if (std::distance(range.first, range.second) > 0) {
std::string name = (*range.first)->name_;
ExchangeDataType type = (*range.first)->type_;
- value = cass_row_get_column_by_name(row, name.c_str());
+ const CassValue* value = cass_row_get_column_by_name(row, name.c_str());
if (NULL == value) {
isc_throw(BadValue, "column name " << name << " doesn't exist");
}