Normalize xml processing
[anna.git] / source / dbms.mysql / Connection.cpp
1 // ANNA - Anna is Not Nothingness Anymore                                                         //
2 //                                                                                                //
3 // (c) Copyright 2005-2015 Eduardo Ramos Testillano & Francisco Ruiz Rayo                         //
4 //                                                                                                //
5 // See project site at http://redmine.teslayout.com/projects/anna-suite                           //
6 // See accompanying file LICENSE or copy at http://www.teslayout.com/projects/public/anna.LICENSE //
7
8
9 #include <mysql/mysql.h>
10
11 #include <anna/core/tracing/Logger.hpp>
12 #include <anna/core/tracing/TraceMethod.hpp>
13 #include <anna/core/functions.hpp>
14
15 #include <anna/dbms.mysql/Database.hpp>
16 #include <anna/dbms.mysql/Connection.hpp>
17 #include <anna/dbms.mysql/ResultCode.hpp>
18
19 using namespace std;
20 using namespace anna;
21 using namespace anna::dbms;
22
23 mysql::Connection::Connection(Database& database, const std::string& name, const char* user, const char* password) :
24   dbms::Connection(database, name, user, password),
25   a_mysqlDatabase(database),
26   a_mysql(NULL) {
27 }
28
29 void mysql::Connection::open()
30 throw(dbms::DatabaseException) {
31   if(a_mysql != NULL) {
32     LOGWARNING(
33       string msg = asString();
34       msg += " | Has already been established";
35       Logger::warning(msg, ANNA_FILE_LOCATION);
36     );
37     return;
38   }
39
40   if((a_mysql = mysql_init(NULL)) == NULL)
41     RuntimeException("Cannot initiate MySQL", ANNA_FILE_LOCATION);
42
43   const char* dbmsName = (a_mysqlDatabase.getType() == Database::Type::Remote) ? a_mysqlDatabase.getName().c_str() : NULL;
44
45   try {
46     if(mysql_real_connect(a_mysql, a_mysqlDatabase.getHost(), a_user.c_str(), a_password.c_str(), dbmsName, 0, NULL, 0L) == NULL) {
47       ResultCode resultCode(a_mysql);
48       throw DatabaseException(resultCode, ANNA_FILE_LOCATION);
49     }
50
51     LOGINFORMATION(
52       string msg("anna::dbms::mysql::Connection::open | ");
53       msg += asString();
54       Logger::information(msg, ANNA_FILE_LOCATION);
55     );
56   } catch(DatabaseException& edbms) {
57     close();
58     throw;
59   }
60 }
61
62 void mysql::Connection::close()
63 throw() {
64   LOGINFORMATION(
65     string msg("anna::dbms::mysql::Connection::close | ");
66     msg += asString();
67     Logger::information(msg, ANNA_FILE_LOCATION);
68   );
69
70   if(a_mysql != NULL) {
71     mysql_close(a_mysql);
72     a_mysql = NULL;
73     LOGINFORMATION(
74       string msg("anna::dbms::mysql::Connection::close | ");
75       msg += asString();
76       Logger::information(msg, ANNA_FILE_LOCATION);
77     );
78   }
79 }
80
81 void mysql::Connection::do_commit()
82 throw(RuntimeException, dbms::DatabaseException) {
83   anna_dbms_mysql_check(mysql_commit(a_mysql), a_mysql);
84 }
85
86 void mysql::Connection::do_rollback()
87 throw() {
88   try {
89     anna_dbms_mysql_check(mysql_rollback(a_mysql), a_mysql);
90   } catch(Exception& ex) {
91     ex.trace();
92   }
93 }
94
95 string mysql::Connection::asString() const
96 throw() {
97   string result("dbms::mysql::Connection { ");
98   result += dbms::Connection::asString();
99   result += " | Context: ";
100   result += (a_mysql == NULL) ? "(null)" : functions::asHexString(anna_ptrnumber_cast(a_mysql));
101   return result += " }";
102 }
103