arachne::penelope::anonymous_namespace{inbox.cpp}::database Class Reference

Public Member Functions
	database (const fs::path &path, const bool writable)
	database (const database &)=delete
database &	operator= (const database &)=delete
	database (database &&)=delete
database &	operator= (database &&)=delete
	~database ()
void	execute (const std::string_view sql)
sqlite3 *	native () const noexcept
	database (const fs::path &path, const bool writable)
	database (const database &)=delete
database &	operator= (const database &)=delete
	database (database &&)=delete
database &	operator= (database &&)=delete
	~database ()
void	execute (const std::string_view sql)
sqlite3 *	native () const noexcept

Private Attributes
sqlite3 *	value_ { nullptr }

Detailed Description

Definition at line 348 of file inbox.cpp.

Constructor & Destructor Documentation

database() [1/6]

arachne::penelope::anonymous_namespace{inbox.cpp}::database::database ( const fs::path & path, const bool writable )

inline

Definition at line 350 of file inbox.cpp.

                                                      {
        const std::string native = path.string();
        const int flags = writable
            ? SQLITE_OPEN_READWRITE | SQLITE_OPEN_FULLMUTEX
            : SQLITE_OPEN_READONLY | SQLITE_OPEN_FULLMUTEX;
        if (sqlite3_open_v2(native.c_str(), &value_, flags, nullptr)
            != SQLITE_OK) {
            const std::string message = sqlite_message(value_, "open database");
            if (value_ != nullptr) {
                sqlite3_close(value_);
                value_ = nullptr;
            }
            throw database_error(message);
        }
        sqlite3_extended_result_codes(value_, 1);
        sqlite3_busy_timeout(value_, 10'000);
        execute("PRAGMA foreign_keys = ON");
        statement version(value_, "PRAGMA user_version");
        if (!version.step() || version.integer(0) != current_product_schema) {
            throw database_error(
                "product database must use schema version 5"
            );
        }
        require_current_product_structure(value_);
    }

References arachne::penelope::anonymous_namespace{inbox.cpp}::current_product_schema, arachne::penelope::anonymous_namespace{inbox.cpp}::statement::integer(), arachne::penelope::anonymous_namespace{inbox.cpp}::require_current_product_structure(), arachne::penelope::anonymous_namespace{inbox.cpp}::statement::step(), and value_.

Referenced by arachne::penelope::rebuild_product_merge_hints(), and arachne::penelope::anonymous_namespace{inbox.cpp}::run_inbox().

Here is the call graph for this function:

Here is the caller graph for this function:

database() [2/6]

arachne::penelope::anonymous_namespace{inbox.cpp}::database::database ( const database & )

delete

database() [3/6]

arachne::penelope::anonymous_namespace{inbox.cpp}::database::database ( database && )

delete

~database() [1/2]

arachne::penelope::anonymous_namespace{inbox.cpp}::database::~database ( )

inline

Definition at line 381 of file inbox.cpp.

                {
        if (value_ != nullptr) {
            sqlite3_close(value_);
        }
    }

References value_.

database() [4/6]

arachne::penelope::anonymous_namespace{inbox.cpp}::database::database ( const fs::path & path, const bool writable )

inline

Definition at line 350 of file inbox.cpp.

                                                      {
        const std::string native = path.string();
        const int flags = writable
            ? SQLITE_OPEN_READWRITE | SQLITE_OPEN_FULLMUTEX
            : SQLITE_OPEN_READONLY | SQLITE_OPEN_FULLMUTEX;
        if (sqlite3_open_v2(native.c_str(), &value_, flags, nullptr)
            != SQLITE_OK) {
            const std::string message = sqlite_message(value_, "open database");
            if (value_ != nullptr) {
                sqlite3_close(value_);
                value_ = nullptr;
            }
            throw database_error(message);
        }
        sqlite3_extended_result_codes(value_, 1);
        sqlite3_busy_timeout(value_, 10'000);
        execute("PRAGMA foreign_keys = ON");
        statement version(value_, "PRAGMA user_version");
        if (!version.step() || version.integer(0) != current_product_schema) {
            throw database_error(
                "product database must use schema version 5"
            );
        }
        require_current_product_structure(value_);
    }

database() [5/6]

arachne::penelope::anonymous_namespace{inbox.cpp}::database::database ( const database & )

delete

database() [6/6]

arachne::penelope::anonymous_namespace{inbox.cpp}::database::database ( database && )

delete

~database() [2/2]

arachne::penelope::anonymous_namespace{inbox.cpp}::database::~database ( )

inline

Definition at line 381 of file inbox.cpp.

                {
        if (value_ != nullptr) {
            sqlite3_close(value_);
        }
    }

Member Function Documentation

execute() [1/2]

void arachne::penelope::anonymous_namespace{inbox.cpp}::database::execute ( const std::string_view sql )

inline

Definition at line 387 of file inbox.cpp.

                                           {
        char* error = nullptr;
        const int status = sqlite3_exec(
            value_, std::string(sql).c_str(), nullptr, nullptr, &error
        );
        if (status != SQLITE_OK) {
            std::string message = error == nullptr
                ? sqlite_message(value_, "execute SQL")
                : std::string(error);
            sqlite3_free(error);
            throw database_error(message);
        }
    }

References value_.

execute() [2/2]

void arachne::penelope::anonymous_namespace{inbox.cpp}::database::execute ( const std::string_view sql )

inline

Definition at line 387 of file inbox.cpp.

                                           {
        char* error = nullptr;
        const int status = sqlite3_exec(
            value_, std::string(sql).c_str(), nullptr, nullptr, &error
        );
        if (status != SQLITE_OK) {
            std::string message = error == nullptr
                ? sqlite_message(value_, "execute SQL")
                : std::string(error);
            sqlite3_free(error);
            throw database_error(message);
        }
    }

native() [1/2]

sqlite3 * arachne::penelope::anonymous_namespace{inbox.cpp}::database::native ( ) const

inlinenodiscardnoexcept

Definition at line 401 of file inbox.cpp.

{ return value_; }

References value_.

Referenced by arachne::penelope::anonymous_namespace{inbox.cpp}::apply_one_batch(), arachne::penelope::anonymous_namespace{inbox.cpp}::prevalidate_semantics(), arachne::penelope::anonymous_namespace{inbox.cpp}::rebuild_hints(), arachne::penelope::anonymous_namespace{inbox.cpp}::record_issues(), and arachne::penelope::anonymous_namespace{inbox.cpp}::run_inbox().

Here is the caller graph for this function:

native() [2/2]

sqlite3 * arachne::penelope::anonymous_namespace{inbox.cpp}::database::native ( ) const

inlinenodiscardnoexcept

Definition at line 401 of file inbox.cpp.

{ return value_; }

operator=() [1/4]

database & arachne::penelope::anonymous_namespace{inbox.cpp}::database::operator= ( const database & )

delete

operator=() [2/4]

database & arachne::penelope::anonymous_namespace{inbox.cpp}::database::operator= ( const database & )

delete

operator=() [3/4]

database & arachne::penelope::anonymous_namespace{inbox.cpp}::database::operator= ( database && )

delete

operator=() [4/4]

database & arachne::penelope::anonymous_namespace{inbox.cpp}::database::operator= ( database && )

delete

Member Data Documentation

value_

sqlite3 * arachne::penelope::anonymous_namespace{inbox.cpp}::database::value_ { nullptr }

private

Definition at line 404 of file inbox.cpp.

{ nullptr };

Referenced by database(), execute(), native(), and ~database().

---

The documentation for this class was generated from the following file:

• inbox.cpp