+++ /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 <orl.h>
-
-#include <anna/config/defines.hpp>
-#include <anna/core/tracing/Logger.hpp>
-#include <anna/core/DataBlock.hpp>
-
-#include <anna/dbms/Float.hpp>
-#include <anna/dbms/ShortBlock.hpp>
-#include <anna/dbms/LongBlock.hpp>
-#include <anna/dbms/String.hpp>
-#include <anna/dbms/Date.hpp>
-#include <anna/dbms/TimeStamp.hpp>
-
-#include <anna/dbms.oracle/oracle.hpp>
-
-using namespace anna;
-using namespace std;
-
-OutputBind::OutputBind(const char* name, dbms::Data& data) :
- dbms::OutputBind(name, data),
- BaseBind(data),
- a_ociDefine(NULL) {
-}
-
-OutputBind::~OutputBind() {
-}
-
-void OutputBind::prepare(dbms::Statement* dbmsStatement, dbms::Connection* connection, const int pos)
-throw(dbms::DatabaseException) {
- if(a_ociDefine != NULL)
- return;
-
- Database& database(static_cast <Database&>(dbmsStatement->getDatabase()));
- OCIError* error = database.getErrorHandler();
- Statement* statement(static_cast <Statement*>(dbmsStatement));
- dbms::Data& data = anna::dbms::Bind::getData();
- oci_param ociparam = getOCIParam(database, static_cast <oracle::Connection*>(connection), data);
-
- if(data.isNulleable() == false) {
- anna_dbms_oracle_check(
- OCIDefineByPos(
- *statement, &a_ociDefine, error, pos, ociparam.buffer, ociparam.maxLength, ociparam.type,
- 0, ociparam.length, 0, OCI_DEFAULT
- ),
- error
- );
- } else {
- anna_dbms_oracle_check(
- OCIDefineByPos(
- *statement, &a_ociDefine, error, pos, ociparam.buffer, ociparam.maxLength, ociparam.type,
- &a_nullIndicator, ociparam.length, 0, OCI_DEFAULT
- ),
- error
- );
- }
-
- LOGDEBUG(
- std::string msg("anna::dbms::oracle::OutputBind::prepare | ");
- msg += asString();
- msg += " | Sentence: ";
- msg += statement->getName();
- msg += " | Position: ";
- msg += functions::asString(pos);
- Logger::debug(msg, ANNA_FILE_LOCATION)
- );
-}
-
-//-------------------------------------------------------------------------------
-// Transfiere la informacin obtenida desde Oracle. Todos los comprobados en �te
-// m�odo son parametros que modificados al ejecuta la sentencia Oracle debido cmo
-// hemos invocamo al m�odo OCIDefineByPos
-//
-// Todo esto se podr� haber hecho en la anna::dbms::DataBlock pero exigir�
-// definir una clase distinta para cada RDBMS. Creo que los Binds particulares de
-// cada base de datos se ocupen toda la complejidad de convertir los datos.
-//
-// (1) Truco para fijar el contenido y la longitud actual.
-//-------------------------------------------------------------------------------
-void OutputBind::decode() const
-throw(RuntimeException) {
- OutputBind* _this = const_cast <OutputBind*>(this);
- char* str;
- Data& data = _this->getData();
- data.setNull(a_nullIndicator < 0);
-
- switch(data.getType()) {
- case Data::Type::String:
- str = (char*) data.getBuffer();
-
- if(data.isNull() == true)
- *str = 0;
- else
- dbms::String::strip(str);
-
- break;
- case Data::Type::Integer:
- throw RuntimeException("anna::dbms::oracle::OutputBind::decode not implemented for Data::Type::Integer", ANNA_FILE_LOCATION);
- break;
- case Data::Type::Float:
- decodeFloat(data);
- break;
- case Data::Type::ShortBlock:
- decodeShortBlock(data);
- break;
- case Data::Type::LongBlock:
- decodeLongBlock(data);
- break;
- case Data::Type::Date:
- case Data::Type::TimeStamp:
-
- try {
- decodeDate(data);
- } catch(DatabaseException& edb) {
- throw RuntimeException(edb);
- }
-
- break;
- }
-}
-
-void OutputBind::decodeFloat(dbms::Data& data) const
-throw(RuntimeException) {
- dbms::Float& _float = static_cast <dbms::Float&>(data);
-
- if(data.isNull() == true) {
- _float = 0.0;
- return;
- }
-
- char* _data = (char*) a_ofb->getData();
- const char decimalPoint = oracle::Database::getDecimalPoint();
-
- if(decimalPoint != 0) {
- char* point = anna_strchr(_data, decimalPoint);
-
- if(point != NULL)
- *point = '.';
- }
-
- sscanf(_data, _float.getFormat(), (float*) _float.getBuffer());
-}
-
-void OutputBind::decodeShortBlock(dbms::Data& data) const
-throw(RuntimeException) {
- const anna::DataBlock& constdbms(static_cast <dbms::ShortBlock&>(data).getValue());
- anna::DataBlock& dataBlock(const_cast <anna::DataBlock&>(constdbms));
-
- if(data.isNull() == true) {
- dataBlock.clear();
- return;
- }
-
- const char* src = a_ofb->getData();
-
- char* dest = (char*) dataBlock.getData();
-
- unsigned char hex;
-
- int j = 0;
-
- for(int i = 1; i < a_length; i += 2, j ++) {
- hex = asByte(src [i - 1]) << 4;
- hex |= asByte(src [i]);
- dest [j] = hex;
- }
-
- dataBlock.clear();
- dataBlock.allocate(j); // (1)
-}
-
-//--------------------------------------------------------------------------------------------
-// (1) Offset = 1 => primer caracter.
-//--------------------------------------------------------------------------------------------
-void OutputBind::decodeLongBlock(dbms::Data& data) const
-throw(RuntimeException) {
- const anna::DataBlock& constdbms(static_cast <dbms::LongBlock&>(data).getValue());
- anna::DataBlock& dataBlock(const_cast <anna::DataBlock&>(constdbms));
- dataBlock.clear();
-
- if(data.isNull() == true)
- return;
-
- ub1* buffer;
- ub4 maxLength;
- ub4 length;
- sword ret;
- bool stop = false;
- ub4 offset = 1; // (1)
-
- try {
- buffer = (ub1*) a_ofb->getData();
- maxLength = a_ofb->getSize();
- length = 0;
-
- do {
- ret = OCILobRead(a_blob.context, a_blob.error, a_blob.handle, &length, offset, buffer, maxLength, 0, 0, 0, SQLCS_IMPLICIT);
-
- switch(ret) {
- case OCI_SUCCESS:
- dataBlock += anna::DataBlock((const char*) buffer, length, false);
- stop = true;
- break;
- case OCI_NEED_DATA:
- dataBlock += anna::DataBlock((const char*) buffer, length, false);
- offset += length;
- break;
- default:
- throw dbms::DatabaseException(oracle::ResultCode(ret, a_blob.error), ANNA_FILE_LOCATION);
- }
- } while(stop == false);
- } catch(dbms::DatabaseException& edbms) {
- throw RuntimeException(edbms);
- }
-}
-
-void OutputBind::do_write(const dbms::LongBlock& data) const
-throw(RuntimeException, dbms::DatabaseException) {
- const anna::DataBlock& dataBlock = data.getValue();
-
- if(a_blob.handle == NULL) {
- string msg("anna::dbms::oracle::OutputBind::do_write | ");
- msg += data.asString();
- msg += " | BLOB must be loaded before modification";
- throw RuntimeException(msg, ANNA_FILE_LOCATION);
- }
-
- ub1* buffer = (ub1*) dataBlock.getData();
- ub4 length = dataBlock.getSize();
- anna_dbms_oracle_check(
- OCILobWrite(a_blob.context, a_blob.error, a_blob.handle, &length, (ub4) 1, buffer, length, OCI_ONE_PIECE, 0, 0, 0, SQLCS_IMPLICIT),
- a_blob.error
- );
-}
-
-void OutputBind::decodeDate(dbms::Data& data) const
-throw(RuntimeException, dbms::DatabaseException) {
- if(data.isNull() == true)
- return;
-
- Date& date = static_cast <Date&>(data);
- sb2 year;
- ub1 month, day;
- anna_dbms_oracle_check(
- OCIDateTimeGetDate(a_datetime.env, a_datetime.error, a_datetime.handle, &year, &month, &day),
- a_datetime.error
- );
- date.setYear(year);
- date.setMonth(month);
- date.setDay(day);
- ub1 hour, min, sec;
- ub4 fsec;
- sword status = OCIDateTimeGetTime(a_datetime.env, a_datetime.error, a_datetime.handle, &hour, &min, &sec, &fsec);
-
- if(status == OCI_SUCCESS) {
- date.setHour(hour);
- date.setMinute(min);
- date.setSecond(sec);
-
- if(data.getType() == Data::Type::TimeStamp)
- static_cast <dbms::TimeStamp&>(data).setFractionalSecond(fsec / 1000);
- } else {
- date.setHour(0);
- date.setMinute(0);
- date.setSecond(0);
-
- if(data.getType() == Data::Type::TimeStamp)
- static_cast <dbms::TimeStamp&>(data).setFractionalSecond(0);
- }
-}
projects / anna.git / blobdiff