Main unified database system class. More...

#include <unified_database_system.h>

Collaboration diagram for database::integrated::unified_database_system:

Classes
class	builder
	Builder class for custom configuration. More...

class	impl

struct	pool_stats
	Get connection pool statistics. More...

Public Member Functions
	unified_database_system ()
	Default constructor (zero-config)

	unified_database_system (const unified_db_config &config)
	Construct with configuration.

	~unified_database_system ()
	Destructor - automatically disconnects and cleans up.

	unified_database_system (const unified_database_system &)=delete

unified_database_system &	operator= (const unified_database_system &)=delete

	unified_database_system (unified_database_system &&) noexcept

unified_database_system &	operator= (unified_database_system &&) noexcept

kcenon::common::VoidResult	connect (const std::string &connection_string)
	Connect to database.

kcenon::common::VoidResult	connect (backend_type backend, const std::string &connection_string)
	Connect to database with specific backend.

kcenon::common::VoidResult	disconnect ()
	Disconnect from database.

bool	is_connected () const
	Check if connected to database.

kcenon::common::Result< query_result >	execute (const std::string &query, const std::vector< query_param > &params={})

kcenon::common::Result< query_result >	select (const std::string &query, const std::vector< query_param > &params={})
	Execute a SELECT query.

kcenon::common::Result< size_t >	insert (const std::string &query, const std::vector< query_param > &params={})
	Execute an INSERT query.

kcenon::common::Result< size_t >	update (const std::string &query, const std::vector< query_param > &params={})
	Execute an UPDATE query.

kcenon::common::Result< size_t >	remove (const std::string &query, const std::vector< query_param > &params={})
	Execute a DELETE query.

std::future< kcenon::common::Result< query_result > >	execute_async (const std::string &query, const std::vector< query_param > &params={})

std::future< kcenon::common::Result< query_result > >	execute_async_priority (const std::string &query, int priority, const std::vector< query_param > &params={})
	Execute a SQL query asynchronously with priority.

kcenon::common::Result< std::unique_ptr< transaction > >	begin_transaction ()

kcenon::common::VoidResult	execute_transaction (const std::vector< std::string > &queries)
	Execute multiple queries in a transaction.

template<typename Func >
kcenon::common::Result< typename std::invoke_result_t< Func, transaction & > >	in_transaction (Func &&func)

query_builder	create_query_builder () const

database_metrics	get_metrics () const
	Get current performance metrics.

health_check	check_health () const
	Perform health check.

void	reset_metrics ()
	Reset metrics counters.

const unified_db_config &	get_config () const
	Get current configuration.

backend_type	get_backend_type () const
	Get database backend type.

pool_stats	get_pool_stats () const

Static Public Member Functions
static builder	create_builder ()
	Create a builder for custom configuration.

Private Attributes
std::unique_ptr< impl >	pimpl_

Detailed Description

Main unified database system class.

This class provides a simple, modern API for database operations with integrated logging, monitoring, and async capabilities.

Thread Safety: All methods are thread-safe Exception Safety: No-throw guarantee (all errors returned via Result) Resource Safety: RAII - resources cleaned up in destructor

Examples: integrated/async_queries.cpp, and integrated/monitoring.cpp.

Definition at line 288 of file unified_database_system.h.

Constructor & Destructor Documentation

◆ unified_database_system() [1/4]

database::integrated::unified_database_system::unified_database_system ( )

Default constructor (zero-config)

Creates a database system with smart defaults:

No backend specified (must call connect)
Connection pool: min=2, max=10
Logging: info level, console + file
Monitoring: enabled
Async: 4 worker threads

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h.

Definition at line 690 of file unified_database_system.cpp.

691 : unified_database_system(unified_db_config{}) {

692}

database::integrated::unified_database_system::unified_database_system

unified_database_system()

Default constructor (zero-config)

Definition unified_database_system.cpp:690

◆ unified_database_system() [2/4]

database::integrated::unified_database_system::unified_database_system ( const unified_db_config & config )

explicit

Construct with configuration.

Parameters

config Database configuration

Definition at line 694 of file unified_database_system.cpp.

695 : pimpl_(std::make_unique<impl>(config)) {

696}

database::integrated::unified_database_system::pimpl_

std::unique_ptr< impl > pimpl_

Definition unified_database_system.h:635

◆ ~unified_database_system()

database::integrated::unified_database_system::~unified_database_system ( )

default

Destructor - automatically disconnects and cleans up.

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h.

◆ unified_database_system() [3/4]

database::integrated::unified_database_system::unified_database_system ( const unified_database_system & )

delete

◆ unified_database_system() [4/4]

