SQL dialect implementation for PostgreSQL, SQLite. More...

#include <query_dialect.h>

Inheritance diagram for database::detail::sql_dialect:

Collaboration diagram for database::detail::sql_dialect:

Public Member Functions
	sql_dialect (database_types db_type)

	~sql_dialect () override=default

void	set_query_type (query_type type) override

query_type	get_query_type () const override

void	set_select_columns (const std::vector< std::string > &columns) override

void	set_from_table (const std::string &table) override

void	add_where_condition (const query_condition &condition) override

void	add_where_condition (const std::string &field, const std::string &op, const core::database_value &value) override

void	add_join (const std::string &table, const std::string &condition, join_type type) override

void	set_group_by (const std::vector< std::string > &columns) override

void	set_having (const std::string &condition) override

void	add_order_by (const std::string &column, sort_order order) override

void	set_limit (size_t count) override

void	set_offset (size_t count) override

void	set_insert_table (const std::string &table) override

void	set_insert_data (const std::map< std::string, core::database_value > &data) override

void	set_insert_rows (const std::vector< std::map< std::string, core::database_value > > &rows) override

void	set_update_table (const std::string &table) override

void	set_update_data (const std::map< std::string, core::database_value > &data) override

void	set_delete_table (const std::string &table) override

void	set_collection (const std::string &name) override

void	set_key (const std::string &key) override

std::string	build () const override

void	reset () override

database_types	get_database_type () const override

Public Member Functions inherited from database::query_dialect
virtual	~query_dialect ()=default

Private Member Functions
std::string	escape_identifier (const std::string &identifier) const

std::string	format_value (const core::database_value &value) const

std::string	join_type_to_string (join_type type) const

Private Attributes
database_types	db_type_

query_type	type_

std::vector< std::string >	select_columns_

std::string	from_table_

std::vector< query_condition >	where_conditions_

std::vector< std::string >	joins_

std::vector< std::string >	group_by_columns_

std::string	having_clause_

std::vector< std::string >	order_by_clauses_

size_t	limit_count_

size_t	offset_count_

std::string	target_table_

std::map< std::string, core::database_value >	set_data_

std::vector< std::map< std::string, core::database_value > >	insert_rows_

Additional Inherited Members
Public Types inherited from database::query_dialect
enum class	query_type { none , select , insert , update , delete_query }

Detailed Description

SQL dialect implementation for PostgreSQL, SQLite.

Definition at line 98 of file query_dialect.h.

Constructor & Destructor Documentation

◆ sql_dialect()

database::detail::sql_dialect::sql_dialect ( database_types db_type )

explicit

Definition at line 35 of file query_dialect.cpp.

            : db_type_(db_type)
            , type_(query_type::none)
            , limit_count_(0)
            , offset_count_(0)
        {
        }

◆ ~sql_dialect()

database::detail::sql_dialect::~sql_dialect ( )

overridedefault

Member Function Documentation

◆ add_join()

void database::detail::sql_dialect::add_join	(	const std::string &	table,
		const std::string &	condition,
		join_type	type )

overridevirtual

Implements database::query_dialect.

Definition at line 74 of file query_dialect.cpp.

        {
            std::ostringstream oss;
            oss << join_type_to_string(type) << " JOIN " << table << " ON " << condition;
            joins_.push_back(oss.str());
        }

References join_type_to_string(), and joins_.

Here is the call graph for this function:

◆ add_order_by()

void database::detail::sql_dialect::add_order_by	(	const std::string &	column,
		sort_order	order )

overridevirtual

Implements database::query_dialect.

Definition at line 91 of file query_dialect.cpp.

        {
            std::ostringstream oss;
            oss << column << " " << (order == sort_order::asc ? "ASC" : "DESC");
            order_by_clauses_.push_back(oss.str());
        }

References database::asc, and order_by_clauses_.

◆ add_where_condition() [1/2]

void database::detail::sql_dialect::add_where_condition ( const query_condition & condition )

overridevirtual

Implements database::query_dialect.

Definition at line 64 of file query_dialect.cpp.

        {
            where_conditions_.push_back(condition);
        }

