connection.cpp

Go to the documentation of this file.

Go to the SVN repository for this file.

/* $Id: connection.cpp 102711 2024-06-28 14:39:22Z ucko $
 * ===========================================================================
 *
 *                            PUBLIC DOMAIN NOTICE
 *               National Center for Biotechnology Information
 *
 *  This software/database is a "United States Government Work" under the
 *  terms of the United States Copyright Act.  It was written as part of
 *  the author's official duties as a United States Government employee and
 *  thus cannot be copyrighted.  This software/database is freely available
 *  to the public for use. The National Library of Medicine and the U.S.
 *  Government have not placed any restriction on its use or reproduction.
 *
 *  Although all reasonable efforts have been taken to ensure the accuracy
 *  and reliability of the software and data, the NLM and the U.S.
 *  Government do not and cannot warrant the performance or results that
 *  may be obtained by using this software or data. The NLM and the U.S.
 *  Government disclaim all warranties, express or implied, including
 *  warranties of performance, merchantability or fitness for any particular
 *  purpose.
 *
 *  Please cite the author in any work or product based on this material.
 *
 * ===========================================================================
 *
 * Author:  Vladimir Soussov
 *
 * File Description:  ODBC connection
 *
 */
 
#include <ncbi_pch.hpp>
#include <corelib/ncbiapp.hpp>
#include <dbapi/driver/odbc/interfaces.hpp>
#include <dbapi/driver/types.hpp>
#include <dbapi/error_codes.hpp>
#include <stdio.h>
#include <string.h>
 
#ifdef HAVE_ODBCSS_H
// #include <odbcss.h>
#include <msodbcsql.h>
#endif
 
#include "odbc_utils.hpp"
 
// #define DEFAULT_ODBC_DRIVER_NAME "SQL Server"
#define DEFAULT_ODBC_DRIVER_NAME "ODBC Driver 18 for SQL Server"
 
#define NCBI_USE_ERRCODE_X   Dbapi_Odbc_Conn
 
#undef NCBI_DATABASE_THROW
#define NCBI_DATABASE_THROW(ex_class, message, err_code, severity) \
    NCBI_ODBC_THROW(ex_class, message, err_code, severity)
// No use of NCBI_DATABASE_RETHROW or DATABASE_DRIVER_*_EX here.
 
// Accommodate all the code of the form
//     string err_message = "..." + GetDbgInfo();
//     DATABASE_DRIVER_ERROR(err_message, ...);
// which will still pick up the desired context due to
// NCBI_DATABASE_THROW's above redefinition.
#define GetDbgInfo() 0
 
BEGIN_NCBI_SCOPE
 
bool IsBCPCapable(void)
{
    return true;
}
 
static bool ODBC_xSendDataPrepare(CStatementBase& stmt,
                                  CDB_BlobDescriptor& descr_in,
                                  SQLLEN size,
                                  bool is_text,
                                  bool logit,
                                  SQLPOINTER id,
                                  SQLLEN* ph);
 
static bool ODBC_xSendDataGetId(CStatementBase& stmt,
                                SQLPOINTER* id);
 
////////////////////////////////////////////////////////////////////////////////
CODBC_Connection::CODBC_Connection(CODBCContext& cntx,
                                   const CDBConnParams& params) :
    impl::CConnection(
        cntx,
        params,
        IsBCPCapable()
        ),
    m_Link(NULL),
    m_ActiveStmt(NULL),
    m_Reporter(0, SQL_HANDLE_DBC, NULL, this, &cntx.GetReporter()),
    m_query_timeout(cntx.GetTimeout()),
    m_cancel_timeout(cntx.GetCancelTimeout())
{
    SetServerType(CDBConnParams::eMSSqlServer);
 
    SQLRETURN rc;
 
    {{
        CWriteLockGuard guard(cntx.x_GetCtxLock());
        rc = SQLAllocHandle(SQL_HANDLE_DBC,
                            cntx.GetODBCContext(),
                            const_cast<SQLHDBC*>(&m_Link));
 
        if (rc != SQL_SUCCESS) {
            cntx.GetReporter().ReportErrors();
        }
        if (rc != SQL_SUCCESS  &&  rc != SQL_SUCCESS_WITH_INFO) {
            DATABASE_DRIVER_ERROR( "Cannot allocate a connection handle.",
                                   100011 );
        }
    }}
 
    // This might look strange, but in current design all errors related to
    // opening of a connection to a database are reported by a DriverContext.
    // Have fun.
    // cntx.SetupErrorReporter(params);
    CODBC_Reporter opening_reporter(&params.GetOpeningMsgHandlers(),
                                    SQL_HANDLE_DBC, m_Link, this,
                                    &cntx.GetReporter());
 
    x_SetupErrorReporter(params);
 
    x_SetConnAttributesBefore(cntx, params);
 
    x_Connect(cntx, params, opening_reporter);
}
 
 
void
CODBC_Connection::x_SetupErrorReporter(const CDBConnParams& params)
{
    _ASSERT(m_Link);
 
    m_Reporter.SetHandle(m_Link);
    m_Reporter.SetHandlerStack(GetMsgHandlers());
    m_Reporter.SetServerName(params.GetServerName());
    m_Reporter.SetUserName(params.GetUserName());
}
 