database::integrated::unified_database_system::unified_database_system ( unified_database_system && )

defaultnoexcept

Member Function Documentation

◆ begin_transaction()

kcenon::common::Result< std::unique_ptr< transaction > > database::integrated::unified_database_system::begin_transaction ( )

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h.

Definition at line 784 of file unified_database_system.cpp.

                                                                                          {
    return pimpl_->begin_transaction();
}

References pimpl_.

Referenced by test_begin_transaction_failure(), test_begin_transaction_success(), test_transaction_commit(), test_transaction_execute(), test_transaction_is_active(), test_transaction_metrics(), test_transaction_raii_cleanup(), and test_transaction_rollback().

Here is the caller graph for this function:

◆ check_health()

health_check database::integrated::unified_database_system::check_health ( ) const

Perform health check.

Returns: Health check results

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h, and integrated/monitoring.cpp.

Definition at line 799 of file unified_database_system.cpp.

                                                         {
    return pimpl_->check_health();
}

References pimpl_.

Referenced by example_alerting(), example_health_monitoring(), test_health_check_api(), and test_thread_safety_health_checks().

Here is the caller graph for this function:

◆ connect() [1/2]

kcenon::common::VoidResult database::integrated::unified_database_system::connect	(	backend_type	backend,
		const std::string &	connection_string )

Connect to database with specific backend.

Parameters

backend	Database backend type
connection_string	Database connection string

Returns: Success or error result

Definition at line 709 of file unified_database_system.cpp.

                                        {
    return pimpl_->connect(backend, connection_string);
}

References pimpl_.

◆ connect() [2/2]

kcenon::common::VoidResult database::integrated::unified_database_system::connect ( const std::string & connection_string )

Connect to database.

Parameters

connection_string Database connection string (format depends on backend)

Returns: Success or error result

Examples:

PostgreSQL: "host=localhost port=5432 dbname=mydb user=user password=pass"
SQLite: "mydb.db" or ":memory:"

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h, integrated/async_queries.cpp, and integrated/monitoring.cpp.

Definition at line 705 of file unified_database_system.cpp.

                                                                                          {
    return pimpl_->connect(backend_type::postgres, connection_string);
}

References connect(), and database::integrated::postgres.

Referenced by connect(), test_begin_transaction_success(), test_connect_mock_backend(), test_connect_typed_backend(), test_connect_unsupported_backend(), test_execute_success(), test_execute_transaction_success(), test_get_pool_stats(), test_insert_success(), test_metrics_update_on_query(), test_remove_success(), test_reset_metrics(), test_select_success(), test_transaction_commit(), test_transaction_execute(), test_transaction_is_active(), test_transaction_metrics(), test_transaction_raii_cleanup(), test_transaction_rollback(), and test_update_success().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ create_builder()

unified_database_system::builder database::integrated::unified_database_system::create_builder ( )

static

Create a builder for custom configuration.

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h.

Definition at line 913 of file unified_database_system.cpp.

                                                                       {
    return builder{};
}

Referenced by database::integrated::create_database(), main(), main(), test_builder_custom(), test_builder_default(), and test_move_semantics().

Here is the caller graph for this function:

◆ create_query_builder()

query_builder database::integrated::unified_database_system::create_query_builder ( ) const

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h.

Definition at line 823 of file unified_database_system.cpp.

                                                                  {
    return pimpl_->create_query_builder();
}

References pimpl_.

Referenced by test_create_query_builder().

Here is the caller graph for this function:

◆ disconnect()

kcenon::common::VoidResult database::integrated::unified_database_system::disconnect ( )

Disconnect from database.

Returns: Success or error result

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h, integrated/async_queries.cpp, and integrated/monitoring.cpp.

Definition at line 715 of file unified_database_system.cpp.

                                                           {
    return pimpl_->disconnect();
}

References pimpl_.

Referenced by test_connect_mock_backend(), and test_connection_state_api().

Here is the caller graph for this function:

◆ execute()

kcenon::common::Result< query_result > database::integrated::unified_database_system::execute	(	const std::string &	query,
		const std::vector< query_param > &	params = {} )

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h, and integrated/monitoring.cpp.

Definition at line 725 of file unified_database_system.cpp.

                                          {
    return pimpl_->execute(query, params);
}

References pimpl_.

Referenced by example_performance_profiling(), test_error_handling_no_connection(), test_execute_success(), test_metrics_update_on_query(), and test_reset_metrics().

Here is the caller graph for this function:

◆ execute_async()

std::future< kcenon::common::Result< query_result > > database::integrated::unified_database_system::execute_async	(	const std::string &	query,
		const std::vector< query_param > &	params = {} )

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h, and integrated/async_queries.cpp.

