Statement.h

/*
 * MIT License
 *
 * Copyright (c) 2025 Adriano dos Santos Fernandes
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included in all
 * copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 * SOFTWARE.
 */
 
#ifndef FBCPP_STATEMENT_H
#define FBCPP_STATEMENT_H
 
#include "config.h"
#include "fb-api.h"
#include "types.h"
#include "Blob.h"
#include "Client.h"
#include "Row.h"
#include "StatementOptions.h"
#include "NumericConverter.h"
#include "CalendarConverter.h"
#include "Descriptor.h"
#include "SmartPtrs.h"
#include "Exception.h"
#include "StructBinding.h"
#include "VariantTypeTraits.h"
#include <charconv>
#include <cerrno>
#include <cstdlib>
#include <limits>
#include <memory>
#include <optional>
#include <stdexcept>
#include <string>
#include <string_view>
#include <type_traits>
#include <vector>
#include <cassert>
#include <cmath>
#include <cstddef>
#include <cstdint>
 
#if FB_CPP_USE_BOOST_MULTIPRECISION != 0
#include <boost/multiprecision/cpp_int.hpp>
#include <boost/multiprecision/cpp_dec_float.hpp>
#endif
 
namespace fbcpp
{
    class Attachment;
    class Transaction;
 
    enum class StatementType : unsigned
    {
        SELECT = isc_info_sql_stmt_select,
        INSERT = isc_info_sql_stmt_insert,
        UPDATE = isc_info_sql_stmt_update,
        DELETE = isc_info_sql_stmt_delete,
        DDL = isc_info_sql_stmt_ddl,
        GET_SEGMENT = isc_info_sql_stmt_get_segment,
        PUT_SEGMENT = isc_info_sql_stmt_put_segment,
        EXEC_PROCEDURE = isc_info_sql_stmt_exec_procedure,
        START_TRANSACTION = isc_info_sql_stmt_start_trans,
        COMMIT = isc_info_sql_stmt_commit,
        ROLLBACK = isc_info_sql_stmt_rollback,
        SELECT_FOR_UPDATE = isc_info_sql_stmt_select_for_upd,
        SET_GENERATOR = isc_info_sql_stmt_set_generator,
        SAVEPOINT = isc_info_sql_stmt_savepoint,
    };
 
    class Statement final
    {
    public:
        explicit Statement(Attachment& attachment, Transaction& transaction, std::string_view sql,
            const StatementOptions& options = {});
 
        Statement(Statement&& o) noexcept;
 
        Statement& operator=(Statement&& o) noexcept;
 
        Statement(const Statement&) = delete;
        Statement& operator=(const Statement&) = delete;
 
        ~Statement() noexcept
        {
            if (isValid())
            {
                try
                {
                    free();
                }
                catch (...)
                {
                    // swallow
                }
            }
        }
 
    public:
 
        Attachment& getAttachment() noexcept
        {
            return *attachment;
        }
 
        bool isValid() noexcept
        {
            return statementHandle != nullptr;
        }
 
        FbRef<fb::IStatement> getStatementHandle() noexcept
        {
            return statementHandle;
        }
 
        FbRef<fb::IResultSet> getResultSetHandle() noexcept
        {
            return resultSetHandle;
        }
 
        FbRef<fb::IMessageMetadata> getInputMetadata() noexcept
        {
            return inMetadata;
        }
 
        std::vector<std::byte>& getInputMessage() noexcept
        {
            return inMessage;
        }
 
        FbRef<fb::IMessageMetadata> getOutputMetadata() noexcept
        {
            return outMetadata;
        }
 
        std::vector<std::byte>& getOutputMessage() noexcept
        {
            return outMessage;
        }
 
        StatementType getType() noexcept
        {
            return type;
        }
 
 
 
        const std::vector<Descriptor>& getInputDescriptors() noexcept
        {
            return inDescriptors;
        }
 
        const std::vector<Descriptor>& getOutputDescriptors() noexcept
        {
            return outDescriptors;
        }
 
 
        void free();
 
        std::string getLegacyPlan();
 
        std::string getPlan();
 
        bool execute(Transaction& transaction);
 
 
        bool fetchNext();
 
        bool fetchPrior();
 
        bool fetchFirst();
 
        bool fetchLast();
 
        bool fetchAbsolute(unsigned position);
 
        bool fetchRelative(int offset);
 
 
 
        void clearParameters()
        {
            assert(isValid());
 
            const auto message = inMessage.data();
 
            for (const auto& descriptor : inDescriptors)
                *reinterpret_cast<std::int16_t*>(&message[descriptor.nullOffset]) = FB_TRUE;
        }
 
        void setNull(unsigned index)
        {
            assert(isValid());
 
            const auto& descriptor = getInDescriptor(index);
            const auto message = inMessage.data();
 
            *reinterpret_cast<std::int16_t*>(&message[descriptor.nullOffset]) = FB_TRUE;
        }
 
        void setBool(unsigned index, std::optional<bool> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            assert(isValid());
 
            const auto& value = optValue.value();
            const auto& descriptor = getInDescriptor(index);
            const auto message = inMessage.data();
 
            switch (descriptor.adjustedType)
            {
                case DescriptorAdjustedType::BOOLEAN:
                    message[descriptor.offset] = value ? std::byte{1} : std::byte{0};
                    break;
 
                default:
                    throwInvalidType("bool", descriptor.adjustedType);
            }
 
            *reinterpret_cast<std::int16_t*>(&message[descriptor.nullOffset]) = FB_FALSE;
        }
 
        void setInt16(unsigned index, std::optional<std::int16_t> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            setNumber(index, DescriptorAdjustedType::INT16, optValue.value(), 0, "std::int16_t");
        }
 
        void setScaledInt16(unsigned index, std::optional<ScaledInt16> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            const auto& value = optValue.value();
            setNumber(index, DescriptorAdjustedType::INT16, value.value, value.scale, "ScaledInt16");
        }
 
