--- /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 <stdlib.h>
+#include <locale.h>
+
+#include <string>
+#include <algorithm>
+
+#include <anna/core/tracing/TraceMethod.hpp>
+
+#include <anna/xml/Node.hpp>
+#include <anna/xml/Attribute.hpp>
+
+#include <anna/comm/INetAddress.hpp>
+
+#include <anna/dbms/Database.hpp>
+#include <anna/dbms/Statement.hpp>
+#include <anna/dbms/FailRecoveryHandler.hpp>
+#include <anna/dbms/internal/sccs.hpp>
+#include <anna/dbms/Float.hpp>
+#include <anna/dbms/StatementTranslator.hpp>
+
+using namespace std;
+using namespace anna;
+using namespace anna::dbms;
+
+Database::Database(const char* className, const char* dbmsName) :
+ Component(className),
+ a_name((dbmsName == NULL) ? "local" : dbmsName),
+ a_type((dbmsName == NULL) ? Type::Local : Type::Remote),
+ a_failRecoveryHandler(NULL),
+ a_statementTranslator(NULL) {
+ dbms::sccs::activate();
+}
+
+Database::~Database() {
+ stop();
+}
+
+void Database::do_initialize()
+throw(RuntimeException) {
+ LOGMETHOD(TraceMethod tm("dbms::Database", "do_initialize", ANNA_FILE_LOCATION));
+ int counter(0);
+ bool error = false;
+
+ for(connection_iterator iic = connection_begin(), maxiic = connection_end(); iic != maxiic; iic ++) {
+ try {
+ connection(iic)->open();
+ counter ++;
+ } catch(Exception& ex) {
+ ex.trace();
+ error = true;
+ }
+ }
+
+ if(counter == 0 && error == true) {
+ string msg(asString());
+ msg += " | No available connections";
+ throw RuntimeException(msg, ANNA_FILE_LOCATION);
+ }
+
+ LOGINFORMATION(
+ Logger::information(asString(), ANNA_FILE_LOCATION);
+ );
+}
+
+void Database::do_stop()
+throw() {
+ LOGMETHOD(TraceMethod tm("dbms::Database", "do_stop", ANNA_FILE_LOCATION));
+
+ try {
+ Connection* _connection;
+
+ for(connection_iterator iic = connection_begin(), maxiic = connection_end(); iic != maxiic; iic ++) {
+ _connection = connection(iic);
+ _connection->close();
+ delete _connection;
+ }
+
+ a_connections.clear();
+ } catch(Exception& ex) {
+ ex.trace();
+ a_connections.clear();
+ }
+}
+
+/**
+ * Para evitar que todos los clones usen la misma conexion a la base de datos, se realiza en
+ * cada uno de ellos una re-conexion, es decir, se cierra la original (abierta por el proceso
+ * padre) y se abre una nueva conexion con los mismos parametros y contra la misma base de datos.
+ */
+void Database::do_cloneChild()
+throw(RuntimeException) {
+ LOGMETHOD(TraceMethod tm("dbms::Database", "do_cloneChild", ANNA_FILE_LOCATION));
+
+ for(connection_iterator ii = connection_begin(), maxii = connection_end(); ii != maxii; ii ++) {
+ dbms::Connection* conn = connection(ii);
+ LOGDEBUG(
+ string msg("dbms::Database::do_cloneChild | ");
+ msg += conn->asString();
+ Logger::debug(msg, ANNA_FILE_LOCATION);
+ );
+ recover(*conn, 0);
+ }
+}
+
+Connection* Database::createConnection(const char* name, const char* user, const char* password)
+throw(RuntimeException, DatabaseException) {
+ Guard guard(this, "dbms::Database (createConnection)");
+
+ if(a_connections.size() >= MaxConnection) {
+ string msg("Database::createConnection | ");
+ msg += asString();
+ msg += functions::asText(" | Cannot create more than %d connections per database", MaxConnection);
+ throw RuntimeException(msg, ANNA_FILE_LOCATION);
+ }
+
+ for(connection_iterator ii = connection_begin(), maxii = connection_end(); ii != maxii; ii ++) {
+ if(connection(ii)->getName() == name) {
+ string msg("Database::createConnection | ");
+ msg += asString();
+ msg += " | Connection: ";
+ msg += name;
+ msg += " | Previously registered";
+ throw RuntimeException(msg, ANNA_FILE_LOCATION);
+ }
+ }
+
+ string strname(name);
+ Connection* result = allocateConnection(strname, user, password);
+
+ if(result == NULL) {
+ string msg(asString());
+ msg += " | ";
+ msg += strname;
+ msg += " | Unable to instance connection";
+ throw RuntimeException(msg, ANNA_FILE_LOCATION);
+ }
+
+ LOGDEBUG(
+ string msg("dbms::Database::createConnection | ");
+ msg += result->asString();
+ Logger::write(Logger::Debug, msg, ANNA_FILE_LOCATION);
+ );
+
+ if(getState() == Component::State::Running) {
+ try {
+ result->open();
+ a_connections.push_back(result);
+ } catch(RuntimeException& ex) {
+ ex.trace();
+ delete result;
+ throw;
+ } catch(DatabaseException& edbms) {
+ edbms.trace();
+ delete result;
+ throw;
+ }
+ } else
+ a_connections.push_back(result);
+
+ return result;
+}
+
+Connection& Database::findConnection(const char* name)
+throw(RuntimeException) {
+ Guard guard(this, "dbms::Database (findConnection)");
+ Connection* result = NULL;
+
+ for(connection_iterator ii = connection_begin(), maxii = connection_end(); ii != maxii; ii ++) {
+ if(anna_strcmp(connection(ii)->getName().c_str(), name) == 0) {
+ result = connection(ii);
+ break;
+ }
+ }
+
+ if(result == NULL) {
+ string msg("Database::findConnection | ");
+ msg += asString();
+ msg += " | Conexion: ";
+ msg += name;
+ msg += " | Unregistered";
+ throw RuntimeException(msg, ANNA_FILE_LOCATION);
+ }
+
+ if(result->isAvailable() == false || result->isEnabled() == false) {
+ string msg("Database::findConnection | ");
+ msg += asString();
+ msg += " | Connection: ";
+ msg += name;
+ msg += " | Unavailable";
+ throw RuntimeException(msg, ANNA_FILE_LOCATION);
+ }
+
+ LOGDEBUG(
+ string msg("Database::findConnection | ");
+ msg += result->asString();
+ Logger::debug(msg, ANNA_FILE_LOCATION);
+ );
+ return *result;
+}
+
+Statement* Database::createStatement(const char* name, const char* expression, const bool isCritical)
+throw(RuntimeException) {
+ if(findStatement(name) != NULL)
+ throw RuntimeException(functions::asString("Sentence: %s | Name already in use", name), ANNA_FILE_LOCATION);
+
+ Guard guard(this, "dbms::Database::createStatement");
+
+ if(a_statementTranslator != NULL)
+ expression = a_statementTranslator->apply(expression);
+
+ Statement* result = allocateStatement(name, expression, isCritical);
+ LOGDEBUG(
+ string msg("dbms::Database::createStatement | ");
+ msg += result->asString();
+
+ if(a_statementTranslator != NULL) {
+ msg += " | Translator: ";
+ msg += a_statementTranslator->getName();
+ }
+ Logger::debug(msg, ANNA_FILE_LOCATION);
+ );
+ a_statements.push_back(result);
+ return result;
+}
+
+Statement* Database::findStatement(const char* name)
+throw() {
+ Guard guard(this, "dbms::Database::findStatement");
+ vector <Statement*>::iterator ii, maxii;
+ Statement* result(NULL);
+
+ for(ii = a_statements.begin(), maxii = a_statements.end(); ii != maxii; ii ++) {
+ if(anna_strcmp((*ii)->getName().c_str(), name) == 0) {
+ result = *ii;
+ break;
+ }
+ }
+
+ return result;
+}
+
+void Database::releaseStatement(Statement* statement)
+throw() {
+ if(statement == NULL) {
+ Logger::write(Logger::Warning, asString(), "Cannot release a NULL SQL sentence", ANNA_FILE_LOCATION);
+ return;
+ }
+
+ LOGDEBUG(
+ string msg("dbms::Database::releaseStatement | ");
+ msg += statement->asString();
+ Logger::debug(msg, ANNA_FILE_LOCATION);
+ );
+ Guard guard(this, "dbms::Database::releaseStatement");
+ vector <Statement*>::iterator end = a_statements.end();
+ vector <Statement*>::iterator ii = find(a_statements.begin(), end, statement);
+
+ if(ii != end) {
+ a_statements.erase(ii);
+ delete statement;
+ }
+}
+
+void Database::recover(Connection& connection, const int tryCounter)
+throw(RuntimeException) {
+ try {
+ connection.close();
+ connection.open();
+ } catch(DatabaseException& edbms) {
+ edbms.trace();
+
+ if(a_failRecoveryHandler != NULL)
+ a_failRecoveryHandler->apply(connection, tryCounter);
+ }
+}
+
+string Database::asString() const
+throw() {
+ string result("dbms::Database { ");
+ result += Component::asString();
+
+ if(a_type == Type::Local)
+ result += " | Type: Local";
+ else {
+ result += " | Type: Remote | Name: ";
+ result += a_name;
+ }
+
+ return result += " }";
+}
+
+xml::Node* Database::asXML(xml::Node* parent) const
+throw() {
+ parent = Component::asXML(parent);
+ xml::Node* result = parent->createChild("dbms.Database");
+ xml::Node* node;
+ result->createAttribute("Type", (a_type == Type::Local) ? "Local" : "Remote");
+
+ if(a_type != Type::Local)
+ result->createAttribute("Name", a_name);
+
+ if(a_statementTranslator != NULL)
+ result->createAttribute("Translator", a_statementTranslator->getName());
+
+ node = result-> createChild("Connections");
+
+ for(const_connection_iterator ii = connection_begin(), maxii = connection_end(); ii != maxii; ii ++)
+ connection(ii)->asXML(node);
+
+ node = result-> createChild("Statements");
+
+ for(const_statement_iterator ii = statement_begin(), maxii = statement_end(); ii != maxii; ii ++)
+ statement(ii)->asXML(node);
+
+ return result;
+}
+
projects / anna.git / blobdiff