Re: SQLGetData() returns len 4095 for empty TEXT on AIX 6.1 without ClientCharset defined

/*
 Author           : [email protected]
 FreeTDS version  : 0.92.377
 Platform         : AIX 6.1 64b
 Fetching a TEXT with default locale, first SQGetData() call returns
 a length of 4095 bytes, when 0 bytes are expected.
 */

#include <stdlib.h>
#include <stdio.h>
#include <string.h>

#include <sql.h>
#include <sqlext.h>

#define CHECK_RCODE(t,h,m) \
   if ( rcode != SQL_NO_DATA \
     && rcode != SQL_SUCCESS \
     && rcode != SQL_SUCCESS_WITH_INFO  \
     && rcode != SQL_NEED_DATA ) { \
      fprintf(stderr,"Error %d at: %s\n",rcode,m); \
      getErrorInfo(t,h); \
      exit(1); \
   }

void getErrorInfo(SQLSMALLINT sqlhdltype, SQLHANDLE sqlhandle)
{
    SQLRETURN rcode = 0;
    SQLCHAR sqlstate[SQL_SQLSTATE_SIZE + 1];
    SQLINTEGER naterror = 0;
    SQLCHAR msgtext[SQL_MAX_MESSAGE_LENGTH + 1];
    SQLSMALLINT msgtextl = 0;
    int ifxerror = 0;
    rcode = SQLGetDiagRec((SQLSMALLINT) sqlhdltype,
                          (SQLHANDLE) sqlhandle,
                          (SQLSMALLINT) 1,
                          (SQLCHAR *) sqlstate,
                          (SQLINTEGER *) & naterror,
                          (SQLCHAR *) msgtext,
                          (SQLSMALLINT) sizeof(msgtext),
                          (SQLSMALLINT *) & msgtextl);
    fprintf(stderr, "Diagnostic info:\n");
    fprintf(stderr, "  SQL State: %s\n", (char *) sqlstate);
    fprintf(stderr, "  SQL code : %d\n", (int) naterror);
    fprintf(stderr, "  Message  : %s\n", (char *) msgtext);
}

