scope_transaction.hpp

浏览该文件的文档.

#ifndef NEFORCE_DATABASE_TRANSACTION_GUARD_HPP__
#define NEFORCE_DATABASE_TRANSACTION_GUARD_HPP__

 
#include "NeForce/db/db_interface.hpp"
NEFORCE_BEGIN_NAMESPACE__


template <typename Connect>
class scope_transaction {
private:
    Connect* conn_ = nullptr; 
    bool committed_ = false;  
 
public:
    explicit scope_transaction(Connect& conn) :
    conn_(&conn) {
        conn_->begin();
    }

    ~scope_transaction() noexcept {
        if (conn_ != nullptr && !committed_) {
            try {
                conn_->rollback();
                // NOLINTNEXTLINE(bugprone-empty-catch)
            } catch (...) {
                // ignore
            }
        }
    }
 
    scope_transaction(const scope_transaction&) = delete;
    scope_transaction& operator=(const scope_transaction&) = delete;

    scope_transaction(scope_transaction&& other) noexcept :
    conn_(other.conn_),
    committed_(other.committed_) {
        other.conn_ = nullptr;
        other.committed_ = true;
    }

    scope_transaction& operator=(scope_transaction&& other) noexcept {
        if (addressof(other) != this) {
            if (conn_ != nullptr && !committed_) {
                try {
                    conn_->rollback();
                    // NOLINTNEXTLINE(bugprone-empty-catch)
                } catch (...) {
                    // ignore
                }
            }
            conn_ = other.conn_;
            committed_ = other.committed_;
            other.conn_ = nullptr;
            other.committed_ = true;
        }
        return *this;
    }

    void commit() {
        if (conn_ != nullptr && !committed_) {
            conn_->commit();
            committed_ = true;
        }
    }

    NEFORCE_NODISCARD bool committed() const noexcept { return committed_; }
};

template <typename Connect>
NEFORCE_NODISCARD scope_transaction<Connect> make_transaction(Connect& conn) {
    return scope_transaction<Connect>(conn);
}
 // Database
 
NEFORCE_END_NAMESPACE__
#endif // NEFORCE_DATABASE_TRANSACTION_GUARD_HPP__