void CODBC_Connection::x_Connect(
    CODBCContext& cntx,
    const CDBConnParams& params,
    const CODBC_Reporter& opening_reporter) const
{
    SQLRETURN rc;
    string server_name;
 
    if (params.GetHost()) {
        server_name = impl::ConvertN2A(params.GetHost());
    } else {
        server_name = params.GetServerName();
    }
 
    EEncoding enc = GetClientEncoding();
 
    if(!cntx.GetUseDSN()) {
        string connect_str;
        string conn_str_suffix = ";SERVER=" + server_name;
 
        if (params.GetHost() && params.GetPort()) {
            conn_str_suffix +=
                ";ADDRESS=" + server_name +
                "," + NStr::IntToString(params.GetPort()) +
                ";NETWORK=DBMSSOCN"
                ;
        }
        conn_str_suffix +=
            ";UID=" + params.GetUserName() +
            ";PWD=" + params.GetPassword() +
            ";TrustServerCertificate=yes"
            ;
 
        CNcbiApplication* app = CNcbiApplication::Instance();
 
        // Connection strings for SQL Native Client 2005.
        // string connect_str("DRIVER={SQL Native Client};MultipleActiveResultSets=true;SERVER=");
        // string connect_str("DRIVER={SQL Native Client};SERVER=");
 
        if (app) {
            const string driver_name = x_GetDriverName(app->GetConfig());
 
            connect_str = "DRIVER={" + driver_name + "}";
        } else {
            connect_str = "DRIVER={" DEFAULT_ODBC_DRIVER_NAME "}";
        }
 
        connect_str += conn_str_suffix;
 
        TSqlString connect_str_ss = x_MakeTSqlString(connect_str, enc);
 
        rc = SQLDriverConnect(m_Link,
                              0,
                              const_cast<TSqlChar*>(connect_str_ss.data()),
                              connect_str_ss.size(),
                              0,
                              0,
                              0,
                              SQL_DRIVER_NOPROMPT);
    }
    else {
        TSqlString server_name_ss = x_MakeTSqlString(server_name, enc);
        TSqlString username_ss = x_MakeTSqlString(params.GetUserName(), enc);
        TSqlString password_ss = x_MakeTSqlString(params.GetPassword(), enc);
        rc = SQLConnect(m_Link,
                        const_cast<TSqlChar*>(server_name_ss.data()),
                        server_name_ss.size(),
                        const_cast<TSqlChar*>(username_ss.data()),
                        username_ss.size(),
                        const_cast<TSqlChar*>(password_ss.data()),
                        password_ss.size());
    }
 
    if (!cntx.CheckSIE(rc, m_Link, opening_reporter)) {
        string err;
 
        err += "Cannot connect to the server '" + server_name;
        err += "' as user '" + params.GetUserName() + "'";
        DATABASE_DRIVER_ERROR( err, 100011 );
    }
}
 
 
void
CODBC_Connection::x_SetConnAttributesBefore(
    const CODBCContext& cntx,
    const CDBConnParams& params)
{
    SQLULEN timeout, login_timeout;
    NStr::StringToNumeric(params.GetParam("timeout"),       &timeout);
    NStr::StringToNumeric(params.GetParam("login_timeout"), &login_timeout);    
    SQLSetConnectAttr(m_Link, SQL_ATTR_CONNECTION_TIMEOUT, (SQLPOINTER)timeout,
                      0);
    SQLSetConnectAttr(m_Link, SQL_ATTR_LOGIN_TIMEOUT,
                      (SQLPOINTER)login_timeout, 0);
 
    if(cntx.GetPacketSize()) {
        SQLSetConnectAttr(m_Link,
                          SQL_ATTR_PACKET_SIZE,
                          (SQLPOINTER)SQLULEN(cntx.GetPacketSize()),
                          0);
    }
 
#ifdef SQL_COPT_SS_BCP
    // Always enable BCP ...
    SQLSetConnectAttr(m_Link,
                      SQL_COPT_SS_BCP,
                      (SQLPOINTER) SQL_BCP_ON,
                      SQL_IS_INTEGER);
#endif
}
 
 
string
CODBC_Connection::x_GetDriverName(const IRegistry& registry)
{
    enum EState {eStInitial, eStSingleQuote};
    vector<string> driver_names;
    const string odbc_driver_name =
        registry.GetString("ODBC", "DRIVER_NAME",
                           "'" DEFAULT_ODBC_DRIVER_NAME "'");
 
    NStr::Split(odbc_driver_name, " ", driver_names,
                NStr::fSplit_MergeDelimiters | NStr::fSplit_Truncate);
    EState state = eStInitial;
    string driver_name;
 
    ITERATE(vector<string>, it, driver_names) {
        bool complete_deriver_name = false;
        const string cur_str(*it);
 
        // Check for quotes ...
        if (state == eStInitial) {
            if (cur_str[0] == '\'') {
                if (cur_str[cur_str.size() - 1] == '\'') {
                    // Skip quote ...
                    driver_name = it->substr(1, cur_str.size() - 2);
                    complete_deriver_name = true;
                } else {
                    // Skip quote ...
                    driver_name = it->substr(1);
                    state = eStSingleQuote;
                }
            } else {
                driver_name = cur_str;
                complete_deriver_name = true;
            }
        } else if (state == eStSingleQuote) {
            if (cur_str[cur_str.size() - 1] == '\'') {
                // Final quote ...
                driver_name += " " + cur_str.substr(0, cur_str.size() - 1);
                state = eStInitial;
                complete_deriver_name = true;
            } else {
                driver_name += " " + cur_str;
            }
        }
 
        if (complete_deriver_name) {
            return driver_name;
        }
    }
 
    return driver_name;
}
 
 
string CODBC_Connection::x_MakeFreeTDSVersion(int version)
{
    string str_version = "TDS_Version=";
 
    switch ( version )
    {
    case 42:
        str_version += "4.2;Port=2158";
        break;
    case 46:
        str_version += "4.6";
        break;
    case 50:
        str_version += "5.0;Port=2158";
        break;
    case 70:
        str_version += "7.0";
        break;
    //case 80:
    //    str_version += "8.0";
    //    break;
    default:
        // DATABASE_DRIVER_ERROR( "Invalid TDS version with the FreeTDS driver.", 100000 );
        //str_version += "8.0";
        //break;
        return string();
    }
 
    return str_version;
}
 
 
bool CODBC_Connection::IsAlive(void)
{
    if (m_Link) {
        SQLINTEGER status;
        SQLRETURN r= SQLGetConnectAttr(m_Link, SQL_ATTR_CONNECTION_DEAD, &status, SQL_IS_INTEGER, 0);
 
        return ((r == SQL_SUCCESS || r == SQL_SUCCESS_WITH_INFO) && (status == SQL_CD_FALSE));
    }
 
    return (m_Link != NULL);
}
 
 
CODBC_LangCmd* CODBC_Connection::xLangCmd(const string& lang_query)
{
    CODBC_LangCmd* lcmd = new CODBC_LangCmd(*this, lang_query);
    return lcmd;
}
 
CDB_LangCmd* CODBC_Connection::LangCmd(const string& lang_query)
{
    return Create_LangCmd(*(xLangCmd(lang_query)));
}
 
 
CDB_RPCCmd* CODBC_Connection::RPC(const string& rpc_name)
{
    CODBC_RPCCmd* rcmd = new CODBC_RPCCmd(*this, rpc_name);
    return Create_RPCCmd(*rcmd);
}
 
 
CDB_BCPInCmd* CODBC_Connection::BCPIn(const string& table_name)
{
    if ( !IsBCPable() ) {
        string err_message = "No bcp on this connection." + GetDbgInfo();
        DATABASE_DRIVER_ERROR( err_message, 410003 );
    }
 
    CODBC_BCPInCmd* bcmd = new CODBC_BCPInCmd(*this, m_Link, table_name);
    return Create_BCPInCmd(*bcmd);
}
 
 
CDB_CursorCmd* CODBC_Connection::Cursor(const string& cursor_name,
                                      const string& query,
                                      unsigned int  batch_size)
{
#if 1
    CODBC_CursorCmdExpl* ccmd = new CODBC_CursorCmdExpl(*this,
                                                        cursor_name,
                                                        query);
#else
    CODBC_CursorCmd* ccmd = new CODBC_CursorCmd(*this,
                                                cursor_name,
                                                query);
#endif
 
    return Create_CursorCmd(*ccmd);
}
 
 
CDB_SendDataCmd* CODBC_Connection::SendDataCmd(I_BlobDescriptor& descr_in,
                                               size_t data_size,
                                               bool log_it,
                                               bool dump_results)
{
    CODBC_SendDataCmd* sd_cmd =
        new CODBC_SendDataCmd(*this,
                              (CDB_BlobDescriptor&)descr_in,
                              data_size,
                              log_it,
                              dump_results);
    return Create_SendDataCmd(*sd_cmd);
}
 
 
bool CODBC_Connection::SendData(I_BlobDescriptor& desc, CDB_Stream& lob,
                                bool log_it)
{
    CStatementBase stmt(*this, kEmptyStr);
 
    SQLPOINTER  p = (SQLPOINTER)2;
    SQLLEN      s = lob.Size();
    SQLLEN      ph;
 
    CDB_BlobDescriptor::ETDescriptorType desc_type
        = CDB_BlobDescriptor::eUnknown;
 
    if (CDB_Object::GetBlobType(lob.GetType()) == eBlobType_Binary) {
        desc_type = CDB_BlobDescriptor::eBinary;
    } else {
        desc_type = CDB_BlobDescriptor::eText;
    }
 
    if((!ODBC_xSendDataPrepare(
            stmt,
            (CDB_BlobDescriptor&)desc,
            s,
            (desc_type == CDB_BlobDescriptor::eText),
            log_it,
            p,
            &ph
            )) ||
       (!ODBC_xSendDataGetId(stmt, &p ))) {
        string err_message = "Cannot prepare a command." + GetDbgInfo();
        DATABASE_DRIVER_ERROR( err_message, 410035 );
    }
 
    return x_SendData(desc_type, stmt, lob);
 
}
 
 
bool CODBC_Connection::Refresh()
{
    // close all commands first
    DeleteAllCommands();
 
    return IsAlive();
}
 
 
I_DriverContext::TConnectionMode CODBC_Connection::ConnectMode() const
{
    I_DriverContext::TConnectionMode mode = 0;
    if ( IsBCPable() ) {
        mode |= I_DriverContext::fBcpIn;
    }
    if ( HasSecureLogin() ) {
        mode |= I_DriverContext::fPasswordEncrypted;
    }
    return mode;
}
 
 
CODBC_Connection::~CODBC_Connection()
{
    try {
        Close();
 
        if(SQLFreeHandle(SQL_HANDLE_DBC, m_Link) == SQL_ERROR) {
            ReportErrors();
        }
    }
    NCBI_CATCH_ALL_X( 1, NCBI_CURRENT_FUNCTION )
    if (m_ActiveStmt) {
        m_ActiveStmt->m_IsActive = false;
    }
}
 
 
bool CODBC_Connection::Abort()
{
    SQLDisconnect(m_Link);
    MarkClosed();
    return false;
}
 
