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;
}