        void setInt32(unsigned index, std::optional<std::int32_t> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            setNumber(index, DescriptorAdjustedType::INT32, optValue.value(), 0, "std::int32_t");
        }
 
        void setScaledInt32(unsigned index, std::optional<ScaledInt32> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            const auto& value = optValue.value();
            setNumber(index, DescriptorAdjustedType::INT32, value.value, value.scale, "ScaledInt32");
        }
 
        void setInt64(unsigned index, std::optional<std::int64_t> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            setNumber(index, DescriptorAdjustedType::INT64, optValue.value(), 0, "std::int64_t");
        }
 
        void setScaledInt64(unsigned index, std::optional<ScaledInt64> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            const auto& value = optValue.value();
            setNumber(index, DescriptorAdjustedType::INT64, value.value, value.scale, "ScaledInt64");
        }
 
        void setOpaqueInt128(unsigned index, std::optional<OpaqueInt128> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            assert(isValid());
 
            const auto& value = optValue.value();
            const auto& descriptor = getInDescriptor(index);
            const auto message = inMessage.data();
 
            switch (descriptor.adjustedType)
            {
                case DescriptorAdjustedType::INT128:
                    *reinterpret_cast<OpaqueInt128*>(&message[descriptor.offset]) = value;
                    break;
 
                default:
                    throwInvalidType("OpaqueInt128", descriptor.adjustedType);
            }
 
            *reinterpret_cast<std::int16_t*>(&message[descriptor.nullOffset]) = FB_FALSE;
        }
 
#if FB_CPP_USE_BOOST_MULTIPRECISION != 0
        void setBoostInt128(unsigned index, std::optional<BoostInt128> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            setNumber(index, DescriptorAdjustedType::INT128, optValue.value(), 0, "BoostInt128");
        }
 
        void setScaledBoostInt128(unsigned index, std::optional<ScaledBoostInt128> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            const auto& value = optValue.value();
            setNumber(index, DescriptorAdjustedType::INT128, value.value, value.scale, "ScaledBoostInt128");
        }
#endif
 
        void setFloat(unsigned index, std::optional<float> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            setNumber(index, DescriptorAdjustedType::FLOAT, optValue.value(), 0, "float");
        }
 
        void setDouble(unsigned index, std::optional<double> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            setNumber(index, DescriptorAdjustedType::DOUBLE, optValue.value(), 0, "double");
        }
 
        void setOpaqueDecFloat16(unsigned index, std::optional<OpaqueDecFloat16> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            assert(isValid());
 
            const auto& value = optValue.value();
            const auto& descriptor = getInDescriptor(index);
            const auto message = inMessage.data();
 
            switch (descriptor.adjustedType)
            {
                case DescriptorAdjustedType::DECFLOAT16:
                    *reinterpret_cast<OpaqueDecFloat16*>(&message[descriptor.offset]) = value;
                    break;
 
                default:
                    throwInvalidType("OpaqueDecFloat16", descriptor.adjustedType);
            }
 
            *reinterpret_cast<std::int16_t*>(&message[descriptor.nullOffset]) = FB_FALSE;
        }
 
#if FB_CPP_USE_BOOST_MULTIPRECISION != 0
        void setBoostDecFloat16(unsigned index, std::optional<BoostDecFloat16> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            setNumber(index, DescriptorAdjustedType::DECFLOAT16, optValue.value(), 0, "BoostDecFloat16");
        }
#endif
 
        void setOpaqueDecFloat34(unsigned index, std::optional<OpaqueDecFloat34> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            assert(isValid());
 
            const auto& value = optValue.value();
            const auto& descriptor = getInDescriptor(index);
            const auto message = inMessage.data();
 
            switch (descriptor.adjustedType)
            {
                case DescriptorAdjustedType::DECFLOAT34:
                    *reinterpret_cast<OpaqueDecFloat34*>(&message[descriptor.offset]) = value;
                    break;
 
                default:
                    throwInvalidType("OpaqueDecFloat34", descriptor.adjustedType);
            }
 
            *reinterpret_cast<std::int16_t*>(&message[descriptor.nullOffset]) = FB_FALSE;
        }
 
#if FB_CPP_USE_BOOST_MULTIPRECISION != 0
        void setBoostDecFloat34(unsigned index, std::optional<BoostDecFloat34> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            setNumber(index, DescriptorAdjustedType::DECFLOAT34, optValue.value(), 0, "BoostDecFloat34");
        }
#endif
 
        void setDate(unsigned index, std::optional<Date> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            assert(isValid());
 
            const auto& value = optValue.value();
            const auto& descriptor = getInDescriptor(index);
            const auto message = inMessage.data();
 
            switch (descriptor.adjustedType)
            {
                case DescriptorAdjustedType::DATE:
                    *reinterpret_cast<OpaqueDate*>(&message[descriptor.offset]) =
                        calendarConverter.dateToOpaqueDate(value);
                    break;
 
                default:
                    throwInvalidType("Date", descriptor.adjustedType);
            }
 
            *reinterpret_cast<std::int16_t*>(&message[descriptor.nullOffset]) = FB_FALSE;
        }
 
        void setOpaqueDate(unsigned index, std::optional<OpaqueDate> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            assert(isValid());
 
            const auto& value = optValue.value();
            const auto& descriptor = getInDescriptor(index);
            const auto message = inMessage.data();
 
            switch (descriptor.adjustedType)
            {
                case DescriptorAdjustedType::DATE:
                    *reinterpret_cast<OpaqueDate*>(&message[descriptor.offset]) = value;
                    break;
 
                default:
                    throwInvalidType("OpaqueDate", descriptor.adjustedType);
            }
 
            *reinterpret_cast<std::int16_t*>(&message[descriptor.nullOffset]) = FB_FALSE;
        }
 