References where_conditions_.

◆ add_where_condition() [2/2]

void database::detail::sql_dialect::add_where_condition	(	const std::string &	field,
		const std::string &	op,
		const core::database_value &	value )

overridevirtual

Implements database::query_dialect.

Definition at line 69 of file query_dialect.cpp.

        {
            where_conditions_.emplace_back(field, op, value);
        }

References where_conditions_.

◆ build()

std::string database::detail::sql_dialect::build ( ) const

overridevirtual

Implements database::query_dialect.

Definition at line 151 of file query_dialect.cpp.

        {
            std::ostringstream oss;
 
            switch (type_) {
                case query_type::select:
                    oss << "SELECT ";
                    if (select_columns_.empty()) {
                        oss << "*";
                    } else {
                        for (size_t i = 0; i < select_columns_.size(); ++i) {
                            if (i > 0) oss << ", ";
                            oss << escape_identifier(select_columns_[i]);
                        }
                    }
                    if (!from_table_.empty()) {
                        oss << " FROM " << escape_identifier(from_table_);
                    }
                    break;
 
                case query_type::insert:
                    oss << "INSERT INTO " << escape_identifier(target_table_);
                    if (!insert_rows_.empty()) {
                        auto& first_row = insert_rows_[0];
                        oss << " (";
                        bool first = true;
                        for (const auto& pair : first_row) {
                            if (!first) oss << ", ";
                            oss << escape_identifier(pair.first);
                            first = false;
                        }
                        oss << ") VALUES ";
                        for (size_t i = 0; i < insert_rows_.size(); ++i) {
                            if (i > 0) oss << ", ";
                            oss << "(";
                            bool first_val = true;
                            for (const auto& pair : insert_rows_[i]) {
                                if (!first_val) oss << ", ";
                                oss << format_value(pair.second);
                                first_val = false;
                            }
                            oss << ")";
                        }
                    } else if (!set_data_.empty()) {
                        oss << " (";
                        bool first = true;
                        for (const auto& pair : set_data_) {
                            if (!first) oss << ", ";
                            oss << escape_identifier(pair.first);
                            first = false;
                        }
                        oss << ") VALUES (";
                        first = true;
                        for (const auto& pair : set_data_) {
                            if (!first) oss << ", ";
                            oss << format_value(pair.second);
                            first = false;
                        }
                        oss << ")";
                    }
                    break;
 
                case query_type::update:
                    oss << "UPDATE " << escape_identifier(target_table_) << " SET ";
                    {
                        bool first = true;
                        for (const auto& pair : set_data_) {
                            if (!first) oss << ", ";
                            oss << escape_identifier(pair.first) << " = " << format_value(pair.second);
                            first = false;
                        }
                    }
                    break;
 
                case query_type::delete_query:
                    oss << "DELETE FROM " << escape_identifier(target_table_);
                    break;
 
                default:
                    throw std::runtime_error("Invalid query type");
            }
 
            // Add JOINs
            for (const auto& join : joins_) {
                oss << " " << join;
            }
 
            // Add WHERE clause
            if (!where_conditions_.empty()) {
                oss << " WHERE ";
                for (size_t i = 0; i < where_conditions_.size(); ++i) {
                    if (i > 0) oss << " AND ";
                    oss << where_conditions_[i].to_sql();
                }
            }
 
            // Add GROUP BY
            if (!group_by_columns_.empty()) {
                oss << " GROUP BY ";
                for (size_t i = 0; i < group_by_columns_.size(); ++i) {
                    if (i > 0) oss << ", ";
                    oss << escape_identifier(group_by_columns_[i]);
                }
            }
 
            // Add HAVING
            if (!having_clause_.empty()) {
                oss << " HAVING " << having_clause_;
            }
 
            // Add ORDER BY
            if (!order_by_clauses_.empty()) {
                oss << " ORDER BY ";
                for (size_t i = 0; i < order_by_clauses_.size(); ++i) {
                    if (i > 0) oss << ", ";
                    oss << order_by_clauses_[i];
                }
            }
 
            // Add LIMIT and OFFSET
            if (limit_count_ > 0) {
                oss << " LIMIT " << limit_count_;
            }
            if (offset_count_ > 0) {
                oss << " OFFSET " << offset_count_;
            }
 
            return oss.str();
        }