bool CODBC_Connection::Close(void)
{
    if (Refresh()) {
        switch(SQLDisconnect(m_Link)) {
        case SQL_SUCCESS_WITH_INFO:
        case SQL_ERROR:
            ReportErrors();
        case SQL_SUCCESS:
            break;
        default:
            {
                string err_message = "SQLDisconnect failed (memory corruption suspected)." + GetDbgInfo();
                DATABASE_DRIVER_ERROR( err_message, 410009 );
            }
        }
 
        MarkClosed();
 
        return true;
    }
 
    return false;
}
 
void CODBC_Connection::SetTimeout(size_t nof_secs)
{
    m_query_timeout = nof_secs;
}
 
void CODBC_Connection::SetCancelTimeout(size_t nof_secs)
{
    m_cancel_timeout = nof_secs;
}
 
string CODBC_Connection::GetDriverName(void) const
{
    string name = GetCDriverContext().GetDriverName();
#ifdef SQL_DRIVER_NAME
    TSqlChar    buffer[256];
    SQLSMALLINT length = sizeof(buffer);
    if (SQL_SUCCEEDED(SQLGetInfo(m_Link, SQL_DRIVER_NAME, buffer, length,
                                 &length))
        &&  length > 0  &&  buffer[0] != _T_NCBI_ODBC('\0')) {
        TSqlString name2(buffer, length);
        name2.erase(name2.find(_T_NCBI_ODBC('\0')));
        name += '(' + CUtf8::AsUTF8(name2) + ')';
    }
#endif
    return name;
}
 
string CODBC_Connection::GetVersionString(void) const
{
    string version = "0.0";
#ifdef SQL_DRIVER_VER
    TSqlChar    buffer[256];
    SQLSMALLINT length = sizeof(buffer);
    if (SQL_SUCCEEDED(SQLGetInfo(m_Link, SQL_DRIVER_VER, buffer, length,
                                 &length))
        &&  length > 0  &&  buffer[0] != _T_NCBI_ODBC('\0')) {
        version = CUtf8::AsUTF8(TSqlString(buffer, length));
    }
#endif
    return version;
}
 
static
bool
ODBC_xCheckSIE(int rc, CStatementBase& stmt)
{
    switch(rc) {
    case SQL_SUCCESS_WITH_INFO:
        stmt.ReportErrors();
    case SQL_SUCCESS: break;
    case SQL_ERROR:
    default:
        stmt.ReportErrors();
        return false;
    }
 
    return true;
}
 
static bool ODBC_xSendDataPrepare(CStatementBase& stmt,
                                  CDB_BlobDescriptor& descr_in,
                                  SQLLEN size,
                                  bool is_text,
                                  bool logit,
                                  SQLPOINTER id,
                                  SQLLEN* ph)
{
    string q = "update ";
    q += descr_in.TableName();
    q += " set ";
    q += descr_in.ColumnName();
    q += "= ? where ";
    q += descr_in.SearchConditions();
    //q+= " ;\nset rowcount 0";
 
#if defined(SQL_TEXTPTR_LOGGING)
    if(!logit) {
        switch(SQLSetStmtAttr(stmt.GetHandle(), SQL_TEXTPTR_LOGGING, /*SQL_SOPT_SS_TEXTPTR_LOGGING,*/
            (SQLPOINTER)SQL_TL_OFF, SQL_IS_INTEGER)) {
        case SQL_SUCCESS_WITH_INFO:
        case SQL_ERROR:
            stmt.ReportErrors();
        default:
            break;
        }
    }
#endif
 
 
    CDB_BlobDescriptor::ETDescriptorType descr_type = descr_in.GetColumnType();
    if (descr_type == CDB_BlobDescriptor::eUnknown) {
        if (is_text) {
            descr_type = CDB_BlobDescriptor::eText;
        } else {
            descr_type = CDB_BlobDescriptor::eBinary;
        }
    }
 
    *ph = SQL_LEN_DATA_AT_EXEC(size);
 
    int c_type = 0;
    int sql_type = 0;
 
    if (descr_type == CDB_BlobDescriptor::eText) {
        // New code ...
        if (stmt.IsMultibyteClientEncoding()) {
            c_type = SQL_C_WCHAR;
            sql_type = SQL_WLONGVARCHAR;
            *ph = SQL_DATA_AT_EXEC;
        } else {
            c_type = SQL_C_CHAR;
            sql_type = SQL_LONGVARCHAR;
        }
        // End of new code ...
        // Old code ...
// #if defined(UNICODE)
//         c_type = SQL_C_WCHAR;
//         sql_type = SQL_WLONGVARCHAR;
// #else
//         c_type = SQL_C_CHAR;
//         sql_type = SQL_LONGVARCHAR;
// #endif
    } else {
        c_type = SQL_C_BINARY;
        sql_type = SQL_LONGVARBINARY;
    }
 
    // Do not use SQLDescribeParam. It is not implemented with the odbc driver
    // from FreeTDS.
 
    if (!ODBC_xCheckSIE(SQLBindParameter(
            stmt.GetHandle(),
            1,
            SQL_PARAM_INPUT,
            c_type,
            sql_type,
            size,
            0,
            id,
            0,
            ph),
        stmt)) {
        return false;
    }
 
    TSqlString ss = x_MakeTSqlString(q, stmt.GetClientEncoding());
    if (!ODBC_xCheckSIE(SQLPrepare(stmt.GetHandle(),
                                   const_cast<TSqlChar*>(ss.data()),
                                   ss.size()),
                        stmt)) {
        return false;
    }
 
    switch(SQLExecute(stmt.GetHandle())) {
    case SQL_NEED_DATA:
        return true;
    case SQL_SUCCESS_WITH_INFO:
    case SQL_ERROR:
        stmt.ReportErrors();
    default:
        return false;
    }
}
 