        void setTime(unsigned index, std::optional<Time> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            assert(isValid());
 
            const auto& value = optValue.value();
            const auto& descriptor = getInDescriptor(index);
            const auto message = inMessage.data();
 
            switch (descriptor.adjustedType)
            {
                case DescriptorAdjustedType::TIME:
                    *reinterpret_cast<OpaqueTime*>(&message[descriptor.offset]) =
                        calendarConverter.timeToOpaqueTime(value);
                    break;
 
                default:
                    throwInvalidType("Time", descriptor.adjustedType);
            }
 
            *reinterpret_cast<std::int16_t*>(&message[descriptor.nullOffset]) = FB_FALSE;
        }
 
        void setOpaqueTime(unsigned index, std::optional<OpaqueTime> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            assert(isValid());
 
            const auto& value = optValue.value();
            const auto& descriptor = getInDescriptor(index);
            const auto message = inMessage.data();
 
            switch (descriptor.adjustedType)
            {
                case DescriptorAdjustedType::TIME:
                    *reinterpret_cast<OpaqueTime*>(&message[descriptor.offset]) = value;
                    break;
 
                default:
                    throwInvalidType("OpaqueTime", descriptor.adjustedType);
            }
 
            *reinterpret_cast<std::int16_t*>(&message[descriptor.nullOffset]) = FB_FALSE;
        }
 
        void setTimestamp(unsigned index, std::optional<Timestamp> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            assert(isValid());
 
            const auto& value = optValue.value();
            const auto& descriptor = getInDescriptor(index);
            const auto message = inMessage.data();
 
            switch (descriptor.adjustedType)
            {
                case DescriptorAdjustedType::TIMESTAMP:
                    *reinterpret_cast<OpaqueTimestamp*>(&message[descriptor.offset]) =
                        calendarConverter.timestampToOpaqueTimestamp(value);
                    break;
 
                default:
                    throwInvalidType("Timestamp", descriptor.adjustedType);
            }
 
            *reinterpret_cast<std::int16_t*>(&message[descriptor.nullOffset]) = FB_FALSE;
        }
 
        void setOpaqueTimestamp(unsigned index, std::optional<OpaqueTimestamp> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            assert(isValid());
 
            const auto& value = optValue.value();
            const auto& descriptor = getInDescriptor(index);
            const auto message = inMessage.data();
 
            switch (descriptor.adjustedType)
            {
                case DescriptorAdjustedType::TIMESTAMP:
                    *reinterpret_cast<OpaqueTimestamp*>(&message[descriptor.offset]) = value;
                    break;
 
                default:
                    throwInvalidType("OpaqueTimestamp", descriptor.adjustedType);
            }
 
            *reinterpret_cast<std::int16_t*>(&message[descriptor.nullOffset]) = FB_FALSE;
        }
 
        void setTimeTz(unsigned index, std::optional<TimeTz> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            assert(isValid());
 
            const auto& value = optValue.value();
            const auto& descriptor = getInDescriptor(index);
            auto* const message = inMessage.data();
 
            switch (descriptor.adjustedType)
            {
                case DescriptorAdjustedType::TIME_TZ:
                    *reinterpret_cast<OpaqueTimeTz*>(&message[descriptor.offset]) =
                        calendarConverter.timeTzToOpaqueTimeTz(&statusWrapper, value);
                    break;
 
                default:
                    throwInvalidType("TimeTz", descriptor.adjustedType);
            }
 
            *reinterpret_cast<std::int16_t*>(&message[descriptor.nullOffset]) = FB_FALSE;
        }
 
        void setOpaqueTimeTz(unsigned index, std::optional<OpaqueTimeTz> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            assert(isValid());
 
            const auto& value = optValue.value();
            const auto& descriptor = getInDescriptor(index);
            auto* const message = inMessage.data();
 
            switch (descriptor.adjustedType)
            {
                case DescriptorAdjustedType::TIME_TZ:
                    *reinterpret_cast<OpaqueTimeTz*>(&message[descriptor.offset]) = value;
                    break;
 
                default:
                    throwInvalidType("OpaqueTimeTz", descriptor.adjustedType);
            }
 
            *reinterpret_cast<std::int16_t*>(&message[descriptor.nullOffset]) = FB_FALSE;
        }
 
        void setTimestampTz(unsigned index, std::optional<TimestampTz> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            assert(isValid());
 
            const auto& value = optValue.value();
            const auto& descriptor = getInDescriptor(index);
            auto* const message = inMessage.data();
 
            switch (descriptor.adjustedType)
            {
                case DescriptorAdjustedType::TIMESTAMP_TZ:
                    *reinterpret_cast<OpaqueTimestampTz*>(&message[descriptor.offset]) =
                        calendarConverter.timestampTzToOpaqueTimestampTz(&statusWrapper, value);
                    break;
 
                default:
                    throwInvalidType("TimestampTz", descriptor.adjustedType);
            }
 
            *reinterpret_cast<std::int16_t*>(&message[descriptor.nullOffset]) = FB_FALSE;
        }
 
        void setOpaqueTimestampTz(unsigned index, std::optional<OpaqueTimestampTz> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            assert(isValid());
 
            const auto& value = optValue.value();
            const auto& descriptor = getInDescriptor(index);
            auto* const message = inMessage.data();
 
            switch (descriptor.adjustedType)
            {
                case DescriptorAdjustedType::TIMESTAMP_TZ:
                    *reinterpret_cast<OpaqueTimestampTz*>(&message[descriptor.offset]) = value;
                    break;
 
                default:
                    throwInvalidType("OpaqueTimestampTz", descriptor.adjustedType);
            }
 
            *reinterpret_cast<std::int16_t*>(&message[descriptor.nullOffset]) = FB_FALSE;
        }
 