Definition at line 769 of file unified_database_system.cpp.

                                          {
    return pimpl_->execute_async(query, params);
}

References pimpl_.

Referenced by example_batch_operations(), example_concurrent_queries(), example_error_handling(), example_query_with_timeout(), and example_single_async_query().

Here is the caller graph for this function:

◆ execute_async_priority()

std::future< kcenon::common::Result< query_result > > database::integrated::unified_database_system::execute_async_priority	(	const std::string &	query,
		int	priority,
		const std::vector< query_param > &	params = {} )

Execute a SQL query asynchronously with priority.

Parameters

query	SQL query string
priority	Task priority (0=lowest, 100=highest)
params	Optional query parameters

Returns: Future that will contain query results

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h.

Definition at line 775 of file unified_database_system.cpp.

                                          {
    return pimpl_->execute_async_priority(query, priority, params);
}

References pimpl_.

◆ execute_transaction()

kcenon::common::VoidResult database::integrated::unified_database_system::execute_transaction ( const std::vector< std::string > & queries )

Execute multiple queries in a transaction.

Parameters

queries List of queries to execute

Returns: Success if all queries succeed and transaction commits, error otherwise

This is a convenience method that automatically begins, executes, and commits/rollbacks.

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h.

Definition at line 788 of file unified_database_system.cpp.

                                         {
    return pimpl_->execute_transaction(queries);
}

References pimpl_.

Referenced by test_execute_transaction_failure(), and test_execute_transaction_success().

Here is the caller graph for this function:

◆ get_backend_type()

backend_type database::integrated::unified_database_system::get_backend_type ( ) const

Get database backend type.

Returns: Backend type

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h.

Definition at line 813 of file unified_database_system.cpp.

                                                             {
    return pimpl_->get_backend_type();
}

References pimpl_.

Referenced by test_get_backend_type().

Here is the caller graph for this function:

◆ get_config()

const unified_db_config & database::integrated::unified_database_system::get_config ( ) const

Get current configuration.

Returns: Database configuration

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h.

Definition at line 809 of file unified_database_system.cpp.

                                                                   {
    return pimpl_->get_config();
}

References pimpl_.

Referenced by test_get_config().

Here is the caller graph for this function:

◆ get_metrics()

database_metrics database::integrated::unified_database_system::get_metrics ( ) const

Get current performance metrics.

Returns: Database performance metrics

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h, integrated/async_queries.cpp, and integrated/monitoring.cpp.

Definition at line 795 of file unified_database_system.cpp.

                                                            {
    return pimpl_->get_metrics();
}

References pimpl_.

Referenced by example_alerting(), example_performance_profiling(), example_realtime_monitoring(), test_metrics_api(), test_metrics_update_on_query(), test_reset_metrics(), test_thread_safety_metrics(), and test_transaction_metrics().

Here is the caller graph for this function:

◆ get_pool_stats()

unified_database_system::pool_stats database::integrated::unified_database_system::get_pool_stats ( ) const

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h.

Definition at line 817 of file unified_database_system.cpp.

                                                                                {
    return pimpl_->get_pool_stats();
}

References pimpl_.

Referenced by test_get_pool_stats().

Here is the caller graph for this function:

◆ in_transaction()

template<typename Func >

kcenon::common::Result< typename std::invoke_result_t< Func, transaction & > > database::integrated::unified_database_system::in_transaction ( Func && func )

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h.

◆ insert()

kcenon::common::Result< size_t > database::integrated::unified_database_system::insert	(	const std::string &	query,
		const std::vector< query_param > &	params = {} )

Execute an INSERT query.

Parameters

query	SQL INSERT statement
params	Optional query parameters

Returns: Result containing number of inserted rows or error

Note: This is a convenience wrapper around execute() that extracts only the affected_rows count from the query_result. Use this method when you only need to know how many rows were inserted.

See also: execute() for the underlying implementation

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h.

Definition at line 737 of file unified_database_system.cpp.

                                          {
    auto result = pimpl_->execute(query, params);
    if (result.is_ok()) {
        return result.value().affected_rows;
    }
    return result.error();
}

References pimpl_.

Referenced by test_insert_failure_not_connected(), and test_insert_success().

Here is the caller graph for this function:

◆ is_connected()

bool database::integrated::unified_database_system::is_connected ( ) const

Check if connected to database.

Returns: true if connected

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h.

Definition at line 719 of file unified_database_system.cpp.

                                                 {
    return pimpl_->is_connected();
}

References pimpl_.

Referenced by test_config_construction(), test_connect_mock_backend(), test_connect_typed_backend(), test_connect_unsupported_backend(), test_connection_state_api(), and test_zero_config_construction().

