PrepareRequest* prepare =

static_cast<PrepareRequest*>(new PrepareRequest());

request_.reset(prepare);

if (request_handler_->request()->opcode() == CQL_OPCODE_EXECUTE) {

const ExecuteRequest* execute = static_cast<const ExecuteRequest*>(

request_handler_->request());

prepare->set_query(execute->prepared()->statement());

return true;

} else if (request_handler_->request()->opcode() == CQL_OPCODE_BATCH) {

const BatchRequest* batch = static_cast<const BatchRequest*>(

request_handler_->request());

std::string prepared_statement;

if (batch->prepared_statement(prepared_id, &prepared_statement)) {

prepare->set_query(prepared_statement);

return true;

}

}

return false; // Invalid request type

switch (response->opcode()) {

case CQL_OPCODE_RESULT: {

ResultResponse* result =

static_cast<ResultResponse*>(response->response_body().get());

if (result->kind() == CASS_RESULT_KIND_PREPARED) {

request_handler_.release()->retry(RETRY_WITH_CURRENT_HOST);

} else {

request_handler_.release()->retry(RETRY_WITH_NEXT_HOST);

}

} break;

case CQL_OPCODE_ERROR:

request_handler_.release()->retry(RETRY_WITH_NEXT_HOST);

break;

default:

break;

}