static bool ODBC_xSendDataGetId(CStatementBase& stmt,
                                SQLPOINTER* id)
{
    switch(SQLParamData(stmt.GetHandle(), id)) {
    case SQL_NEED_DATA:
        return true;
    case SQL_SUCCESS_WITH_INFO:
    case SQL_ERROR:
        stmt.ReportErrors();
    default:
        return false;
    }
}
 
bool
CODBC_Connection::x_SendData(CDB_BlobDescriptor::ETDescriptorType descr_type,
                             CStatementBase& stmt,
                             CDB_Stream& stream)
{
    char buff[1800];
 
    int rc;
 
    size_t len = 0;
    size_t invalid_len = 0;
 
    while(( len = stream.Read(buff + invalid_len, sizeof(buff) - invalid_len - 1)) != 0 ) {
        len += invalid_len;
        // New code ...
//         size_t valid_len = len;
//
//         if (stmt.GetClientEncoding() == eEncoding_UTF8 &&
//             descr_type == CDB_BlobDescriptor::eText) {
//
//             valid_len = CStringUTF8::GetValidBytesCount(buff, len);
//             invalid_len = len - valid_len;
//         }
//
//         {
//             TSqlString ss = x_MakeTSqlString(CTempString(buff, valid_len),
//                                              stmt.GetClientEncoding());
//             odbc::TChar* tchar_str = const_cast<odbc::TChar*>(ss.data());
//
//             rc = SQLPutData(stmt.GetHandle(),
//                             static_cast<SQLPOINTER>(tchar_str),
//                             static_cast<SQLINTEGER>(ss.byte_count())
//                             );
//         }
//
//         if (stmt.GetClientEncoding() == eEncoding_UTF8 &&
//             descr_type == CDB_BlobDescriptor::eText) {
//
//             if (valid_len < len) {
//                 memmove(buff, buff + valid_len, invalid_len);
//             }
//         }
        // End of new code ...
 
 
        // Old code ...
        if (stmt.GetClientEncoding() == eEncoding_UTF8 &&
            descr_type == CDB_BlobDescriptor::eText) {
 
            size_t valid_len = impl::GetValidUTF8Len(CTempString(buff, len));
            invalid_len = len - valid_len;
 
            // Encoding is always eEncoding_UTF8 in here.
            TSqlString ss = x_MakeTSqlString(CTempString(buff, valid_len),
                                             eEncoding_UTF8);
            odbc::TChar* tchar_str = const_cast<odbc::TChar*>(ss.c_str());
 
            rc = SQLPutData(stmt.GetHandle(),
                            static_cast<SQLPOINTER>(tchar_str),
                            static_cast<SQLINTEGER>(ss.byte_count())
                            );
 
            if (valid_len < len) {
                memmove(buff, buff + valid_len, invalid_len);
            }
        } else {
            // Experimental code ...
//             size_t valid_len = len;
//
//             TSqlString ss = x_MakeTSqlString(CTempString(buff, valid_len),
//                                              stmt.GetClientEncoding());
//             odbc::TChar* tchar_str = const_cast<odbc::TChar*>(ss.data());
//
//             rc = SQLPutData(stmt.GetHandle(),
//                             static_cast<SQLPOINTER>(tchar_str),
//                             static_cast<SQLINTEGER>(ss.byte_count())
//                             );
            rc = SQLPutData(stmt.GetHandle(),
                            static_cast<SQLPOINTER>(buff),
                            static_cast<SQLINTEGER>(len) // Number of bytes ...
                            );
        }
        // End of old code ...
 
        switch( rc ) {
        case SQL_SUCCESS_WITH_INFO:
            stmt.ReportErrors();
        case SQL_NEED_DATA:
            continue;
        case SQL_NO_DATA:
            return true;
        case SQL_SUCCESS:
            break;
        case SQL_ERROR:
            stmt.ReportErrors();
        default:
            return false;
        }
    }
 
    if (invalid_len > 0) {
        DATABASE_DRIVER_ERROR( "Invalid encoding of a text string." + GetDbgInfo(), 410055 );
    }
 
    switch(SQLParamData(stmt.GetHandle(), (SQLPOINTER*)&len)) {
    case SQL_SUCCESS_WITH_INFO: stmt.ReportErrors();
    case SQL_SUCCESS:           break;
    case SQL_NO_DATA:           return true;
    case SQL_NEED_DATA:
        {
            string err_message = "Not all the data were sent." + GetDbgInfo();
            DATABASE_DRIVER_ERROR( err_message, 410044 );
        }
    case SQL_ERROR:             stmt.ReportErrors();
    default:
        {
            string err_message = "SQLParamData failed." + GetDbgInfo();
            DATABASE_DRIVER_ERROR( err_message, 410045 );
        }
    }
 
    for(;;) {
        switch(SQLMoreResults( stmt.GetHandle() )) {
        case SQL_SUCCESS_WITH_INFO: stmt.ReportErrors();
        case SQL_SUCCESS:           continue;
        case SQL_NO_DATA:           break;
        case SQL_ERROR:
            {
                stmt.ReportErrors();
                string err_message = "SQLMoreResults failed." + GetDbgInfo();
                DATABASE_DRIVER_ERROR( err_message, 410014 );
            }
        default:
            {
                string err_message = "SQLMoreResults failed (memory corruption suspected)." + GetDbgInfo();
                DATABASE_DRIVER_ERROR( err_message, 410015 );
            }
        }
        break;
    }
 
    return true;
}
 
 
/////////////////////////////////////////////////////////////////////////////
CStatementBase::CStatementBase(CODBC_Connection& conn, const string& query) :
    impl::CBaseCmd(conn, query),
    m_RowCount(-1),
    m_Reporter(&conn.GetMsgHandlers(), SQL_HANDLE_STMT, NULL, &conn,
               &conn.m_Reporter),
    m_IsActive(true)
{
    x_Init();
}
 
CStatementBase::CStatementBase(CODBC_Connection& conn,
                               const string& cursor_name,
                               const string& query) :
    impl::CBaseCmd(conn, cursor_name, query),
    m_RowCount(-1),
    m_Reporter(&conn.GetMsgHandlers(), SQL_HANDLE_STMT, NULL, &conn,
               &conn.m_Reporter),
    m_IsActive(true)
{
    x_Init();
}
 
void
CStatementBase::x_Init(void)
{
    if (GetConnection().m_ActiveStmt) {
        GetConnection().m_ActiveStmt->m_IsActive = false;
    }
    GetConnection().m_ActiveStmt = this;
 
    SQLRETURN rc
        = SQLAllocHandle(SQL_HANDLE_STMT, GetConnection().m_Link, &m_Cmd);
 
    if(rc == SQL_ERROR) {
        GetConnection().ReportErrors();
    }
    m_Reporter.SetHandle(m_Cmd);
 
    SQLUINTEGER query_timeout
        = static_cast<SQLUINTEGER>(GetConnection().GetTimeout());
    switch(SQLSetStmtAttr(GetHandle(),
                       SQL_ATTR_QUERY_TIMEOUT,
                       (SQLPOINTER)static_cast<uintptr_t>(query_timeout),
                       0))
    {
    case SQL_SUCCESS_WITH_INFO:
    case SQL_ERROR:
    case SQL_INVALID_HANDLE:
        ReportErrors();
        break;
    default: // SQL_SUCCESS
        break;
    };
}
 
