transaction.h

#ifndef DBALLE_DB_V7_TRANSACTION_H
#define DBALLE_DB_V7_TRANSACTION_H
 
#include <dballe/db/db.h>
#include <dballe/db/v7/batch.h>
#include <dballe/db/v7/data.h>
#include <dballe/db/v7/fwd.h>
#include <dballe/sql/fwd.h>
#include <memory>
 
namespace dballe {
namespace db {
namespace v7 {
 
struct Transaction : public dballe::db::Transaction
{
protected:
    v7::Repinfo* m_repinfo          = nullptr;
    v7::Station* m_station          = nullptr;
    v7::LevTr* m_levtr              = nullptr;
    v7::StationData* m_station_data = nullptr;
    v7::Data* m_data                = nullptr;

    std::vector<std::weak_ptr<dballe::Cursor>> tracked_cursors;
 
    void add_msg_to_batch(Tracer<>& trc, const Message& message,
                          const dballe::DBImportOptions& opts);
    void track_cursor(std::weak_ptr<dballe::Cursor> cursor);
 
public:
    typedef v7::DB DB;
 
    std::shared_ptr<v7::DB> db;
    std::shared_ptr<dballe::sql::Transaction> sql_transaction;
    bool fired = false;
    v7::Batch batch;
    v7::Tracer<v7::trace::Transaction> trc;
 
    Transaction(std::shared_ptr<v7::DB> db,
                std::unique_ptr<dballe::sql::Transaction> sql_transaction);
    Transaction(const Transaction&)            = delete;
    Transaction(Transaction&&)                 = delete;
    Transaction& operator=(const Transaction&) = delete;
    Transaction& operator=(Transaction&&)      = delete;
    ~Transaction();

    v7::Repinfo& repinfo();
    v7::Station& station();
    v7::LevTr& levtr();
    v7::StationData& station_data();
    v7::Data& data();
 
    void commit() override;
    void rollback() override;
    void rollback_nothrow() noexcept override;
    void clear_cached_state() override;
 
    std::shared_ptr<dballe::CursorStation>
    query_stations(const Query& query) override;
    std::shared_ptr<dballe::CursorStationData>
    query_station_data(const Query& query) override;
    std::shared_ptr<dballe::CursorData> query_data(const Query& query) override;
    std::shared_ptr<dballe::CursorSummary>
    query_summary(const Query& query) override;
    std::shared_ptr<dballe::CursorMessage>
    query_messages(const Query& query) override;
    void attr_query_station(
        int data_id,
        std::function<void(std::unique_ptr<wreport::Var>)> dest) override;
    void attr_query_data(
        int data_id,
        std::function<void(std::unique_ptr<wreport::Var>)> dest) override;
 
    void insert_station_data(dballe::Data& vals,
                             const dballe::DBInsertOptions& opts =
                                 dballe::DBInsertOptions::defaults) override;
    void insert_data(dballe::Data& vals,
                     const dballe::DBInsertOptions& opts =
                         dballe::DBInsertOptions::defaults) override;
    void remove_station_data(const Query& query) override;
    void remove_data(const Query& query) override;
    void remove_station_data_by_id(int id);
    void remove_data_by_id(int id);
    void remove_all() override;
 
    void attr_insert_station(int data_id, const Values& attrs) override;
    void attr_insert_data(int data_id, const Values& attrs) override;
    void attr_remove_station(int data_id, const db::AttrList& attrs) override;
    void attr_remove_data(int data_id, const db::AttrList& attrs) override;
    void import_message(const Message& message,
                        const dballe::DBImportOptions& opts) override;
    void import_messages(const std::vector<std::shared_ptr<Message>>& msgs,
                         const dballe::DBImportOptions& opts) override;
    void update_repinfo(const char* repinfo_file, int* added, int* deleted,
                        int* updated) override;
 
    static Transaction& downcast(dballe::db::Transaction& transaction);
 
    void dump(FILE* out) override;
};
 
struct TestTransaction : public Transaction
{
    using Transaction::Transaction;
 
    void commit() override;
};
 
} // namespace v7
} // namespace db
} // namespace dballe
#endif