ARCHIVE/clio
1
0
Fork 0
mirror of https://github.com/XRPLF/clio.git synced 2025-11-29 08:05:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

remove books table from postgres

Browse Source
This commit is contained in:
CJ Cobb
2021-05-29 09:52:02 -04:00
parent 7f16951a18
commit 4c12bb51dd
3 changed files with 0 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
reporting/Pg.cpp
View File

@@ -841,15 +841,6 @@ create table if not exists account_transactions5 partition of account_transactio
create table if not exists account_transactions6 partition of account_transactions for values from (50000000) to (60000000); create table if not exists account_transactions6 partition of account_transactions for values from (50000000) to (60000000);
create table if not exists account_transactions7 partition of account_transactions for values from (60000000) to (70000000); create table if not exists account_transactions7 partition of account_transactions for values from (60000000) to (70000000);
-- Table that maps a book to a list of offers in that book. Deletes from the ledger table
-- cascade here based on ledger_seq.
CREATE TABLE IF NOT EXISTS books (
ledger_seq bigint NOT NULL,
book bytea NOT NULL,
offer_key bytea NOT NULL
);
CREATE INDEX book_idx ON books using btree(ledger_seq, book, offer_key);
CREATE TABLE IF NOT EXISTS keys ( CREATE TABLE IF NOT EXISTS keys (
ledger_seq bigint NOT NULL, ledger_seq bigint NOT NULL,

5
reporting/PostgresBackend.cpp
View File

@@ -643,9 +643,6 @@ PostgresBackend::doFinishWrites() const
std::string keysStr = keysBuffer_.str(); std::string keysStr = keysBuffer_.str();
if (keysStr.size()) if (keysStr.size())
writeConnection_.bulkInsert("keys", keysStr); writeConnection_.bulkInsert("keys", keysStr);
std::string booksStr = booksBuffer_.str();
if (booksStr.size())
writeConnection_.bulkInsert("books", booksStr);
} }
auto res = writeConnection_("COMMIT"); auto res = writeConnection_("COMMIT");
if (!res || res.status() != PGRES_COMMAND_OK) if (!res || res.status() != PGRES_COMMAND_OK)
@@ -658,8 +655,6 @@ PostgresBackend::doFinishWrites() const
transactionsBuffer_.clear(); transactionsBuffer_.clear();
objectsBuffer_.str(""); objectsBuffer_.str("");
objectsBuffer_.clear(); objectsBuffer_.clear();
booksBuffer_.str("");
booksBuffer_.clear();
keysBuffer_.str(""); keysBuffer_.str("");
keysBuffer_.clear(); keysBuffer_.clear();
accountTxBuffer_.str(""); accountTxBuffer_.str("");

1
reporting/PostgresBackend.h
View File

@@ -9,7 +9,6 @@ class PostgresBackend : public BackendInterface
private: private:
mutable size_t numRowsInObjectsBuffer_ = 0; mutable size_t numRowsInObjectsBuffer_ = 0;
mutable std::stringstream objectsBuffer_; mutable std::stringstream objectsBuffer_;
mutable std::stringstream booksBuffer_;
mutable std::stringstream keysBuffer_; mutable std::stringstream keysBuffer_;
mutable std::stringstream transactionsBuffer_; mutable std::stringstream transactionsBuffer_;
mutable std::stringstream accountTxBuffer_; mutable std::stringstream accountTxBuffer_;