CStatementBase::~CStatementBase(void)
{
    try {
        SQLRETURN rc = SQLFreeHandle(SQL_HANDLE_STMT, m_Cmd);
        if(rc != SQL_SUCCESS) {
            ReportErrors();
        }
    }
    NCBI_CATCH_ALL_X( 2, NCBI_CURRENT_FUNCTION )
    if (m_IsActive) {
        GetConnection().m_ActiveStmt = NULL;
    }
}
 
bool
CStatementBase::CheckRC(int rc) const
{
    switch (rc)
    {
    case SQL_SUCCESS:
        return true;
    case SQL_SUCCESS_WITH_INFO:
    case SQL_ERROR:
        ReportErrors();
        break;
    case SQL_INVALID_HANDLE:
        {
            string err_message = "Invalid handle." + GetDbgInfo();
            DATABASE_DRIVER_ERROR( err_message, 0 );
        }
        break;
    }
 
    return false;
}
 
int
CStatementBase::CheckSIE(int rc, const char* msg, unsigned int msg_num) const
{
    switch( rc ) {
    case SQL_SUCCESS_WITH_INFO:
        ReportErrors();
 
    case SQL_SUCCESS:
        break;
 
    case SQL_ERROR:
        ReportErrors();
        {
            string err_message = msg + GetDbgInfo();
            DATABASE_DRIVER_ERROR( err_message, msg_num );
        }
    default:
        {
            string err_message;
 
            err_message.append(msg);
            err_message.append(" (memory corruption suspected).");
 
            DATABASE_DRIVER_ERROR( err_message, 420001 );
        }
    }
 
    return rc;
}
 
int
CStatementBase::CheckSIENd(int rc, const char* msg, unsigned int msg_num) const
{
    switch( rc ) {
    case SQL_SUCCESS_WITH_INFO:
        ReportErrors();
 
    case SQL_SUCCESS:
        break;
 
    case SQL_ERROR:
        ReportErrors();
        {
            string err_message = msg + GetDbgInfo();
            DATABASE_DRIVER_ERROR( err_message, msg_num );
        }
    default:
        {
            string err_message;
 
            err_message.append(msg);
            err_message.append(" (memory corruption suspected).");
 
            DATABASE_DRIVER_ERROR( err_message, 420001 );
        }
    }
 
    return rc;
}
 
 
string
CStatementBase::Type2String(const CDB_Object& param) const
{
    string type_str;
 
    switch (param.GetType()) {
    case eDB_Bit:
        type_str = "bit";
        break;
    case eDB_Int:
        type_str = "int";
        break;
    case eDB_SmallInt:
        type_str = "smallint";
        break;
    case eDB_TinyInt:
        type_str = "tinyint";
        break;
    case eDB_BigInt:
        type_str = "numeric";
        break;
    case eDB_Char:
    case eDB_VarChar:
        // New code ...
        if (IsMultibyteClientEncoding()) {
            type_str = "nvarchar(4000)";
        } else {
            type_str = "varchar(8000)";
        }
        // End of new code ...
        // Old code ...
//         if (IsMultibyteClientEncoding()) {
//             type_str = "nvarchar(255)";
//         } else {
//             type_str = "varchar(255)";
//         }
        break;
    case eDB_LongChar:
        if (IsMultibyteClientEncoding()) {
            type_str = "nvarchar(4000)";
        } else {
            type_str = "varchar(8000)";
        }
        break;
    case eDB_Binary:
    case eDB_VarBinary:
        // New code ...
        type_str = "varbinary(8000)";
        // Old code ...
//         type_str = "varbinary(255)";
        break;
    case eDB_LongBinary:
        type_str = "varbinary(8000)";
        break;
    case eDB_Float:
        type_str = "real";
        break;
    case eDB_Double:
        type_str = "float";
        break;
    case eDB_SmallDateTime:
        type_str = "smalldatetime";
        break;
    case eDB_DateTime:
        type_str = "datetime";
        break;
    case eDB_BigDateTime:
        type_str = ((CDB_BigDateTime&)param)
            .GetSQLTypeName(CDB_BigDateTime::eSyntax_Microsoft
                            /* GetConnection().GetDateTimeSyntax() */);
        break;
    case eDB_Text:
        if (IsMultibyteClientEncoding()) {
            type_str = "ntext";
        } else {
            type_str = "text";
        }
    case eDB_Image:
        type_str = "image";
        break;
    case eDB_VarCharMax:
        if (IsMultibyteClientEncoding()) {
            type_str = "nvarchar(max)";
        } else {
            type_str = "varchar(max)";
        }
        break;
    case eDB_VarBinaryMax:
        type_str = "varbinary(max)";
        break;
    default:
        break;
    }
 
    return type_str;
}
 
