TeOCICursor Class Reference

#include <TeOCICursor.h>

---

Detailed Description

This class contains attributes and methods to handle a record set to ORACLE DBMS using OCI (Oracle Call Interface) library.

A record set is generated by a query on the data in the database server. The class OCICursor is used by the drivers TeOCIOracle and TeOCIOracleSpatial that are responsible for the link between ORACLE DBMS and TerraLib.

See also:

TeOCIConnect

Definition at line 114 of file TeOCICursor.h.

Buffers to store data in memory - client side
vector< void * >	buffers_
	buffer to store simple data type (varchar, number, date, etc)
vector< OCIDefine * >	defines_
	Number of rows to be fetched into memory from database server.
SDO_GEOMETRY_ind *	global_geom_ind_ [MAX_ROWS]
	buffer to store spatial object indicator
SDO_GEOMETRY_TYPE *	global_geom_obj_ [MAX_ROWS]
	buffer to store spatial object
bool	hasBlob_
	vector of buffers to store blob
vector< indarray >	ind_
	buffer to store null indicator
vector< unsigned char * >	lobBuffer_
unsigned long	maxBuflen_
	Flag that indicates if the cursor has blob data type.
int	maxRows_
	Max memory the will be allocated to store blob data.
OCIArray *	ordinates_
	store the ordinates to be used in a query (bind)
Information about columns of the record set in memory
vector< string >	colBlobName_
	name of the BLOB columns only
vector< string >	colName_
	name of the columns
vector< int >	colScale_
	scale of the columns
vector< int >	colSize_
	size of the columns
vector< int >	colType_
	type of the columns
int	numColls_
	number of columns
Information to handle the records or rows stored in memory (buffers)
bool	last_Row_
	if the current row is the last
int	row_Cur_
	absolute current row index in the memory buffer
short	row_Index_
	relative current row index in the memory buffer
int	rows_Fetched_
	number of rows fetched from database
int	rows_Mem_
	number of rows on memory buffer - client side
Methods to return information about the columns and rows in the record set
string	colName (int colnumber)
	Returns the column name of a specific column.
int	colScale (int colnumber)
	Returns the column scale (number of digits after decimal point) of a specific column.
int	colSize (int colnumber)
	Returns the column size of a specific column.
int	colType (int colnumber)
	Returns the column type (SQLT) of a specific column.
void	loadCollDescription ()
	Loads all column descriptions (name, type, size and scale).
int	numCol (void)
	Returns the columns number in the client side.
int	numRows (void)
	Returns the rows number in the client side.
Methods to deal with long binary (blob) type
unsigned int	getBlobSize (const string &blobCol)
	Returns the size (in unsigend int) of a specific blob column.
bool	readBlob (double **buffer)
	Gets a pointer to buffer of blob.
bool	readBlob (double *buffer, unsigned int &bufsize)
	Reads a long binary (blob) from database server and returns it as a double vector.
bool	readBlob (unsigned char *buffer, unsigned int &bufsize, const string &blobCol)
	Reads a long binary (blob) column (blobCol) from database server and returns it as a unsigned char vector.
bool	readBlob (unsigned char *buffer, unsigned int &bufsize, unsigned int &blobCol)
	Reads a long binary (blob) column (blobCol) from database server and returns it as a unsigned char vector.
Methods to deal with SDO_GEOMETRY, SDO_ELEM_INFO and SDO_ORDINATES types of the Oracle Spatial
bool	getCoordinates (vector< TeCoord2D > &result)
	Gets all coordinates of the SDO_ORDINATES array of the record set current row.
bool	getCoordinates (int i, TeCoord2D &coord)
	Gets the i-th coordinate of the SDO_ORDINATES array of the record set current row.
int	getDimArraySize ()
	Gets the size of the SDO_ELEM_INFO array of the record set current row.
bool	getDimElement (int i, int &elem)
	Gets the i-th element of the SDO_ELEM_INFO array of the record set current row.
int	getGeometryType ()
	Gets the geometry type of the SDO_GEOMETRY type of the record set current row.
int	getNumberOrdinates (void)
	Gets the number of ordinates in the SDO_ORDINATES array of the record set current row.
int	getSpatialReferenceId ()
	Gets the spatial reference of the SDO_GEOMETRY type of the record set current row.
bool	getXYZcoord (double &x, double &y)
	Gets a coordinate (x and y) of the SDO_POINT type of the record set current row.
Public Member Functions
bool	allocateCursor (void)
	Locates memory to store the record set in the client side.
bool	appendOrdinates (const double &val)
	Appends the new value to the internal ordinate vector.
bool	bindOrdinates ()
	Binds the internal ordinate array with the SQL statement.
void	close ()
	Closes the cursor.
TeOCIConnection *	conn ()
	Returns the connection to the database server.
int	currentRow ()
	Returns the current row index.
void	defineByPos (int pos, void *value, int size, void *indicator, int type)
	Defines the OCI handles by position.
bool	execute ()
	Executes the SQL statement set previously.
bool	fetch (int rows)
	Fetchs a number of rows.
void	freeResult (void)
	Clears the memory and structures located by the record set.
string	getErrorMessage ()
	Returns the error message.
char *	getFieldValue (int i)
	Gets the i-th field value from record set.
bool	isOpen ()
	Checks if the cursor is opened.
bool	moveFirst ()
	Moves to the first row in the record set.
bool	moveLast ()
	Moves to the last row in the record set.
bool	moveNext ()
	Moves to the next row in the record set.
bool	moveTo (int pos)
	Moves to a specific position in the record set.
bool	open ()
	Opens the cursor locating memory and initializing the enviroment.
bool	prepare (const string &stmt)
	Sets and prepares the SQL statement to be executed.
bool	query (const string &query)
	Executes a query defined by a SQL statement that returns a record set as result.
bool	querySDO (const string &query)
	Executes a query defined by a SQL statement that uses SDO_GEOMETRY type and returns a record set as result.
int	queryType ()
	Returns the query type based on the SQL statement set previously.
	TeOCICursor (TeOCIConnection *conn, const unsigned long &maxBlobSize=0, const unsigned long &maxRowNum=0)
	Constructor.
	~TeOCICursor ()
	Destructor.
Protected Member Functions
bool	checkError (sword status)
	Checks the error associated to error OCI handle.
Protected Attributes
TeOCIConnection *	connection_
	A pointer to a opened connection.
OCIDescribe *	dschp_
	OCI environment describe handle - describes objects.
string	errorMessage_
	error message returned by the ORACLE DBMS
string	fieldValue_
	temporary variable
bool	isOpen_
	indicates if the cursor is opened or not (if the stmthpToQuery was located)
OCIStmt *	stmthpToQuery_
	OCI statement handle to query.

---

Constructor & Destructor Documentation

TeOCICursor::TeOCICursor	(	TeOCIConnection *	conn,
		const unsigned long &	maxBlobSize = 0,
		const unsigned long &	maxRowNum = 0
	)

Definition at line 104 of file TeOCICursor.cpp.

References colBlobName_, connection_, dschp_, errorMessage_, fieldValue_, global_geom_ind_, global_geom_obj_, hasBlob_, isOpen_, last_Row_, MAX_BLOB_LENGTH, MAX_ROWS, maxBuflen_, maxRows_, NULL, numColls_, ordinates_, row_Cur_, row_Index_, rows_Fetched_, rows_Mem_, stmthpToQuery_, and TeOCIConnection::useSDOType().

{
        if(!connec)
                return;
        
        maxRows_ = MAX_ROWS;
        maxBuflen_ = MAX_BLOB_LENGTH;

        //size in bytes to each blob
        if(maxBlobSize>0)
                maxBuflen_ = maxBlobSize;

        if(maxRowNum>0)
                maxRows_ = maxRowNum;
        
        connection_ = connec;
        stmthpToQuery_ = NULL;
        dschp_ = NULL;
        fieldValue_ = "";
        ordinates_ = 0;
        isOpen_ = false;
        hasBlob_ = false;
        row_Index_ = -1;
        rows_Fetched_ = 0;
        rows_Mem_ = 0;
        row_Cur_ = -1;
        last_Row_ = false;
        errorMessage_ = "";
        numColls_ = -1;
        colBlobName_.clear();

        if(connection_->useSDOType())
        {
                for(int i=0;i<maxRows_;i++)
                {
                        global_geom_obj_[i] = NULL;
                        global_geom_ind_[i] = NULL;
                }
        }
}

TeOCICursor::~TeOCICursor

(

)

[inline]

Definition at line 170 of file TeOCICursor.h.

{ close(); }

---

Member Function Documentation

bool TeOCICursor::allocateCursor

(

void

)

Definition at line 857 of file TeOCICursor.cpp.