main(int argc,char **argv)
{
    SQLRETURN rcode;
    SQLHENV m_henv;
    SQLHDBC m_hdbc;
    SQLHSTMT m_hstmt;
    SQLHSTMT m_hstmt_2;
    int i,j;
    char * dbname;
    char * usernm;
    char * passwd;
#define ARRAY_SIZE 1   /* Expected, since we use SQLGetData()... */
    int v_k[ARRAY_SIZE];
    SQLLEN v_ind_1[ARRAY_SIZE];
    SQLLEN v_ind_2[ARRAY_SIZE];
    SQLULEN nrows;
    SQLSMALLINT ncols;
    SQLSMALLINT fc;
#define LOB_BLOCK_SIZE 4096
    char buf[LOB_BLOCK_SIZE];
    SQLLEN len;

    if (argc == 1) {
        dbname = "ftm_msvtest1_cobra";
        usernm = "msvuser";
        passwd = "fourjs";
    } else if (argc == 4) {
        dbname = argv[1];
        usernm = argv[2];
        passwd = argv[3];
    } else {
        fprintf(stderr,"Usage: %s dsn user pswd\n", argv[0]);
        exit(1);
    }

    m_henv = 0;
    rcode = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &m_henv);
    CHECK_RCODE(SQL_HANDLE_ENV,NULL,"SQLAllocHandle EnvH");

    rcode = SQLSetEnvAttr(m_henv, SQL_ATTR_ODBC_VERSION, (SQLPOINTER) SQL_OV_ODBC3, SQL_IS_UINTEGER);
    CHECK_RCODE(SQL_HANDLE_ENV,m_henv,"ODBC V3");

    m_hdbc = 0;
    rcode = SQLAllocHandle(SQL_HANDLE_DBC, (SQLHANDLE) m_henv, (SQLHANDLE *) &m_hdbc);
    CHECK_RCODE(SQL_HANDLE_ENV,m_henv,"SQLAllocHandle DbcH");

    rcode = SQLConnect((SQLHANDLE) m_hdbc,
                       (SQLCHAR *) dbname,
                       (SQLINTEGER) SQL_NTS,
                       (SQLCHAR *) usernm,
                       (SQLINTEGER) SQL_NTS,
                       (SQLCHAR *) passwd,
                       (SQLINTEGER) SQL_NTS);
    CHECK_RCODE(SQL_HANDLE_DBC,m_hdbc,"SQLConnect");

    rcode = SQLSetConnectAttr(m_hdbc,
               SQL_ATTR_AUTOCOMMIT, (SQLPOINTER) SQL_AUTOCOMMIT_ON, SQL_IS_UINTEGER);
    CHECK_RCODE(SQL_HANDLE_ENV,m_henv,"SQLSetConnectAttr(autocommit)");

    m_hstmt = NULL;
    rcode = SQLAllocHandle(SQL_HANDLE_STMT, m_hdbc, &m_hstmt);
    CHECK_RCODE(SQL_HANDLE_DBC,m_hdbc,"SQLAllocHandle StmtH 1");

    SQLExecDirect(m_hstmt, (SQLCHAR *) "drop table mytab1", SQL_NTS);
    SQLExecDirect(m_hstmt, (SQLCHAR *) "create table mytab1 ( k int, t text)", SQL_NTS);
    CHECK_RCODE(SQL_HANDLE_STMT,m_hstmt,"SQLExecDirect create table failed");
    SQLExecDirect(m_hstmt, (SQLCHAR *) "insert into mytab1 values ( 1, '' )", SQL_NTS);
    CHECK_RCODE(SQL_HANDLE_STMT,m_hstmt,"SQLExecDirect insert 1 failed");

    rcode = SQLAllocHandle(SQL_HANDLE_STMT, m_hdbc, &m_hstmt_2);
    CHECK_RCODE(SQL_HANDLE_DBC,m_hdbc,"SQLAllocHandle StmtH 1");

    rcode = SQLSetStmtAttr(m_hstmt_2, SQL_ATTR_CURSOR_SCROLLABLE,
                           (SQLPOINTER) SQL_NONSCROLLABLE,
                           SQL_IS_UINTEGER);
    CHECK_RCODE(SQL_HANDLE_STMT,m_hstmt_2,"SetStmtAttr NONSCROLLABLE");
    rcode = SQLSetStmtAttr(m_hstmt_2, SQL_ATTR_CURSOR_SENSITIVITY,
                           (SQLPOINTER) SQL_SENSITIVE, SQL_IS_UINTEGER);
    CHECK_RCODE(SQL_HANDLE_STMT,m_hstmt_2,"SetStmtAttr SENSITIVE");

    for (i = 0; i < ARRAY_SIZE; i++) {
        v_ind_1[i] = 0;
        v_ind_2[i] = SQL_DATA_AT_EXEC;
    }

    rcode = SQLPrepare(m_hstmt_2, "select k, t from mytab1", SQL_NTS);
    CHECK_RCODE(SQL_HANDLE_STMT,m_hstmt_2,"SQLPrepare #1");

    rcode = SQLExecute(m_hstmt_2);
    CHECK_RCODE(SQL_HANDLE_STMT,m_hstmt_2,"SQLExecute #1");

    rcode = SQLNumResultCols(m_hstmt_2, &fc);
    CHECK_RCODE(SQL_HANDLE_STMT,m_hstmt_2,"SQLNumResultCols #1");
    fprintf(stdout, "num cols: %d\n", fc);

    rcode = SQLMoreResults(m_hstmt_2);
    CHECK_RCODE(SQL_HANDLE_STMT,m_hstmt_2,"SQLMoreResults #1");

    rcode = SQLSetStmtAttr(m_hstmt_2, SQL_ATTR_ROW_BIND_TYPE,
                           (SQLPOINTER) SQL_BIND_BY_COLUMN, SQL_IS_UINTEGER);
    CHECK_RCODE(SQL_HANDLE_STMT,m_hstmt_2,"SQLSetStmtAttr SQL_ATTR_ROW_BIND_TYPE");
    rcode = SQLSetStmtAttr(m_hstmt_2, SQL_ATTR_ROW_ARRAY_SIZE,
                           (SQLPOINTER) ARRAY_SIZE, SQL_IS_UINTEGER);
    CHECK_RCODE(SQL_HANDLE_STMT,m_hstmt_2,"SQLSetStmtAttr SQL_ATTR_ROW_ARRAY_SIZE");
    rcode = SQLSetStmtAttr(m_hstmt_2, SQL_ATTR_ROWS_FETCHED_PTR,
                           (SQLPOINTER) & (nrows), SQL_IS_UINTEGER);
    CHECK_RCODE(SQL_HANDLE_STMT,m_hstmt_2,"SQLSetStmtAttr SQL_ATTR_ROWS_FETCHED_PTR");

    rcode = SQLBindCol(m_hstmt_2, 1, SQL_C_LONG, v_k, sizeof(v_k), v_ind_1);
    CHECK_RCODE(SQL_HANDLE_STMT,m_hstmt_2,"SQLBindCol 1");
    rcode = SQLBindCol(m_hstmt_2, 2, SQL_C_CHAR, NULL, 0, v_ind_2);
    CHECK_RCODE(SQL_HANDLE_STMT,m_hstmt_2,"SQLBindCol 1");

    rcode = SQLFetchScroll(m_hstmt_2, SQL_FETCH_NEXT, 0);
    CHECK_RCODE(SQL_HANDLE_STMT,m_hstmt_2,"SQLFetch #1 failed");
    fprintf(stdout, "fetch 1: rows fetched = %d\n", nrows);

    rcode = SQLGetData(m_hstmt_2, 2, SQL_C_CHAR, (SQLPOINTER) buf, sizeof(buf), &len);
    CHECK_RCODE(SQL_HANDLE_STMT,m_hstmt_2,"SQLGetData #1 failed");
    fprintf(stdout, "get data 1: len = %ld\n", len);


    rcode = SQLMoreResults(m_hstmt_2);
    CHECK_RCODE(SQL_HANDLE_STMT,m_hstmt_2,"SQLMoreResults #2");

    rcode = SQLFreeHandle(SQL_HANDLE_STMT, (SQLHANDLE) m_hstmt_2);
    CHECK_RCODE(SQL_HANDLE_STMT,m_hstmt_2,"SQLFreeHandle");

    rcode = SQLFreeHandle(SQL_HANDLE_STMT, (SQLHANDLE) m_hstmt);
    CHECK_RCODE(SQL_HANDLE_STMT,m_hstmt,"SQLFreeHandle");

    rcode = SQLDisconnect(m_hdbc);
    CHECK_RCODE(SQL_HANDLE_DBC,m_hdbc,"SQLDisconnect");

    rcode = SQLFreeHandle(SQL_HANDLE_DBC, (SQLHANDLE) m_hdbc);
    CHECK_RCODE(SQL_HANDLE_DBC,m_hdbc,"SQLFreeHandle DbcH");

    rcode = SQLFreeHandle(SQL_HANDLE_ENV, (SQLHANDLE) m_henv);
    CHECK_RCODE(SQL_HANDLE_ENV,m_henv,"SQLFreeHandle EnvH");

}