References database::query_dialect::delete_query, escape_identifier(), format_value(), from_table_, group_by_columns_, having_clause_, database::query_dialect::insert, insert_rows_, joins_, limit_count_, offset_count_, order_by_clauses_, database::query_dialect::select, select_columns_, set_data_, target_table_, type_, database::query_dialect::update, and where_conditions_.

Here is the call graph for this function:

◆ escape_identifier()

std::string database::detail::sql_dialect::escape_identifier ( const std::string & identifier ) const

private

Definition at line 303 of file query_dialect.cpp.

        {
            switch (db_type_) {
                case database_types::postgres:
                    return "\"" + identifier + "\"";
                case database_types::sqlite:
                    return "[" + identifier + "]";
                default:
                    return identifier;
            }
        }

References db_type_, database::postgres, and database::sqlite.

Referenced by build().

Here is the caller graph for this function:

◆ format_value()

std::string database::detail::sql_dialect::format_value ( const core::database_value & value ) const

private

Definition at line 315 of file query_dialect.cpp.

        {
            std::ostringstream oss;
            std::visit([&oss](const auto& val) {
                using T = std::decay_t<decltype(val)>;
                if constexpr (std::is_same_v<T, std::string>) {
                    // Escape single quotes by doubling them (SQL standard)
                    std::string escaped;
                    escaped.reserve(val.size() + 10);
                    for (char c : val) {
                        if (c == '\'') {
                            escaped += "''";
                        } else {
                            escaped += c;
                        }
                    }
                    oss << "'" << escaped << "'";
                } else if constexpr (std::is_same_v<T, int64_t>) {
                    oss << val;
                } else if constexpr (std::is_same_v<T, double>) {
                    oss << val;
                } else if constexpr (std::is_same_v<T, bool>) {
                    oss << (val ? "TRUE" : "FALSE");
                } else if constexpr (std::is_same_v<T, std::monostate> || std::is_same_v<T, std::nullptr_t>) {
                    oss << "NULL";
                }
            }, value);
            return oss.str();
        }

Referenced by build().

Here is the caller graph for this function:

◆ get_database_type()

database_types database::detail::sql_dialect::get_database_type ( ) const

overridevirtual

Implements database::query_dialect.

Definition at line 298 of file query_dialect.cpp.

        {
            return db_type_;
        }

References db_type_.

◆ get_query_type()

query_dialect::query_type database::detail::sql_dialect::get_query_type ( ) const

overridevirtual

Implements database::query_dialect.

Definition at line 48 of file query_dialect.cpp.

        {
            return type_;
        }

References type_.

◆ join_type_to_string()

std::string database::detail::sql_dialect::join_type_to_string ( join_type type ) const

private

Definition at line 345 of file query_dialect.cpp.

        {
            switch (type) {
                case join_type::inner: return "INNER";
                case join_type::left: return "LEFT";
                case join_type::right: return "RIGHT";
                case join_type::full_outer: return "FULL OUTER";
                case join_type::cross: return "CROSS";
                default: return "INNER";
            }
        }

References database::cross, database::full_outer, database::inner, database::left, and database::right.

Referenced by add_join().

Here is the caller graph for this function:

◆ reset()

void database::detail::sql_dialect::reset ( )

overridevirtual

Implements database::query_dialect.

Definition at line 281 of file query_dialect.cpp.

        {
            type_ = query_type::none;
            select_columns_.clear();
            from_table_.clear();
            where_conditions_.clear();
            joins_.clear();
            group_by_columns_.clear();
            having_clause_.clear();
            order_by_clauses_.clear();
            limit_count_ = 0;
            offset_count_ = 0;
            target_table_.clear();
            set_data_.clear();
            insert_rows_.clear();
        }

References from_table_, group_by_columns_, having_clause_, insert_rows_, joins_, limit_count_, database::query_dialect::none, offset_count_, order_by_clauses_, select_columns_, set_data_, target_table_, type_, and where_conditions_.

