static int ExecuteSQL( SQLHDBC hDbc, char *szSQL, char cDelimiter, int bColumnNames, int bHTMLTable )
{
......
    if ( SQLAllocStmt( hDbc, &hStmt ) != SQL_SUCCESS )
.....
    if ( SQLPrepare( hStmt, (SQLCHAR*)szSQL, strlen( szSQL )) != SQL_SUCCESS )
.....
    ret =  SQLExecute( hStmt );
.....
    /*
     * Loop while SQLMoreResults returns success
     */
    do
    {
        .....
        if ( SQLNumResultCols( hStmt, &cols ) != SQL_SUCCESS )
        .....
        WriteFooterNormal( hStmt, szSepLine, nRows );
    }
    while ( SQL_SUCCEEDED( ret = SQLMoreResults( hStmt )));
.....
    SQLFreeStmt( hStmt, SQL_DROP );
.....
}

static void WriteFooterNormal( SQLHSTMT hStmt, SQLCHAR  *szSepLine, SQLLEN nRows )
{
    SQLLEN  nRowsAffected   = -1;

    fputs( (char*)szSepLine, stdout );

    SQLRowCount( hStmt, &nRowsAffected );
    printf( "SQLRowCount returns %ld\n", nRowsAffected );

    if ( nRows ) printf( "%ld rows fetched\n", nRows );
}

bool OdbcConnection::execute(const QString &query)
{
    qDeleteAll(tables);
    tables.clear();
    error.clear();
    SQLHSTMT hstmt = NULL;
    RETCODE retcode;
    SQLLEN cb;
    bool isSuccess = false;
    QTime timer;
    timer.start();
    retcode = SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &hstmt);
    if (check(retcode, hdbc, SQL_HANDLE_DBC))
    {
        retcode = SQLPrepareA(hstmt, (SQLCHAR*)query.toLocal8Bit().data(), SQL_NTS);
        if (!check(retcode, hstmt, SQL_HANDLE_STMT))
        {
            SQLFreeHandle(SQL_HANDLE_STMT, hstmt);
            hstmt = NULL;
            return false;
        }
        retcode = SQLExecute(hstmt);
        /*
        SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER)SQL_CURSOR_STATIC, SQL_IS_INTEGER);
        retcode = SQLExecDirectA(hstmt, (SQLCHAR*)query.toLocal8Bit().data(), SQL_NTS);
        !!!! in this case SQLRowCount always returns -1 (FreeTDS), and SQLFetch acts very slow
        */
        while (check(retcode, hstmt, SQL_HANDLE_STMT))
        {
            isSuccess = true;
            SQLSMALLINT col_count, name_length, data_type, dec_digits, nullable_desc;
            SQLULEN col_size;
            SQLWCHAR col_name[128];
            retcode = SQLNumResultCols(hstmt, &col_count);
            if (check(retcode, hstmt, SQL_HANDLE_STMT) && col_count)
            {
                int rowcount = 0;
                OdbcTable *table = new OdbcTable();
                tables.append(table);
                for (int i = 0; i < col_count; i++)
                {
                    SQLDescribeColW(hstmt, i + 1, col_name, 128, &name_length, &data_type, &col_size, &dec_digits, &nullable_desc);
                    table->addColumn(QString::fromUtf16(col_name), data_type, col_size, dec_digits, nullable_desc);
                }
                while ((retcode = SQLFetch(hstmt)) != SQL_NO_DATA)
                {
                    if (!check(retcode, hstmt, SQL_HANDLE_STMT)) break;
                    OdbcRow& row = table->addRow();
                    rowcount++;
                    for (int i = 0; i < col_count; i++)
                    {
                        /* ......... получение значений колонок ........*/
                    }
                    if (rowcount % 100 == 0) emit fetched(rowcount);
                }
                if (rowcount == 0 || rowcount % 100 != 0) emit fetched(rowcount);
                //if (rowcount) emit message(tr("%1 rows fetched").arg(rowcount));
            }
            retcode = SQLRowCount(hstmt, &cb);
            if (check(retcode, hdbc, SQL_HANDLE_DBC) && cb != -1)
            {
                if (col_count)
                    emit message(tr("%1 rows fetched").arg(cb));
                else
                    emit message(tr("%1 rows affected").arg(cb));
            }
            retcode = SQLMoreResults(hstmt);
        }
        if (retcode == SQL_NO_DATA) isSuccess = true;
        SQLFreeHandle(SQL_HANDLE_STMT, hstmt);
        hstmt = NULL;
    }
    if (isSuccess) emit message(QDateTime::fromMSecsSinceEpoch(timer.elapsed()).toString("mm:ss.z"));
    return isSuccess;
}

bool OdbcConnection::check(RETCODE retcode, SQLHANDLE handle, SQLSMALLINT handle_type)
{
    error.clear();
    if (retcode == SQL_SUCCESS) return true;
    if (retcode == SQL_NO_DATA) return false;
    SQLINTEGER NativeError;
    SQLCHAR SqlState[6];
    SQLCHAR BufErrMsg[SQL_MAX_MESSAGE_LENGTH];
    SQLSMALLINT MsgLen;
    RETCODE rc;

    int i = 0;
    do
    {
        MsgLen = 0; NativeError = 0;
        rc = SQLGetDiagRecA(handle_type, handle, ++i, SqlState, &NativeError, BufErrMsg, sizeof(BufErrMsg), &MsgLen);
        BufErrMsg[MsgLen] = 0;
        if (MsgLen > 0 || NativeError != 0)
        {
            bool is_warn = (strncmp((char*)SqlState, "01000", 5) == 0 || strncmp((char*)SqlState, "00000", 5) == 0);
            if (!is_warn || NativeError)
                error.append(QString("%1 %2, state %3, message: ").arg(is_warn ? "warinig" : "error", QString::number(NativeError)).arg((char*)SqlState));
            error.append((char*)BufErrMsg).append("\n");
        }
        else if (rc == -2)
        {
            error.append("invalid handle\n");
            break;
        }
    }
    while (rc == SQL_SUCCESS);
    emit message(error);
    return (retcode == SQL_SUCCESS_WITH_INFO);
}