References buffers_, colScale_, colSize_, colType_, connection_, defines_, dvoid, TeOCIConnection::envhp_, TeOCIConnection::errhp_, global_geom_ind_, global_geom_obj_, hasBlob_, ind_, lobBuffer_, maxBuflen_, maxRows_, NULL, numColls_, OCI_DEFAULT, OCI_DURATION_SESSION, OCI_SUCCESS, OCI_SUCCESS_WITH_INFO, OCI_TYPECODE_OBJECT, OCIDefineArrayOfStruct(), OCIDefineByPos(), OCIDefineObject(), SDO_OCIDefineByPos(), SDO_OCIObjectNew(), SQLT_LBI, SQLT_NTY, SQLT_ODT, SQLT_STR, SQLT_VNU, stmthpToQuery_, TeOCIConnection::svchp_, TeOCIConnection::tdo_geometry_, and TRUE.

Referenced by query(), and querySDO().

 {
        int                     size;
        int                     coltype=0;
        int                     colsize=0;
        int                     colscale=0;
        sword           status;
        
        try
        {
                ind_.resize(numColls_);

                for(int nc=0; nc<numColls_; ++nc)
                {
                        defines_.push_back (0);
                        buffers_.push_back (0);
                }

                for(int i=1; i<=numColls_;i++)
                {
                        coltype = colType_[i-1];
                        colsize = colSize_[i-1];
                        colscale = colScale_[i-1];

                        switch (coltype)
                        {
                                case 3: //INTEGER
                                        buffers_[i-1] = new signed int[maxRows_];
                                        colsize = sizeof(signed int);

                                        status = OCIDefineByPos(stmthpToQuery_, &(defines_[i-1]), connection_->errhp_, (ub4)i, 
                                                        (dvoid *)(signed int*)buffers_[i-1], (sb4)colsize, coltype, 
                                                        (dvoid *)&ind_[i-1], (ub2 *)0, (ub2 *)0,(ub4)OCI_DEFAULT);
                                        if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                                                return false;

                                        break;

                        
                                case 2: //NUMBER
                                                                                
                                        buffers_[i-1] = (OCINumber *) new OCINumber[maxRows_]; //();                                                            
                                        status = OCIDefineByPos(stmthpToQuery_, &(defines_[i-1]), connection_->errhp_, (ub4)i, 
                                                        (dvoid *)buffers_[i-1], sizeof(OCINumber), SQLT_VNU, 
                                                        (dvoid *)&ind_[i-1], (ub2 *)0, (ub2 *)0,(ub4)OCI_DEFAULT);
                                        if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                                                return false;
                        
                                        break;
                                                        

                                case 4: //FLOAT DOUBLE
                                        
                                        buffers_[i-1] = new double[maxRows_];
                                        colsize = sizeof(double);
                                        coltype = 4;
                                
                                        status = SDO_OCIDefineByPos(stmthpToQuery_, &(defines_[i-1]), connection_->errhp_, (ub4)i, 
                                                        (dvoid *)(double*)buffers_[i-1], (sb4)colsize, coltype, 
                                                        (dvoid *)&ind_[i-1], (ub2 *)0, (ub2 *)0, (ub4)OCI_DEFAULT);
                                        if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                                                return false;
                                
                                
                                        break;

                                case 96: //CHAR
                                case 9: //VARCHAR:
                                case 1: //VARCHAR2:
                                        buffers_[i-1] = (char *) new char[maxRows_*(colsize+1)];
                        
                                        status = SDO_OCIDefineByPos(stmthpToQuery_, &(defines_[i-1]), connection_->errhp_, (ub4)i, 
                                                        (dvoid *)buffers_[i-1], (sb4)(colsize+1), SQLT_STR, 
                                                        (dvoid *)&ind_[i-1], (ub2 *)0, (ub2 *)0,(ub4)OCI_DEFAULT);
                                                if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                                                        return false;
                                
                                        break;

                                case 12: //Date
                                        buffers_[i-1] = (OCIDate *) new OCIDate[maxRows_]; //();                                                                
                                        status = OCIDefineByPos(stmthpToQuery_, &(defines_[i-1]), connection_->errhp_, (ub4)i, 
                                                        (dvoid *)buffers_[i-1], sizeof(OCIDate), SQLT_ODT, 
                                                        (dvoid *)&ind_[i-1], (ub2 *)0, (ub2 *)0,(ub4)OCI_DEFAULT);
                                        if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                                                        return false;
                                
                                        break;


                                case 108: //OBJECT SDO_GEOMETRY
                                
                                        status = SDO_OCIObjectNew(connection_->envhp_, connection_->errhp_, connection_->svchp_,
                                                        OCI_TYPECODE_OBJECT, connection_->tdo_geometry_, (dvoid*)NULL, 
                                                        OCI_DURATION_SESSION, TRUE, 
                                                        (dvoid**)global_geom_obj_);
                                        if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                                                        return false;
                                        
                                        defines_[i-1] = NULL;
                                                                
                                        status = SDO_OCIDefineByPos(stmthpToQuery_, &(defines_[i-1]), connection_->errhp_, (ub4)i, 
                                                        (dvoid *)0, (sb4)0, SQLT_NTY, (dvoid *)&ind_[i-1],
                                                        (ub2 *)0, (ub2 *)0, (ub4)OCI_DEFAULT);
                                        if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                                                        return false;
                                        
                                        status = OCIDefineObject(defines_[i-1], connection_->errhp_, connection_->tdo_geometry_, 
                                                        (dvoid **)global_geom_obj_, (ub4 *)0, 
                                                        (dvoid **)global_geom_ind_, (ub4 *)0);
                                        if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                                                        return false;

                                        break;

                                case 113 :      //SQLT_BLOB
                                        
                                        hasBlob_ = true;
                                        lobBuffer_.push_back(NULL);
                                        lobBuffer_[lobBuffer_.size()-1] = new unsigned char[maxBuflen_*maxRows_]; 
                                        size = sizeof(unsigned char)*maxBuflen_;
                                                                                
                                        status = OCIDefineByPos (stmthpToQuery_, &(defines_[i-1]), connection_->errhp_, (ub4)i, 
                                                (dvoid *)lobBuffer_[lobBuffer_.size()-1], size, SQLT_LBI, (void *)&ind_[i-1], (ub2 *)0, (ub2 *)0, 
                                                (ub4)OCI_DEFAULT); 
                                        if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                                                        return false;
                                        
                                        status = OCIDefineArrayOfStruct(defines_[i-1], connection_->errhp_, size, 0, 0, 0);
                                        if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                                                return false;
                                        break;
                                default:
                                        break;
                        
                        } //switch
        
                } //for
        }//try

        catch(...) 
        {
                return false;
        }

        return true;
}       

bool TeOCICursor::appendOrdinates

(

const double &

val

)

Definition at line 307 of file TeOCICursor.cpp.

References connection_, dvoid, TeOCIConnection::envhp_, TeOCIConnection::errhp_, NULL, OCI_DURATION_SESSION, OCI_SUCCESS, OCI_SUCCESS_WITH_INFO, OCI_TYPECODE_VARRAY, OCICollAppend(), OCINumberFromReal(), ordinates_, SDO_OCIObjectNew(), TeOCIConnection::svchp_, TeOCIConnection::tdo_ordinates_, and TRUE.

Referenced by TeOracleSpatial::allocateOrdinatesObject().

{
        
        OCINumber       oci_number;
        sword       status;

        if(!ordinates_)
        {
                status = SDO_OCIObjectNew(connection_->envhp_, connection_->errhp_, connection_->svchp_, OCI_TYPECODE_VARRAY, 
                                        connection_->tdo_ordinates_, (dvoid*)NULL, OCI_DURATION_SESSION, TRUE, 
                                        (dvoid**)&ordinates_);

                if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                        return false;
        }
        
        status = OCINumberFromReal(connection_->errhp_, (dvoid *)&(val), 
                (uword)sizeof(double),&oci_number);

        status = OCICollAppend(connection_->envhp_, connection_->errhp_, 
                (dvoid *) &oci_number,
                (dvoid *)0, (OCIColl *)ordinates_);

        if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                return false;

        return true;
}

bool TeOCICursor::bindOrdinates

(

)

Definition at line 336 of file TeOCICursor.cpp.

References connection_, dvoid, TeOCIConnection::envhp_, TeOCIConnection::errhp_, NULL, OCI_DEFAULT, OCI_DURATION_SESSION, OCI_SUCCESS, OCI_SUCCESS_WITH_INFO, OCI_TYPECODE_VARRAY, OCIBindByName(), OCIBindObject(), ordinates_, SDO_OCIObjectNew(), SQLT_NTY, stmthpToQuery_, TeOCIConnection::svchp_, TeOCIConnection::tdo_ordinates_, and TRUE.

Referenced by querySDO().

{
        OCIBind         *bnd1p = NULL;
        sword           status; 

        if(!ordinates_)
        {
                status = SDO_OCIObjectNew(connection_->envhp_, connection_->errhp_, connection_->svchp_, OCI_TYPECODE_VARRAY, 
                                        connection_->tdo_ordinates_, (dvoid*)NULL, OCI_DURATION_SESSION, TRUE, 
                                        (dvoid**)&ordinates_);

                if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                        return false;
        }
        
        /* bind coordinate varray object */
        status = OCIBindByName(stmthpToQuery_, &bnd1p, connection_->errhp_, 
            (text *)":ordinates_", (sb4)-1, (dvoid *)0, (sb4)0, SQLT_NTY, (dvoid *)0, 
                (ub2 *)0, (ub2 *)0, (ub4)0, (ub4 *)0, (ub4)OCI_DEFAULT);
        if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                return false;

        status = OCIBindObject(bnd1p, connection_->errhp_, connection_->tdo_ordinates_, (dvoid **)&ordinates_, (ub4 *)0, 
            (dvoid **)0, (ub4 *)0);
        if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                return false;

        return true;
}

