Manages database connections and operations. More...

#include <database_manager.h>

Collaboration diagram for database::database_manager:

Public Member Functions
	database_manager (std::shared_ptr< database_context > context)

virtual	~database_manager ()
	Destructor.

bool	set_mode (const database_types &database_type)
	Sets the database mode (type) for the manager.

database_types	database_type (void)
	Retrieves the current database type used by the manager.

query_builder	create_query_builder ()
	Creates a query builder for the current database type.

query_builder	create_query_builder (database_types db_type)
	Creates a query builder for a specific database type.

kcenon::common::VoidResult	connect_result (const std::string &connect_string)
	Result-based wrapper for connect().

kcenon::common::VoidResult	disconnect_result ()
	Result-based wrapper for disconnect().

kcenon::common::VoidResult	create_query_result (const std::string &query_string)
	Result-based wrapper for create_query().

kcenon::common::Result< core::database_result >	select_query_result (const std::string &query_string)
	Execute a SELECT query and return results.

kcenon::common::VoidResult	execute_query_result (const std::string &query_string)
	Result-based wrapper for execute_query().

kcenon::common::VoidResult	begin_transaction ()
	Begin a database transaction.

kcenon::common::VoidResult	commit_transaction ()
	Commit the current transaction.

kcenon::common::VoidResult	rollback_transaction ()
	Rollback the current transaction.

bool	in_transaction () const
	Check if currently in a transaction.

std::string	last_error () const
	Get last error message from the backend.

std::map< std::string, std::string >	connection_info () const
	Get connection information for monitoring.

Private Attributes
bool	connected_
	Indicates whether a database connection is active.

std::unique_ptr< core::database_backend >	database_
	The underlying database backend.

std::shared_ptr< database_context >	context_
	Dependency injection context.

std::string	connect_string_
	Cached connection string for initialization.

Detailed Description

Manages database connections and operations.

The database_manager class provides a high-level interface for controlling database connections and executing queries. It wraps a database_backend instance and exposes methods such as connect, disconnect, create_query, execute_query, etc.

Note: As of Issue #287, this class uses database_backend internally instead of the deprecated database_base interface. The public API remains backward compatible, but also provides new Result-based methods.; As of Sprint 2, this class uses dependency injection pattern. Access via constructor with database_context parameter.

Definition at line 37 of file database_manager.h.

Constructor & Destructor Documentation

◆ database_manager()

database::database_manager::database_manager ( std::shared_ptr< database_context > context )

explicit

Examples: /home/runner/work/database_system/database_system/database/database_manager.h.

Definition at line 20 of file database_manager.cpp.

        : connected_(false)
        , database_(nullptr)
        , context_(std::move(context))
    {
        // DI constructor - recommended for new code
        if (!context_)
        {
            // Fallback to default context if nullptr passed
            context_ = std::make_shared<database_context>();
        }
    }

References context_.

◆ ~database_manager()

database::database_manager::~database_manager ( )

virtual

Destructor.

Cleans up resources and disconnects from the database if an active connection exists.

Examples: /home/runner/work/database_system/database_system/database/database_manager.h.

Definition at line 33 of file database_manager.cpp.

33{}

Member Function Documentation

◆ begin_transaction()

kcenon::common::VoidResult database::database_manager::begin_transaction ( )

Begin a database transaction.

Returns: VoidResult indicating success or failure.

Examples: /home/runner/work/database_system/database_system/database/database_manager.h.

Definition at line 156 of file database_manager.cpp.

    {
        if (!database_)
        {
            return kcenon::common::VoidResult(
                kcenon::common::error_info{-1, "No database backend", "database_manager"});
        }
        return database_->begin_transaction();
    }

References database_.

◆ commit_transaction()

kcenon::common::VoidResult database::database_manager::commit_transaction ( )

Commit the current transaction.

Returns: VoidResult indicating success or failure.

Examples: /home/runner/work/database_system/database_system/database/database_manager.h.

Definition at line 166 of file database_manager.cpp.

    {
        if (!database_)
        {
            return kcenon::common::VoidResult(
                kcenon::common::error_info{-1, "No database backend", "database_manager"});
        }
        return database_->commit_transaction();
    }

References database_.

◆ connect_result()

kcenon::common::VoidResult database::database_manager::connect_result ( const std::string & connect_string )

Result-based wrapper for connect().

Examples: /home/runner/work/database_system/database_system/database/database_manager.h.

Definition at line 87 of file database_manager.cpp.

    {
        if (!database_)
        {
            return kcenon::common::VoidResult(
                kcenon::common::error_info{-1, "No database backend configured", "database_manager"});
        }
 
        // Store connection string for potential reconnection
        connect_string_ = connect_string;
 
        // Use database_backend's initialize method with connection_config
        auto config = core::connection_config::from_string(connect_string);
        auto result = database_->initialize(config);
 
        if (result.is_ok())
        {
            connected_ = true;
        }
        return result;
    }

References connect_string_, connected_, database_, and database::core::connection_config::from_string().

Here is the call graph for this function:

◆ connection_info()

std::map< std::string, std::string > database::database_manager::connection_info ( ) const

Get connection information for monitoring.

Returns: Map of connection properties.

Examples: /home/runner/work/database_system/database_system/database/database_manager.h.

Definition at line 204 of file database_manager.cpp.

    {
        if (!database_)
        {
            return {};
        }
        return database_->connection_info();
    }

References database_.

◆ create_query_builder() [1/2]

query_builder database::database_manager::create_query_builder ( )

Creates a query builder for the current database type.

Returns: A query builder configured for the current database

Examples: /home/runner/work/database_system/database_system/database/database_manager.h.