        void setString(unsigned index, std::optional<std::string_view> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            assert(isValid());
 
            auto& client = getClient();
            const auto value = optValue.value();
            const auto& descriptor = getInDescriptor(index);
            const auto message = inMessage.data();
            const auto data = &message[descriptor.offset];
 
            switch (descriptor.adjustedType)
            {
                case DescriptorAdjustedType::BOOLEAN:
                    message[descriptor.offset] = numericConverter.stringToBoolean(value);
                    break;
 
                case DescriptorAdjustedType::INT16:
                case DescriptorAdjustedType::INT32:
                case DescriptorAdjustedType::INT64:
                {
                    std::string strValue(value);
                    int scale = 0;
 
                    if (const auto dotPos = strValue.find_last_of('.'); dotPos != std::string_view::npos)
                    {
                        for (auto pos = dotPos + 1; pos < strValue.size(); ++pos)
                        {
                            const char c = value[pos];
 
                            if (c < '0' || c > '9')
                                break;
 
                            --scale;
                        }
 
                        strValue.erase(dotPos, 1);
                    }
 
                    static_assert(sizeof(long long) == sizeof(std::int64_t));
                    std::int64_t intValue;
                    const auto convResult =
                        std::from_chars(strValue.data(), strValue.data() + strValue.size(), intValue);
                    if (convResult.ec != std::errc{} || convResult.ptr != strValue.data() + strValue.size())
                        numericConverter.throwConversionErrorFromString(strValue);
                    auto scaledValue = ScaledInt64{intValue, scale};
 
                    if (scale != descriptor.scale)
                    {
                        scaledValue.value =
                            numericConverter.numberToNumber<std::int64_t>(scaledValue, descriptor.scale);
                        scaledValue.scale = descriptor.scale;
                    }
 
                    setScaledInt64(index, scaledValue);
                    return;
                }
 
                case DescriptorAdjustedType::INT128:
                {
                    std::string strValue(value);
                    client.getInt128Util(&statusWrapper)
                        ->fromString(
                            &statusWrapper, descriptor.scale, strValue.c_str(), reinterpret_cast<OpaqueInt128*>(data));
                    break;
                }
 
                case DescriptorAdjustedType::FLOAT:
                case DescriptorAdjustedType::DOUBLE:
                {
                    double doubleValue;
#if defined(__APPLE__)
                    errno = 0;
                    std::string valueString{value};
                    char* parseEnd = nullptr;
                    doubleValue = std::strtod(valueString.c_str(), &parseEnd);
                    if (parseEnd != valueString.c_str() + valueString.size() || errno == ERANGE)
                        numericConverter.throwConversionErrorFromString(std::move(valueString));
#else
                    const auto convResult = std::from_chars(value.data(), value.data() + value.size(), doubleValue);
                    if (convResult.ec != std::errc{} || convResult.ptr != value.data() + value.size())
                        numericConverter.throwConversionErrorFromString(std::string{value});
#endif
                    setDouble(index, doubleValue);
                    return;
                }
 
                case DescriptorAdjustedType::DATE:
                    *reinterpret_cast<OpaqueDate*>(data) = calendarConverter.stringToOpaqueDate(value);
                    break;
 
                case DescriptorAdjustedType::TIME:
                    *reinterpret_cast<OpaqueTime*>(data) = calendarConverter.stringToOpaqueTime(value);
                    break;
 
                case DescriptorAdjustedType::TIMESTAMP:
                    *reinterpret_cast<OpaqueTimestamp*>(data) = calendarConverter.stringToOpaqueTimestamp(value);
                    break;
 
                case DescriptorAdjustedType::TIME_TZ:
                    *reinterpret_cast<OpaqueTimeTz*>(data) =
                        calendarConverter.stringToOpaqueTimeTz(&statusWrapper, value);
                    break;
 
                case DescriptorAdjustedType::TIMESTAMP_TZ:
                    *reinterpret_cast<OpaqueTimestampTz*>(data) =
                        calendarConverter.stringToOpaqueTimestampTz(&statusWrapper, value);
                    break;
 
#if FB_CPP_USE_BOOST_MULTIPRECISION != 0
                case DescriptorAdjustedType::DECFLOAT16:
                {
                    std::string strValue{value};
                    client.getDecFloat16Util(&statusWrapper)
                        ->fromString(&statusWrapper, strValue.c_str(), reinterpret_cast<OpaqueDecFloat16*>(data));
                    break;
                }
 
                case DescriptorAdjustedType::DECFLOAT34:
                {
                    std::string strValue{value};
                    client.getDecFloat34Util(&statusWrapper)
                        ->fromString(&statusWrapper, strValue.c_str(), reinterpret_cast<OpaqueDecFloat34*>(data));
                    break;
                }
#endif
 
                case DescriptorAdjustedType::STRING:
                    if (value.length() > descriptor.length)
                    {
                        static constexpr std::intptr_t STATUS_STRING_TRUNCATION[] = {
                            isc_arith_except,
                            isc_string_truncation,
                            isc_arg_end,
                        };
 
                        throw DatabaseException(client, STATUS_STRING_TRUNCATION);
                    }
 
                    *reinterpret_cast<std::uint16_t*>(data) = static_cast<std::uint16_t>(value.length());
                    std::copy(value.begin(), value.end(),
                        reinterpret_cast<char*>(&message[descriptor.offset + sizeof(std::uint16_t)]));
                    break;
 
                default:
                    throwInvalidType("std::string_view", descriptor.adjustedType);
            }
 
            *reinterpret_cast<std::int16_t*>(&message[descriptor.nullOffset]) = FB_FALSE;
        }
 
        void setBlobId(unsigned index, std::optional<BlobId> optValue)
        {
            if (!optValue.has_value())
            {
                setNull(index);
                return;
            }
 
            assert(isValid());
 
            const auto& value = optValue.value();
            const auto& descriptor = getInDescriptor(index);
            auto* const message = inMessage.data();
 
            switch (descriptor.adjustedType)
            {
                case DescriptorAdjustedType::BLOB:
                    *reinterpret_cast<ISC_QUAD*>(&message[descriptor.offset]) = value.id;
                    break;
 
                default:
                    throwInvalidType("BlobId", descriptor.adjustedType);
            }
 
            *reinterpret_cast<std::int16_t*>(&message[descriptor.nullOffset]) = FB_FALSE;
        }
 
