---

cOracleConnection.cpp

Go to the documentation of this file.

/******************************************************************************/
/*                                                                            */
/* POLiTe - Persistent Object Library Test                                    */
/*                                        Ph.D. Thesis by Mgr. Michal Kopecky */
/*                                                                            */
/* Charles University Prague                                                  */
/*                                                                            */
/******************************************************************************/
/*                                                                            */
/* File name: ...                                                             */
/* Module: ......                                                             */
/*                                                                            */
/******************************************************************************/

// OCI Interface Header
#include <lOracle.h>    //OCI interface for database emulation

// Common POLiTe Header(s)
#include <lDefs.h>
#include <lTypes.h>
#include <lTrace.h>

// Own Header
#include <cOracleConnection.h>

// Other POLiTe Header(s)
#include <cOracleCursor.h>

#ifdef NO_DATABASE_PRESENT
        long _OidGenerator = 0;
        long _VersionGenerator = 0;
        // thiose variables are there temporary
        // if the database connectivity is not available
#endif

OracleConnection::OracleConnection(
        class Database *DB,
        const char *UserName,
        const char *Password,
        const int LocHandle,
        const int GlobHandle
        ): Connection(DB,UserName,Password,LocHandle,GlobHandle)
//Creates a new database connection
{
        #ifdef C_ORACLECONNECTION_TRACE
                logmsg("OracleConnection::OracleConnection() invoked");
        #endif

        int i;
        char *addr;

        addr = (char *)&_HDA;
        for (i = 0; i < HDA_SIZE; i++)
                addr[i] = '\0';
        addr = (char *)&_LDA;
        for (i = 0; i < sizeof(Lda_Def); i++)
                addr[i] = '\0';
        _DefaultCursor = new OracleCursor(this);

        #ifdef C_ORACLECONNECTION_TRACE
                logmsg("OracleConnection::OracleConnection() finished");
        #endif
};

OracleConnection::~OracleConnection()
//OracleConnection object destructor
{
        #ifdef C_ORACLECONNECTION_TRACE
                logmsg("OracleConnection::~OracleConnection() invoked and finished");
        #endif
}

bool OracleConnection::_Sql(const char * const SqlCommand)
{
        #ifdef C_ORACLECONNECTION_TRACE
                logmsg(TL_INFO_SQL,"O7DbC::_Sql(\"%s\") invoked",SqlCommand);
        #endif

        if (_DefaultCursor == NULL)
                throw ObjLibException_ConnectionError();
        _Open();
        _Prepare(SqlCommand);
        _Execute();
        _Close();
        return true;
};

bool OracleConnection::_Commit()
{
        #ifdef C_ORACLECONNECTION_TRACE
                logmsg(TL_INFO_SQL,"O7DbC::_Commit() invoked");
        #endif
        if (ocom((Lda_Def *)&_LDA))
                throw ObjLibException_ConnectionError();
        return true;
};

bool OracleConnection::_Rollback()
{
        #ifdef C_ORACLECONNECTION_TRACE
                logmsg(TL_INFO_SQL,"O7DbC::_Rollback() invoked");
        #endif
        if (orol((Lda_Def *)&_LDA))
                throw ObjLibException_ConnectionError();
        return true;
};

bool OracleConnection::_Savepoint(const char * const Name)
{
        #ifdef C_ORACLECONNECTION_TRACE
                logmsg(TL_INFO_SQL,"O7DbC::_Savepoint(\"%s\") invoked",Name);
        #endif
        char *stmt = NULL;
        StrCat(stmt,2,"SAVEPOINT ",Name);
        _Sql(stmt);
        StrFree(stmt);
        return true;
};

bool OracleConnection::_RollbackToSavepoint(const char * const Name)
{
        #ifdef C_ORACLECONNECTION_TRACE
                logmsg(TL_INFO_SQL,"O7DbC::_RollbackToSavepoint(\"%s\") invoked",Name);
        #endif
        char *stmt = NULL;
        StrCat(stmt,2,"ROLLBACK TO SAVEPOINT ",Name);
        _Sql(stmt);
        StrFree(stmt);
        return true;
};

bool OracleConnection::Sql(const char * const SqlCommand)
{
        #ifdef C_ORACLECONNECTION_TRACE
                logmsg("OracleConnection::Sql(\"%s\") invoked", SqlCommand);
        #endif
        return Connection::Sql(SqlCommand);
};

bool OracleConnection::Commit()
//Commit database, after storing modified objects
{
        #ifdef C_ORACLECONNECTION_TRACE
                logmsg("OracleConnection::Commit() invoked");
        #endif
        return(Connection::Commit());
};

