SqlOdbcStatement Class Reference

#include <SqlOdbcStatement.h>

Inheritance diagram for SqlOdbcStatement:

[legend]Collaboration diagram for SqlOdbcStatement:

[legend]

Public Member Functions
	SqlOdbcStatement ()
void	setConnection (AbsSqlConnection *conn)
	sets connection handle to be used for subsequent operations
DbRetVal	prepare (char *stmt)
	compiles the sql statement.
DbRetVal	execute (int &rowsAffect)
	executes the sql statement.
DbRetVal	bindParam (int pos, void *)
	binds application buffer to the specified parameter position in the sql statement.
DbRetVal	bindField (int pos, void *val)
	binds application buffer to the specified field position of the projection list in the select query or for fields in the insert statement.
void *	fetch ()
	fetches the next tuple from the result of the execution of sql select query.
void *	fetchAndPrint (bool SQL)
	fetches the next tuple from the result of the execution of sql select query and prints it to stdout.
void *	next ()
	same as fetch, but does not populate bindFieldValues
DbRetVal	close ()
	Closes the iterator and makes the statement ready for another execution.
int	noOfProjFields ()
	Retrieves the total number of projection fields in the statement.
void *	getFieldValuePtr (int pos)
	get FieldValue->value ptr after fetch is done.
DbRetVal	free ()
	Frees all the resources held for the sql statement.
int	noOfParamFields ()
	Retrieves the total number of parameters in the statement.
DbRetVal	getProjFldInfo (int projPos, FieldInfo *&info)
	Retrieves the field info for the required projection field position in statement.
DbRetVal	getParamFldInfo (int paramPos, FieldInfo *&info)
	Retrieves the field info for the required parameter position in statement.
void	setShortParam (int paramPos, short value)
	Sets the value for the required parameter position in statement.
void	setIntParam (int paramPos, int value)
	Sets the value for the required parameter position in statement.
void	setLongParam (int paramPos, long value)
	Sets the value for the required parameter position in statement.
void	setLongLongParam (int paramPos, long long value)
	Sets the value for the required parameter position in statement.
void	setByteIntParam (int paramPos, ByteInt value)
	Sets the value for the required parameter position in statement.
void	setFloatParam (int paramPos, float value)
	Sets the value for the required parameter position in statement.
void	setDoubleParam (int paramPos, double value)
	Sets the value for the required parameter position in statement.
void	setStringParam (int paramPos, char *value)
	Sets the value for the required parameter position in statement.
void	setDateParam (int paramPos, Date value)
	Sets the value for the required parameter position in statement.
void	setTimeParam (int paramPos, Time value)
	Sets the value for the required parameter position in statement.
void	setTimeStampParam (int paramPos, TimeStamp value)
	Sets the value for the required parameter position in statement.
bool	isSelect ()
	Returns whether the statement prepared is select statement.
void	getPrimaryKeyFieldName (char *tablename, char *pkfieldname)
Friends
class	SqlFactory

---

Detailed Description

Definition at line 26 of file SqlOdbcStatement.h.

---

Constructor & Destructor Documentation

SqlOdbcStatement::SqlOdbcStatement

(

)

[inline]

Definition at line 29 of file SqlOdbcStatement.h.

References AbsSqlStatement::con, and AbsSqlStatement::innerStmt.

{innerStmt = NULL; con = NULL;}

---

Member Function Documentation

DbRetVal SqlOdbcStatement::bindField	(	int	pos,
		void *	val
	)			[virtual]

binds application buffer to the specified field position of the projection list in the select query or for fields in the insert statement.

This method should be called for select queries, insert, update statements. Before executing select queries, required fields must be binded first. Before executing insert statement, required fields must be binded first. Before executing update statement, required fields to be updated must be binded first.

Parameters:

	pos	position in the projection list
	val	address of the application buffer. Memory should be allocated by the application before binding the buffer.

Implements AbsSqlStatement.

Definition at line 217 of file SqlOdbcStatement.cxx.

References ErrBadArg, List::get(), OK, and printError.

Referenced by execute(), fetch(), fetchAndPrint(), free(), prepare(), setByteIntParam(), setDateParam(), setDoubleParam(), setFloatParam(), setIntParam(), setLongLongParam(), setLongParam(), setShortParam(), setStringParam(), setTimeParam(), and setTimeStampParam().

{
    if (!isPrepared) return OK;
    BindSqlProjectField *bindField = (BindSqlProjectField*)bindList.get(pos);
    if (NULL == bindField) 
    {
        printError(ErrBadArg, "Could not get the projection list. Should be called only for SELECT statement");
        return ErrBadArg;
    }
    bindField->value = value;
    return OK;
}