◆ set_collection()

void database::detail::sql_dialect::set_collection ( const std::string & name )

overridevirtual

Implements database::query_dialect.

Definition at line 141 of file query_dialect.cpp.

        {
            // No-op for SQL
        }

◆ set_delete_table()

void database::detail::sql_dialect::set_delete_table ( const std::string & table )

overridevirtual

Implements database::query_dialect.

Definition at line 135 of file query_dialect.cpp.

        {
            type_ = query_type::delete_query;
            target_table_ = table;
        }

References database::query_dialect::delete_query, target_table_, and type_.

◆ set_from_table()

void database::detail::sql_dialect::set_from_table ( const std::string & table )

overridevirtual

Implements database::query_dialect.

Definition at line 59 of file query_dialect.cpp.

        {
            from_table_ = table;
        }

References from_table_.

◆ set_group_by()

void database::detail::sql_dialect::set_group_by ( const std::vector< std::string > & columns )

overridevirtual

Implements database::query_dialect.

Definition at line 81 of file query_dialect.cpp.

        {
            group_by_columns_ = columns;
        }

References group_by_columns_.

◆ set_having()

void database::detail::sql_dialect::set_having ( const std::string & condition )

overridevirtual

Implements database::query_dialect.

Definition at line 86 of file query_dialect.cpp.

        {
            having_clause_ = condition;
        }

References having_clause_.

◆ set_insert_data()

void database::detail::sql_dialect::set_insert_data ( const std::map< std::string, core::database_value > & data )

overridevirtual

Implements database::query_dialect.

Definition at line 114 of file query_dialect.cpp.

        {
            set_data_ = data;
        }

References set_data_.

◆ set_insert_rows()

void database::detail::sql_dialect::set_insert_rows ( const std::vector< std::map< std::string, core::database_value > > & rows )

overridevirtual

Implements database::query_dialect.

Definition at line 119 of file query_dialect.cpp.

        {
            insert_rows_ = rows;
        }

References insert_rows_.

◆ set_insert_table()

void database::detail::sql_dialect::set_insert_table ( const std::string & table )

overridevirtual

Implements database::query_dialect.

Definition at line 108 of file query_dialect.cpp.

        {
            type_ = query_type::insert;
            target_table_ = table;
        }

References database::query_dialect::insert, target_table_, and type_.

◆ set_key()

void database::detail::sql_dialect::set_key ( const std::string & key )

overridevirtual

Implements database::query_dialect.

Definition at line 146 of file query_dialect.cpp.

        {
            // No-op for SQL
        }

◆ set_limit()

void database::detail::sql_dialect::set_limit ( size_t count )

overridevirtual

Implements database::query_dialect.

Definition at line 98 of file query_dialect.cpp.

        {
            limit_count_ = count;
        }

References limit_count_.

◆ set_offset()

void database::detail::sql_dialect::set_offset ( size_t count )

overridevirtual

Implements database::query_dialect.

Definition at line 103 of file query_dialect.cpp.

        {
            offset_count_ = count;
        }

References offset_count_.

◆ set_query_type()

void database::detail::sql_dialect::set_query_type ( query_type type )

overridevirtual

Implements database::query_dialect.

Definition at line 43 of file query_dialect.cpp.

        {
            type_ = type;
        }

References type_.

◆ set_select_columns()

void database::detail::sql_dialect::set_select_columns ( const std::vector< std::string > & columns )

overridevirtual

Implements database::query_dialect.

Definition at line 53 of file query_dialect.cpp.

        {
            type_ = query_type::select;
            select_columns_ = columns;
        }

References database::query_dialect::select, select_columns_, and type_.

◆ set_update_data()

void database::detail::sql_dialect::set_update_data ( const std::map< std::string, core::database_value > & data )

overridevirtual

Implements database::query_dialect.

Definition at line 130 of file query_dialect.cpp.

        {
            set_data_ = data;
        }

References set_data_.

◆ set_update_table()

void database::detail::sql_dialect::set_update_table ( const std::string & table )

overridevirtual

Implements database::query_dialect.

