ARCHIVE/clio
1
0
Fork 0
mirror of https://github.com/XRPLF/clio.git synced 2026-04-29 15:37:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

create cassandra keyspace if it doesn't exist

Browse Source
This commit is contained in:
CJ Cobb
2021-05-19 17:49:22 +00:00
parent fa8eb67ca6
commit 0e52ebef48
1 changed files with 29 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
reporting/CassandraBackend.cpp
View File

@@ -1479,8 +1479,36 @@ CassandraBackend::open(bool readOnly)
{
std::stringstream ss;
ss << "nodestore: Error connecting Cassandra session keyspace: "
<< rc << ", " << cass_error_desc(rc);
<< rc << ", " << cass_error_desc(rc)
<< ", trying to create it ourselves";
BOOST_LOG_TRIVIAL(error) << ss.str();
// if the keyspace doesn't exist, try to create it
session_.reset(cass_session_new());
fut = cass_session_connect(session_.get(), cluster);
rc = cass_future_error_code(fut);
cass_future_free(fut);
if (rc != CASS_OK)
{
std::stringstream ss;
ss << "nodestore: Error connecting Cassandra session at all: "
<< rc << ", " << cass_error_desc(rc);
BOOST_LOG_TRIVIAL(error) << ss.str();
}
else
{
std::stringstream query;
query
<< "CREATE KEYSPACE IF NOT EXISTS " << keyspace
<< " WITH replication = {'class': 'SimpleStrategy', "
"'replication_factor': '3'} AND durable_writes = true";
if (!executeSimpleStatement(query.str()))
continue;
query = {};
query << "USE " << keyspace;
if (!executeSimpleStatement(query.str()))
continue;
}
continue;
}