bool
CStatementBase::x_BindParam_ODBC(const CDB_Object& param,
                               CMemPot& bind_guard,
                               SQLLEN* indicator_base,
                               unsigned int pos) const
{
    SQLRETURN rc = 0;
 
    EDB_Type data_type = param.GetType();
 
    switch (data_type) {
    case eDB_Text:
    case eDB_Image:
    case eDB_Bit:
    case eDB_Numeric:
    case eDB_UnsupportedType:
        return false;
    default:
        break;
    }
 
    SQLSMALLINT scale;
    switch (data_type) {
    case eDB_DateTime:     scale = 3;  break;
    case eDB_BigDateTime:  scale = 7;  break;
    default:               scale = 0;  break;
    }
 
    indicator_base[pos] = x_GetIndicator(param);
 
    rc = SQLBindParameter(GetHandle(),
                          pos + 1,
                          SQL_PARAM_INPUT,
                          x_GetCType(param),
                          x_GetSQLType(param),
                          x_GetMaxDataSize(param),
                          scale,
                          x_GetData(param, bind_guard),
                          x_GetCurDataSize(param),
                          indicator_base + pos);
 
    CheckSIE(rc, "SQLBindParameter failed", 420066);
 
    return true;
}
 
 
SQLSMALLINT
CStatementBase::x_GetCType(const CDB_Object& param) const
{
    SQLSMALLINT type = 0;
 
    switch (param.GetType()) {
    case eDB_Int:
        type = SQL_C_SLONG;
        break;
    case eDB_SmallInt:
        type = SQL_C_SSHORT;
        break;
    case eDB_TinyInt:
        type = SQL_C_UTINYINT;
        break;
    case eDB_BigInt:
        type = SQL_C_SBIGINT;
        break;
    case eDB_Char:
    case eDB_VarChar:
    case eDB_LongChar:
    case eDB_VarCharMax:
        // New code ...
        if (IsMultibyteClientEncoding()) {
            type = SQL_C_WCHAR;
        } else {
            type = SQL_C_CHAR;
        }
        // End of new code ...
        // Old code ...
// #ifdef UNICODE
//         type = SQL_C_WCHAR;
// #else
//         type = SQL_C_CHAR;
// #endif
        break;
    case eDB_Binary:
    case eDB_VarBinary:
    case eDB_LongBinary:
    case eDB_VarBinaryMax:
        type = SQL_C_BINARY;
        break;
    case eDB_Float:
        type = SQL_C_FLOAT;
        break;
    case eDB_Double:
        type = SQL_C_DOUBLE;
        break;
    case eDB_SmallDateTime:
    case eDB_DateTime:
    case eDB_BigDateTime:
        type = SQL_C_TYPE_TIMESTAMP;
        break;
    default:
        break;
    }
 
    return type;
}
 
 
SQLSMALLINT
CStatementBase::x_GetSQLType(const CDB_Object& param) const
{
    SQLSMALLINT type = SQL_UNKNOWN_TYPE;
 
    switch (param.GetType()) {
    case eDB_Int:
        type = SQL_INTEGER;
        break;
    case eDB_SmallInt:
        type = SQL_SMALLINT;
        break;
    case eDB_TinyInt:
        type = SQL_TINYINT;
        break;
    case eDB_BigInt:
        type = SQL_NUMERIC;
        break;
    case eDB_Char:
    case eDB_VarChar:
        // New code ...
        if (IsMultibyteClientEncoding()) {
            type = SQL_WVARCHAR;
        } else {
            type = SQL_VARCHAR;
        }
        // End of new code ...
        // Old code ...
// #ifdef UNICODE
//         type = SQL_WVARCHAR;
// #else
//         type = SQL_VARCHAR;
// #endif
        break;
    case eDB_LongChar:
    case eDB_VarCharMax:
        // New code ...
        if (IsMultibyteClientEncoding()) {
            type = SQL_WLONGVARCHAR;
        } else {
            type = SQL_LONGVARCHAR;
        }
        // End of new code ...
        // Old code ...
// #ifdef UNICODE
//         type = SQL_WLONGVARCHAR;
// #else
//         type = SQL_LONGVARCHAR;
// #endif
        break;
    case eDB_Binary:
    case eDB_VarBinary:
    case eDB_LongBinary:
        type = SQL_VARBINARY;
        break;
    case eDB_VarBinaryMax:
        type = SQL_LONGVARBINARY;
        break;
    case eDB_Float:
        type = SQL_REAL;
        break;
    case eDB_Double:
        type = SQL_FLOAT;
        break;
    case eDB_SmallDateTime:
    case eDB_DateTime:
    case eDB_BigDateTime:
        type = SQL_TYPE_TIMESTAMP;
        break;
    default:
        break;
    }
 
    return type;
}
 
 
SQLULEN
CStatementBase::x_GetMaxDataSize(const CDB_Object& param) const
{
    SQLULEN size = 0;
 
    switch (param.GetType()) {
    case eDB_Int:
        size = 4;
        break;
    case eDB_SmallInt:
        size = 2;
        break;
    case eDB_TinyInt:
        size = 1;
        break;
    case eDB_BigInt:
        size = 18;
        break;
    case eDB_Char:
    case eDB_VarChar:
        // New code ...
        if (IsMultibyteClientEncoding()) {
            size = 8000 / sizeof(odbc::TChar);
        } else {
            size = 8000;
        }
        // End of new code ...
 
        // Old code ...
//         size = 255;
        break;
    case eDB_LongChar:
        // New code ...
        if (IsMultibyteClientEncoding()) {
            size = 8000 / sizeof(odbc::TChar);
        } else {
            size = 8000;
        }
        // End of new code ...
 
        // Old code ...
//         size = 8000 / sizeof(odbc::TChar);
        break;
    case eDB_Binary:
    case eDB_VarBinary:
        size = 8000;
        break;
    case eDB_LongBinary:
        size = 8000;
        break;
    case eDB_Float:
        size = 4;
        break;
    case eDB_Double:
        size = 8;
        break;
    case eDB_SmallDateTime:
        size = 16;
        break;
    case eDB_DateTime:
        size = 23;
        break;
    case eDB_BigDateTime:
        size = 27;
        break;
    case eDB_VarCharMax:
#if 0
        if (IsMultibyteClientEncoding()) {
            size = kMax_UInt / sizeof(odbc::TChar);
        } else {
            size = kMax_UInt;
        }
#else
        size = static_cast<const CDB_VarCharMax&>(param).Size();
        if (size == 0) {
            size = 1;
        }
#endif
        break;
    case eDB_VarBinaryMax:
#if 0
        size = kMax_UInt;
#else
        size = static_cast<const CDB_VarBinaryMax&>(param).Size();
        if (size == 0) {
            size = 1;
        }
#endif
        break;
    default:
        break;
    }
 
    return size;
}
 
 
SQLLEN
CStatementBase::x_GetCurDataSize(const CDB_Object& param) const
{
    SQLLEN size = 0;
 
    switch (param.GetType()) {
    case eDB_Int:
    case eDB_SmallInt:
    case eDB_TinyInt:
    case eDB_BigInt:
    case eDB_Binary:
    case eDB_VarBinary:
    case eDB_Float:
    case eDB_Double:
        size = x_GetMaxDataSize(param);
        break;
    case eDB_Char:
    case eDB_VarChar:
    case eDB_LongChar:
        size = dynamic_cast<const CDB_String&>(param).Size() * sizeof(odbc::TChar);
        break;
    case eDB_LongBinary:
        size = dynamic_cast<const CDB_LongBinary&>(param).Size();
        break;
    case eDB_SmallDateTime:
    case eDB_DateTime:
    case eDB_BigDateTime:
        size = sizeof(SQL_TIMESTAMP_STRUCT);
        break;
    case eDB_VarCharMax:
        size = dynamic_cast<const CDB_VarCharMax&>(param).Size()
            * sizeof(odbc::TChar);
        break;
    case eDB_VarBinaryMax:
        size = dynamic_cast<const CDB_VarBinaryMax&>(param).Size();
        break;
    default:
        break;
    }
 
    return size;
}
 
 
SQLLEN
CStatementBase::x_GetIndicator(const CDB_Object& param) const
{
    if (param.IsNULL()) {
        return SQL_NULL_DATA;
    }
 
    switch (param.GetType()) {
    case eDB_Char:
    case eDB_VarChar:
    case eDB_LongChar:
        return dynamic_cast<const CDB_String&>(param).Size()
            * sizeof(TSqlChar);
    case eDB_Binary:
        return dynamic_cast<const CDB_Binary&>(param).Size();
    case eDB_VarBinary:
        return dynamic_cast<const CDB_VarBinary&>(param).Size();
    case eDB_LongBinary:
        return dynamic_cast<const CDB_LongBinary&>(param).DataSize();
    case eDB_SmallDateTime:
    case eDB_DateTime:
    case eDB_BigDateTime:
        return sizeof(SQL_TIMESTAMP_STRUCT);
        break;
    case eDB_VarCharMax:
        return dynamic_cast<const CDB_VarCharMax&>(param).Size()
            * sizeof(TSqlChar);
    case eDB_VarBinaryMax:
        return dynamic_cast<const CDB_VarBinaryMax&>(param).Size();
    default:
        break;
    }
 
    return x_GetMaxDataSize(param);
}
 
 
SQLPOINTER
CStatementBase::x_GetData(const CDB_Object& param,
                          CMemPot& bind_guard) const
{
    SQLPOINTER data = NULL;
 
    switch (param.GetType()) {
    case eDB_Int:
        data = dynamic_cast<const CDB_Int&>(param).BindVal();
        break;
    case eDB_SmallInt:
        data = dynamic_cast<const CDB_SmallInt&>(param).BindVal();
        break;
    case eDB_TinyInt:
        data = dynamic_cast<const CDB_TinyInt&>(param).BindVal();
        break;
    case eDB_BigInt:
        data = dynamic_cast<const CDB_BigInt&>(param).BindVal();
        break;
    case eDB_Char:
    case eDB_VarChar:
    case eDB_LongChar:
#ifdef UNICODE
        data = const_cast<wchar_t *>(dynamic_cast<const CDB_String&>(param)
                                     .AsWString(GetClientEncoding()).data());
#else
        data = const_cast<char *>(dynamic_cast<const CDB_String&>(param)
                                  .Data());
#endif
        break;
    case eDB_Binary:
        data = const_cast<void *>(dynamic_cast<const CDB_Binary&>(param).Value());
        break;
    case eDB_VarBinary:
        data = const_cast<void *>(dynamic_cast<const CDB_VarBinary&>(param).Value());
        break;
    case eDB_LongBinary:
        data = const_cast<void *>(dynamic_cast<const CDB_LongBinary&>(param).Value());
        break;
    case eDB_Float:
        data = dynamic_cast<const CDB_Float&>(param).BindVal();
        break;
    case eDB_Double:
        data = dynamic_cast<const CDB_Double&>(param).BindVal();
        break;
    case eDB_SmallDateTime:
        if(!param.IsNULL()) {
            SQL_TIMESTAMP_STRUCT* ts = NULL;
 
            ts = (SQL_TIMESTAMP_STRUCT*)bind_guard.Alloc(sizeof(SQL_TIMESTAMP_STRUCT));
            const CTime& t = dynamic_cast<const CDB_SmallDateTime&>(param).Value();
            ts->year = t.Year();
            ts->month = t.Month();
            ts->day = t.Day();
            ts->hour = t.Hour();
            ts->minute = t.Minute();
 
            ts->second = 0;
            ts->fraction = 0;
 
            data = ts;
        }
        break;
    case eDB_DateTime:
        if(!param.IsNULL()) {
            SQL_TIMESTAMP_STRUCT* ts = NULL;
 
            ts = (SQL_TIMESTAMP_STRUCT*)bind_guard.Alloc(sizeof(SQL_TIMESTAMP_STRUCT));
            const CTime& t = dynamic_cast<const CDB_DateTime&>(param).Value();
            ts->year = t.Year();
            ts->month = t.Month();
            ts->day = t.Day();
            ts->hour = t.Hour();
            ts->minute = t.Minute();
 
            ts->second = t.Second();
            ts->fraction = t.NanoSecond()/1000000;
            ts->fraction *= 1000000; /* MSSQL has a bug - it cannot handle fraction of msecs */
 
            data = ts;
        }
        break;
    case eDB_BigDateTime:
        if( !param.IsNULL() ) {
            SQL_TIMESTAMP_STRUCT* ts = NULL;
 
            ts = (SQL_TIMESTAMP_STRUCT*)bind_guard.Alloc
                (sizeof(SQL_TIMESTAMP_STRUCT));
            const CTime& t = ((const CDB_BigDateTime&)param).GetCTime();
            ts->year = t.Year();
            ts->month = t.Month();
            ts->day = t.Day();
            ts->hour = t.Hour();
            ts->minute = t.Minute();
 
            ts->second = t.Second();
            ts->fraction = t.NanoSecond() / 100 * 100;
 
            data = ts;
        }
        break;
    case eDB_VarCharMax:
#ifdef UNICODE
        if( !param.IsNULL() ) {
            CDB_Stream& par = static_cast<CDB_Stream&>
                (const_cast<CDB_Object&>(param));
            size_t n = par.Size();
            AutoArray<char> raw_data(n);
            par.MoveTo(0);
            _VERIFY(par.Read(raw_data.get(), n) == n);
            CStringUTF8 utf_data
                = CUtf8::AsUTF8(CTempString(raw_data.get(), n),
                                GetClientEncoding());
            raw_data.reset();
            wstring wdata = CUtf8::AsBasicString<TSqlChar>(utf_data);
            utf_data.clear();
            n = wdata.size() * sizeof(TSqlChar);
            data = bind_guard.Alloc(n);
            memcpy(data, wdata.data(), n);
        }
        break;
// else fall through
#endif
    case eDB_VarBinaryMax:
        if( !param.IsNULL() ) {
            CDB_Stream& par = static_cast<CDB_Stream&>
                (const_cast<CDB_Object&>(param));
            size_t n = par.Size();
            data = bind_guard.Alloc(n);
            par.MoveTo(0);
            _VERIFY(par.Read(data, n) == n);
        }
        break;
    default:
        break;
    }
 
    return data;
}
 
 
int
CStatementBase::RowCount() const
{
    return static_cast<int>(m_RowCount);
}
 