bool OracleConnection::Rollback()
//Rollback database, then destroy all copies in memory
{
        #ifdef C_ORACLECONNECTION_TRACE
                logmsg("OracleConnection::Rollback() invoked");
        #endif
        return(Connection::Rollback());
};

bool OracleConnection::Savepoint(const char * const Name)
//Create savepoint, after storing all modified objects
{
        #ifdef C_ORACLECONNECTION_TRACE
                logmsg("OracleConnection::Savepoint(\"%s\") invoked",Name);
        #endif
        return(Connection::Savepoint(Name));
};

bool OracleConnection::RollbackToSavepoint(const char * const Name)
//Rollback to savepoint, then destroy all data in memory
{
        #ifdef C_ORACLECONNECTION_TRACE
                logmsg("OracleConnection::RollbackToSavepoint(\"%s\") invoked",Name);
        #endif
        return(Connection::RollbackToSavepoint(Name));
};

bool OracleConnection::Disconnect()
//Commit work and disconnect from database
{
        int oci_ret; //return value of the OCI call

        #ifdef C_ORACLECONNECTION_TRACE
                logmsg("OracleConnection::Disconnect() invoked");
        #endif
        if (!Commit())
                return(false);
        //Commit work release
        oci_ret = ologof((Lda_Def *)&_LDA);
        if (oci_ret) {
                #ifdef C_ORACLECONNECTION_TRACE
                        logmsg(TL_ERROR,"Disconnect(): ologof returns %d", oci_ret);
                #endif
                throw ObjLibException_ConnectionError();
        };
        return(Connection::Disconnect());
};

bool OracleConnection::Abort()
//Rollback work and disconnect from database
{
        int oci_ret; //return value of the OCI call

        #ifdef C_ORACLECONNECTION_TRACE
                logmsg("OracleConnection::Abort() invoked");
        #endif
        if (!Rollback())
                return(false);
        //Rollback work release
        oci_ret = ologof((Lda_Def *)&_LDA);
        if (oci_ret) {
                #ifdef C_ORACLECONNECTION_TRACE
                        logmsg(TL_ERROR,"Abort(): ologof returns %d", oci_ret);
                #endif
                throw ObjLibException_ConnectionError();
    };
        return(Connection::Abort());
};

bool OracleConnection::Autocommit(bool ac)
{
        int oci_ret; //return value of the OCI call
        #ifdef C_ORACLECONNECTION_TRACE
                logmsg("bool OracleConnection::Autocommit(bool) invoked");
        #endif
        if (ac)
                oci_ret = ocon((Lda_Def *)&_LDA);
        else
                oci_ret = ocof((Lda_Def *)&_LDA);
        if (oci_ret)
        {
                #ifdef C_ORACLECONNECTION_TRACE
                        logmsg(TL_ERROR,"Autocommit(): ocon/ocof returns %d", oci_ret);
                #endif
                throw ObjLibException_ConnectionError();
    };
        return true;
};

//Obtaining of the new cursor
Cursor *OracleConnection::_GetNewCursor()
{
        Cursor *_retval = new OracleCursor(this);
        if (_retval == NULL)
                throw ObjLibException_NoMemory();
        return _retval;
};


bool OracleConnection::_NextOID(long int &nxtoid, long int &nxtsn)
// generates new OID and Serial Number for new object
{
        bool retval;

        retval = _Open();
        retval = retval && _Prepare(
                "SELECT OID_GENERATOR.NEXTVAL, VERSION_GENERATOR.NEXTVAL FROM DUAL"
                // VERSION_GENERATOR is a DB SEQUENCE
                );
        retval = retval && _Execute();
        retval = retval && _PreFetchBind(1,&nxtoid,sizeof(long int),'l');
        retval = retval && _PreFetchBind(2,&nxtsn,sizeof(long int),'l');
        retval = retval && _FetchNext();
        retval = retval && _Close();
        #ifdef NO_DATABASE_PRESENT
                nxtsn = ++_VersionGenerator;
        #endif // NO_DATABASE_PRESENT
        return retval;
};

bool OracleConnection::_NextSN(long int curoid, long int &nxtsn)
// generates new Serial Number for object
{
        bool retval;

        retval = _Open();
        retval = retval && _Prepare(
                "SELECT VERSION_GENERATOR.NEXTVAL FROM DUAL"
                // VERSION_GENERATOR is a DB SEQUENCE
                );
        retval = retval && _Execute();
        retval = retval && _PreFetchBind(1,&nxtsn,sizeof(long int),'l');
        retval = retval && _FetchNext();
        retval = retval && _Close();
        #ifdef NO_DATABASE_PRESENT
                nxtsn = ++_VersionGenerator;
        #endif // NO_DATABASE_PRESENT
        return retval;
};

---