        void set(unsigned index, std::nullopt_t)
        {
            setNull(index);
        }
 
        void set(unsigned index, BlobId value)
        {
            setBlobId(index, value);
        }
 
        void set(unsigned index, std::optional<BlobId> value)
        {
            setBlobId(index, value);
        }
 
        void set(unsigned index, bool value)
        {
            setBool(index, value);
        }
 
        void set(unsigned index, std::int16_t value)
        {
            setInt16(index, value);
        }
 
        void set(unsigned index, ScaledInt16 value)
        {
            setScaledInt16(index, value);
        }
 
        void set(unsigned index, std::int32_t value)
        {
            setInt32(index, value);
        }
 
        void set(unsigned index, ScaledInt32 value)
        {
            setScaledInt32(index, value);
        }
 
        void set(unsigned index, std::int64_t value)
        {
            setInt64(index, value);
        }
 
        void set(unsigned index, ScaledInt64 value)
        {
            setScaledInt64(index, value);
        }
 
        void set(unsigned index, OpaqueInt128 value)
        {
            setOpaqueInt128(index, value);
        }
 
#if FB_CPP_USE_BOOST_MULTIPRECISION != 0
        void set(unsigned index, BoostInt128 value)
        {
            setBoostInt128(index, value);
        }
 
        void set(unsigned index, ScaledBoostInt128 value)
        {
            setScaledBoostInt128(index, value);
        }
#endif
 
        void set(unsigned index, float value)
        {
            setFloat(index, value);
        }
 
        void set(unsigned index, double value)
        {
            setDouble(index, value);
        }
 
        void set(unsigned index, OpaqueDecFloat16 value)
        {
            setOpaqueDecFloat16(index, value);
        }
 
#if FB_CPP_USE_BOOST_MULTIPRECISION != 0
        void set(unsigned index, BoostDecFloat16 value)
        {
            setBoostDecFloat16(index, value);
        }
#endif
 
        void set(unsigned index, OpaqueDecFloat34 value)
        {
            setOpaqueDecFloat34(index, value);
        }
 
#if FB_CPP_USE_BOOST_MULTIPRECISION != 0
        void set(unsigned index, BoostDecFloat34 value)
        {
            setBoostDecFloat34(index, value);
        }
#endif
 
        void set(unsigned index, Date value)
        {
            setDate(index, value);
        }
 
        void set(unsigned index, OpaqueDate value)
        {
            setOpaqueDate(index, value);
        }
 
        void set(unsigned index, Time value)
        {
            setTime(index, value);
        }
 
        void set(unsigned index, OpaqueTime value)
        {
            setOpaqueTime(index, value);
        }
 
        void set(unsigned index, Timestamp value)
        {
            setTimestamp(index, value);
        }
 
        void set(unsigned index, OpaqueTimestamp value)
        {
            setOpaqueTimestamp(index, value);
        }
 
        void set(unsigned index, TimeTz value)
        {
            setTimeTz(index, value);
        }
 
        void set(unsigned index, OpaqueTimeTz value)
        {
            setOpaqueTimeTz(index, value);
        }
 
        void set(unsigned index, TimestampTz value)
        {
            setTimestampTz(index, value);
        }
 
        void set(unsigned index, OpaqueTimestampTz value)
        {
            setOpaqueTimestampTz(index, value);
        }
 
        void set(unsigned index, std::string_view value)
        {
            setString(index, value);
        }
 
        template <typename T>
        void set(unsigned index, std::optional<T> value)
        {
            if (value.has_value())
                set(index, value.value());
            else
                setNull(index);
        }
 
 
 
        bool isNull(unsigned index)
        {
            assert(isValid());
            return outRow->isNull(index);
        }
 
        std::optional<bool> getBool(unsigned index)
        {
            assert(isValid());
            return outRow->getBool(index);
        }
 
        std::optional<std::int16_t> getInt16(unsigned index)
        {
            assert(isValid());
            return outRow->getInt16(index);
        }
 
        std::optional<ScaledInt16> getScaledInt16(unsigned index)
        {
            assert(isValid());
            return outRow->getScaledInt16(index);
        }
 
        std::optional<std::int32_t> getInt32(unsigned index)
        {
            assert(isValid());
            return outRow->getInt32(index);
        }
 
        std::optional<ScaledInt32> getScaledInt32(unsigned index)
        {
            assert(isValid());
            return outRow->getScaledInt32(index);
        }
 
        std::optional<std::int64_t> getInt64(unsigned index)
        {
            assert(isValid());
            return outRow->getInt64(index);
        }
 
        std::optional<ScaledInt64> getScaledInt64(unsigned index)
        {
            assert(isValid());
            return outRow->getScaledInt64(index);
        }
 
        std::optional<ScaledOpaqueInt128> getScaledOpaqueInt128(unsigned index)
        {
            assert(isValid());
            return outRow->getScaledOpaqueInt128(index);
        }
 
#if FB_CPP_USE_BOOST_MULTIPRECISION != 0
        std::optional<BoostInt128> getBoostInt128(unsigned index)
        {
            assert(isValid());
            return outRow->getBoostInt128(index);
        }
 
        std::optional<ScaledBoostInt128> getScaledBoostInt128(unsigned index)
        {
            assert(isValid());
            return outRow->getScaledBoostInt128(index);
        }
#endif
 
        std::optional<float> getFloat(unsigned index)
        {
            assert(isValid());
            return outRow->getFloat(index);
        }
 
        std::optional<double> getDouble(unsigned index)
        {
            assert(isValid());
            return outRow->getDouble(index);
        }
 