Definition at line 215 of file database_manager.cpp.

    {
        return query_builder(database_type());
    }

References database_type().

Here is the call graph for this function:

◆ create_query_builder() [2/2]

query_builder database::database_manager::create_query_builder ( database_types db_type )

Creates a query builder for a specific database type.

Parameters

db_type The database type to create a builder for

Returns: A query builder configured for the specified database

Definition at line 220 of file database_manager.cpp.

    {
        return query_builder(db_type);
    }

◆ create_query_result()

kcenon::common::VoidResult database::database_manager::create_query_result ( const std::string & query_string )

Result-based wrapper for create_query().

Examples: /home/runner/work/database_system/database_system/database/database_manager.h.

Definition at line 125 of file database_manager.cpp.

    {
        if (!database_)
        {
            return kcenon::common::VoidResult(
                kcenon::common::error_info{-1, "No database backend", "database_manager"});
        }
        // database_backend uses execute_query for DDL/prepared statements
        return database_->execute_query(query_string);
    }

References database_.

◆ database_type()

database_types database::database_manager::database_type ( void )

Retrieves the current database type used by the manager.

Returns: An enum value of database_types representing the current database mode.

Examples: /home/runner/work/database_system/database_system/database/database_manager.h.

Definition at line 77 of file database_manager.cpp.

    {
        if (!database_)
        {
            return database_types::none;
        }
 
        return database_->type();
    }

References database_, and database::none.

Referenced by create_query_builder(), and set_mode().

Here is the caller graph for this function:

◆ disconnect_result()

kcenon::common::VoidResult database::database_manager::disconnect_result ( )

Result-based wrapper for disconnect().

Examples: /home/runner/work/database_system/database_system/database/database_manager.h.

Definition at line 109 of file database_manager.cpp.

    {
        if (!database_)
        {
            return kcenon::common::VoidResult(
                kcenon::common::error_info{-1, "No database backend", "database_manager"});
        }
 
        auto result = database_->shutdown();
        if (result.is_ok())
        {
            connected_ = false;
        }
        return result;
    }

References connected_, and database_.

◆ execute_query_result()

kcenon::common::VoidResult database::database_manager::execute_query_result ( const std::string & query_string )

Result-based wrapper for execute_query().

Parameters

query_string The SQL statement.

Returns: VoidResult indicating success or failure.

Examples: /home/runner/work/database_system/database_system/database/database_manager.h.

Definition at line 146 of file database_manager.cpp.

    {
        if (!database_)
        {
            return kcenon::common::VoidResult(
                kcenon::common::error_info{-1, "No database backend", "database_manager"});
        }
        return database_->execute_query(query_string);
    }

References database_.

◆ in_transaction()

bool database::database_manager::in_transaction ( ) const

Check if currently in a transaction.

Returns: true if a transaction is active.

Examples: /home/runner/work/database_system/database_system/database/database_manager.h.

Definition at line 186 of file database_manager.cpp.

    {
        if (!database_)
        {
            return false;
        }
        return database_->in_transaction();
    }

References database_.

◆ last_error()

std::string database::database_manager::last_error ( ) const

Get last error message from the backend.

Returns: Error message string.

Examples: /home/runner/work/database_system/database_system/database/database_manager.h.

Definition at line 195 of file database_manager.cpp.

    {
        if (!database_)
        {
            return "No database backend";
        }
        return database_->last_error();
    }

References database_.

◆ rollback_transaction()

kcenon::common::VoidResult database::database_manager::rollback_transaction ( )

Rollback the current transaction.

Returns: VoidResult indicating success or failure.

Examples: /home/runner/work/database_system/database_system/database/database_manager.h.

Definition at line 176 of file database_manager.cpp.

    {
        if (!database_)
        {
            return kcenon::common::VoidResult(
                kcenon::common::error_info{-1, "No database backend", "database_manager"});
        }
        return database_->rollback_transaction();
    }

References database_.

◆ select_query_result()

kcenon::common::Result< core::database_result > database::database_manager::select_query_result ( const std::string & query_string )

Execute a SELECT query and return results.

Parameters

query_string The SQL SELECT statement.

Returns: Query results, or error.

Examples: /home/runner/work/database_system/database_system/database/database_manager.h.

Definition at line 136 of file database_manager.cpp.

    {
        if (!database_)
        {
            return kcenon::common::Result<core::database_result>(
                kcenon::common::error_info{-1, "No database backend", "database_manager"});
        }
        return database_->select_query(query_string);
    }

References database_.

◆ set_mode()

bool database::database_manager::set_mode ( const database_types & database_type )

Sets the database mode (type) for the manager.

Parameters

database_type An enum value of database_types that specifies the target database type (e.g., PostgreSQL, SQLite).

Returns: true on success (e.g., if a corresponding database implementation is available), false otherwise.

Examples: /home/runner/work/database_system/database_system/database/database_manager.h.

Definition at line 35 of file database_manager.cpp.

    {
        if (connected_)
        {
            return false;
        }
 
        database_.reset();
 
        // Create the appropriate backend directly
        // This ensures backends are linked even when static library registration
        // might not work due to initialization order
        switch (database_type)
        {
        case database_types::postgres:
            database_ = backends::postgresql_backend::create();
            break;
        case database_types::sqlite:
            database_ = backends::sqlite_backend::create();
            break;
#ifdef USE_MONGODB
        case database_types::mongodb:
            database_ = backends::mongodb_backend::create();
            break;
#endif
#ifdef USE_REDIS
        case database_types::redis:
            database_ = backends::redis_backend::create();
            break;
#endif
        default:
            return false;
        }
 
        if (database_ == nullptr)
        {
            return false;
        }
 
        return true;
    }