unixodbc, oid and c++ error at insert - Mailing list pgsql-general

Hello.
I have a db with a table that it has a two oid fields. in the next code
i insert a new row in the table with this oid fields but it crash.

This crash is when called the function SQLParamData that it return -1
why does it crash? any ideas?


int PgsqlImageDao::insertImage(Connection* conn, const Image& image,
                    unsigned char* previewData, unsigned int
previewSize,
                    Date photoDate, Date insDate,
                    const string& info) throw(DataAccessException) {

    char ODBC_ident[IDENT_SIZE];
    char ODBC_info[INFO_SIZE];
    unsigned char* imageData = NULL;
    long ODBC_result;                               // Result of
function calls.
    SQLHDBC ODBC_conHnd;                            // Handle for a
connection
    SQLHSTMT ODBC_stmHnd;                           // Handle for a
statement
    SQLINTEGER ODBC_id;
    SQLINTEGER ODBC_size;
    SQLINTEGER ODBC_previewSize;
    SQLINTEGER ODBC_strlen = 0;
    SQLINTEGER ODBC_dataPar;
    SQLINTEGER ODBC_previewPar;
    SQLPOINTER ODBC_token;
    SQLSMALLINT ODBC_shortCols[IMAGE_SHORT_BINDS];
    SQL_DATE_STRUCT ODBC_photoDate;
    SQL_DATE_STRUCT ODBC_insDate;

    ODBC_conHnd = conn->getHnd();
    ODBC_result = SQLAllocHandle(SQL_HANDLE_STMT, ODBC_conHnd,
&ODBC_stmHnd);

    if ((ODBC_result != SQL_SUCCESS) && (ODBC_result !=
SQL_SUCCESS_WITH_INFO)) {
       delete conn;
       throw SysDataAccessException(ODBC_result, "Cannot allocate
statement handle");
    }

    /* Get new image ID. */
    SQLBindCol(ODBC_stmHnd, 1, SQL_C_ULONG, &ODBC_id, 1, &ODBC_strlen);
    ODBC_result = SQLExecDirect(ODBC_stmHnd, (SQLCHAR*) GET_ID_QUERY,
SQL_NTS);

    if ((ODBC_result != SQL_SUCCESS) && (ODBC_result !=
SQL_SUCCESS_WITH_INFO)) {

      SQLFreeHandle(SQL_HANDLE_STMT, ODBC_stmHnd);
      delete conn;
      throw SysDataAccessException(ODBC_result,
              "Cannot execute statement GET_ID_QUERY");
    }

    ODBC_result = SQLFetch(ODBC_stmHnd);

    if (ODBC_result == SQL_NO_DATA) {
       SQLFreeHandle(SQL_HANDLE_STMT, ODBC_stmHnd);
       delete conn;
       throw
UserDataAccessException(UserDataAccessException::DATA_NOT_FOUND,
               "Cannot get a new image ID (GET_ID_QUERY)");
    }

    ODBC_result = SQLFreeStmt(ODBC_stmHnd, SQL_CLOSE);
    ODBC_result = SQLFreeStmt(ODBC_stmHnd, SQL_UNBIND);
    ODBC_result = SQLFreeStmt(ODBC_stmHnd, SQL_RESET_PARAMS);

    /* Set query parameters values with the image properties. */
    imageData = ((Image&) image).ImageB();
    ODBC_shortCols[0] = image.getType();
    ODBC_shortCols[1] = image.getNCol();
    ODBC_shortCols[2] = image.getNLin();
    ODBC_size = image.SizeOfImage();
    ODBC_previewSize = previewSize;
    ODBC_photoDate.year = photoDate.getYear();
    ODBC_photoDate.month = photoDate.getMonth();
    ODBC_photoDate.day = photoDate.getDay();
    ODBC_insDate.year = insDate.getYear();
    ODBC_insDate.month = insDate.getMonth();
    ODBC_insDate.day = insDate.getDay();
    {
      const string& ident = image.getIdent();
      ident.copy(ODBC_ident, IDENT_LENGTH);
      int i = (ident.length() < IDENT_LENGTH)? ident.length():
IDENT_LENGTH;
      ODBC_ident[i] = '\0';
      ODBC_ident[IDENT_LENGTH] = '\0';

      info.copy(ODBC_info, INFO_LENGTH);
      i = (info.length() < INFO_LENGTH)? info.length(): INFO_LENGTH;
      ODBC_info[i] = '\0';
      ODBC_info[INFO_LENGTH] = '\0';
    }
    ODBC_strlen = SQL_NTS;

    SQLPrepare(ODBC_stmHnd, (SQLCHAR*) INSERT_IMAGE_QUERY, SQL_NTS);

    SQLBindParameter(ODBC_stmHnd, 1, SQL_PARAM_INPUT, SQL_C_SLONG,
             SQL_INTEGER, 0, 0, &ODBC_id, 0, NULL);
    SQLBindParameter(ODBC_stmHnd, 2, SQL_PARAM_INPUT, SQL_C_SSHORT,
             SQL_SMALLINT, 0, 0, &ODBC_shortCols[0], 0, NULL);
    SQLBindParameter(ODBC_stmHnd, 3, SQL_PARAM_INPUT, SQL_C_SSHORT,
             SQL_SMALLINT, 0, 0, &ODBC_shortCols[1], 0, NULL);
    SQLBindParameter(ODBC_stmHnd, 4, SQL_PARAM_INPUT, SQL_C_SSHORT,
             SQL_SMALLINT, 0, 0, &ODBC_shortCols[2], 0, NULL);
    SQLBindParameter(ODBC_stmHnd, 5, SQL_PARAM_INPUT, SQL_C_SLONG,
             SQL_INTEGER, 0, 0, &ODBC_size, 0, NULL);
    SQLBindParameter(ODBC_stmHnd, 6, SQL_PARAM_INPUT, SQL_C_TYPE_DATE,
             SQL_DATE, 0, 0, &ODBC_photoDate, 0, NULL);
    SQLBindParameter(ODBC_stmHnd, 7, SQL_PARAM_INPUT, SQL_C_TYPE_DATE,
             SQL_DATE, 0, 0, &ODBC_insDate, 0, NULL);
    SQLBindParameter(ODBC_stmHnd, 8, SQL_PARAM_INPUT, SQL_C_CHAR,
             SQL_CHAR, IDENT_LENGTH, 0, &ODBC_ident, 0, &ODBC_strlen);
    SQLBindParameter(ODBC_stmHnd, 9, SQL_PARAM_INPUT, SQL_C_CHAR,
             SQL_CHAR, INFO_LENGTH, 0, &ODBC_info, 0, &ODBC_strlen);
    SQLBindParameter(ODBC_stmHnd, 10, SQL_PARAM_INPUT, SQL_C_BINARY,
             SQL_LONGVARBINARY, 0, 0, (SQLPOINTER) DATA_TOKEN, 0,
&ODBC_dataPar);
    SQLBindParameter(ODBC_stmHnd, 11, SQL_PARAM_INPUT, SQL_C_BINARY,
             SQL_LONGVARBINARY, 0, 0, (SQLPOINTER) PREVIEW_TOKEN, 0,
&ODBC_previewPar);
    ODBC_previewPar = SQL_LEN_DATA_AT_EXEC(0);
    ODBC_dataPar = SQL_LEN_DATA_AT_EXEC(0);
    ODBC_result = SQLExecute(ODBC_stmHnd);

    /* Send DATA_AT_EXEC. */
    while (ODBC_result == SQL_NEED_DATA) {
      ODBC_result = SQLParamData(ODBC_stmHnd, &ODBC_token);
    cout << sqlstate << endl;
      if (ODBC_result == SQL_NEED_DATA) {
          long putResult;

          switch ((int) ODBC_token) {

              case DATA_TOKEN:
                    putResult = SQLPutData(ODBC_stmHnd, imageData,
ODBC_size);
                    if ((putResult != SQL_SUCCESS) && (putResult !=
SQL_SUCCESS_WITH_INFO)) {
                      SQLFreeHandle(SQL_HANDLE_STMT, ODBC_stmHnd);
                      delete conn;
                      throw SysDataAccessException(ODBC_result,
                              "Error(s) sending DATA_AT_EXEC
(DATA_TOKEN) in INSERT_IMAGE_QUERY");
                    }
                    break;

              case PREVIEW_TOKEN:
                    putResult = SQLPutData(ODBC_stmHnd, previewData,
ODBC_previewSize);
                    if ((putResult != SQL_SUCCESS) && (putResult !=
SQL_SUCCESS_WITH_INFO)) {
                      SQLFreeHandle(SQL_HANDLE_STMT, ODBC_stmHnd);
                      delete conn;
                      throw SysDataAccessException(ODBC_result,
                              "Error(s) sending DATA_AT_EXEC
(PREVIEW_TOKEN) in INSERT_IMAGE_QUERY");
                    }
                    break;

              default :
                    SQLFreeHandle(SQL_HANDLE_STMT, ODBC_stmHnd);
                    delete conn;
                    throw SysDataAccessException(0,
                              "Error(s) sending DATA_AT_EXEC
(unrecognized token) in INSERT_IMAGE_QUERY");
          }
      }
    }

    if ((ODBC_result != SQL_SUCCESS) && (ODBC_result !=
SQL_SUCCESS_WITH_INFO)) {

      SQLFreeHandle(SQL_HANDLE_STMT, ODBC_stmHnd);
      delete conn;
      throw SysDataAccessException(ODBC_result,
              "Cannot execute statement INSERT_IMAGE_QUERY");
    }

    SQLFreeHandle(SQL_HANDLE_STMT, ODBC_stmHnd);
    delete conn;
    return ODBC_id;
}