        std::optional<OpaqueDecFloat16> getOpaqueDecFloat16(unsigned index)
        {
            assert(isValid());
            return outRow->getOpaqueDecFloat16(index);
        }
 
#if FB_CPP_USE_BOOST_MULTIPRECISION != 0
        std::optional<BoostDecFloat16> getBoostDecFloat16(unsigned index)
        {
            assert(isValid());
            return outRow->getBoostDecFloat16(index);
        }
#endif
 
        std::optional<OpaqueDecFloat34> getOpaqueDecFloat34(unsigned index)
        {
            assert(isValid());
            return outRow->getOpaqueDecFloat34(index);
        }
 
#if FB_CPP_USE_BOOST_MULTIPRECISION != 0
        std::optional<BoostDecFloat34> getBoostDecFloat34(unsigned index)
        {
            assert(isValid());
            return outRow->getBoostDecFloat34(index);
        }
#endif
 
        std::optional<Date> getDate(unsigned index)
        {
            assert(isValid());
            return outRow->getDate(index);
        }
 
        std::optional<OpaqueDate> getOpaqueDate(unsigned index)
        {
            assert(isValid());
            return outRow->getOpaqueDate(index);
        }
 
        std::optional<Time> getTime(unsigned index)
        {
            assert(isValid());
            return outRow->getTime(index);
        }
 
        std::optional<OpaqueTime> getOpaqueTime(unsigned index)
        {
            assert(isValid());
            return outRow->getOpaqueTime(index);
        }
 
        std::optional<Timestamp> getTimestamp(unsigned index)
        {
            assert(isValid());
            return outRow->getTimestamp(index);
        }
 
        std::optional<OpaqueTimestamp> getOpaqueTimestamp(unsigned index)
        {
            assert(isValid());
            return outRow->getOpaqueTimestamp(index);
        }
 
        std::optional<TimeTz> getTimeTz(unsigned index)
        {
            assert(isValid());
            return outRow->getTimeTz(index);
        }
 
        std::optional<OpaqueTimeTz> getOpaqueTimeTz(unsigned index)
        {
            assert(isValid());
            return outRow->getOpaqueTimeTz(index);
        }
 
        std::optional<TimestampTz> getTimestampTz(unsigned index)
        {
            assert(isValid());
            return outRow->getTimestampTz(index);
        }
 
        std::optional<OpaqueTimestampTz> getOpaqueTimestampTz(unsigned index)
        {
            assert(isValid());
            return outRow->getOpaqueTimestampTz(index);
        }
 
        std::optional<BlobId> getBlobId(unsigned index)
        {
            assert(isValid());
            return outRow->getBlobId(index);
        }
 
        std::optional<std::string> getString(unsigned index)
        {
            assert(isValid());
            return outRow->getString(index);
        }
 
 
        template <typename T>
        T get(unsigned index)
        {
            assert(isValid());
            return outRow->get<T>(index);
        }
 
        template <Aggregate T>
        T get()
        {
            assert(isValid());
            return outRow->get<T>();
        }
 
        template <Aggregate T>
        void set(const T& value)
        {
            using namespace impl::reflection;
 
            constexpr std::size_t N = fieldCountV<T>;
 
            if (N != inDescriptors.size())
            {
                throw FbCppException("Struct field count (" + std::to_string(N) +
                    ") does not match input parameter count (" + std::to_string(inDescriptors.size()) + ")");
            }
 
            setStruct(value, std::make_index_sequence<N>{});
        }
 
        template <TupleLike T>
        T get()
        {
            assert(isValid());
            return outRow->get<T>();
        }
 
        template <TupleLike T>
        void set(const T& value)
        {
            constexpr std::size_t N = std::tuple_size_v<T>;
 
            if (N != inDescriptors.size())
            {
                throw FbCppException("Tuple element count (" + std::to_string(N) +
                    ") does not match input parameter count (" + std::to_string(inDescriptors.size()) + ")");
            }
 
            setTuple(value, std::make_index_sequence<N>{});
        }
 
        template <VariantLike V>
        V get(unsigned index)
        {
            assert(isValid());
            return outRow->get<V>(index);
        }
 
        template <VariantLike V>
        void set(unsigned index, const V& value)
        {
            using namespace impl::reflection;
 
            static_assert(variantAlternativesSupportedV<V>,
                "Variant contains unsupported types. All variant alternatives must be types supported by fb-cpp "
                "(e.g., std::int32_t, std::string, Date, ScaledOpaqueInt128, etc.). Check VariantTypeTraits.h for the "
                "complete list of supported types.");
 
            std::visit(
                [this, index](const auto& v)
                {
                    using T = std::decay_t<decltype(v)>;
 
                    if constexpr (std::is_same_v<T, std::monostate>)
                        setNull(index);
                    else
                        set(index, v);
                },
                value);
        }
 
    private:
        const Descriptor& getInDescriptor(unsigned index)
        {
            if (index >= inDescriptors.size())
                throw std::out_of_range("index out of range");
 
            return inDescriptors[index];
        }
 
        template <typename T, std::size_t... Is>
        void setStruct(const T& value, std::index_sequence<Is...>)
        {
            using namespace impl::reflection;
 
            const auto tuple = toTupleRef(value);
            (set(static_cast<unsigned>(Is), std::get<Is>(tuple)), ...);
        }
 
        template <typename T, std::size_t... Is>
        void setTuple(const T& value, std::index_sequence<Is...>)
        {
            (set(static_cast<unsigned>(Is), std::get<Is>(value)), ...);
        }
 
