diff --git a/src/data/BackendFactory.hpp b/src/data/BackendFactory.hpp index db364f001..7e2c1b630 100644 --- a/src/data/BackendFactory.hpp +++ b/src/data/BackendFactory.hpp @@ -51,8 +51,7 @@ make_Backend(util::Config const& config) auto const type = config.value("database.type"); std::shared_ptr backend = nullptr; - // TODO: retire `cassandra-new` by next release after 2.0 - if (boost::iequals(type, "cassandra") or boost::iequals(type, "cassandra-new")) { + if (boost::iequals(type, "cassandra")) { auto cfg = config.section("database." + type); backend = std::make_shared(data::cassandra::SettingsProvider{cfg}, readOnly); } diff --git a/src/data/CassandraBackend.hpp b/src/data/CassandraBackend.hpp index 9c1bf2f61..79c5776ba 100644 --- a/src/data/CassandraBackend.hpp +++ b/src/data/CassandraBackend.hpp @@ -22,7 +22,6 @@ #include "data/BackendInterface.hpp" #include "data/DBHelpers.hpp" #include "data/Types.hpp" -#include "data/cassandra/Concepts.hpp" #include "data/cassandra/Handle.hpp" #include "data/cassandra/Schema.hpp" #include "data/cassandra/SettingsProvider.hpp" @@ -94,7 +93,7 @@ class BasicCassandraBackend : public BackendInterface { , executor_{settingsProvider_.getSettings(), handle_} { if (auto const res = handle_.connect(); not res) - throw std::runtime_error("Could not connect to Cassandra: " + res.error()); + throw std::runtime_error("Could not connect to databse: " + res.error()); if (not readOnly) { if (auto const res = handle_.execute(schema_.createKeyspace); not res) { @@ -346,7 +345,7 @@ class BasicCassandraBackend : public BackendInterface { hashes.push_back(std::move(hash)); auto end = std::chrono::system_clock::now(); - LOG(log_.debug()) << "Fetched " << hashes.size() << " transaction hashes from Cassandra in " + LOG(log_.debug()) << "Fetched " << hashes.size() << " transaction hashes from database in " << std::chrono::duration_cast(end - start).count() << " milliseconds"; @@ -659,7 +658,7 @@ class BasicCassandraBackend : public BackendInterface { }); ASSERT(numHashes == results.size(), "Number of hashes and results must match"); - LOG(log_.debug()) << "Fetched " << numHashes << " transactions from Cassandra in " << timeDiff + LOG(log_.debug()) << "Fetched " << numHashes << " transactions from database in " << timeDiff << " milliseconds"; return results; } @@ -779,7 +778,7 @@ class BasicCassandraBackend : public BackendInterface { if (keys.empty()) return {}; - LOG(log_.debug()) << "Fetched " << keys.size() << " diff hashes from Cassandra in " << timeDiff + LOG(log_.debug()) << "Fetched " << keys.size() << " diff hashes from database in " << timeDiff << " milliseconds"; auto const objs = fetchLedgerObjects(keys, ledgerSequence, yield); @@ -867,7 +866,7 @@ class BasicCassandraBackend : public BackendInterface { std::string&& metadata ) override { - LOG(log_.trace()) << "Writing txn to cassandra"; + LOG(log_.trace()) << "Writing txn to database"; executor_.write(schema_->insertLedgerTransaction, seq, hash); executor_.write(