bool TeOCICursor::checkError

(

sword

status

)

[protected]

Definition at line 530 of file TeOCICursor.cpp.

References connection_, dvoid, TeOCIConnection::errhp_, errorMessage_, NULL, OCI_CONTINUE, OCI_ERROR, OCI_HTYPE_ERROR, OCI_INVALID_HANDLE, OCI_NEED_DATA, OCI_NO_DATA, OCI_STILL_EXECUTING, OCI_SUCCESS, OCI_SUCCESS_WITH_INFO, and SDO_OCIErrorGet().

Referenced by moveFirst(), and query().

{
        sb4 errcode = 0;
        char message[256];
        bool returnedVal = false;

        if (status == OCI_ERROR)
        {
                SDO_OCIErrorGet((dvoid*)connection_->errhp_, (ub4)1, (text*)NULL, &errcode, 
                                                (text*)message, (ub4)256, OCI_HTYPE_ERROR);

                errorMessage_ = message;
                return false;
        }
        
        switch (status)
        { 
                case OCI_SUCCESS:
                        errorMessage_ = "Success!";
                        returnedVal = true;
                        break;

                case OCI_SUCCESS_WITH_INFO:
                        errorMessage_ = "Success with information!";
                        returnedVal = true;
                        break;

                case OCI_NEED_DATA:
                        errorMessage_ = "Need data!";
                        break;
                
                case OCI_NO_DATA:
                        errorMessage_ = "No data!";
                        break;

                //An invalid handle was passed as a parameter or a user callback is passed an
                //invalid handle or invalid context. No further diagnostics are available.
                case OCI_INVALID_HANDLE:
                        errorMessage_ = "Invalid handle!";
                        break;

                case OCI_STILL_EXECUTING:
                        errorMessage_ = "Still executing!";
                        break;

                case OCI_CONTINUE:
                        errorMessage_ = "Continue!";
                        break;
                default:
                        break;
        }

        return returnedVal;

}

void TeOCICursor::close

(

void

)

Definition at line 191 of file TeOCICursor.cpp.

References dschp_, dvoid, freeResult(), isOpen_, NULL, numColls_, OCI_HTYPE_DESCRIBE, OCI_HTYPE_STMT, SDO_OCIHandleFree(), and stmthpToQuery_.

Referenced by open().

{
        freeResult(); //free all located memory
        // Finalize stmthpToQuery_ and dschp_
        if(isOpen_)
        {
                SDO_OCIHandleFree((dvoid *)stmthpToQuery_, (ub4)OCI_HTYPE_STMT);
                SDO_OCIHandleFree((dvoid*)dschp_, (ub4)OCI_HTYPE_DESCRIBE);
                stmthpToQuery_ = NULL;
                dschp_ = NULL;
        }
        isOpen_ = false;
        numColls_ = -1;
}

string TeOCICursor::colName

(

int

colnumber

)

Definition at line 827 of file TeOCICursor.cpp.

References colName_.

Referenced by TeOCIOraclePortal::query(), and TeOracleSpatialPortal::querySDO().

{       
        //first coll number is 1
        if((colnumber==0) || (colnumber>(int)colName_.size()))
                return "";

        return colName_[colnumber-1];
}

int TeOCICursor::colScale

(

int

colnumber

)

Definition at line 847 of file TeOCICursor.cpp.

References colScale_.

{
        //first coll number is 1
        if((colnumber==0) || (colnumber>(int)colScale_.size()))
                return 0;

        return colScale_[colnumber-1];
}

int TeOCICursor::colSize

(

int

colnumber

)

Definition at line 837 of file TeOCICursor.cpp.

References colSize_.

Referenced by TeOCIOraclePortal::query(), and TeOracleSpatialPortal::querySDO().

{
        //first coll number is 1
        if((colnumber==0) || (colnumber>(int)colSize_.size()))
                return 0;

        return colSize_[colnumber-1];
}

int TeOCICursor::colType

(

int

colnumber

)

Definition at line 817 of file TeOCICursor.cpp.

References colType_.

Referenced by TeOCIOraclePortal::query(), and TeOracleSpatialPortal::querySDO().

{
        //first coll number is 1
        if((colnumber==0) || (colnumber>(int)colType_.size()))
                return 0;

        return colType_[colnumber-1];
}

TeOCIConnection* TeOCICursor::conn

(

)

[inline]

Definition at line 182 of file TeOCICursor.h.

Referenced by TeOCIOraclePortal::isConnected().

{ return connection_; }

int TeOCICursor::currentRow

(

)

[inline]

Definition at line 185 of file TeOCICursor.h.

Referenced by TeOCIOraclePortal::fetchRow().

{ return row_Cur_; }

void TeOCICursor::defineByPos	(	int	pos,
		void *	value,
		int	size,
		void *	indicator,
		int	type
	)

Definition at line 282 of file TeOCICursor.cpp.

References connection_, dvoid, TeOCIConnection::errhp_, NULL, OCI_DEFAULT, SDO_OCIDefineByPos(), and stmthpToQuery_.

{
        OCIDefine *defnp = NULL;

        SDO_OCIDefineByPos(stmthpToQuery_, &defnp, connection_->errhp_, (ub4)pos, 
                                                                  (dvoid *)value, (sb4)size, type, 
                                                                  (dvoid *)indicator, (ub2 *)0, (ub2 *)0,
                                                                  (ub4)OCI_DEFAULT);
}

bool TeOCICursor::execute

(

)

bool TeOCICursor::fetch

(

int

rows

)

Definition at line 294 of file TeOCICursor.cpp.

References connection_, TeOCIConnection::errhp_, OCI_DEFAULT, OCI_FETCH_NEXT, OCI_SUCCESS, OCI_SUCCESS_WITH_INFO, OCIStmtFetch(), and stmthpToQuery_.

{
        sword status;
        status = OCIStmtFetch(stmthpToQuery_, connection_->errhp_, (ub4) rows, (ub4) OCI_FETCH_NEXT,
                               (ub4) OCI_DEFAULT);

        if (status == OCI_SUCCESS || status == OCI_SUCCESS_WITH_INFO)
                return true;
        else
                return false;

}

void TeOCICursor::freeResult

(

void

)

free the spatial object instance

Definition at line 206 of file TeOCICursor.cpp.

References buffers_, colBlobName_, colName_, colScale_, colSize_, colType_, connection_, defines_, dvoid, TeOCIConnection::envhp_, TeOCIConnection::errhp_, global_geom_ind_, global_geom_obj_, hasBlob_, ind_, lobBuffer_, maxRows_, NULL, numColls_, OCI_OBJECTFREE_FORCE, OCIObjectFree(), ordinates_, and TeOCIConnection::useSDOType().

Referenced by close(), TeOCIOraclePortal::freeResult(), query(), and querySDO().

{       
        //vector of buffers to store blob
        for(unsigned int b=0; b<lobBuffer_.size(); ++b)
        {
                if(lobBuffer_[b])
                {
                        delete [] lobBuffer_[b];
                        lobBuffer_[b] = NULL;
                }
        }
        lobBuffer_.clear();
        
        //buffer to store alphanumeric data
        for(unsigned int i=0; i<buffers_.size();i++)
        {
                int coltype = colType_[i];
                switch (coltype)
                {
                        case 3: //INTEGER
                                delete [] ((signed int*) buffers_[i]);
                                break;
                        
                        case 2: //NUMBER
                                delete [] ((OCINumber*) buffers_[i]);
                                break;
                        
                        case 4: //FLOAT DOUBLE
                                delete [] ((double*) buffers_[i]);
                                break;
                        
                        case 96: //CHAR
                        case 9: //VARCHAR:
                        case 1: //VARCHAR2:     
                                delete [] ((char *) buffers_[i]);
                                break;
                        
                        case 12: //Date
                                        delete [] ((OCIDate *) buffers_[i]);
                                        break;
                        default:
                                        break;
                        
                } //switch
        } //for

        //sdo geometry
        if(connection_->useSDOType())  
        {
                for(int i=0;i<maxRows_;i++) 
                {
                        /// free the spatial object instance 
                        OCIObjectFree(connection_->envhp_, connection_->errhp_, (dvoid *)global_geom_obj_[i], 
                                   (ub2)OCI_OBJECTFREE_FORCE);
                        
                        global_geom_obj_[i] = NULL;
                        global_geom_ind_[i] = NULL;
                }

                OCIObjectFree(connection_->envhp_, connection_->errhp_, (dvoid *)ordinates_, (ub2)OCI_OBJECTFREE_FORCE);
                ordinates_ = 0;
        }

        buffers_.clear();
        defines_.clear(); // ver se o freestmtp desaloca os OCIDefines 
        ind_.clear();
        colType_.clear();
        colSize_.clear();
        colScale_.clear();
        colName_.clear();
        numColls_ = -1;
        hasBlob_ = false;
        colBlobName_.clear();
}