Here is the call graph for this function:

Here is the caller graph for this function:

DbRetVal SqlOdbcStatement::bindParam	(	int	pos,
		void *
	)			[virtual]

binds application buffer to the specified parameter position in the sql statement.

This method should be called for all the parameters in the sql statement. Parameters shall be specified for predicate for select, update, delete statements. Parameters shall be specified for field list value in SET of update statements. If value is not set for all parameters, execute will return error.

Parameters:

	pos	position of the parameter in the statement
	val	address of the application buffer. Memory should be allocated by the application before binding the buffer.

Implements AbsSqlStatement.

Definition at line 210 of file SqlOdbcStatement.cxx.

References ErrWarning, OK, and printError.

{
    DbRetVal rv = OK;
    printError(ErrWarning, "Deprecated. Use setParamXXX instead\n");
    return rv;
}

DbRetVal SqlOdbcStatement::close

(

)

[virtual]

Closes the iterator and makes the statement ready for another execution.

Returns:

DbRetVal

Implements AbsSqlStatement.

Definition at line 327 of file SqlOdbcStatement.cxx.

References OK, and SQLCloseCursor().

{
    if (!isPrepared) return OK;
    SQLCloseCursor(hstmt);
    return OK;
}

Here is the call graph for this function:

DbRetVal SqlOdbcStatement::execute

(

int &

rowsAffect

)

[virtual]

executes the sql statement.

For insert, update, delete queries execute performs the required operation on the table. For Select queries, application should call execute before they start fetching the values from the table.This starts scan on the table.

Parameters:

rowsAffect

number of rows affected by the sql statement

Returns:

DbRetVal

Implements AbsSqlStatement.

Definition at line 160 of file SqlOdbcStatement.cxx.

References bindField(), AllDataType::copyVal(), TimeStamp::dayOfMonth(), Date::dayOfMonth(), ErrBadCall, List::getIterator(), ListIterator::hasElement(), TimeStamp::hours(), Time::hours(), TimeStamp::minutes(), Time::minutes(), TimeStamp::month(), Date::month(), ListIterator::nextElement(), OK, TimeStamp::seconds(), Time::seconds(), SQLExecute(), typeDate, typeTime, typeTimeStamp, TimeStamp::year(), and Date::year().

{
    DbRetVal rv = OK;
    if (!isPrepared) return OK;
    ListIterator iter = paramList.getIterator();
    BindSqlField *bindField = NULL;
    while (iter.hasElement())
    {
        bindField = (BindSqlField*)iter.nextElement();
        switch(bindField->type)
        {
            case typeDate: {
                Date *dtCSQL = (Date*) bindField->value;
                DATE_STRUCT *dtTarget = (DATE_STRUCT*) bindField->targetvalue;
                dtTarget->year= dtCSQL->year();
                dtTarget->month= dtCSQL->month();
                dtTarget->day = dtCSQL->dayOfMonth();
                break;
            }
            case typeTime: {
                Time *dtCSQL = (Time*) bindField->value;
                TIME_STRUCT *dtTarget = (TIME_STRUCT*) bindField->targetvalue;
                dtTarget->hour = dtCSQL->hours();
                dtTarget->minute = dtCSQL->minutes();
                dtTarget->second = dtCSQL->seconds();
                break;
            }
            case typeTimeStamp: {
                TimeStamp *dtCSQL = (TimeStamp*) bindField->value;
                TIMESTAMP_STRUCT *dtTarget = (TIMESTAMP_STRUCT*) bindField->targetvalue;
                dtTarget->year= dtCSQL->year();
                dtTarget->month= dtCSQL->month();
                dtTarget->day = dtCSQL->dayOfMonth();
                dtTarget->hour = dtCSQL->hours();
                dtTarget->minute = dtCSQL->minutes();
                dtTarget->second = dtCSQL->seconds();
                break;
            }
            default: {
                AllDataType::copyVal(bindField->targetvalue, bindField->value,
                                     bindField->type, bindField->length);
                break;
            }
        }
    }
    int retValue = SQLExecute (hstmt);
    if (retValue) return ErrBadCall;
    return rv;
}

Here is the call graph for this function:

void * SqlOdbcStatement::fetch

(

)

[virtual]

fetches the next tuple from the result of the execution of sql select query.

execute should be called before calling this method. Application buffer should be binded to get the tuple values.

Returns:

void* NULL if there is no tuple.

Implements AbsSqlStatement.