Here is the caller graph for this function:

◆ operator=() [1/2]

unified_database_system & database::integrated::unified_database_system::operator= ( const unified_database_system & )

delete

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h.

◆ operator=() [2/2]

unified_database_system & database::integrated::unified_database_system::operator= ( unified_database_system && )

defaultnoexcept

◆ remove()

kcenon::common::Result< size_t > database::integrated::unified_database_system::remove	(	const std::string &	query,
		const std::vector< query_param > &	params = {} )

Execute a DELETE query.

Parameters

query	SQL DELETE statement
params	Optional query parameters

Returns: Result containing number of deleted rows or error

Note: This is a convenience wrapper around execute() that extracts only the affected_rows count from the query_result. Use this method when you only need to know how many rows were deleted.

See also: execute() for the underlying implementation

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h.

Definition at line 757 of file unified_database_system.cpp.

                                          {
    auto result = pimpl_->execute(query, params);
    if (result.is_ok()) {
        return result.value().affected_rows;
    }
    return result.error();
}

References pimpl_.

Referenced by test_remove_failure_not_connected(), and test_remove_success().

Here is the caller graph for this function:

◆ reset_metrics()

void database::integrated::unified_database_system::reset_metrics ( )

Reset metrics counters.

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h.

Definition at line 803 of file unified_database_system.cpp.

                                            {
    pimpl_->reset_metrics();
}

References pimpl_.

Referenced by test_metrics_update_on_query(), test_reset_metrics(), and test_transaction_metrics().

Here is the caller graph for this function:

◆ select()

kcenon::common::Result< query_result > database::integrated::unified_database_system::select	(	const std::string &	query,
		const std::vector< query_param > &	params = {} )

Execute a SELECT query.

Parameters

query	SQL SELECT statement
params	Optional query parameters

Returns: Result containing selected rows or error

Note: This is a convenience wrapper around execute() that returns the full query_result. Use this method when you need all columns and rows from a SELECT statement.

See also: execute() for the underlying implementation

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h.

Definition at line 731 of file unified_database_system.cpp.

                                          {
    return pimpl_->execute(query, params);
}

References pimpl_.

Referenced by test_select_failure_not_connected(), and test_select_success().

Here is the caller graph for this function:

◆ update()

kcenon::common::Result< size_t > database::integrated::unified_database_system::update	(	const std::string &	query,
		const std::vector< query_param > &	params = {} )

Execute an UPDATE query.

Parameters

query	SQL UPDATE statement
params	Optional query parameters

Returns: Result containing number of updated rows or error

Note: This is a convenience wrapper around execute() that extracts only the affected_rows count from the query_result. Use this method when you only need to know how many rows were updated.

See also: execute() for the underlying implementation

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h.

Definition at line 747 of file unified_database_system.cpp.

                                          {
    auto result = pimpl_->execute(query, params);
    if (result.is_ok()) {
        return result.value().affected_rows;
    }
    return result.error();
}

References pimpl_.

Referenced by test_update_failure_not_connected(), and test_update_success().

Here is the caller graph for this function:

Member Data Documentation

◆ pimpl_

std::unique_ptr<impl> database::integrated::unified_database_system::pimpl_

private

Examples: /home/runner/work/database_system/database_system/database/integrated/unified_database_system.h.

Definition at line 635 of file unified_database_system.h.

Referenced by begin_transaction(), check_health(), connect(), create_query_builder(), disconnect(), execute(), execute_async(), execute_async_priority(), execute_transaction(), get_backend_type(), get_config(), get_metrics(), get_pool_stats(), insert(), is_connected(), remove(), reset_metrics(), select(), and update().

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

database/integrated/unified_database_system.h
database/integrated/unified_database_system.cpp

Classes

Public Member Functions

Static Public Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ unified_database_system() [1/4]

◆ unified_database_system() [2/4]

◆ ~unified_database_system()

◆ unified_database_system() [3/4]

◆ unified_database_system() [4/4]

Member Function Documentation

◆ begin_transaction()

◆ check_health()

◆ connect() [1/2]

◆ connect() [2/2]

◆ create_builder()

◆ create_query_builder()

◆ disconnect()

◆ execute()

◆ execute_async()

◆ execute_async_priority()

◆ execute_transaction()

◆ get_backend_type()

◆ get_config()

◆ get_metrics()

◆ get_pool_stats()

◆ in_transaction()

◆ insert()

◆ is_connected()

◆ operator=() [1/2]

◆ operator=() [2/2]

◆ remove()

◆ reset_metrics()

◆ select()

◆ update()

Member Data Documentation

◆ pimpl_