source/dbms.oracle/InputBind.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 <oci.h>
  10
  11 #include <time.h>
  12
  13 #include <anna/config/defines.hpp>
  14 #include <anna/core/functions.hpp>
  15 #include <anna/core/DataBlock.hpp>
  16 #include <anna/core/tracing/Logger.hpp>
  17
  18 #include <anna/dbms/Float.hpp>
  19 #include <anna/dbms/ShortBlock.hpp>
  20 #include <anna/dbms/Date.hpp>
  21 #include <anna/dbms/TimeStamp.hpp>
  22 #include <anna/dbms/Database.hpp>
  23
  24 #include <anna/dbms.oracle/oracle.hpp>
  25
  26 using namespace std;
  27 using namespace anna;
  28
  29 InputBind::InputBind(const char* name, dbms::Data&  data) :
  30   dbms::InputBind(name, data),
  31   BaseBind(data),
  32   a_ociBind(NULL) {
  33 }
  34
  35 InputBind::~InputBind() {
  36 }
  37
  38 // Slo se invoca una vez. Establece las variables atrav� de las que nos vamos a poder
  39 // comunicar con Oracle, para indicar la longitud de una variable, o su estado de nulo o
  40 // no nulo.
  41 void InputBind::prepare(dbms::Statement* dbmsStatement, dbms::Connection* connection, const int pos)
  42 throw(RuntimeException, dbms::DatabaseException) {
  43   if(a_ociBind != NULL)
  44     return;
  45
  46   Data& data = anna::dbms::Bind::getData();
  47
  48   if(data.getType() == Data::Type::LongBlock) {
  49     string msg("anna::dbms::oracle::InputBind::prepare | ");
  50     msg += data.asString();
  51     msg += " | This RDBMS doesn't support BLOB type as BindInput (see anna::dbms::OutputBind::write)";
  52     throw RuntimeException(msg, ANNA_FILE_LOCATION);
  53   }
  54
  55   Database& database = static_cast <Database&>(dbmsStatement->getDatabase());
  56   OCIError* error = database.getErrorHandler();
  57   Statement* statement(static_cast <Statement*>(dbmsStatement));
  58   oci_param ociparam = getOCIParam(database, static_cast <oracle::Connection*>(connection), data);
  59
  60   if(data.isNulleable() == false) {
  61     anna_dbms_oracle_check(
  62       OCIBindByPos(
  63         *statement, &a_ociBind, error, pos, ociparam.buffer, ociparam.maxLength, ociparam.type,
  64         0, ociparam.length, 0, 0, 0, OCI_DEFAULT
  65       ),
  66       error
  67     );
  68   } else {
  69     anna_dbms_oracle_check(
  70       OCIBindByPos(
  71         *statement, &a_ociBind, error, pos, ociparam.buffer, ociparam.maxLength, ociparam.type,
  72         &a_nullIndicator, ociparam.length, 0, 0, 0, OCI_DEFAULT
  73       ),
  74       error
  75     );
  76   }
  77
  78   LOGDEBUG(
  79     std::string msg("anna::dbms::oracle::InputBind::prepare | ");
  80     msg += asString();
  81     msg += " | Sentence: ";
  82     msg += statement->getName();
  83     msg += " | Position: ";
  84     msg += functions::asString(pos);
  85     Logger::debug(msg, ANNA_FILE_LOCATION)
  86   );
  87 }
  88
  89 //-------------------------------------------------------------------------------
  90 // Establece la informacin mediante la que conectamos con Oracle. Todos los
  91 // par�etros que modificamos en �te m�odo tienen efecto en la llamada a Oracle
  92 // debido cmo hemos invocamo al m�odo OCIBindByPos.
  93 //
  94 // Todo esto se podr� haber hecho en la anna::dbms::DataBlock pero exigir�
  95 // definir una clase distinta para cada RDBMS. Creo que los Binds particulares de
  96 // cada base de datos se ocupen toda la complejidad de convertir los datos.
  97 //-------------------------------------------------------------------------------
  98 void InputBind::code() const
  99 throw(RuntimeException) {
 100   InputBind* _this = const_cast <InputBind*>(this);
 101   Data& data = _this->getData();
 102
 103   if((_this->a_nullIndicator = data.isNull() ? -1 : 0) == -1)
 104     return;
 105
 106   switch(data.getType())  {
 107   case Data::Type::Float:
 108     codeFloat(data);
 109     break;
 110   case Data::Type::ShortBlock:
 111     codeShortBlock(data);
 112     break;
 113   case Data::Type::Date:
 114   case Data::Type::TimeStamp:
 115
 116     try {
 117       codeDate(data);
 118     } catch(DatabaseException& edb) {
 119       throw RuntimeException(edb);
 120     }
 121
 122     break;
 123   }
 124 }
 125
 126 /**
 127  * Transfiere el valor numerico del float, al buffer reservado para
 128  * ubiucarlo como una cadena. Ã\89ste buffer es el que está "conectado" con
 129  * Oracle (tm).
 130  */
 131 void InputBind::codeFloat(dbms::Data& data) const
 132 throw() {
 133   dbms::Float& _float = static_cast <dbms::Float&>(data);
 134   InputBind* _this = const_cast <InputBind*>(this);
 135   char* buffer = (char*) _this->a_ofb->getData();
 136   snprintf(buffer, FloatSize, _float.getFormat(), _float.getValue());
 137   const char decimalPoint = oracle::Database::getDecimalPoint();
 138
 139   if(decimalPoint != 0) {
 140     char* point = anna_strchr(buffer, '.');
 141
 142     if(point != NULL)
 143       *point = decimalPoint;
 144   }
 145 }
 146
 147 void InputBind::codeShortBlock(dbms::Data& data) const
 148 throw() {
 149   const int length = static_cast <dbms::ShortBlock&>(data).getSize();
 150   InputBind* _this = const_cast <InputBind*>(this);
 151
 152   if(length == 0) {
 153     _this->a_ofb->clear();
 154     _this->a_length = 0;
 155     return;
 156   }
 157
 158   const char* src = (const char*) data.getBuffer();
 159
 160   char* dest = const_cast <char*>(a_ofb->getData());
 161
 162   int j = 0;
 163
 164   for(int i = 0; i < length; i ++) {
 165     dest [j ++] = asCharacter((src [i] & 0xf0) >> 4);
 166     dest [j ++] = asCharacter(src [i] & 0x0f);
 167   }
 168
 169   dest [j ++] = 0;
 170   _this->a_length = j;
 171 }
 172
 173 void InputBind::codeDate(dbms::Data& data) const
 174 throw(RuntimeException, dbms::DatabaseException) {
 175   dbms::Date& date = static_cast <dbms::Date&>(data);
 176   ub4 fsec(0);
 177
 178   if(data.getType() == Data::Type::TimeStamp)
 179     fsec = static_cast <dbms::TimeStamp&>(data).getFractionalSecond() * 1000;
 180
 181   anna_dbms_oracle_check(
 182     OCIDateTimeConstruct(
 183       a_datetime.env, a_datetime.error, a_datetime.handle,
 184       date.getYear(), date.getMonth(), date.getDay(), date.getHour(), date.getMinute(), date.getSecond(), fsec, NULL, 0
 185     ),
 186     a_datetime.error
 187   );
 188   ub4 errorMask(0);
 189   anna_dbms_oracle_check(
 190     OCIDateTimeCheck(a_datetime.env, a_datetime.error, a_datetime.handle, &errorMask),
 191     a_datetime.error
 192   );
 193
 194   if(errorMask != 0) {
 195     string msg(data.asString());
 196     msg += anna::functions::asHexText(" | Invalid date | ErrorCode: ", (int) errorMask);
 197     throw RuntimeException(msg, ANNA_FILE_LOCATION);
 198   }
 199 }