bool
CStatementBase::Close(void) const
{
    SQLUINTEGER cancel_timeout
        = static_cast<SQLUINTEGER>(GetConnection().GetCancelTimeout());
    SQLSetStmtAttr(GetHandle(),
                   SQL_ATTR_QUERY_TIMEOUT,
                   (SQLPOINTER)static_cast<uintptr_t>(cancel_timeout),
                   0);
    try {
        bool result = CheckRC( SQLFreeStmt(m_Cmd, SQL_CLOSE) );
        SQLUINTEGER query_timeout
            = static_cast<SQLUINTEGER>(GetConnection().GetTimeout());
        SQLSetStmtAttr(GetHandle(),
                       SQL_ATTR_QUERY_TIMEOUT,
                       (SQLPOINTER)static_cast<uintptr_t>(query_timeout),
                       0);
        return result;
    }
    catch (CDB_Exception&) {
        SQLUINTEGER query_timeout
            = static_cast<SQLUINTEGER>(GetConnection().GetTimeout());
        SQLSetStmtAttr(GetHandle(),
                       SQL_ATTR_QUERY_TIMEOUT,
                       (SQLPOINTER)static_cast<uintptr_t>(query_timeout),
                       0);
        throw;
    }
}
 
 
/////////////////////////////////////////////////////////////////////////////
//
//  CODBC_SendDataCmd::
//
 
CODBC_SendDataCmd::CODBC_SendDataCmd(CODBC_Connection& conn,
                                     CDB_BlobDescriptor& descr,
                                     size_t nof_bytes,
                                     bool logit,
                                     bool dump_results) :
    CStatementBase(conn, kEmptyStr),
    impl::CSendDataCmd(conn, nof_bytes),
    m_DescrType(descr.GetColumnType() == CDB_BlobDescriptor::eText ?
                CDB_BlobDescriptor::eText : CDB_BlobDescriptor::eBinary),
    m_Res(NULL),
    m_HasMoreResults(false),
    m_DumpResults(dump_results)
{
    SQLPOINTER p = (SQLPOINTER)1;
    if((!ODBC_xSendDataPrepare(*this, descr, (SQLINTEGER)nof_bytes,
                              false, logit, p, &m_ParamPH)) ||
       (!ODBC_xSendDataGetId(*this, &p))) {
 
        string err_message = "Cannot prepare a command." + GetDbgInfo();
        DATABASE_DRIVER_ERROR( err_message, 410035 );
    }
}
 