unsigned int TeOCICursor::getBlobSize

(

const string &

blobCol

)

Definition at line 1366 of file TeOCICursor.cpp.

References colBlobName_, getFieldValue(), numColls_, and TeStringCompare().

Referenced by TeOCIOraclePortal::getBlob().

{
        int blobIndex = -1;
        if(colBlobName_.empty())
                return 0;
        if(colBlobName_.size()==1)
                blobIndex=0;
        else
        {
                for(unsigned int j=0; j<colBlobName_.size(); j++)
                {
                        if(TeStringCompare(blobCol, colBlobName_[j]))
                        {
                                blobIndex = j;
                                break;
                        }
                }
        }

        if(blobIndex<0)
                return 0;

        int index = numColls_-(colBlobName_.size()-(blobIndex+1)); 
        return (atoi(getFieldValue(index))*sizeof(unsigned char));
}

bool TeOCICursor::getCoordinates

(

vector< TeCoord2D > &

result

)

Definition at line 1178 of file TeOCICursor.cpp.

References connection_, dvoid, TeOCIConnection::envhp_, TeOCIConnection::errhp_, global_geom_obj_, OCI_SUCCESS, OCIIterCreate(), OCIIterDelete(), OCIIterNext(), OCINumberToReal(), row_Index_, and sdo_geometry::sdo_ordinates.

{
        
        OCIIter         *iterator;
        dvoid           *elem;
        OCIInd          *elemind ;
        double          ordinate1, ordinate2; 
        OCINumber       *aux1;
        OCINumber       *aux2;
        //boolean               eoc;
        int                     eoc;

        sword status = OCIIterCreate(connection_->envhp_, connection_->errhp_, 
                (OCIArray *)(global_geom_obj_[row_Index_]->sdo_ordinates), &iterator);
        if (status != OCI_SUCCESS)
                return false;
        
        /* Get the first and second element of the clients varray */
        status = OCIIterNext(connection_->envhp_, connection_->errhp_, iterator, &elem,
                (dvoid **) &elemind, (boolean *)&eoc);
        if (eoc || status != OCI_SUCCESS)
        {
                OCIIterDelete(connection_->envhp_, connection_->errhp_, &iterator);
                return false;
        }

        aux1 = (OCINumber *)elem;
        OCINumberToReal(connection_->errhp_, (OCINumber *)aux1, (uword)sizeof(double),
                                        (dvoid *)&ordinate1);

        status = OCIIterNext(connection_->envhp_, connection_->errhp_, iterator, &elem,
                                (dvoid **)&elemind, (boolean *)&eoc);
        if (eoc || status != OCI_SUCCESS)
        {
                OCIIterDelete(connection_->envhp_, connection_->errhp_, &iterator);
                return false;
        }

        aux2 = (OCINumber *)elem;
        OCINumberToReal(connection_->errhp_, (OCINumber *) aux2, (uword)sizeof(double),
                                        (dvoid *)&ordinate2);

        TeCoord2D coord(ordinate1, ordinate2);
        result.push_back (coord);
        
        while (!eoc && status == OCI_SUCCESS)
        {
                status = OCIIterNext(connection_->envhp_, connection_->errhp_, iterator, &elem,
                                (dvoid **)&elemind, (boolean *)&eoc);
                if (status != OCI_SUCCESS)
                {
                        OCIIterDelete(connection_->envhp_, connection_->errhp_, &iterator);
                        return false;
                }

                aux1 = (OCINumber *)elem;
                OCINumberToReal(connection_->errhp_, (OCINumber *)aux1, (uword)sizeof(double),
                                        (dvoid *)&ordinate1);

                status = OCIIterNext(connection_->envhp_, connection_->errhp_, iterator, &elem,
                                (dvoid **)&elemind, (boolean *)&eoc);
                if (status != OCI_SUCCESS)
                {
                        OCIIterDelete(connection_->envhp_, connection_->errhp_, &iterator);
                        return false;
                }

                aux2 = (OCINumber *)elem;
                OCINumberToReal(connection_->errhp_, (OCINumber *) aux2, (uword)sizeof(double),
                                        (dvoid *)&ordinate2);

                TeCoord2D coord(ordinate1, ordinate2);
                result.push_back (coord);
        }

        /* destroy the iterator */
        status = OCIIterDelete(connection_->envhp_, connection_->errhp_, &iterator);
        return true;
}

bool TeOCICursor::getCoordinates	(	int	i,
		TeCoord2D &	coord
	)

Definition at line 1144 of file TeOCICursor.cpp.

References connection_, dvoid, TeOCIConnection::envhp_, TeOCIConnection::errhp_, global_geom_obj_, OCICollGetElem(), OCINumberToReal(), row_Index_, sdo_geometry::sdo_ordinates, TeCoord2D::x(), and TeCoord2D::y().

Referenced by TeOracleSpatialPortal::fetchGeometry(), and TeOracleSpatialPortal::getCoordinates().

{
        int                             exists;
        OCINumber               *oci_number;
        double                  coor_x;
        double                  coor_y;

        int pos = i;

        OCICollGetElem(connection_->envhp_, connection_->errhp_, 
           (OCIColl *)(global_geom_obj_[row_Index_]->sdo_ordinates), 
           (sb4)(pos-1), (boolean *)&exists, 
           (dvoid **)&oci_number, (dvoid **)0);

        OCINumberToReal(connection_->errhp_, oci_number, (uword)sizeof(double),
                (dvoid *)&coor_x);
        
        pos++;

        OCICollGetElem(connection_->envhp_, connection_->errhp_, 
           (OCIColl *)(global_geom_obj_[row_Index_]->sdo_ordinates),  
           (sb4)(pos-1), (boolean *)&exists, 
           (dvoid **)&oci_number, (dvoid **)0);

        OCINumberToReal(connection_->errhp_, oci_number, (uword)sizeof(double),
                (dvoid *)&coor_y);

        coord.x(coor_x);
        coord.y(coor_y);

        return true;
}

int TeOCICursor::getDimArraySize

(

)

Definition at line 1102 of file TeOCICursor.cpp.

References connection_, TeOCIConnection::envhp_, TeOCIConnection::errhp_, global_geom_obj_, OCICollSize(), row_Index_, and sdo_geometry::sdo_elem_info.

Referenced by TeOracleSpatialPortal::getDimArraySize().

{
        int ndim=-1;

        // Get the size of the elem info array
    OCICollSize(connection_->envhp_, connection_->errhp_, 
                                (OCIColl *)(global_geom_obj_[row_Index_]->sdo_elem_info), &ndim);

        return(ndim);
}

bool TeOCICursor::getDimElement	(	int	i,
		int &	elem
	)

Definition at line 1113 of file TeOCICursor.cpp.

References connection_, dvoid, TeOCIConnection::envhp_, TeOCIConnection::errhp_, global_geom_obj_, OCICollGetElem(), OCINumberToReal(), row_Index_, and sdo_geometry::sdo_elem_info.

Referenced by TeOracleSpatialPortal::getDimElement().

{
        int                             exists;
        OCINumber               *oci_number;
        double                  el;


        OCICollGetElem(connection_->envhp_, connection_->errhp_, 
           (OCIColl *)(global_geom_obj_[row_Index_]->sdo_elem_info), 
           (sb4)i-1, (boolean *)&exists, 
           (dvoid **)&oci_number, (dvoid **)0);

        OCINumberToReal(connection_->errhp_, oci_number, (uword)sizeof(double),
                (dvoid *)&el);
        
        elem = (int)el;
        return true;
}

string TeOCICursor::getErrorMessage

(

)

[inline]

Definition at line 176 of file TeOCICursor.h.

References errorMessage_.

Referenced by TeOracleSpatialPortal::fetchGeometry(), TeOCIOraclePortal::fetchGeometry(), TeOCIOraclePortal::query(), and TeOracleSpatialPortal::querySDO().

{ return errorMessage_;}

char * TeOCICursor::getFieldValue

(

int

i

)

Definition at line 1005 of file TeOCICursor.cpp.

References buffers_, colSize_, colType_, connection_, dvoid, TeOCIConnection::errhp_, fieldValue_, ind_, memcpy(), NULL, OCI_SUCCESS, OCI_SUCCESS_WITH_INFO, OCIDateToText(), OCINumberToReal(), row_Index_, StrClean(), and Te2String().

Referenced by getBlobSize(), TeOCIOraclePortal::getBool(), TeOCIOraclePortal::getData(), TeOCIOraclePortal::getDate(), and readBlob().