        template <typename T>
        void setNumber(unsigned index, DescriptorAdjustedType valueType, T value, int scale, const char* typeName)
        {
            assert(isValid());
 
            const auto& descriptor = getInDescriptor(index);
            auto* const message = inMessage.data();
 
            const auto descriptorData = &message[descriptor.offset];
            std::optional<int> descriptorScale{descriptor.scale};
 
            Descriptor valueDescriptor;
            valueDescriptor.adjustedType = valueType;
            valueDescriptor.scale = scale;
 
            const auto valueAddress = reinterpret_cast<const std::byte*>(&value);
 
            switch (descriptor.adjustedType)
            {
                case DescriptorAdjustedType::INT16:
                    *reinterpret_cast<std::int16_t*>(descriptorData) =
                        convertNumber<std::int16_t>(valueDescriptor, valueAddress, descriptorScale, "std::int16_t");
                    break;
 
                case DescriptorAdjustedType::INT32:
                    *reinterpret_cast<std::int32_t*>(descriptorData) =
                        convertNumber<std::int32_t>(valueDescriptor, valueAddress, descriptorScale, "std::int32_t");
                    break;
 
                case DescriptorAdjustedType::INT64:
                    *reinterpret_cast<std::int64_t*>(descriptorData) =
                        convertNumber<std::int64_t>(valueDescriptor, valueAddress, descriptorScale, "std::int64_t");
                    break;
 
#if FB_CPP_USE_BOOST_MULTIPRECISION != 0
                case DescriptorAdjustedType::INT128:
                {
                    const auto boostInt128 =
                        convertNumber<BoostInt128>(valueDescriptor, valueAddress, descriptorScale, "BoostInt128");
                    *reinterpret_cast<OpaqueInt128*>(descriptorData) =
                        numericConverter.boostInt128ToOpaqueInt128(boostInt128);
                    break;
                }
#endif
 
                case DescriptorAdjustedType::FLOAT:
                    *reinterpret_cast<float*>(descriptorData) =
                        convertNumber<float>(valueDescriptor, valueAddress, descriptorScale, "float");
                    break;
 
                case DescriptorAdjustedType::DOUBLE:
                    *reinterpret_cast<double*>(descriptorData) =
                        convertNumber<double>(valueDescriptor, valueAddress, descriptorScale, "double");
                    break;
 
#if FB_CPP_USE_BOOST_MULTIPRECISION != 0
                case DescriptorAdjustedType::DECFLOAT16:
                {
                    const auto boostDecFloat16 = convertNumber<BoostDecFloat16>(
                        valueDescriptor, valueAddress, descriptorScale, "BoostDecFloat16");
                    *reinterpret_cast<OpaqueDecFloat16*>(descriptorData) =
                        numericConverter.boostDecFloat16ToOpaqueDecFloat16(&statusWrapper, boostDecFloat16);
                    break;
                }
 
                case DescriptorAdjustedType::DECFLOAT34:
                {
                    const auto boostDecFloat34 = convertNumber<BoostDecFloat34>(
                        valueDescriptor, valueAddress, descriptorScale, "BoostDecFloat34");
                    *reinterpret_cast<OpaqueDecFloat34*>(descriptorData) =
                        numericConverter.boostDecFloat34ToOpaqueDecFloat34(&statusWrapper, boostDecFloat34);
                    break;
                }
#endif
 
                default:
                    throwInvalidType(typeName, descriptor.adjustedType);
            }
 
            *reinterpret_cast<std::int16_t*>(&message[descriptor.nullOffset]) = FB_FALSE;
        }
 
        [[noreturn]] static void throwInvalidType(const char* actualType, DescriptorAdjustedType descriptorType)
        {
            throw FbCppException("Invalid type: actual type " + std::string(actualType) + ", descriptor type " +
                std::to_string(static_cast<unsigned>(descriptorType)));
        }
 
        template <typename T>
        T convertNumber(
            const Descriptor& descriptor, const std::byte* data, std::optional<int>& toScale, const char* toTypeName)
        {
            if (!toScale.has_value())
            {
                switch (descriptor.adjustedType)
                {
                    case DescriptorAdjustedType::DECFLOAT16:
                    case DescriptorAdjustedType::DECFLOAT34:
                    case DescriptorAdjustedType::FLOAT:
                    case DescriptorAdjustedType::DOUBLE:
                        throwInvalidType(toTypeName, descriptor.adjustedType);
 
                    default:
                        break;
                }
 
                toScale = descriptor.scale;
            }
 
            switch (descriptor.adjustedType)
            {
                case DescriptorAdjustedType::INT16:
                    return numericConverter.numberToNumber<T>(
                        ScaledInt16{*reinterpret_cast<const std::int16_t*>(data), descriptor.scale}, toScale.value());
                    break;
 
                case DescriptorAdjustedType::INT32:
                    return numericConverter.numberToNumber<T>(
                        ScaledInt32{*reinterpret_cast<const std::int32_t*>(data), descriptor.scale}, toScale.value());
 
                case DescriptorAdjustedType::INT64:
                    return numericConverter.numberToNumber<T>(
                        ScaledInt64{*reinterpret_cast<const std::int64_t*>(data), descriptor.scale}, toScale.value());
 
#if FB_CPP_USE_BOOST_MULTIPRECISION != 0
                case DescriptorAdjustedType::INT128:
                    return numericConverter.numberToNumber<T>(
                        ScaledBoostInt128{*reinterpret_cast<const BoostInt128*>(data), descriptor.scale},
                        toScale.value());
 
                case DescriptorAdjustedType::DECFLOAT16:
                    return numericConverter.numberToNumber<T>(
                        *reinterpret_cast<const BoostDecFloat16*>(data), toScale.value());
 
                case DescriptorAdjustedType::DECFLOAT34:
                    return numericConverter.numberToNumber<T>(
                        *reinterpret_cast<const BoostDecFloat34*>(data), toScale.value());
#endif
 
                case DescriptorAdjustedType::FLOAT:
                    return numericConverter.numberToNumber<T>(*reinterpret_cast<const float*>(data), toScale.value());
                    break;
 
                case DescriptorAdjustedType::DOUBLE:
                    return numericConverter.numberToNumber<T>(*reinterpret_cast<const double*>(data), toScale.value());
                    break;
 
                default:
                    throwInvalidType(toTypeName, descriptor.adjustedType);
            }
        }
 
    private:
        Client& getClient() noexcept;
 
