mssql.hxx

Go to the documentation of this file.

/*
 * Copyright (C) 2024-2026 David C. Manuelda (StormBytePP)
 *
 * This file is part of StormByte-Database.
 *
 * SPDX-License-Identifier: LGPL-3.0-or-later OR LicenseRef-StormByte-Commercial
 */
 
#pragma once
 
#include <StormByte/database/database.hxx>
#include <StormByte/database/mssql/telemetry.hxx>
#include <StormByte/database/mssql/prepared_stmt.hxx>
 
#include <string>
#include <string_view>
#include <vector>
 
struct tds_dblib_dbprocess;
 
namespace StormByte {
    namespace Database {
        namespace MSSQL {
            class STORMBYTE_DATABASE_PUBLIC MSSQL : public StormByte::Database::Database {
                public:
                    MSSQL(const MSSQL&) = delete;
                    MSSQL(MSSQL&& other) noexcept;
                    MSSQL& operator=(const MSSQL&) = delete;
                    MSSQL& operator=(MSSQL&& other) noexcept;
                    ~MSSQL() noexcept override;
 
                    ExpectedRows Query(std::string_view query) noexcept override;
                    bool SilentQuery(std::string_view query) noexcept override;
 
                protected:
                    MSSQL(std::string_view host, std::string_view user, std::string_view password,
                        std::string_view database, int port, const StormByte::Safe::Shared<Logger::Log>& logger);
 
                    bool DoSilentQuery(std::string_view query) noexcept override;
 
                private:
                    friend class PreparedSTMT;
                    std::string m_host; 
                    std::string m_user; 
                    std::string m_password; 
                    std::string m_database; 
                    int m_port; 
                    struct tds_dblib_dbprocess* m_connection; 
                    std::string m_last_error; 
 
                    bool DoConnect() noexcept override;
                    void DoDisconnect() noexcept override;
                    void DoPreDisconnect() noexcept override;
                    StormByte::Safe::Unique<StormByte::Database::PreparedSTMT> CreatePreparedSTMT(
                        std::string_view name, std::string_view query) noexcept override;
                    void DoBeginTransaction(IsolationLevel level) override;
 
                    static int ErrorHandler(struct tds_dblib_dbprocess* process, int severity, int database_error,
                        int operating_system_error, char* database_message, char* operating_system_message);
                    static int MessageHandler(struct tds_dblib_dbprocess* process, int message_number, int state,
                        int severity, char* text, char* server, char* procedure, int line);
                    ExpectedRows ExecuteParameterized(std::string_view query, const std::vector<Value>& parameters);
            };
        }
    }
}