{ 
        
        int                             tempInt;
        double                  tempDouble;
        char                    str[30];
        unsigned int    size; 
        string                  tempDate;
        sword                   status;
                
        if(i < 1)
                return (char*)0;

        int coltype = colType_[i-1]; 
        int colsize = colSize_[i-1]; 
        
        //OBS:  When the SQL use grouping functions (MAX, MIN, etc), the returned value always has
        //              colscale equal to zero, even when it is double
        int indica = ind_[i-1].sbind[row_Index_];

        std::string format = "DD/MM/YYYY HH24:MI:SS";
        size = format.size();

        switch (coltype)
        {
                case 3: //INTEGER
                        if(indica == -1)
                                return "";

                        tempInt = *((int*)buffers_[i-1]+row_Index_);
                        fieldValue_ = Te2String(tempInt);
                        return ((char*)fieldValue_.c_str());
                        break;

                case 2: //NUMBER
                        
                        if(indica == -1)
                                return "";
                        status = OCINumberToReal(connection_->errhp_, ((OCINumber *)buffers_[i-1]+row_Index_), 
                                (uword)sizeof(double), (dvoid *)&tempDouble);
                        if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                                return "";
                        
                        fieldValue_ = Te2String(tempDouble, 10);
                        return ((char*)fieldValue_.c_str());
                        break;
                        

                case 4: //FLOAT DOUBLE
                                
                        if(indica == -1)
                                return "";
                        
                        tempDouble = *((const double*)buffers_[i-1]+row_Index_);
                        fieldValue_ = Te2String(tempDouble, 10);
                        return ((char*)fieldValue_.c_str());
                        break;

                case 96: //CHAR
                case 9: //VARCHAR:
                case 1: //VARCHAR2:
                        
                        if(indica == -1)
                                return "";

                        fieldValue_ = ((char*)buffers_[i-1]+((colsize+1)*row_Index_));
                        fieldValue_ = StrClean((char*)fieldValue_.c_str());
                        return ((char*)fieldValue_.c_str());
                        break;

                case 12: //Date
                        
                        if(indica == -1)
                                return "";

                        fieldValue_ = "";
                        //size = sizeof(OCIDate);
                                                                                                        
                        status =  OCIDateToText(connection_->errhp_, ((OCIDate *)buffers_[i-1]+row_Index_), 
                                (unsigned char*)format.c_str(), format.size(), NULL, 0, &size, (unsigned char*)tempDate.c_str());
                        if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                                return "";
                        memcpy(str, tempDate.c_str(), size);
                        strncat((char*)fieldValue_.c_str(), str, size);

                        return ((char*)fieldValue_.c_str());
                        break;

                case 108: //OBJECT SDO_GEOMETRY
                default:
                        break;
                                                        
        } //switch
                
        return (char*)"";
}

int TeOCICursor::getGeometryType

(

)

Definition at line 1260 of file TeOCICursor.cpp.

References connection_, dvoid, TeOCIConnection::errhp_, global_geom_obj_, OCI_NUMBER_SIGNED, OCINumberToInt(), row_Index_, and sdo_geometry::sdo_gtype.

Referenced by TeOracleSpatialPortal::getGeometryType().

{
        int gtype=-1;

        OCINumberToInt(connection_->errhp_, &(global_geom_obj_[row_Index_]->sdo_gtype),
                                 (uword)sizeof(int), OCI_NUMBER_SIGNED,
                                 (dvoid *)&gtype);

        return gtype;
}

int TeOCICursor::getNumberOrdinates

(

void

)

Definition at line 1133 of file TeOCICursor.cpp.

References connection_, TeOCIConnection::envhp_, TeOCIConnection::errhp_, global_geom_obj_, OCICollSize(), row_Index_, and sdo_geometry::sdo_ordinates.

Referenced by TeOracleSpatialPortal::numberOfOrdinates().

{
        int nOrds=-1;

        /* Get the size of the ordinates_ array */
    OCICollSize(connection_->envhp_, connection_->errhp_, 
                                (OCIColl *)(global_geom_obj_[row_Index_]->sdo_ordinates), &nOrds);

        return(nOrds);
}

int TeOCICursor::getSpatialReferenceId

(

)

Definition at line 1272 of file TeOCICursor.cpp.

References connection_, dvoid, TeOCIConnection::errhp_, global_geom_obj_, OCI_NUMBER_SIGNED, OCINumberToInt(), row_Index_, and sdo_geometry::sdo_srid.

Referenced by TeOracleSpatialPortal::getSpatialReferenceId().

{
        int srid=-1;

        OCINumberToInt(connection_->errhp_, &(global_geom_obj_[row_Index_]->sdo_srid),
                                 (uword)sizeof(int), OCI_NUMBER_SIGNED,
                                 (dvoid *)&srid);

        return srid;
}

bool TeOCICursor::getXYZcoord	(	double &	x,
		double &	y
	)

Definition at line 1284 of file TeOCICursor.cpp.

References SDO_GEOMETRY_ind::_atomic, connection_, dvoid, TeOCIConnection::errhp_, global_geom_ind_, global_geom_obj_, OCI_IND_NOTNULL, OCI_SUCCESS, OCI_SUCCESS_WITH_INFO, OCINumberToReal(), row_Index_, sdo_geometry::sdo_point, sdo_point_type::x, and sdo_point_type::y.

Referenced by TeOracleSpatialPortal::getPointXYZ().

{
        if (global_geom_ind_[row_Index_]->sdo_point._atomic == OCI_IND_NOTNULL)
        {
                if (global_geom_ind_[row_Index_]->sdo_point.x == OCI_IND_NOTNULL)
                {
                        sword status = OCINumberToReal(connection_->errhp_, &(global_geom_obj_[row_Index_]->sdo_point.x), 
                                                                                 (uword)sizeof(double),(dvoid *)&x);

                        if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                                return false;
                }

                if (global_geom_ind_[row_Index_]->sdo_point.y == OCI_IND_NOTNULL)
                {
                        sword status = OCINumberToReal(connection_->errhp_, &(global_geom_obj_[row_Index_]->sdo_point.y), 
                                                                                 (uword)sizeof(double),(dvoid *)&y);
                        if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                                return false;
                }
                return true;
        }
        else
                return false;
}

bool TeOCICursor::isOpen

(

)

[inline]

Definition at line 179 of file TeOCICursor.h.

Referenced by TeOCIOraclePortal::query(), and TeOracleSpatialPortal::querySDO().

{ return isOpen_; }

void TeOCICursor::loadCollDescription

(

)

Definition at line 765 of file TeOCICursor.cpp.

References colName_, colScale_, colSize_, colType_, connection_, dvoid, TeOCIConnection::errhp_, hasBlob_, NULL, numCol(), numColls_, OCI_ATTR_DATA_SIZE, OCI_ATTR_DATA_TYPE, OCI_ATTR_NAME, OCI_ATTR_SCALE, OCI_DTYPE_PARAM, OCI_HTYPE_STMT, OCIAttrGet(), SDO_OCIAttrGet(), SDO_OCIParamGet(), and stmthpToQuery_.

Referenced by query(), and querySDO().

{
        OCIParam* colhd=NULL;
        //int           dtype;
        ub2     dtype = 0;
        string  colname;
        //int           colsize;
        ub2  colsize = (ub2) 0;
        //int           colscale;
        sb1  colscale = (sb1) 0;
        
        numCol(); // atualize the numColls_ variable
        hasBlob_ = false;

        int i;
        for(i=1; i<=numColls_; ++i)
        {
                // get parameter for i-th column
                SDO_OCIParamGet((dvoid*)stmthpToQuery_, (ub4)OCI_HTYPE_STMT, (OCIError *)connection_->errhp_, (dvoid**)&colhd, (ub4)i);

                // get data type 
                SDO_OCIAttrGet((dvoid *)colhd, (ub4)OCI_DTYPE_PARAM, (dvoid *)&dtype, (ub4*)0, (ub4)OCI_ATTR_DATA_TYPE, (OCIError *)connection_->errhp_);

                // get coll name 
                text *colname_ = NULL;
                ub4     colnamesz_;
                                
                OCIAttrGet((dvoid *)colhd, (ub4)OCI_DTYPE_PARAM, (dvoid **)&colname_, (ub4*)&colnamesz_, (ub4)OCI_ATTR_NAME, (OCIError *)connection_->errhp_ );

                char temp[100];
                for(int j=0;j<(int)colnamesz_;j++)
                        temp[j] = colname_[j];
                temp[colnamesz_] = '\0';
                colname = temp;

                // retrieve the column size attribute
                SDO_OCIAttrGet((dvoid *)colhd, (ub4)OCI_DTYPE_PARAM, (dvoid *)&colsize, (ub4*)0, (ub4)OCI_ATTR_DATA_SIZE, (OCIError *)connection_->errhp_ );

                // retrieve the column scale attribute
                SDO_OCIAttrGet((dvoid *)colhd, (ub4)OCI_DTYPE_PARAM, (dvoid *)&colscale, (ub4*)0, (ub4)OCI_ATTR_SCALE, (OCIError *)connection_->errhp_ );

                colName_.push_back(colname);
                colType_.push_back((int)dtype);
                colSize_.push_back((int)colsize);
                colScale_.push_back((int)colscale);

                if(dtype==113)
                        hasBlob_ = true;
        }
}

bool TeOCICursor::moveFirst

(

)

Definition at line 366 of file TeOCICursor.cpp.