Definition at line 229 of file SqlOdbcStatement.cxx.

References bindField(), AllDataType::copyVal(), List::getIterator(), ListIterator::hasElement(), ListIterator::nextElement(), Time::set(), Date::set(), TimeStamp::setDate(), TimeStamp::setTime(), SQLFetch(), typeDate, typeTime, and typeTimeStamp.

Referenced by next().

{
    if (!isPrepared) return NULL;
    int retValue = SQLFetch (hstmt);
    if (retValue) return NULL;
    ListIterator iter = bindList.getIterator();
    BindSqlProjectField *bindField = NULL;
    void *ptrToFirstField = NULL;
    while (iter.hasElement())
    {
        bindField = (BindSqlProjectField*)iter.nextElement();
        switch(bindField->type)
        {
            case typeDate: {
                Date *dtCSQL = (Date*) bindField->value;
                DATE_STRUCT *dtTarget = (DATE_STRUCT*) bindField->targetvalue;
                dtCSQL->set(dtTarget->year,dtTarget->month,dtTarget->day);
                break;
            }
            case typeTime: {
                Time *dtCSQL = (Time*) bindField->value;
                TIME_STRUCT *dtTarget = (TIME_STRUCT*) bindField->targetvalue;
                dtCSQL->set(dtTarget->hour,dtTarget->minute,dtTarget->second);
                break;
            }
            case typeTimeStamp: {
                TimeStamp *dtCSQL = (TimeStamp*) bindField->value;
                TIMESTAMP_STRUCT *dtTarget = (TIMESTAMP_STRUCT*) bindField->targetvalue;
                dtCSQL->setDate(dtTarget->year,dtTarget->month,dtTarget->day);
                dtCSQL->setTime(dtTarget->hour,dtTarget->minute,
                                dtTarget->second, dtTarget->fraction);
                break;
            }
            default: {
                AllDataType::copyVal(bindField->value, bindField->targetvalue,
                                     bindField->type, bindField->length);
                break;
            }
        } 
        if (ptrToFirstField == NULL) ptrToFirstField=bindField->value;
    }
    return ptrToFirstField;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void * SqlOdbcStatement::fetchAndPrint

(

bool

SQL

)

[virtual]

fetches the next tuple from the result of the execution of sql select query and prints it to stdout.

execute should be called before calling this method.

Returns:

void* NULL if there is no tuple.

Implements AbsSqlStatement.

Definition at line 273 of file SqlOdbcStatement.cxx.

References bindField(), tagTIMESTAMP_STRUCT::day, tagDATE_STRUCT::day, tagTIMESTAMP_STRUCT::fraction, List::getIterator(), ListIterator::hasElement(), tagTIMESTAMP_STRUCT::hour, tagTIME_STRUCT::hour, tagTIMESTAMP_STRUCT::minute, tagTIME_STRUCT::minute, tagTIMESTAMP_STRUCT::month, tagDATE_STRUCT::month, ListIterator::nextElement(), AllDataType::printVal(), tagTIMESTAMP_STRUCT::second, tagTIME_STRUCT::second, Time::set(), Date::set(), TimeStamp::setDate(), TimeStamp::setTime(), SQLFetch(), typeDate, typeTime, typeTimeStamp, tagTIMESTAMP_STRUCT::year, and tagDATE_STRUCT::year.

{
    if (!isPrepared) return NULL;
    int retValue = SQLFetch (hstmt);
    if (retValue) return NULL;
    ListIterator iter = bindList.getIterator();
    BindSqlProjectField *bindField = NULL;
    void *ptrToFirstField = NULL;
    while (iter.hasElement())
    {
        bindField = (BindSqlProjectField*)iter.nextElement();
        switch(bindField->type)
        {
            case typeDate: {
                Date dtCSQL;
                DATE_STRUCT *dtTarget = (DATE_STRUCT*) bindField->targetvalue;
                dtCSQL.set(dtTarget->year,dtTarget->month,dtTarget->day);
                AllDataType::printVal(&dtCSQL, bindField->type, bindField->length);
                break;
            }
            case typeTime: {
                Time dtCSQL;
                TIME_STRUCT *dtTarget = (TIME_STRUCT*) bindField->targetvalue;
                dtCSQL.set(dtTarget->hour,dtTarget->minute,dtTarget->second);
                AllDataType::printVal(&dtCSQL, bindField->type, bindField->length);
                break;
            }
            case typeTimeStamp: {
                TimeStamp dtCSQL;
                TIMESTAMP_STRUCT *dtTarget = (TIMESTAMP_STRUCT*) bindField->targetvalue;
                dtCSQL.setDate(dtTarget->year,dtTarget->month,dtTarget->day);
                dtCSQL.setTime(dtTarget->hour,dtTarget->minute,
                                dtTarget->second, dtTarget->fraction);
                AllDataType::printVal(&dtCSQL, bindField->type, bindField->length);
                break;
            }
            default: {
                AllDataType::printVal(bindField->targetvalue,
                                     bindField->type, bindField->length);
                break;
            }
        }
        if (ptrToFirstField == NULL) ptrToFirstField=bindField->targetvalue;
        printf("\t");
    }

    return ptrToFirstField;
}

Here is the call graph for this function:

DbRetVal SqlOdbcStatement::free

(

)

[virtual]

Frees all the resources held for the sql statement.

Needs to be called before calling prepare again on the same statement handle.

Returns:

DbRetVal

Implements AbsSqlStatement.

Definition at line 390 of file SqlOdbcStatement.cxx.

References bindField(), List::getIterator(), ListIterator::hasElement(), ListIterator::nextElement(), OK, List::reset(), SQL_HANDLE_STMT, SQLFreeHandle(), and BindSqlProjectField::targetvalue.

{
    isPrepared = false;
    ListIterator biter = bindList.getIterator();
    BindSqlProjectField *elem = NULL;
    while (biter.hasElement())
    {
        elem = (BindSqlProjectField*) biter.nextElement();
        ::free(elem->targetvalue); 
        delete elem;
    }
    bindList.reset();
    ListIterator piter = paramList.getIterator();
    BindSqlField *bindField = NULL;
    while (piter.hasElement())
    {
        bindField = (BindSqlField*) piter.nextElement();
        ::free(bindField->value);
        ::free(bindField->targetvalue);
        delete bindField; 
    }
    paramList.reset();

    SQLFreeHandle (SQL_HANDLE_STMT, hstmt);
    return OK;
}

Here is the call graph for this function:

void * SqlOdbcStatement::getFieldValuePtr

(

int

pos

)

[virtual]

get FieldValue->value ptr after fetch is done.

Returns:

address void*

Implements AbsSqlStatement.

Definition at line 334 of file SqlOdbcStatement.cxx.

{
    return NULL;
}

DbRetVal SqlOdbcStatement::getParamFldInfo	(	int	paramPos,
		FieldInfo *&	info
	)			[virtual]

Retrieves the field info for the required parameter position in statement.

Parameters:

	projPos	int - parameter position
	info	FieldInfo*& - OUT parameter

Returns:

DbRetVal

Implements AbsSqlStatement.

Definition at line 371 of file SqlOdbcStatement.cxx.

References ErrNotFound, List::getIterator(), ListIterator::hasElement(), BindSqlField::length, FieldInfo::length, ListIterator::nextElement(), OK, BindSqlField::type, and FieldInfo::type.

{
    ListIterator biter = paramList.getIterator();
    BindSqlField *elem = NULL;
    int count =0;
    while (biter.hasElement())
    {
        elem = (BindSqlField*) biter.nextElement();
        if (count == parampos) 
        {
            fInfo->length = elem->length;
            fInfo->type =elem->type;
            return OK;
        }
        count++;
    }
    return ErrNotFound;
}

Here is the call graph for this function:

void SqlOdbcStatement::getPrimaryKeyFieldName	(	char *	tablename,
		char *	pkfieldname
	)

Definition at line 523 of file SqlOdbcStatement.cxx.

References AbsSqlStatement::con, conn, SQL_C_CHAR, SQL_HANDLE_STMT, SQL_NTS, SQLAllocHandle(), SQLFetch(), SQLFreeHandle(), SQLGetData(), and SQLPrimaryKeys().

Referenced by insert(), remove(), and verifyPrimKeyFldVal().

{
    if (pkfieldname == NULL) return;
    SqlOdbcConnection *conn = (SqlOdbcConnection*)con;
    int retValue=SQLAllocHandle (SQL_HANDLE_STMT, conn->dbHdl, &hstmt);
    if (retValue) return ;
    char columnName[128];
    SQLINTEGER cbData;     // Output length of data
    SQLPrimaryKeys(hstmt, NULL, 0, NULL, 0, (SQLCHAR*) tablename, SQL_NTS);
    SQLFetch(hstmt);
    SQLGetData(hstmt, 4, SQL_C_CHAR, (SQLCHAR*) columnName, sizeof(columnName),&cbData);
    strcpy(pkfieldname, columnName);
    SQLFreeHandle (SQL_HANDLE_STMT, hstmt);
    return;
}

Here is the call graph for this function:

Here is the caller graph for this function:

DbRetVal SqlOdbcStatement::getProjFldInfo	(	int	projPos,
		FieldInfo *&	info
	)			[virtual]

Retrieves the field info for the required projection field position in statement.

Parameters:

	projPos	int - projection field position
	info	FieldInfo*& - OUT parameter

Returns:

DbRetVal

Implements AbsSqlStatement.

Definition at line 351 of file SqlOdbcStatement.cxx.

References ErrNotFound, FieldInfo::fldName, BindSqlProjectField::fName, List::getIterator(), ListIterator::hasElement(), BindSqlProjectField::length, FieldInfo::length, ListIterator::nextElement(), OK, BindSqlProjectField::type, and FieldInfo::type.

{
    ListIterator biter = bindList.getIterator();
    BindSqlProjectField *elem = NULL;
    int count =0;
    while (biter.hasElement())
    {
        elem = (BindSqlProjectField*) biter.nextElement();
        if (count == projpos) 
        {
            strcpy(fInfo->fldName, elem->fName);
            fInfo->length = elem->length;
            fInfo->type =elem->type;
            return OK;
        }
        count++;
    }
    return ErrNotFound;
}

Here is the call graph for this function:

bool SqlOdbcStatement::isSelect

(

)

[virtual]

Returns whether the statement prepared is select statement.

Returns:

bool true if it is select stmt, false otherwise

Implements AbsSqlStatement.

Definition at line 154 of file SqlOdbcStatement.cxx.

{
    //TODO
    return false;
}

void * SqlOdbcStatement::next

(

)

[virtual]

same as fetch, but does not populate bindFieldValues

Returns:

address void*

Implements AbsSqlStatement.

Definition at line 322 of file SqlOdbcStatement.cxx.

References fetch().

{
    return fetch();
}

Here is the call graph for this function:

int SqlOdbcStatement::noOfParamFields

(

)

[virtual]

Retrieves the total number of parameters in the statement.

Returns:

int no of parameters

Implements AbsSqlStatement.

Definition at line 345 of file SqlOdbcStatement.cxx.

References List::size().

{
    if (!isPrepared) return 0;
    return paramList.size();
}

Here is the call graph for this function:

int SqlOdbcStatement::noOfProjFields

(

)

[virtual]

Retrieves the total number of projection fields in the statement.

Returns:

int no of projection fields

Implements AbsSqlStatement.

Definition at line 339 of file SqlOdbcStatement.cxx.

References List::size().

{
    if (!isPrepared) return 0;
    return bindList.size();
}

Here is the call graph for this function:

DbRetVal SqlOdbcStatement::prepare

(

char *

stmt

)

[virtual]

compiles the sql statement.

It calls the parser and tokenizes the statement into logical plan. This method sets the statement string which needs to be executed. free method needs to be called, if application wants to use the same handle to compile another sql statement.

Parameters:

stmt

sql statement string

Returns:

DbRetVal

Implements AbsSqlStatement.

Definition at line 26 of file SqlOdbcStatement.cxx.

References AllDataType::alloc(), List::append(), bindField(), AbsSqlStatement::con, conn, AllDataType::convertFromSQLType(), AllDataType::convertToSQL_C_Type(), AllDataType::convertToSQLType(), ErrBadCall, BindSqlProjectField::fName, IDENTIFIER_LENGTH, AbsSqlStatement::innerStmt, BindSqlProjectField::length, OK, SQL_HANDLE_STMT, SQL_NTS, SQL_PARAM_INPUT, SQLAllocHandle(), SQLBindCol(), SQLBindParameter(), SQLDescribeCol(), SQLDescribeParam(), SQLNumParams(), SQLNumResultCols(), SQLPrepare(), SQLULEN, BindSqlProjectField::targetvalue, BindSqlProjectField::type, typeDate, typeString, typeTime, typeTimeStamp, and BindSqlProjectField::value.

{
    DbRetVal rv = OK;
    if (innerStmt) rv = ErrBadCall;
    if (rv != OK) return rv;
    int retValue;
    isPrepared = false;
    SqlOdbcConnection *conn = (SqlOdbcConnection*)con;
    retValue=SQLAllocHandle (SQL_HANDLE_STMT, conn->dbHdl, &hstmt);
    if (retValue) return ErrBadCall;
    retValue = SQLPrepare (hstmt, (unsigned char *) stmtstr, SQL_NTS);
    if (retValue) return ErrBadCall;
    isPrepared = true;
    short totalFields=0;
    retValue = SQLNumResultCols (hstmt, &totalFields);
    if (retValue) return ErrBadCall;
    BindSqlProjectField *bindProjField = NULL;
    UWORD                   icol;
    UCHAR                   colName[IDENTIFIER_LENGTH];
    SWORD                   colNameMax;
    SWORD                   nameLength;
    SWORD                   colType;
    SQLULEN                 colLength;
    SWORD                   scale;
    SWORD                   nullable;
    icol = 1; colNameMax = IDENTIFIER_LENGTH;
    while (icol <= totalFields)
    {
        retValue = SQLDescribeCol(hstmt, icol, colName, colNameMax,
                   &nameLength, &colType, &colLength,
                   &scale, &nullable);
        if (retValue) return ErrBadCall;
        
        bindProjField = new BindSqlProjectField();
        strncpy(bindProjField->fName, (char*)colName, IDENTIFIER_LENGTH);
        bindProjField->fName[IDENTIFIER_LENGTH] = '\0';
        bindProjField->type = AllDataType::convertFromSQLType(colType);
        bindProjField->length = colLength +1;
        bindProjField->value = NULL;
        bindProjField->targetvalue = NULL;
        int fieldsize =0;
        switch(bindProjField->type)
        {
            case typeString:
                fieldsize = colLength+1;
                bindProjField->targetvalue = malloc(fieldsize); 
                break;
            case typeDate:
                fieldsize = sizeof(DATE_STRUCT);
                bindProjField->targetvalue = malloc(sizeof(DATE_STRUCT));
                break;
            case typeTime:
                fieldsize = sizeof(TIME_STRUCT);
                bindProjField->targetvalue = malloc(sizeof(TIME_STRUCT));
                break;
            case typeTimeStamp:
                fieldsize = sizeof(TIMESTAMP_STRUCT);
                bindProjField->targetvalue = malloc(sizeof(TIMESTAMP_STRUCT));
                break;
            default:
                bindProjField->targetvalue = AllDataType::alloc(bindProjField->type, bindProjField->length);
        }
        retValue = SQLBindCol(hstmt, icol, 
                              AllDataType::convertToSQLType(bindProjField->type),
                              bindProjField->targetvalue, fieldsize, NULL);
        if (retValue) return ErrBadCall; 
        bindList.append(bindProjField);
        icol++;
       
    }
    totalFields =0;
    BindSqlField *bindField;
    retValue = SQLNumParams (hstmt, &totalFields);
    if (retValue) return ErrBadCall;
    icol = 1; colNameMax = IDENTIFIER_LENGTH;
    SWORD                   cType=0;
    SQLULEN                 cLength=0;
    while (icol <= totalFields)
    {
        retValue = SQLDescribeParam(hstmt, icol, &cType, &cLength,
                   &scale, &nullable);
        //Note: MySQL Bug
        //Bug #1382     SQLDescribeParam returns the same type information

        if (retValue) return ErrBadCall;
        
        bindField = new BindSqlField();
        bindField->type = AllDataType::convertFromSQLType(cType);
        bindField->length = cLength;
        bindField->value =  AllDataType::alloc(bindField->type, cLength);
        bindField->targetvalue = NULL;
        int fieldsize =0;
        switch(bindField->type)
        {
            case typeString:
                fieldsize = cLength;
                bindField->targetvalue = malloc(fieldsize);
                break;
            case typeDate:
                fieldsize = sizeof(DATE_STRUCT);
                bindField->targetvalue = malloc(sizeof(DATE_STRUCT));
                break;
            case typeTime:
                fieldsize = sizeof(TIME_STRUCT);
                bindField->targetvalue = malloc(sizeof(TIME_STRUCT));
                break;
            case typeTimeStamp:
                fieldsize = sizeof(TIMESTAMP_STRUCT);
                bindField->targetvalue = malloc(sizeof(TIMESTAMP_STRUCT));
                break;
            default:
                bindField->targetvalue = AllDataType::alloc(bindField->type, cLength);
                break;

        }
        retValue = SQLBindParameter(hstmt, icol, SQL_PARAM_INPUT, 
                      AllDataType::convertToSQL_C_Type(bindField->type), 
                      cType, fieldsize, scale, bindField->targetvalue, 
                      fieldsize, NULL);
        if (retValue) return ErrBadCall;
        paramList.append(bindField);
        icol++;
    }
    //TODO::deallocate memory and remove elements from list in case of any
    //failure in any of the above ODBC functions
    return OK;
}

Here is the call graph for this function:

void SqlOdbcStatement::setByteIntParam	(	int	paramPos,
		ByteInt	value
	)			[virtual]

Sets the value for the required parameter position in statement.

Parameters:

	paramPos	int - parameter position
	value	ByteInt - value to be set

Implements AbsSqlStatement.

Definition at line 460 of file SqlOdbcStatement.cxx.

References bindField(), AllDataType::convertToString(), List::get(), and typeByteInt.

{
    if (!isPrepared) return ;
    BindSqlField *bindField = (BindSqlField*)paramList.get(paramPos);
    //if (bindField->type != typeByteInt) return;
    //*(char*)(bindField->value) = value;
    AllDataType::convertToString(bindField->value, &value, typeByteInt);

}

Here is the call graph for this function:

void SqlOdbcStatement::setConnection

(

AbsSqlConnection *

conn

)

[inline, virtual]

sets connection handle to be used for subsequent operations

Parameters:

con

SqlConnection*

Reimplemented from AbsSqlStatement.

Definition at line 31 of file SqlOdbcStatement.h.

References AbsSqlStatement::con, conn, AbsSqlStatement::innerStmt, and AbsSqlStatement::setConnection().

    {
        if (innerStmt) innerStmt->setConnection(conn->getInnerConnection());
        con = conn;
    }

Here is the call graph for this function:

void SqlOdbcStatement::setDateParam	(	int	paramPos,
		Date	value
	)			[virtual]

Sets the value for the required parameter position in statement.

Parameters:

	paramPos	int - parameter position
	value	Date - value to be set

Implements AbsSqlStatement.

Definition at line 496 of file SqlOdbcStatement.cxx.

References bindField(), AllDataType::convertToString(), List::get(), and typeDate.

{
    if (!isPrepared) return ;
    BindSqlField *bindField = (BindSqlField*)paramList.get(paramPos);
    //if (bindField->type != typeDate) return;
    //*(Date*)(bindField->value) = value;
    AllDataType::convertToString(bindField->value, &value, typeDate);

}

Here is the call graph for this function:

void SqlOdbcStatement::setDoubleParam	(	int	paramPos,
		double	value
	)			[virtual]

Sets the value for the required parameter position in statement.

Parameters:

	paramPos	int - parameter position
	value	double - value to be set

Implements AbsSqlStatement.

Definition at line 477 of file SqlOdbcStatement.cxx.

References bindField(), AllDataType::convertToString(), List::get(), and typeDouble.

{
    if (!isPrepared) return ;
    BindSqlField *bindField = (BindSqlField*)paramList.get(paramPos);
    //if (bindField->type != typeDouble) return;
    //*(double*)(bindField->value) = value;
    AllDataType::convertToString(bindField->value, &value, typeDouble);

}

Here is the call graph for this function:

void SqlOdbcStatement::setFloatParam	(	int	paramPos,
		float	value
	)			[virtual]

Sets the value for the required parameter position in statement.

Parameters:

	paramPos	int - parameter position
	value	float - value to be set

Implements AbsSqlStatement.

Definition at line 469 of file SqlOdbcStatement.cxx.

References bindField(), AllDataType::convertToString(), List::get(), and typeFloat.

{
    if (!isPrepared) return ;
    BindSqlField *bindField = (BindSqlField*)paramList.get(paramPos);
    //if (bindField->type != typeFloat) return;
    //*(float*)(bindField->value) = value;
    AllDataType::convertToString(bindField->value, &value, typeFloat);
}

Here is the call graph for this function:

void SqlOdbcStatement::setIntParam	(	int	paramPos,
		int	value
	)			[virtual]

Sets the value for the required parameter position in statement.

Parameters:

	paramPos	int - parameter position
	value	int - value to be set

Implements AbsSqlStatement.

Definition at line 424 of file SqlOdbcStatement.cxx.

References bindField(), AllDataType::convertToString(), List::get(), and typeInt.

{
    if (!isPrepared) return ;
    BindSqlField *bindField = (BindSqlField*)paramList.get(paramPos);
    /*if (bindField->type != typeInt) return;
    *(int*)(bindField->value) = value;
    */

     //Note: MySQL Bug
     //Bug #1382     SQLDescribeParam returns the same type information, varchar
    AllDataType::convertToString(bindField->value, &value, typeInt);

    return;

}

Here is the call graph for this function:

void SqlOdbcStatement::setLongLongParam	(	int	paramPos,
		long long	value
	)			[virtual]

Sets the value for the required parameter position in statement.

Parameters:

	paramPos	int - parameter position
	value	long long - value to be set

Implements AbsSqlStatement.

Definition at line 451 of file SqlOdbcStatement.cxx.

References bindField(), AllDataType::convertToString(), List::get(), and typeLongLong.

{
    if (!isPrepared) return ;
    BindSqlField *bindField = (BindSqlField*)paramList.get(paramPos);
    //if (bindField->type != typeLongLong) return;
    //*(long long*)(bindField->value) = value;
    AllDataType::convertToString(bindField->value, &value, typeLongLong);
    return;
}

Here is the call graph for this function:

void SqlOdbcStatement::setLongParam	(	int	paramPos,
		long	value
	)			[virtual]

Sets the value for the required parameter position in statement.

Parameters:

	paramPos	int - parameter position
	value	long - value to be set

Implements AbsSqlStatement.

Definition at line 439 of file SqlOdbcStatement.cxx.

References bindField(), AllDataType::convertToString(), List::get(), and typeLong.

{
    if (!isPrepared) return ;
    BindSqlField *bindField = (BindSqlField*)paramList.get(paramPos);
    //if (bindField->type != typeLong) return;
    //*(long*)(bindField->value) = value;
     //Note: MySQL Bug
     //Bug #1382     SQLDescribeParam returns the same type information, varchar
    AllDataType::convertToString(bindField->value, &value, typeLong);
    return;

}

Here is the call graph for this function:

void SqlOdbcStatement::setShortParam	(	int	paramPos,
		short	value
	)			[virtual]

Sets the value for the required parameter position in statement.

Parameters:

	paramPos	int - parameter position
	value	short - value to be set

Implements AbsSqlStatement.

Definition at line 416 of file SqlOdbcStatement.cxx.

References bindField(), List::get(), and typeShort.

{
    if (!isPrepared) return ;
    BindSqlField *bindField = (BindSqlField*)paramList.get(paramPos);
    if (bindField->type != typeShort) return;
    *(short*)(bindField->value) = value;
    return;
}

Here is the call graph for this function:

void SqlOdbcStatement::setStringParam	(	int	paramPos,
		char *	value
	)			[virtual]

Sets the value for the required parameter position in statement.

Parameters:

	paramPos	int - parameter position
	value	char* - value to be set

Implements AbsSqlStatement.

Definition at line 486 of file SqlOdbcStatement.cxx.

References bindField(), List::get(), and typeString.

{
    if (!isPrepared) return ;
    BindSqlField *bindField = (BindSqlField*)paramList.get(paramPos);
    if (bindField->type != typeString) return;
    char *dest = (char*)bindField->value;
    strncpy(dest, value, bindField->length);
    dest[ bindField->length - 1] ='\0';
    return;
}

Here is the call graph for this function:

void SqlOdbcStatement::setTimeParam	(	int	paramPos,
		Time	value
	)			[virtual]

Sets the value for the required parameter position in statement.

Parameters:

	paramPos	int - parameter position
	value	Time - value to be set

Implements AbsSqlStatement.

Definition at line 505 of file SqlOdbcStatement.cxx.

References bindField(), AllDataType::convertToString(), List::get(), and typeTime.

{
    if (!isPrepared) return ;
    BindSqlField *bindField = (BindSqlField*)paramList.get(paramPos);
    //if (bindField->type != typeTime) return;
    //*(Time*)(bindField->value) = value;
    AllDataType::convertToString(bindField->value, &value, typeTime);

}

Here is the call graph for this function:

void SqlOdbcStatement::setTimeStampParam	(	int	paramPos,
		TimeStamp	value
	)			[virtual]

Sets the value for the required parameter position in statement.

Parameters:

	paramPos	int - parameter position
	value	TimeStamp - value to be set

Implements AbsSqlStatement.

Definition at line 514 of file SqlOdbcStatement.cxx.

References bindField(), AllDataType::convertToString(), List::get(), and typeTimeStamp.

{
    if (!isPrepared) return ;
    BindSqlField *bindField = (BindSqlField*) paramList.get(paramPos);
    //if (bindField->type != typeTimeStamp) return;
    //*(TimeStamp*)(bindField->value) = value;
    AllDataType::convertToString(bindField->value, &value, typeTimeStamp);
}

Here is the call graph for this function:

---

Friends And Related Function Documentation

friend class SqlFactory [friend]

Definition at line 79 of file SqlOdbcStatement.h.

---

The documentation for this class was generated from the following files:

• include/SqlOdbcStatement.h
• src/adapter/SqlOdbcStatement.cxx

---