SociDB.h

#ifndef XRPL_SOCIDB_H_INCLUDED
#define XRPL_SOCIDB_H_INCLUDED
 
#if defined(__clang__)
#pragma clang diagnostic push
#pragma clang diagnostic ignored "-Wdeprecated"
#endif
 
#include <xrpld/core/JobQueue.h>
 
#include <xrpl/basics/Log.h>
 
#define SOCI_USE_BOOST
#include <soci/soci.h>
 
#include <cstdint>
#include <string>
#include <vector>
 
namespace sqlite_api {
struct sqlite3;
}
 
namespace ripple {
 
class BasicConfig;
 
class DBConfig
{
    std::string connectionString_;
    explicit DBConfig(std::string const& dbPath);
 
public:
    DBConfig(BasicConfig const& config, std::string const& dbName);
    std::string
    connectionString() const;
    void
    open(soci::session& s) const;
};
 
void
open(soci::session& s, BasicConfig const& config, std::string const& dbName);
 
void
open(
    soci::session& s,
    std::string const& beName,
    std::string const& connectionString);
 
std::uint32_t
getKBUsedAll(soci::session& s);
std::uint32_t
getKBUsedDB(soci::session& s);
 
void
convert(soci::blob& from, std::vector<std::uint8_t>& to);
void
convert(soci::blob& from, std::string& to);
void
convert(std::vector<std::uint8_t> const& from, soci::blob& to);
void
convert(std::string const& from, soci::blob& to);
 
class Checkpointer : public std::enable_shared_from_this<Checkpointer>
{
public:
    virtual std::uintptr_t
    id() const = 0;
    virtual ~Checkpointer() = default;
 
    virtual void
    schedule() = 0;
 
    virtual void
    checkpoint() = 0;
};
 
std::shared_ptr<Checkpointer>
makeCheckpointer(
    std::uintptr_t id,
    std::weak_ptr<soci::session>,
    JobQueue&,
    Logs&);
 
}  // namespace ripple
 
#if defined(__clang__)
#pragma clang diagnostic pop
#endif
 
#endif