References checkError(), connection_, dvoid, TeOCIConnection::errhp_, hasBlob_, last_Row_, maxRows_, OCI_ATTR_ROW_COUNT, OCI_DEFAULT, OCI_FETCH_FIRST, OCI_FETCH_NEXT, OCI_HTYPE_STMT, OCI_NO_DATA, OCI_SUCCESS, OCI_SUCCESS_WITH_INFO, OCIAttrGet(), OCIStmtFetch2(), row_Cur_, row_Index_, rows_Fetched_, rows_Mem_, and stmthpToQuery_.

Referenced by TeOCIOraclePortal::moveFirst(), and moveTo().

{               
        sword status;
        if(!hasBlob_)
                // this is for scroolable cursor
                status = OCIStmtFetch2(stmthpToQuery_, connection_->errhp_, (ub4)maxRows_, OCI_FETCH_FIRST, (sb4) 0, OCI_DEFAULT);
        else
                status = OCIStmtFetch2(stmthpToQuery_, connection_->errhp_, (ub4)maxRows_, OCI_FETCH_NEXT, (sb4) 0, OCI_DEFAULT);

        checkError(status);
        if (status == OCI_SUCCESS || status == OCI_SUCCESS_WITH_INFO  || status == OCI_NO_DATA)
        {
                OCIAttrGet((dvoid *)stmthpToQuery_, (ub4)OCI_HTYPE_STMT,
                             (dvoid *)&rows_Fetched_, (ub4 *)0, 
                             (ub4)OCI_ATTR_ROW_COUNT, connection_->errhp_);

                if(!rows_Fetched_)  
                        return false;

                if(status == OCI_NO_DATA)
                        last_Row_ = true;

                row_Index_ = 0;

                if(rows_Fetched_ < maxRows_)  
                        rows_Mem_ = rows_Fetched_;
                else
                        rows_Mem_ = maxRows_;

                row_Cur_ = 0;
                return true;
        }
        return false;
}

bool TeOCICursor::moveLast

(

)

Definition at line 450 of file TeOCICursor.cpp.

References connection_, TeOCIConnection::errhp_, last_Row_, OCI_DEFAULT, OCI_FETCH_LAST, OCI_SUCCESS, OCI_SUCCESS_WITH_INFO, OCIStmtFetch2(), and stmthpToQuery_.

{
        sword status = OCIStmtFetch2(stmthpToQuery_, connection_->errhp_, (ub4) 1, 
                               OCI_FETCH_LAST, (sb4) 0, OCI_DEFAULT);
        //podemos pegar informacao da ultima linha
        if (status == OCI_SUCCESS || status == OCI_SUCCESS_WITH_INFO)
        {
                last_Row_ = true;
                return true;
        }
        else
                return false;
}

bool TeOCICursor::moveNext

(

)

Definition at line 401 of file TeOCICursor.cpp.

References connection_, dvoid, TeOCIConnection::errhp_, last_Row_, maxRows_, OCI_ATTR_ROWS_FETCHED, OCI_DEFAULT, OCI_FETCH_NEXT, OCI_HTYPE_STMT, OCI_NO_DATA, OCI_SUCCESS, OCI_SUCCESS_WITH_INFO, OCIAttrGet(), OCIStmtFetch2(), row_Cur_, row_Index_, rows_Fetched_, rows_Mem_, and stmthpToQuery_.

Referenced by TeOCIOraclePortal::moveNext(), and moveTo().

{
        sword status;
                
        if((row_Index_+1) >= rows_Mem_) 
        {
                if(last_Row_)
                        return false;
                
                // this is for scroolable cursor
                status = OCIStmtFetch2(stmthpToQuery_, connection_->errhp_, (ub4) maxRows_, OCI_FETCH_NEXT, (sb4) 0, OCI_DEFAULT);

                if (status == OCI_SUCCESS || status == OCI_SUCCESS_WITH_INFO || status == OCI_NO_DATA)
                {
                        OCIAttrGet((dvoid *)stmthpToQuery_, (ub4)OCI_HTYPE_STMT,
                                        (dvoid *)&rows_Fetched_, (ub4 *)0, 
                                        (ub4)OCI_ATTR_ROWS_FETCHED, connection_->errhp_);

                        if(!rows_Fetched_)
                                return false;

                        if(status == OCI_NO_DATA)
                        {
                                if(last_Row_)
                                        return false;
                                else
                                        last_Row_ = true;
                        }

                        row_Index_ = 0;

                        if(rows_Fetched_ < maxRows_)
                                rows_Mem_ = rows_Fetched_;
                        else
                                rows_Mem_ = maxRows_;

                        row_Cur_++;
                        return true;
                }
                else
                        return false;
        }
        else
                row_Index_++;
        
        row_Cur_++;
        return true;
}

bool TeOCICursor::moveTo

(

int

pos

)

Definition at line 464 of file TeOCICursor.cpp.

References connection_, dvoid, TeOCIConnection::errhp_, hasBlob_, last_Row_, maxRows_, moveFirst(), moveNext(), OCI_ATTR_ROWS_FETCHED, OCI_DEFAULT, OCI_FETCH_ABSOLUTE, OCI_HTYPE_STMT, OCI_NO_DATA, OCI_SUCCESS, OCI_SUCCESS_WITH_INFO, OCIAttrGet(), OCIStmtFetch2(), row_Cur_, row_Index_, rows_Fetched_, and stmthpToQuery_.

Referenced by TeOCIOraclePortal::fetchRow().

{
        // It is not possible use scrollable cursor with blob
        if(hasBlob_) 
        {
                // for non-scroolable cursor, needs to query again
                // if pos is at the end of recordset may be slow
                int topos;
                if(pos > 0)
                        topos = pos-1;
                else
                        topos = row_Cur_ + pos;
                if(topos < 0)
                        topos = 0;

                if(!moveFirst())
                        return false;

                while(row_Cur_ != topos)
                {
                        if(!moveNext())
                                return false;
                }
                return true;
        }

        sword status;
        int auxPos = maxRows_*int(pos/maxRows_);

        // row_Cur_ = absolute current row 
        // row_Index_ = relative current row - client side
        if(int(row_Cur_/maxRows_) == int(pos/maxRows_)) 
        {
                row_Index_ = pos - (maxRows_*int(pos/maxRows_));
                row_Cur_ = pos;
                return true;
        }

        if(pos<row_Cur_)
        {
                if(!moveFirst())
                        return false;
        }

        status = OCIStmtFetch2(stmthpToQuery_, connection_->errhp_, (ub4) maxRows_, OCI_FETCH_ABSOLUTE, (sb4)auxPos+1, OCI_DEFAULT); 
        row_Index_ = pos-auxPos;
        row_Cur_ = pos;

        if (status == OCI_SUCCESS || status == OCI_SUCCESS_WITH_INFO || status == OCI_NO_DATA)
        {
                OCIAttrGet((dvoid *)stmthpToQuery_, (ub4)OCI_HTYPE_STMT,
                                 (dvoid *)&rows_Fetched_, (ub4 *)0, 
                                 (ub4)OCI_ATTR_ROWS_FETCHED, connection_->errhp_);

                if(!rows_Fetched_)
                        return false;
                
                if(status == OCI_NO_DATA)
                        last_Row_ = true;
                return true;
        }

        return false;
}

int TeOCICursor::numCol

(

void

)

Definition at line 740 of file TeOCICursor.cpp.

References colBlobName_, connection_, TeOCIConnection::errhp_, numColls_, OCI_ATTR_PARAM_COUNT, OCI_HTYPE_STMT, OCIAttrGet(), and stmthpToQuery_.

Referenced by loadCollDescription(), TeOCIOraclePortal::query(), and TeOracleSpatialPortal::querySDO().

{       
        if(numColls_>=0)
                return (numColls_-(colBlobName_.size()));
        
        /* Get the number of columns in the query */
        OCIAttrGet(stmthpToQuery_, OCI_HTYPE_STMT, &numColls_,
        0, OCI_ATTR_PARAM_COUNT, connection_->errhp_);
        
        return (numColls_-(colBlobName_.size()));
}

int TeOCICursor::numRows

(

void

)

Definition at line 753 of file TeOCICursor.cpp.

References connection_, dvoid, TeOCIConnection::errhp_, OCI_ATTR_ROW_COUNT, OCI_HTYPE_STMT, SDO_OCIAttrGet(), and stmthpToQuery_.

{
        int numrows_ = 0;
        
        /* Get the number of rows in the query */
        SDO_OCIAttrGet((dvoid*)stmthpToQuery_, (ub4)OCI_HTYPE_STMT, (dvoid*)&numrows_,
        (ub4*)0, (ub4)OCI_ATTR_ROW_COUNT, (OCIError*)connection_->errhp_);
        return (numrows_);

}

bool TeOCICursor::open

(

)

Definition at line 145 of file TeOCICursor.cpp.

References close(), connection_, dschp_, dvoid, TeOCIConnection::envhp_, TeOCIConnection::errhp_, isOpen_, NULL, OCI_DURATION_SESSION, OCI_HTYPE_DESCRIBE, OCI_HTYPE_STMT, OCI_SUCCESS, OCI_SUCCESS_WITH_INFO, OCI_TYPECODE_VARRAY, ordinates_, SDO_OCIHandleAlloc(), SDO_OCIHandleFree(), SDO_OCIObjectNew(), stmthpToQuery_, TeOCIConnection::svchp_, TeOCIConnection::tdo_ordinates_, TRUE, and TeOCIConnection::useSDOType().

