Oracle+OCI+API封装类

/*--------------------------------------------------------------------------- @doc @module OciCursor.cpp | This module contains the <c COciCursor> class implementation. Author: Fabio Angelini Docs and test: Abbondio Vago ---------------------------------------------------------------------------*/ extern "C"{ #include <ocidem.h> #include <ociapr.h> } #include "OciClassDef.h" #include <string.h> #include <ctype.h> #include <stdarg.h> #include "OciException.h" #include "OciDatabase.h" #include "OciVariable.h" #include "OciCursor.h" /*--------------------------------------------------------------------------- @mfunc Create "cursor" object. By default, exceptions are allowed to raise. @parm Can be set to COciException::enabled (default) or COciException::disabled. ---------------------------------------------------------------------------*/ COciCursor::COciCursor( int exception_enabled ) : m_RowProceddesCount( m_Cda.rpc ), m_FunctionCode( m_Cda.ft ), m_ReturnCode( m_Cda.rc ), m_ParseErrorOffset( m_Cda.peo ) { // vl = 0; // vl_len = 0; m_pDb = NULL; m_pStmText = NULL; m_ExceptionEnabled = exception_enabled; memset( &m_Cda, 0, sizeof(m_Cda) ); } /*--------------------------------------------------------------------------- @mfunc Create "cursor" object and open cursor via "connect". @parm Database object @parm Can be set to COciException::enabled (default) or COciException::disabled. ---------------------------------------------------------------------------*/ COciCursor::COciCursor( COciDatabase& db, int exception_enabled ) : m_RowProceddesCount( m_Cda.rpc ), m_FunctionCode( m_Cda.ft ), m_ReturnCode( m_Cda.rc ), m_ParseErrorOffset( m_Cda.peo ) { // vl = 0; // vl_len = 0; m_pDb = &db; m_pStmText = NULL; m_ExceptionEnabled = exception_enabled; Open( db ); } /*--------------------------------------------------------------------------- @mfunc The destructor closes the cursor (if opened). ---------------------------------------------------------------------------*/ COciCursor::~COciCursor() { Close(); if ( m_pStmText != NULL ) { delete[] m_pStmText; m_pStmText = NULL; } } /*--------------------------------------------------------------------------- @mfunc Raise database exceptions @parm Condition to raise the exception @rdesc bCondition is returned. ---------------------------------------------------------------------------*/ BOOL COciCursor::RaiseDbException( BOOL bCondition ) { if( ( bCondition ) && ( m_ExceptionEnabled ) ) throw COciException( m_pDb->m_Lda, m_pStmText ); return bCondition; } /*--------------------------------------------------------------------------- @mfunc Raise cursor exceptions @parm Condition to raise the exception @rdesc bCondition is returned. ---------------------------------------------------------------------------*/ BOOL COciCursor::RaiseCursorException( BOOL bCondition ) { if( ( bCondition ) && ( m_ExceptionEnabled ) ) throw COciException( m_Cda, m_pStmText ); return bCondition; } /*--------------------------------------------------------------------------- @mfunc Open cursor via COciDatabase. @parm Database object @rdesc Returns TRUE on success, FALSE on failure. @devnote This funtion calls the OCI function oopen() to open the cursor. <nl> oopen(Cda_Def *cursor, Lda_Def *lda, text *dbn, sword dbnl, sword arsize, text *uid, sword uidl); ---------------------------------------------------------------------------*/ BOOL COciCursor::Open( COciDatabase& db ) { if( !db.IsConnected() ) return FALSE; m_pDb = &db; if ( m_ReturnCode != oci_blocked) memset( &m_Cda, 0, sizeof( m_Cda ) ); m_IsConnected = !oopen( &m_Cda, &db.m_Lda, 0, -1, -1, 0, -1); RaiseDbException( !m_IsConnected ); return m_IsConnected; } /*--------------------------------------------------------------------------- @mfunc Close cursor. @rdesc Returns TRUE on success, FALSE on failure. @devnote This funtion calls the OCI function oclose() to disconnect a cursor from the data areas in the Oracle Server with which it is associated. <nl> oclose(Cda_Def *cursor); ---------------------------------------------------------------------------*/ BOOL COciCursor::Close( void ) { if ( !m_IsConnected ) return FALSE; if( m_pDb ) { if( !m_pDb->IsConnected() ) { m_IsConnected = FALSE; m_pDb = NULL; return FALSE; } } int result = oclose( &m_Cda ); m_IsConnected = FALSE; m_pDb = NULL; RaiseCursorException( result ); return !result; } /*--------------------------------------------------------------------------- @mfunc Cancel a query after the desired number of rows have been fetched. @rdesc Returns TRUE on success, FALSE on failure. @devnote This funtion calls the OCI function: <nl> ocan(Cda_Def *cursor); ---------------------------------------------------------------------------*/ BOOL COciCursor::Cancel( void ) { if ( !m_IsConnected ) return FALSE; int result = ocan( &m_Cda ); RaiseCursorException( result ); return !result; } /*--------------------------------------------------------------------------- @mfunc Set rollback options for non-fatal Oracle errors. @rdesc Returns TRUE on success, FALSE on failure. @parm The action to be taken when a non-fatal Oracle error occurs. If this option is set to zero, all errors, even non-fatal errors, cause the current transaction to be rolled back. If this option is set to 2, only the failing row will be rolled back during a non-fatal row-level error. This is the default setting. <nl> NOTE: rbopt parameter is not supported in Oracle Server Version 6 or later. @parm Specifies whether to wait for resources or return with an error if they are currently not available. If this option is set to zero, the program waits indefinitely if resources are not available. This is the default action. If this option is set to 4, the program will receive an error return code whenever a resource is requested but is unavailable. Use of waitopt set to 4 can cause many error return codes while waiting for internal resources that are locked for short durations. The only resource errors received are for resources requested by the calling process. @devnote This funtion calls the OCI function oopt() to set rollback options for non-fatal Oracle errors involving multi-row INSERT and UPDATE SQL statements. It also sets wait options in cases where requested resources are not available; for example, whether to wait for locks. <nl> oopt(Cda_Def *cursor, sword rbopt, sword waitopt); ---------------------------------------------------------------------------*/ BOOL COciCursor::Option( int rbopt, int waitopt ) { if ( !m_IsConnected ) return FALSE; int result = oopt( &m_Cda, rbopt, waitopt ); RaiseCursorException( result ); return !result; } /*--------------------------------------------------------------------------- @mfunc Fetch a portion of a LONG or LONG RAW column. @rdesc Returns TRUE on success, FALSE on failure. @parm Column number: 1,2,... @parm Pointer to buffer @parm Buffer size @parm Buffer data type, see ext* "enum" @parm Retu