Definition at line 124 of file query_dialect.cpp.

        {
            type_ = query_type::update;
            target_table_ = table;
        }

References target_table_, type_, and database::query_dialect::update.

Member Data Documentation

◆ db_type_

database_types database::detail::sql_dialect::db_type_

private

Definition at line 142 of file query_dialect.h.

Referenced by escape_identifier(), and get_database_type().

◆ from_table_

std::string database::detail::sql_dialect::from_table_

private

Definition at line 145 of file query_dialect.h.

Referenced by build(), reset(), and set_from_table().

◆ group_by_columns_

std::vector<std::string> database::detail::sql_dialect::group_by_columns_

private

Definition at line 148 of file query_dialect.h.

Referenced by build(), reset(), and set_group_by().

◆ having_clause_

std::string database::detail::sql_dialect::having_clause_

private

Definition at line 149 of file query_dialect.h.

Referenced by build(), reset(), and set_having().

◆ insert_rows_

std::vector<std::map<std::string, core::database_value> > database::detail::sql_dialect::insert_rows_

private

Definition at line 156 of file query_dialect.h.

Referenced by build(), reset(), and set_insert_rows().

◆ joins_

std::vector<std::string> database::detail::sql_dialect::joins_

private

Definition at line 147 of file query_dialect.h.

Referenced by add_join(), build(), and reset().

◆ limit_count_

size_t database::detail::sql_dialect::limit_count_

private

Definition at line 151 of file query_dialect.h.

Referenced by build(), reset(), and set_limit().

◆ offset_count_

size_t database::detail::sql_dialect::offset_count_

private

Definition at line 152 of file query_dialect.h.

Referenced by build(), reset(), and set_offset().

◆ order_by_clauses_

std::vector<std::string> database::detail::sql_dialect::order_by_clauses_

private

Definition at line 150 of file query_dialect.h.

Referenced by add_order_by(), build(), and reset().

◆ select_columns_

std::vector<std::string> database::detail::sql_dialect::select_columns_

private

Definition at line 144 of file query_dialect.h.

Referenced by build(), reset(), and set_select_columns().

◆ set_data_

std::map<std::string, core::database_value> database::detail::sql_dialect::set_data_

private

Definition at line 155 of file query_dialect.h.

Referenced by build(), reset(), set_insert_data(), and set_update_data().

◆ target_table_

std::string database::detail::sql_dialect::target_table_

private

Definition at line 154 of file query_dialect.h.

Referenced by build(), reset(), set_delete_table(), set_insert_table(), and set_update_table().

◆ type_

query_type database::detail::sql_dialect::type_

private

Definition at line 143 of file query_dialect.h.

Referenced by build(), get_query_type(), reset(), set_delete_table(), set_insert_table(), set_query_type(), set_select_columns(), and set_update_table().

◆ where_conditions_

std::vector<query_condition> database::detail::sql_dialect::where_conditions_

private

Definition at line 146 of file query_dialect.h.

Referenced by add_where_condition(), add_where_condition(), build(), and reset().

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

database/query_dialect.h
database/query_dialect.cpp

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ sql_dialect()

◆ ~sql_dialect()

Member Function Documentation

◆ add_join()

◆ add_order_by()

◆ add_where_condition() [1/2]

◆ add_where_condition() [2/2]

◆ build()

◆ escape_identifier()

◆ format_value()

◆ get_database_type()

◆ get_query_type()

◆ join_type_to_string()

◆ reset()

◆ set_collection()

◆ set_delete_table()

◆ set_from_table()

◆ set_group_by()

◆ set_having()

◆ set_insert_data()

◆ set_insert_rows()

◆ set_insert_table()

◆ set_key()

◆ set_limit()

◆ set_offset()

◆ set_query_type()

◆ set_select_columns()

◆ set_update_data()

◆ set_update_table()

Member Data Documentation

◆ db_type_

◆ from_table_

◆ group_by_columns_

◆ having_clause_

◆ insert_rows_

◆ joins_

◆ limit_count_

◆ offset_count_

◆ order_by_clauses_

◆ select_columns_

◆ set_data_

◆ target_table_

◆ type_

◆ where_conditions_