Referenced by TeOCIOraclePortal::query(), query(), TeOracleSpatialPortal::querySDO(), and querySDO().

{
        if(!connection_)
                return false;

        sword status;
        if(isOpen_)
                this->close();
        isOpen_ = false;

        // Initialize statement handle 
        status = SDO_OCIHandleAlloc((dvoid*)connection_->envhp_, (dvoid**)&stmthpToQuery_, 
                                                                  (ub4)OCI_HTYPE_STMT, (size_t)0, (dvoid**)0);
        if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                return false;
        
        // describe spatial object types (OCIDescribe)
        status = SDO_OCIHandleAlloc((dvoid*)connection_->envhp_, (dvoid**)&dschp_, 
                                                                (ub4)OCI_HTYPE_DESCRIBE, (size_t)0, (dvoid **)0);
        if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
        {
                //free stmthpToQuery_ located previously
                SDO_OCIHandleFree((dvoid *)stmthpToQuery_, (ub4)OCI_HTYPE_STMT);
                return false;
        }

        if(connection_->useSDOType())
        {
                status = SDO_OCIObjectNew(connection_->envhp_, connection_->errhp_, connection_->svchp_, OCI_TYPECODE_VARRAY, 
                                        connection_->tdo_ordinates_, (dvoid*)NULL, OCI_DURATION_SESSION, TRUE, 
                                        (dvoid**)&ordinates_);

                if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                {
                        //free dschp_ located previously
                        SDO_OCIHandleFree((dvoid*)dschp_, (ub4)OCI_HTYPE_DESCRIBE);
                        //free stmthpToQuery_ located previously
                        SDO_OCIHandleFree((dvoid *)stmthpToQuery_, (ub4)OCI_HTYPE_STMT);
            return false;
                }
        }
        isOpen_ = true;
        return true;
}

bool TeOCICursor::prepare

(

const string &

stmt

)

Definition at line 587 of file TeOCICursor.cpp.

References connection_, TeOCIConnection::errhp_, OCI_DEFAULT, OCI_NTV_SYNTAX, OCI_SUCCESS, OCI_SUCCESS_WITH_INFO, SDO_OCIStmtPrepare(), stmthpToQuery_, and TeOCIConnection::svchp_.

Referenced by query(), and querySDO().

