---

sqldbvaluer.cpp

Go to the documentation of this file.

//============================================================================= 
//
// XDFLengine library
//
//-----------------------------------------------------------------------------
//  SQLDBVALUER.CPP
//-----------------------------------------------------------------------------
//_____________________________________________________________________________
//
//  Copyright (C) 2003 Guillaume Baurand. All Rights Reserved.
//
//  This file is part of the XDFLengine project.
//
//  The XDFLengine is free software; you can redistribute it and/or modify
//  it under the terms of the GNU General Public License as published by
//  the Free Software Foundation; either version 2 of the License, or
//  (at your option) any later version.
//
//  This program is distributed in the hope that it will be useful,
//  but WITHOUT ANY WARRANTY; without even the implied warranty of
//  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
//  GNU General Public License for more details.
//
//  You should have received a copy of the GNU General Public License
//  along with this program; if not, write to the Free Software
//  Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307,
//  USA.
//
//  For more information, 
//      contact  : guillaume@baurand.net 
//      or visit : http://xdflengine.sourceforge.net
//
//============================================================================= 

#   include "sqldbvaluer.hpp"

BEGIN_XDFLENGINE_NS

//=============================================================================
//  CLASS SQLDBVALUER
//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

    //_________________________________________________________________________
    //  SQLDBVALUER
    //-------------------------------------------------------------------------
    SQLDBValuer::SQLDBValuer()
    {
        m_pConnection=0;
        DEBUG_CREATE(SQLDBValuer)
    }

    //_________________________________________________________________________
    //  ~SQLDBVALUER
    //-------------------------------------------------------------------------
    SQLDBValuer::~SQLDBValuer()
    {
        DEBUG_DEL(SQLDBValuer)
    }

    //_________________________________________________________________________
    //  SETCONNECTION
    //-------------------------------------------------------------------------
    void SQLDBValuer::setConnection(otl_connect* p_pConnection)
    {   
        m_pConnection=p_pConnection;
    }

    //_________________________________________________________________________
    //  CALCULATEEXPRESSION
    //-------------------------------------------------------------------------
    char* SQLDBValuer::calculateExpression(const char* p_pszExpression)
    {
        //---------------------------------------------------------------------
        otl_stream*             l_prsData;
        char*                   l_pszValue=0;
        int                     l_iSize=0;
        XMLFlowException*       l_pXMLFlowException;
        //---------------------------------------------------------------------

        DEBUG_FUNC(SQLDBValuer::calculateExpression)

        if( m_pConnection)
        {

            try
            {
                //execute SQL
                l_prsData=new otl_stream();
                l_prsData->set_all_column_types(otl_all_num2str | otl_all_date2str);  // set all columns to strings
                l_prsData->open(    SQLVALUER_OTL_BUFFER, p_pszExpression, (*m_pConnection)  );
                l_prsData->flush(); //  force execution

                DEBUG_ECHO << "ok\n";
            }
            catch(otl_exception& p)
            { // intercept OTL exceptions
                m_pConnection->rollback();
                l_pXMLFlowException = new XMLFlowException( ERRCODE_LOC_SQLDBVALUER + ERRCODE_CAUSE_DATAACCESS , "Error while opening data stream.", (char*)(&(p.msg)), "SQLDBValuer::calculateExpression", "", false);
                p.~otl_tmpl_exception();
                throw l_pXMLFlowException;  
            }

            l_iSize = l_prsData->describe_next_out_var()->elem_size;
            l_pszValue = allocCharBuffer(l_iSize+1);
            (*l_prsData) >> l_pszValue;
            
            //l_rsData->clean();
            l_prsData->close();
            delete(l_prsData);

            return l_pszValue;
        }
        else return 0;
    }

//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
//=============================================================================
      
END_XDFLENGINE_NS

---