+++ /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 <mysql/mysql.h>
-
-#include <anna/config/defines.hpp>
-#include <anna/core/tracing/TraceMethod.hpp>
-
-#include <anna/dbms.mysql/mysql.hpp>
-
-using namespace std;
-using namespace anna;
-
-dbms::mysql::Statement::~Statement() {
- if(a_mysqlStmt) {
- try {
- anna_dbms_mysql_check(mysql_stmt_close(a_mysqlStmt), a_mysqlStmt);
- } catch(DatabaseException& edb) {
- edb.trace();
- }
- }
-
- delete [] a_params;
- delete [] a_results;
-}
-
-/**
- * Según el ejemplo de: http://dev.mysql.com/doc/refman/4.1/en/mysql-stmt-fetch.html
- *
- */
-void dbms::mysql::Statement::prepare(dbms::Connection* dbmsConnection)
-throw(RuntimeException, dbms::DatabaseException) {
- LOGMETHOD(TraceMethod tm("anna::dbms::mysql::Statement", "prepare", ANNA_FILE_LOCATION));
- Connection* connection(static_cast <Connection*>(dbmsConnection));
- //Database& dbms(static_cast <Database&>(connection->getDatabase()));
- LOGDEBUG(
- string msg("anna::dbms::mysql::Statement::prepare | ");
- msg += asString();
- Logger::debug(msg, ANNA_FILE_LOCATION);
- );
-
- /*
- * Libera la información establecida anteriormente. Las sentencias se pueden reusar.
- */
- if(a_mysqlStmt != NULL) {
- anna_dbms_mysql_check(mysql_stmt_reset(a_mysqlStmt), a_mysqlStmt);
- delete [] a_params;
- delete [] a_results;
- a_params = a_results = NULL;
- } else if((a_mysqlStmt = mysql_stmt_init(*connection)) == NULL) {
- string msg(asString());
- msg += " | Insufficient memory";
- throw RuntimeException(msg, ANNA_FILE_LOCATION);
- }
-
- const char* expression = dbms::Statement::getExpression().c_str();
-
- anna_dbms_mysql_check(mysql_stmt_prepare(a_mysqlStmt, expression, anna_strlen(expression)), a_mysqlStmt);
-
- const int paramCount = mysql_stmt_param_count(a_mysqlStmt);
-
- const int inputSize = dbms::Statement::input_size();
-
- const int outputSize = dbms::Statement::output_size();
-
- /*
- * Verifica que el número de parámetros de entrada de la sentencia coincida con el número de parámetros
- * indicados por el programador.
- */
- if(paramCount != inputSize) {
- string msg(asString());
- msg += " | Wrong input parameters";
- throw RuntimeException(msg, ANNA_FILE_LOCATION);
- }
-
- /*
- * Verifica que el número de parámetros de salida de la sentencia coincida con el número de parámetros
- * indicados por el programador. Si no tiene parámetros de salida (INSERT) => no debe tener parámetros
- * indicados por el programador.
- */
- MYSQL_RES* metaResult = mysql_stmt_result_metadata(a_mysqlStmt);
-
- try {
- if(metaResult == NULL) {
- if(outputSize != 0) {
- string msg(asString());
- msg += " | Wrong output parameters";
- throw RuntimeException(msg, ANNA_FILE_LOCATION);
- }
- } else if(mysql_num_fields(metaResult) != outputSize) {
- string msg(asString());
- msg += " | Wrong output parameters";
- throw RuntimeException(msg, ANNA_FILE_LOCATION);
- }
- } catch(RuntimeException&) {
- mysql_free_result(metaResult);
- throw;
- }
-
- /*
- * Define las estructuras requeridas para asociar las columasn MySQL con las áreas de memoria C++
- */
- int pos;
-
- if((a_params = create(inputSize, "input")) != NULL) {
- pos = 0;
-
- for(input_iterator ii = input_begin(), maxii = input_end(); ii != maxii; ii ++)
- inputBind(ii)->prepare(this, dbmsConnection, pos ++);
-
- anna_dbms_mysql_check(mysql_stmt_bind_param(a_mysqlStmt, a_params), a_mysqlStmt);
- }
-
- if((a_results = create(outputSize, "output")) != NULL) {
- pos = 0;
-
- for(output_iterator oo = output_begin(), maxoo = output_end(); oo != maxoo; oo ++)
- outputBind(oo)->prepare(this, dbmsConnection, pos ++);
-
- anna_dbms_mysql_check(mysql_stmt_bind_result(a_mysqlStmt, a_results), a_mysqlStmt);
- }
-}
-
-dbms::ResultCode dbms::mysql::Statement::execute(dbms::Connection* dbmsConnection)
-throw(RuntimeException, dbms::DatabaseException) {
- //Connection* connection(static_cast <Connection*>(dbmsConnection));
-
- for(input_iterator ii = input_begin(), maxii = input_end(); ii != maxii; ii ++) {
- inputBind(ii)->code();
- LOGDEBUG(
- string msg("anna::dbms::mysql::Statement::InputBind: ");
- msg += inputBind(ii)->asString();
- Logger::debug(msg, ANNA_FILE_LOCATION);
- );
- }
-
- anna_dbms_mysql_check(mysql_stmt_execute(a_mysqlStmt), a_mysqlStmt)
- ResultCode result(a_mysqlStmt);
- return result;
-}
-
-/*
- * Según la información de http://dev.mysql.com/doc/refman/4.1/en/mysql-stmt-fetch.html
- */
-bool dbms::mysql::Statement::fetch()
-throw(RuntimeException, dbms::DatabaseException) {
- bool result = false;
-
- switch(mysql_stmt_fetch(a_mysqlStmt)) {
- case 0:
- result = true;
-
- for(output_iterator oo = output_begin(), maxoo = output_end(); oo != maxoo; oo ++) {
- outputBind(oo)->decode();
- LOGDEBUG(Logger::write(Logger::Debug, outputBind(oo)->asString(), ANNA_FILE_LOCATION));
- }
-
- break;
- case 1:
- throw DatabaseException(ResultCode(a_mysqlStmt), ANNA_FILE_LOCATION);
- default:
- result = false;
- break;
- }
-
- LOGDEBUG(
- string msg("anna::dbms::mysql::Statement::fetch | Result: ");
- msg += functions::asString(result);
- Logger::debug(msg, ANNA_FILE_LOCATION);
- );
- return result;
-}
-
-st_mysql_bind* dbms::mysql::Statement::create(const int size, const char* whatis)
-throw(RuntimeException) {
- st_mysql_bind* result = NULL;
-
- if(size > 0) {
- if((result = new st_mysql_bind [size]) == NULL) {
- string msg(asString());
- msg += anna::functions::asString("Insufficient memory to create %d parameters of %s", size, whatis);
- throw RuntimeException(msg, ANNA_FILE_LOCATION);
- }
- }
-
- return result;
-}
projects / anna.git / blobdiff