{       
        ub4 size = stmt.size();
        sword status = SDO_OCIStmtPrepare(connection_->svchp_, (OCIStmt *)stmthpToQuery_, connection_->errhp_, (text*)stmt.c_str(), (ub4)size,  
                (text*)0, (ub4)0, (ub4)OCI_NTV_SYNTAX, (ub4)OCI_DEFAULT);
        if((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                return false;

        return true;
}

bool TeOCICursor::query

(

const string &

query

)

Definition at line 610 of file TeOCICursor.cpp.

References allocateCursor(), checkError(), colBlobName_, colName_, colType_, connection_, TeOCIConnection::errhp_, freeResult(), getSQLToLoadBlobLength(), hasBlob_, isOpen_, last_Row_, loadCollDescription(), maxRows_, NULL, OCI_DEFAULT, OCI_STMT_SCROLLABLE_READONLY, OCI_SUCCESS, OCI_SUCCESS_WITH_INFO, OCIStmtExecute(), open(), prepare(), queryType(), row_Cur_, row_Index_, rows_Fetched_, rows_Mem_, stmthpToQuery_, and TeOCIConnection::svchp_.

Referenced by TeOCIOraclePortal::query().

{
        if (!isOpen_)
                open();
                        
        row_Index_ = -1;
        rows_Fetched_ = 0;
        rows_Mem_ = 0;
        row_Cur_ = -1;
        last_Row_ = false;

        if(!prepare(query))
                return false;   
        
        // query type equal to 1 = OCI_STMT_SELECT
        if(queryType()!=1) 
                return false;
                
         //iters equal to zero because the defines_ (OCIDefines) have not located yet 
        sword status = OCIStmtExecute(connection_->svchp_, stmthpToQuery_, connection_->errhp_, (ub4)0, (ub4)0, (OCISnapshot *)NULL, 
                                                                  (OCISnapshot *)NULL, OCI_STMT_SCROLLABLE_READONLY);
        checkError(status);
        if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                return false;

        loadCollDescription(); // load columns description
        
        if(hasBlob_)
        {
                vector<string> auxBlobColls;
                string sql ="";
                for(unsigned int blobIndex=0; blobIndex<colType_.size(); ++blobIndex)
                {
                        if(colType_[blobIndex]==113) //blob type
                                auxBlobColls.push_back(colName_[blobIndex]);
                }
                
                if(!auxBlobColls.empty())
                        sql = getSQLToLoadBlobLength(query, auxBlobColls);

                freeResult();
                colBlobName_ = auxBlobColls;

                maxRows_ = 10; //get only 10 rows from server when there is blob type.
                
                if(!prepare(sql))
                        return false;
                
                // Is is not possible use the scrollable cursor with blob data type
                status = OCIStmtExecute(connection_->svchp_, stmthpToQuery_, connection_->errhp_, (ub4)0, (ub4)0, (OCISnapshot *)NULL, 
                                                                  (OCISnapshot *)NULL, OCI_DEFAULT);
                if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                        return false;

                loadCollDescription(); // to get the new attribute in SQL
        }

        if(!allocateCursor())
                return false;
        return true; 
}

bool TeOCICursor::querySDO

(

const string &

query

)

Definition at line 673 of file TeOCICursor.cpp.

References allocateCursor(), bindOrdinates(), colBlobName_, colName_, colType_, connection_, TeOCIConnection::errhp_, freeResult(), getSQLToLoadBlobLength(), hasBlob_, isOpen_, last_Row_, loadCollDescription(), maxRows_, NULL, OCI_DEFAULT, OCI_STMT_SCROLLABLE_READONLY, OCI_SUCCESS, OCI_SUCCESS_WITH_INFO, OCIStmtExecute(), open(), prepare(), queryType(), row_Cur_, row_Index_, rows_Fetched_, rows_Mem_, stmthpToQuery_, and TeOCIConnection::svchp_.

Referenced by TeOracleSpatialPortal::querySDO().

{
        if (!isOpen_)
                open();

        row_Index_ = -1;
        rows_Fetched_ = 0;
        rows_Mem_ = 0;
        row_Cur_ = -1;
        last_Row_ = false;

        if(!prepare(query))
                return false;

        if(!bindOrdinates())
                return false;   

        // query type equal to 1 = OCI_STMT_SELECT
        if (queryType() != 1) //must be executed by TeOCIConnect->execute()
                return false;
                
        //iters equal to zero because the defines_ (OCIDefines) have not located yet 
        sword status = OCIStmtExecute(connection_->svchp_, stmthpToQuery_, connection_->errhp_, (ub4)0, (ub4)0, (OCISnapshot *)NULL, 
                                                                  (OCISnapshot *)NULL, OCI_STMT_SCROLLABLE_READONLY);
        
        if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                return false;
        
        loadCollDescription(); // load columns description

        if(hasBlob_)
        {
                vector<string> auxBlobColls;
                string sql ="";
                for(unsigned int blobIndex=0; blobIndex<colType_.size(); ++blobIndex)
                {
                        if(colType_[blobIndex]==113) //blob type
                                auxBlobColls.push_back(colName_[blobIndex]);
                }
                
                if(!auxBlobColls.empty())
                        sql = getSQLToLoadBlobLength(query, auxBlobColls);

                freeResult();
                colBlobName_ = auxBlobColls;

                maxRows_ = 10; //get only 10 rows from server when there is blob type.

                if(!prepare(sql))
                        return false;
                
                // Is is not possible use the scrollable cursor with blob data type
                status = OCIStmtExecute(connection_->svchp_, stmthpToQuery_, connection_->errhp_, (ub4)0, (ub4)0, (OCISnapshot *)NULL, 
                                                                  (OCISnapshot *)NULL, OCI_DEFAULT);
                if ((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                        return false;

                loadCollDescription(); // to get the new attribute in SQL
        }

        if(!allocateCursor())
                return false;

        return true; 
}

int TeOCICursor::queryType

(

void

)

Definition at line 599 of file TeOCICursor.cpp.

References connection_, dvoid, TeOCIConnection::errhp_, NULL, OCI_ATTR_STMT_TYPE, OCI_HTYPE_STMT, OCI_SUCCESS, OCI_SUCCESS_WITH_INFO, OCIAttrGet(), and stmthpToQuery_.

Referenced by query(), and querySDO().

{       
        ub2 querytype_;
                
        sword status = OCIAttrGet((dvoid *)stmthpToQuery_, (ub4)OCI_HTYPE_STMT, (ub2 *)&querytype_,
        (ub4*)NULL, (ub4)OCI_ATTR_STMT_TYPE, (OCIError *)connection_->errhp_);
        if((status != OCI_SUCCESS) && (status!=OCI_SUCCESS_WITH_INFO))
                return -1;
        return (querytype_);
}

bool TeOCICursor::readBlob

(

double **

buffer

)

Definition at line 1359 of file TeOCICursor.cpp.

References lobBuffer_, maxBuflen_, and row_Index_.

{
        *buffer = (double*)&(lobBuffer_[0][row_Index_*maxBuflen_]);
        return true;
}

bool TeOCICursor::readBlob	(	double *	buffer,
		unsigned int &	bufsize
	)

Definition at line 1349 of file TeOCICursor.cpp.

References lobBuffer_, maxBuflen_, memcpy(), and row_Index_.

{
        //bufsize em double
        //size em bytes
        int size = bufsize*sizeof(double);
        memcpy(buffer,&(lobBuffer_[0][row_Index_*maxBuflen_]),size);
        return true;
}

bool TeOCICursor::readBlob	(	unsigned char *	buffer,
		unsigned int &	bufsize,
		const string &	blobCol
	)

Definition at line 1318 of file TeOCICursor.cpp.

References colBlobName_, getFieldValue(), lobBuffer_, maxBuflen_, memcpy(), numColls_, row_Index_, and TeStringCompare().

{
        int blobIndex = -1;
        if(colBlobName_.size()==1)
                blobIndex=0;
        else
        {
                for(unsigned int j=0; j<colBlobName_.size(); j++)
                {
                        if(TeStringCompare(blobCol, colBlobName_[j]))
                        {
                                blobIndex = j;
                                break;
                        }
                }
        }

        if(blobIndex<0)
                return false;

        int index = numColls_-(colBlobName_.size()-(blobIndex+1)); 
        
        //bufsize em bytes
        bufsize = atoi(getFieldValue(index))*sizeof(unsigned char);
        //buffer = new unsigned char[bufsize];
        memcpy(buffer,&(lobBuffer_[blobIndex][row_Index_*maxBuflen_]),bufsize);
        return true;
}

bool TeOCICursor::readBlob	(	unsigned char *	buffer,
		unsigned int &	bufsize,
		unsigned int &	blobCol
	)

Definition at line 1311 of file TeOCICursor.cpp.

References colName_.

Referenced by TeOCIOraclePortal::getBlob(), and TeOCIOraclePortal::getLinearRing().

{
        string blobColS = colName_[blobCol];
        return(readBlob(buffer, bufsize, blobColS));
}

---

Field Documentation

vector<void *> TeOCICursor::buffers_ [protected]

Definition at line 126 of file TeOCICursor.h.

Referenced by allocateCursor(), freeResult(), and getFieldValue().

vector<string> TeOCICursor::colBlobName_ [protected]

Definition at line 161 of file TeOCICursor.h.

Referenced by freeResult(), getBlobSize(), numCol(), query(), querySDO(), readBlob(), and TeOCICursor().

vector<string> TeOCICursor::colName_ [protected]

Definition at line 157 of file TeOCICursor.h.

Referenced by colName(), freeResult(), loadCollDescription(), query(), querySDO(), and readBlob().

vector<int> TeOCICursor::colScale_ [protected]

Definition at line 160 of file TeOCICursor.h.

Referenced by allocateCursor(), colScale(), freeResult(), and loadCollDescription().

vector<int> TeOCICursor::colSize_ [protected]

Definition at line 159 of file TeOCICursor.h.

Referenced by allocateCursor(), colSize(), freeResult(), getFieldValue(), and loadCollDescription().

vector<int> TeOCICursor::colType_ [protected]

Definition at line 158 of file TeOCICursor.h.

Referenced by allocateCursor(), colType(), freeResult(), getFieldValue(), loadCollDescription(), query(), and querySDO().

TeOCIConnection* TeOCICursor::connection_ [protected]

Definition at line 117 of file TeOCICursor.h.

Referenced by allocateCursor(), appendOrdinates(), bindOrdinates(), checkError(), defineByPos(), fetch(), freeResult(), getCoordinates(), getDimArraySize(), getDimElement(), getFieldValue(), getGeometryType(), getNumberOrdinates(), getSpatialReferenceId(), getXYZcoord(), loadCollDescription(), moveFirst(), moveLast(), moveNext(), moveTo(), numCol(), numRows(), open(), prepare(), query(), querySDO(), queryType(), and TeOCICursor().

vector<OCIDefine *> TeOCICursor::defines_ [protected]

OCIDefine objects to link buffers in client side and the statement handle

Definition at line 137 of file TeOCICursor.h.

Referenced by allocateCursor(), and freeResult().

OCIDescribe* TeOCICursor::dschp_ [protected]

Definition at line 119 of file TeOCICursor.h.

Referenced by close(), open(), and TeOCICursor().

string TeOCICursor::errorMessage_ [protected]

Definition at line 121 of file TeOCICursor.h.

Referenced by checkError(), and TeOCICursor().

string TeOCICursor::fieldValue_ [protected]

Definition at line 141 of file TeOCICursor.h.

Referenced by getFieldValue(), and TeOCICursor().

SDO_GEOMETRY_ind* TeOCICursor::global_geom_ind_[MAX_ROWS] [protected]

Definition at line 130 of file TeOCICursor.h.

Referenced by allocateCursor(), freeResult(), getXYZcoord(), and TeOCICursor().

SDO_GEOMETRY_TYPE* TeOCICursor::global_geom_obj_[MAX_ROWS] [protected]

Definition at line 129 of file TeOCICursor.h.

Referenced by allocateCursor(), freeResult(), getCoordinates(), getDimArraySize(), getDimElement(), getGeometryType(), getNumberOrdinates(), getSpatialReferenceId(), getXYZcoord(), and TeOCICursor().

bool TeOCICursor::hasBlob_ [protected]

Definition at line 133 of file TeOCICursor.h.

Referenced by allocateCursor(), freeResult(), loadCollDescription(), moveFirst(), moveTo(), query(), querySDO(), and TeOCICursor().

vector<indarray> TeOCICursor::ind_ [protected]

Definition at line 127 of file TeOCICursor.h.

Referenced by allocateCursor(), freeResult(), and getFieldValue().

bool TeOCICursor::isOpen_ [protected]

Definition at line 120 of file TeOCICursor.h.

Referenced by close(), open(), query(), querySDO(), and TeOCICursor().

bool TeOCICursor::last_Row_ [protected]

Definition at line 150 of file TeOCICursor.h.

Referenced by moveFirst(), moveLast(), moveNext(), moveTo(), query(), querySDO(), and TeOCICursor().

vector<unsigned char*> TeOCICursor::lobBuffer_ [protected]

Definition at line 132 of file TeOCICursor.h.

Referenced by allocateCursor(), freeResult(), and readBlob().

unsigned long TeOCICursor::maxBuflen_ [protected]

Definition at line 134 of file TeOCICursor.h.

Referenced by allocateCursor(), readBlob(), and TeOCICursor().

int TeOCICursor::maxRows_ [protected]

Definition at line 135 of file TeOCICursor.h.

Referenced by allocateCursor(), freeResult(), moveFirst(), moveNext(), moveTo(), query(), querySDO(), and TeOCICursor().

int TeOCICursor::numColls_ [protected]

Definition at line 156 of file TeOCICursor.h.

Referenced by allocateCursor(), close(), freeResult(), getBlobSize(), loadCollDescription(), numCol(), readBlob(), and TeOCICursor().

OCIArray* TeOCICursor::ordinates_ [protected]

Definition at line 138 of file TeOCICursor.h.

Referenced by appendOrdinates(), bindOrdinates(), freeResult(), open(), and TeOCICursor().

int TeOCICursor::row_Cur_ [protected]

Definition at line 147 of file TeOCICursor.h.

Referenced by moveFirst(), moveNext(), moveTo(), query(), querySDO(), and TeOCICursor().

short TeOCICursor::row_Index_ [protected]

Definition at line 146 of file TeOCICursor.h.

Referenced by getCoordinates(), getDimArraySize(), getDimElement(), getFieldValue(), getGeometryType(), getNumberOrdinates(), getSpatialReferenceId(), getXYZcoord(), moveFirst(), moveNext(), moveTo(), query(), querySDO(), readBlob(), and TeOCICursor().

int TeOCICursor::rows_Fetched_ [protected]

Definition at line 148 of file TeOCICursor.h.

Referenced by moveFirst(), moveNext(), moveTo(), query(), querySDO(), and TeOCICursor().

int TeOCICursor::rows_Mem_ [protected]

Definition at line 149 of file TeOCICursor.h.

Referenced by moveFirst(), moveNext(), query(), querySDO(), and TeOCICursor().

OCIStmt* TeOCICursor::stmthpToQuery_ [protected]

Definition at line 118 of file TeOCICursor.h.

Referenced by allocateCursor(), bindOrdinates(), close(), defineByPos(), fetch(), loadCollDescription(), moveFirst(), moveLast(), moveNext(), moveTo(), numCol(), numRows(), open(), prepare(), query(), querySDO(), queryType(), and TeOCICursor().

---

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

• TeOCICursor.h
• TeOCICursor.cpp

---