+++ /dev/null
-// ANNA - Anna is Not Nothingness Anymore //
-// //
-// (c) Copyright 2005-2015 Eduardo Ramos Testillano & Francisco Ruiz Rayo //
-// //
-// See project site at http://redmine.teslayout.com/projects/anna-suite //
-// See accompanying file LICENSE or copy at http://www.teslayout.com/projects/public/anna.LICENSE //
-
-
-#include <oci.h>
-
-#include <anna/core/tracing/Logger.hpp>
-#include <anna/core/tracing/TraceMethod.hpp>
-#include <anna/core/functions.hpp>
-
-#include <anna/dbms.oracle/Database.hpp>
-#include <anna/dbms.oracle/Connection.hpp>
-#include <anna/dbms.oracle/ResultCode.hpp>
-
-using namespace std;
-using namespace anna;
-using namespace anna::dbms;
-
-oracle::Connection::Connection(Database& database, const std::string& name, const char* user, const char* password) :
- dbms::Connection(database, name, user, password),
- a_context(NULL),
- a_session(NULL),
- a_server(NULL),
- a_oracleDatabase(database) {
-}
-
-void oracle::Connection::open()
-throw(dbms::DatabaseException) {
- OCIError* error = a_oracleDatabase.getErrorHandler();
-
- if(a_context != NULL) {
- LOGWARNING(
- string msg = asString();
- msg += " | Already established";
- Logger::warning(msg, ANNA_FILE_LOCATION);
- );
- return;
- }
-
- try {
- anna_dbms_oracle_check(OCIHandleAlloc(a_oracleDatabase, (void**) &a_context, OCI_HTYPE_SVCCTX, 0, 0), error);
- anna_dbms_oracle_check(OCIHandleAlloc(a_oracleDatabase, (void**) &a_session, OCI_HTYPE_SESSION, 0, 0), error);
- anna_dbms_oracle_check(OCIHandleAlloc(a_oracleDatabase, (void**) &a_server, OCI_HTYPE_SERVER, 0, 0), error);
- const char* dbmsName = NULL;
- int lenDBName = 0;
-
- if(a_oracleDatabase.getType() == Database::Type::Remote) {
- dbmsName = a_oracleDatabase.getName().c_str();
- lenDBName = anna_strlen(dbmsName);
- }
-
- anna_dbms_oracle_check(
- OCIServerAttach(a_server, error, (unsigned char*) dbmsName, lenDBName, OCI_DEFAULT),
- error
- );
- anna_dbms_oracle_check(OCIAttrSet(a_context, OCI_HTYPE_SVCCTX, a_server, 0, OCI_ATTR_SERVER, error), error);
- anna_dbms_oracle_check(
- OCIAttrSet(a_session, OCI_HTYPE_SESSION, (void*) a_user.c_str(), a_user.size(), OCI_ATTR_USERNAME, error),
- error
- );
- anna_dbms_oracle_check(
- OCIAttrSet(a_session, OCI_HTYPE_SESSION, (void*) a_password.c_str(), a_password.size(), OCI_ATTR_PASSWORD, error),
- error
- );
- anna_dbms_oracle_check(OCISessionBegin(a_context, error, a_session, OCI_CRED_RDBMS, OCI_DEFAULT), error);
- anna_dbms_oracle_check(OCIAttrSet(a_context, OCI_HTYPE_SVCCTX, a_session, 0, OCI_ATTR_SESSION, error), error);
- LOGINFORMATION(
- string msg("anna::dbms::oracle::Connection::open | ");
- msg += asString();
- Logger::information(msg, ANNA_FILE_LOCATION);
- );
- } catch(DatabaseException& edbms) {
- close();
- throw;
- }
-}
-
-void oracle::Connection::close()
-throw() {
- OCIError* error = a_oracleDatabase.getErrorHandler();
-
- try {
- LOGINFORMATION(
- string msg("anna::dbms::oracle::Connection::close | ");
- msg += asString();
- Logger::information(msg, ANNA_FILE_LOCATION);
- );
-
- if(a_session != NULL && a_context != NULL) {
- OCISessionEnd(a_context, error, a_session, OCI_DEFAULT);
- a_session = NULL;
- }
-
- if(a_server != NULL) {
- OCIServerDetach(a_server, error, OCI_DEFAULT);
- OCIHandleFree(a_server, OCI_HTYPE_SERVER);
- a_server = NULL;
- }
-
- if(a_context != NULL) {
- OCIHandleFree(a_context, OCI_HTYPE_SVCCTX);
- a_context = NULL;
- }
-
- LOGINFORMATION(
- string msg("anna::dbms::oracle::Connection::close | ");
- msg += asString();
- Logger::information(msg, ANNA_FILE_LOCATION);
- );
- } catch(DatabaseException& ex) {
- ex.trace();
- }
-}
-
-void oracle::Connection::do_commit()
-throw(RuntimeException, dbms::DatabaseException) {
- OCIError* error = a_oracleDatabase.getErrorHandler();
- anna_dbms_oracle_check(OCITransCommit(a_context, error, 0), error);
-}
-
-void oracle::Connection::do_rollback()
-throw() {
- try {
- OCIError* error = a_oracleDatabase.getErrorHandler();
- anna_dbms_oracle_check(OCITransRollback(a_context, error, 0), error);
- } catch(Exception& ex) {
- ex.trace();
- }
-}
-
-string oracle::Connection::asString() const
-throw() {
- string result("dbms::oracle::Connection { ");
- result += dbms::Connection::asString();
- result += " | Context: ";
- result += (a_context == NULL) ? "(null)" : functions::asHexString(anna_ptrnumber_cast(a_context));
- result += " | Session: ";
- result += (a_session == NULL) ? "(null)" : functions::asHexString(anna_ptrnumber_cast(a_session));
- result += " | Server: ";
- result += (a_server == NULL) ? "(null)" : functions::asHexString(anna_ptrnumber_cast(a_server));
- return result += " }";
-}
-