size_t CODBC_SendDataCmd::SendChunk(const void* chunk_ptr, size_t nof_bytes)
{
    if(nof_bytes > GetBytes2Go()) nof_bytes= GetBytes2Go();
    if(nof_bytes < 1) return 0;
 
    int rc;
 
 
    // New code ...
//     size_t valid_len = nof_bytes;
//
//     if (GetClientEncoding() == eEncoding_UTF8 &&
//         m_DescrType == CDB_BlobDescriptor::eText) {
//
//         valid_len = CStringUTF8::GetValidBytesCount(static_cast<const char*>(chunk_ptr),
//                                                     nof_bytes);
//
//         if (valid_len == 0) {
//             DATABASE_DRIVER_ERROR( "Invalid encoding of a text string." + GetDbgInfo(), 410055 );
//         }
//
//         nof_bytes = valid_len;
//     }
//
//     {
//         TSqlString ss = x_MakeTSqlString(CTempString(chunk_ptr, valid_len),
//                                          GetClientEncoding());
//         odbc::TChar* tchar_str = const_cast<odbc::TChar*>(ss.data());
//
//         rc = SQLPutData(GetHandle(),
//                         static_cast<SQLPOINTER>(tchar_str),
//                         static_cast<SQLINTEGER>(ss.byte_count())
//                         );
//     }
    // End of new code ...
 
    // Old code ...
    if (GetClientEncoding() == eEncoding_UTF8 &&
        m_DescrType == CDB_BlobDescriptor::eText) {
        size_t valid_len = 0;
 
        valid_len = impl::GetValidUTF8Len(
            CTempString(static_cast<const char*>(chunk_ptr),nof_bytes));
 
        if (valid_len < nof_bytes) {
            DATABASE_DRIVER_ERROR( "Invalid encoding of a text string." + GetDbgInfo(), 410055 );
        }
 
        // Encoding is always eEncoding_UTF8 in here.
        TSqlString ss = x_MakeTSqlString
            (CTempString(static_cast<const char*>(chunk_ptr), valid_len),
             eEncoding_UTF8);
        odbc::TChar* tchar_str = const_cast<odbc::TChar*>(ss.data());
        nof_bytes = valid_len;
 
        rc = SQLPutData(GetHandle(),
                        static_cast<SQLPOINTER>(tchar_str),
                        static_cast<SQLINTEGER>(ss.byte_count())
                        );
    } else {
        rc = SQLPutData(GetHandle(),
                        const_cast<SQLPOINTER>(chunk_ptr),
                        static_cast<SQLINTEGER>(nof_bytes)
                        );
    }
    // End of old code ...
 
 
    switch( rc ) {
    case SQL_SUCCESS_WITH_INFO:
        ReportErrors();
    case SQL_NEED_DATA:
    case SQL_NO_DATA:
    case SQL_SUCCESS:
        SetBytes2Go(GetBytes2Go() - nof_bytes);
        if(GetBytes2Go() == 0) break;
        return nof_bytes;
    case SQL_ERROR:
        ReportErrors();
    default:
        return 0;
    }
 
    SQLPOINTER s= (SQLPOINTER)1;
    switch(SQLParamData(GetHandle(), (SQLPOINTER*)&s)) {
    case SQL_SUCCESS_WITH_INFO: ReportErrors();
    case SQL_SUCCESS:           break;
    case SQL_NO_DATA:           break;
    case SQL_NEED_DATA:
        {
            string err_message = "Not all the data were sent." + GetDbgInfo();
            DATABASE_DRIVER_ERROR( err_message, 410044 );
        }
    case SQL_ERROR:             ReportErrors();
    default:
        {
            string err_message = "SQLParamData failed." + GetDbgInfo();
            DATABASE_DRIVER_ERROR( err_message, 410045 );
        }
    }
 
    for(;;) {
        switch(SQLMoreResults(GetHandle())) {
        case SQL_SUCCESS_WITH_INFO: ReportErrors();
        case SQL_SUCCESS:           continue;
        case SQL_NO_DATA:           break;
        case SQL_ERROR:
            {
                ReportErrors();
                string err_message = "SQLMoreResults failed." + GetDbgInfo();
                DATABASE_DRIVER_ERROR( err_message, 410014 );
            }
        default:
            {
                string err_message = "SQLMoreResults failed (memory corruption suspected)." + GetDbgInfo();
                DATABASE_DRIVER_ERROR( err_message, 410015 );
            }
        }
        break;
    }
 
    return nof_bytes;
}
 
bool CODBC_SendDataCmd::Cancel(void)
{
    if (GetBytes2Go() > 0) {
        xCancel();
        SetBytes2Go(0);
        return true;
    }
 
    return false;
}
 
CODBC_SendDataCmd::~CODBC_SendDataCmd()
{
    try {
        DetachSendDataIntf();
 
        GetConnection().DropCmd(*(impl::CSendDataCmd*)this);
 
        Cancel();
    }
    NCBI_CATCH_ALL_X( 3, NCBI_CURRENT_FUNCTION )
}
 
void CODBC_SendDataCmd::xCancel()
{
    if ( !Close() ) {
        return;
    }
    ResetParams();
}
 
CDB_Result* CODBC_SendDataCmd::Result()
{
    if (m_Res) {
        delete m_Res;
        m_Res = 0;
        m_HasMoreResults = xCheck4MoreResults();
    }
 
    if ( !CStatementBase::WasSent() ) {
        string err_message = "A command has to be sent first." + GetDbgInfo();
        DATABASE_DRIVER_ERROR( err_message, 420010 );
    }
 
    if(!m_HasMoreResults) {
        CStatementBase::SetWasSent(false);
        return 0;
    }
 
    while(m_HasMoreResults) {
        SQLSMALLINT nof_cols= 0;
        CheckSIE(SQLNumResultCols(GetHandle(), &nof_cols),
                 "SQLNumResultCols failed", 420011);
 
        if(nof_cols < 1) { // no data in this result set
            SQLLEN rc;
 
            CheckSIE(SQLRowCount(GetHandle(), &rc),
                     "SQLRowCount failed", 420013);
 
            m_RowCount = rc;
            m_HasMoreResults = xCheck4MoreResults();
            continue;
        }
 
        m_Res = new CODBC_RowResult(*this, nof_cols, &m_RowCount);
        return Create_Result(*m_Res);
    }
 
    CStatementBase::SetWasSent(false);
    return 0;
}
 
bool CODBC_SendDataCmd::HasMoreResults() const
{
    return m_HasMoreResults;
}
 
bool CODBC_SendDataCmd::xCheck4MoreResults()
{
    //     int rc = CheckSIE(SQLMoreResults(GetHandle()), "SQLBindParameter failed", 420066);
    //
    //     return (rc == SQL_SUCCESS_WITH_INFO || rc == SQL_SUCCESS);
 
    switch(SQLMoreResults(GetHandle())) {
    case SQL_SUCCESS_WITH_INFO: ReportErrors();
    case SQL_SUCCESS:           return true;
    case SQL_NO_DATA:           return false;
    case SQL_ERROR:
        {
            ReportErrors();
 
            string err_message = "SQLMoreResults failed." + GetDbgInfo();
            DATABASE_DRIVER_ERROR( err_message, 420014 );
        }
    default:
        {
            string err_message = "SQLMoreResults failed (memory corruption suspected)." + GetDbgInfo();
            DATABASE_DRIVER_ERROR( err_message, 420015 );
        }
    }
}
 
END_NCBI_SCOPE