    private:
        Attachment* attachment;
        impl::StatusWrapper statusWrapper;
        impl::CalendarConverter calendarConverter;
        impl::NumericConverter numericConverter;
        FbRef<fb::IStatement> statementHandle;
        FbRef<fb::IResultSet> resultSetHandle;
        FbRef<fb::IMessageMetadata> inMetadata;
        std::vector<Descriptor> inDescriptors;
        std::vector<std::byte> inMessage;
        FbRef<fb::IMessageMetadata> outMetadata;
        std::vector<Descriptor> outDescriptors;
        std::vector<std::byte> outMessage;
        std::unique_ptr<Row> outRow;
        StatementType type;
        unsigned cursorFlags = 0;
    };
 
 
    template <>
    inline std::optional<bool> Statement::get<std::optional<bool>>(unsigned index)
    {
        return getBool(index);
    }
 
    template <>
    inline std::optional<BlobId> Statement::get<std::optional<BlobId>>(unsigned index)
    {
        return getBlobId(index);
    }
 
    template <>
    inline std::optional<std::int16_t> Statement::get<std::optional<std::int16_t>>(unsigned index)
    {
        return getInt16(index);
    }
 
    template <>
    inline std::optional<ScaledInt16> Statement::get<std::optional<ScaledInt16>>(unsigned index)
    {
        return getScaledInt16(index);
    }
 
    template <>
    inline std::optional<std::int32_t> Statement::get<std::optional<std::int32_t>>(unsigned index)
    {
        return getInt32(index);
    }
 
    template <>
    inline std::optional<ScaledInt32> Statement::get<std::optional<ScaledInt32>>(unsigned index)
    {
        return getScaledInt32(index);
    }
 
    template <>
    inline std::optional<std::int64_t> Statement::get<std::optional<std::int64_t>>(unsigned index)
    {
        return getInt64(index);
    }
 
    template <>
    inline std::optional<ScaledInt64> Statement::get<std::optional<ScaledInt64>>(unsigned index)
    {
        return getScaledInt64(index);
    }
 
    template <>
    inline std::optional<ScaledOpaqueInt128> Statement::get<std::optional<ScaledOpaqueInt128>>(unsigned index)
    {
        return getScaledOpaqueInt128(index);
    }
 
#if FB_CPP_USE_BOOST_MULTIPRECISION != 0
    template <>
    inline std::optional<BoostInt128> Statement::get<std::optional<BoostInt128>>(unsigned index)
    {
        return getBoostInt128(index);
    }
 
    template <>
    inline std::optional<ScaledBoostInt128> Statement::get<std::optional<ScaledBoostInt128>>(unsigned index)
    {
        return getScaledBoostInt128(index);
    }
#endif
 
    template <>
    inline std::optional<float> Statement::get<std::optional<float>>(unsigned index)
    {
        return getFloat(index);
    }
 
    template <>
    inline std::optional<double> Statement::get<std::optional<double>>(unsigned index)
    {
        return getDouble(index);
    }
 
    template <>
    inline std::optional<OpaqueDecFloat16> Statement::get<std::optional<OpaqueDecFloat16>>(unsigned index)
    {
        return getOpaqueDecFloat16(index);
    }
 
#if FB_CPP_USE_BOOST_MULTIPRECISION != 0
    template <>
    inline std::optional<BoostDecFloat16> Statement::get<std::optional<BoostDecFloat16>>(unsigned index)
    {
        return getBoostDecFloat16(index);
    }
#endif
 
    template <>
    inline std::optional<OpaqueDecFloat34> Statement::get<std::optional<OpaqueDecFloat34>>(unsigned index)
    {
        return getOpaqueDecFloat34(index);
    }
 
#if FB_CPP_USE_BOOST_MULTIPRECISION != 0
    template <>
    inline std::optional<BoostDecFloat34> Statement::get<std::optional<BoostDecFloat34>>(unsigned index)
    {
        return getBoostDecFloat34(index);
    }
#endif
 
    template <>
    inline std::optional<Date> Statement::get<std::optional<Date>>(unsigned index)
    {
        return getDate(index);
    }
 
    template <>
    inline std::optional<OpaqueDate> Statement::get<std::optional<OpaqueDate>>(unsigned index)
    {
        return getOpaqueDate(index);
    }
 
    template <>
    inline std::optional<Time> Statement::get<std::optional<Time>>(unsigned index)
    {
        return getTime(index);
    }
 
    template <>
    inline std::optional<OpaqueTime> Statement::get<std::optional<OpaqueTime>>(unsigned index)
    {
        return getOpaqueTime(index);
    }
 
    template <>
    inline std::optional<OpaqueTimestamp> Statement::get<std::optional<OpaqueTimestamp>>(unsigned index)
    {
        return getOpaqueTimestamp(index);
    }
 
    template <>
    inline std::optional<Timestamp> Statement::get<std::optional<Timestamp>>(unsigned index)
    {
        return getTimestamp(index);
    }
 
    template <>
    inline std::optional<TimeTz> Statement::get<std::optional<TimeTz>>(unsigned index)
    {
        return getTimeTz(index);
    }
 
    template <>
    inline std::optional<OpaqueTimeTz> Statement::get<std::optional<OpaqueTimeTz>>(unsigned index)
    {
        return getOpaqueTimeTz(index);
    }
 
    template <>
    inline std::optional<TimestampTz> Statement::get<std::optional<TimestampTz>>(unsigned index)
    {
        return getTimestampTz(index);
    }
 
    template <>
    inline std::optional<OpaqueTimestampTz> Statement::get<std::optional<OpaqueTimestampTz>>(unsigned index)
    {
        return getOpaqueTimestampTz(index);
    }
 
    template <>
    inline std::optional<std::string> Statement::get<std::optional<std::string>>(unsigned index)
    {
        return getString(index);
    }
 
}  // namespace fbcpp
 
 
#endif  // FBCPP_STATEMENT_H