database::async::async_database Class Reference

Asynchronous database interface wrapper. More...

#include <async_operations.h>

Collaboration diagram for database::async::async_database:

Public Member Functions
	async_database (std::shared_ptr< core::database_backend > db, std::shared_ptr< async_executor > executor)
async_result< bool >	execute_async (const std::string &query)
async_result< core::database_result >	select_async (const std::string &query)
async_result< std::vector< bool > >	execute_batch_async (const std::vector< std::string > &queries)
async_result< std::vector< core::database_result > >	select_batch_async (const std::vector< std::string > &queries)
async_result< bool >	begin_transaction_async ()
async_result< bool >	commit_transaction_async ()
async_result< bool >	rollback_transaction_async ()
async_result< bool >	connect_async (const std::string &connection_string)
async_result< bool >	disconnect_async ()

Private Attributes
std::shared_ptr< core::database_backend >	db_
std::shared_ptr< async_executor >	executor_

Detailed Description

Asynchronous database interface wrapper.

Definition at line 275 of file async_operations.h.

Constructor & Destructor Documentation

async_database()

database::async::async_database::async_database ( std::shared_ptr< core::database_backend > db, std::shared_ptr< async_executor > executor )

inline

Examples

/home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 735 of file async_operations.h.

        : db_(std::move(db))
        , executor_(std::move(executor))
    {
    }

Member Function Documentation

begin_transaction_async()

async_result< bool > database::async::async_database::begin_transaction_async ( )

inline

Examples

/home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 807 of file async_operations.h.

    {
        auto db = db_;
        auto future = executor_->submit([db]() -> bool {
            auto result = db->begin_transaction();
            if (result.is_err()) {
                throw std::runtime_error(result.error().message);
            }
            return true;
        });
        return async_result<bool>(std::move(future));
    }

References db_, and executor_.

commit_transaction_async()

async_result< bool > database::async::async_database::commit_transaction_async ( )

inline

Examples

/home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 820 of file async_operations.h.

    {
        auto db = db_;
        auto future = executor_->submit([db]() -> bool {
            auto result = db->commit_transaction();
            if (result.is_err()) {
                throw std::runtime_error(result.error().message);
            }
            return true;
        });
        return async_result<bool>(std::move(future));
    }

References db_, and executor_.

connect_async()

async_result< bool > database::async::async_database::connect_async ( const std::string & connection_string )

inline

Examples

/home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 846 of file async_operations.h.

    {
        auto db = db_;
        auto future = executor_->submit([db, connection_string]() -> bool {
            auto config = core::connection_config::from_string(connection_string);
            auto result = db->initialize(config);
            if (result.is_err()) {
                throw std::runtime_error(result.error().message);
            }
            return true;
        });
        return async_result<bool>(std::move(future));
    }

References db_, executor_, and database::core::connection_config::from_string().

Here is the call graph for this function:

disconnect_async()

async_result< bool > database::async::async_database::disconnect_async ( )

inline

Examples

/home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 860 of file async_operations.h.

    {
        auto db = db_;
        auto future = executor_->submit([db]() -> bool {
            auto result = db->shutdown();
            if (result.is_err()) {
                throw std::runtime_error(result.error().message);
            }
            return true;
        });
        return async_result<bool>(std::move(future));
    }

References db_, and executor_.

execute_async()

async_result< bool > database::async::async_database::execute_async ( const std::string & query )

inline

Examples

/home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 743 of file async_operations.h.

    {
        auto db = db_;
        auto future = executor_->submit([db, query]() -> bool {
            auto result = db->execute_query(query);
            if (result.is_err()) {
                throw std::runtime_error(result.error().message);
            }
            return true;
        });
        return async_result<bool>(std::move(future));
    }

References db_, and executor_.

execute_batch_async()

async_result< std::vector< bool > > database::async::async_database::execute_batch_async ( const std::vector< std::string > & queries )

inline

Examples

/home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 769 of file async_operations.h.

    {
        auto db = db_;
        auto queries_copy = queries;
        auto future = executor_->submit([db, queries_copy]() -> std::vector<bool> {
            std::vector<bool> results;
            results.reserve(queries_copy.size());
            for (const auto& q : queries_copy) {
                auto result = db->execute_query(q);
                results.push_back(result.is_ok());
            }
            return results;
        });
        return async_result<std::vector<bool>>(std::move(future));
    }

References db_, and executor_.

rollback_transaction_async()

async_result< bool > database::async::async_database::rollback_transaction_async ( )

inline

Examples

/home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 833 of file async_operations.h.

    {
        auto db = db_;
        auto future = executor_->submit([db]() -> bool {
            auto result = db->rollback_transaction();
            if (result.is_err()) {
                throw std::runtime_error(result.error().message);
            }
            return true;
        });
        return async_result<bool>(std::move(future));
    }

References db_, and executor_.

select_async()

async_result< core::database_result > database::async::async_database::select_async ( const std::string & query )

inline

Examples

/home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 756 of file async_operations.h.

    {
        auto db = db_;
        auto future = executor_->submit([db, query]() -> core::database_result {
            auto result = db->select_query(query);
            if (result.is_err()) {
                throw std::runtime_error(result.error().message);
            }
            return result.value();
        });
        return async_result<core::database_result>(std::move(future));
    }

References db_, and executor_.

select_batch_async()

async_result< std::vector< core::database_result > > database::async::async_database::select_batch_async ( const std::vector< std::string > & queries )

inline

Examples

/home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 786 of file async_operations.h.

    {
        auto db = db_;
        auto queries_copy = queries;
        auto future = executor_->submit([db, queries_copy]() -> std::vector<core::database_result> {
            std::vector<core::database_result> results;
            results.reserve(queries_copy.size());
            for (const auto& q : queries_copy) {
                auto result = db->select_query(q);
                if (result.is_ok()) {
                    results.push_back(result.value());
                } else {
                    results.push_back(core::database_result{});
                }
            }
            return results;
        });
        return async_result<std::vector<core::database_result>>(std::move(future));
    }

References db_, and executor_.

Member Data Documentation

db_

std::shared_ptr<core::database_backend> database::async::async_database::db_

private

Examples

/home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 304 of file async_operations.h.

Referenced by begin_transaction_async(), commit_transaction_async(), connect_async(), disconnect_async(), execute_async(), execute_batch_async(), rollback_transaction_async(), select_async(), and select_batch_async().

executor_

std::shared_ptr<async_executor> database::async::async_database::executor_

private

Examples

/home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 305 of file async_operations.h.

Referenced by begin_transaction_async(), commit_transaction_async(), connect_async(), disconnect_async(), execute_async(), execute_batch_async(), rollback_transaction_async(), select_async(), and select_batch_async().

---

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

• database/async/async_operations.h