---

TypeConversions_impl.cpp

Go to the documentation of this file.

/* --------------------------------------------------------------
Copyright (C) 2001 LifeLine Networks BV <soap2corba@lifeline.nl>

This program 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., 675 Mass Ave, Cambridge, MA 02139, USA.
-------------------------------------------------------------- */
#include <iostream.h>
#include <OB/CORBA.h>
#include <OB/CosNaming.h>
#include "BridgeStub.h"
#include "Parser.h"
#include "StdAfx.h"
#include "SoapCorba.h"
#include "DbObjects.h"
#include "ReadIR.h"
#include "SoapBridge.h"
#include "SoapBridge_skel.h"
#include <sys/timeb.h>
#include "sbimpl.h"

SOAPBridge_TypeConversions_impl::SOAPBridge_TypeConversions_impl(PortableServer::POA_ptr poa)
    : poa_(PortableServer::POA::_duplicate(poa))
{
}

SOAPBridge_TypeConversions_impl::~SOAPBridge_TypeConversions_impl()
{
}

PortableServer::POA_ptr
SOAPBridge_TypeConversions_impl::_default_POA()
{
    return PortableServer::POA::_duplicate(poa_);
}

void
SOAPBridge_TypeConversions_impl::Set(const SOAPBridge::TypeConversions::Specification& spec)
throw(SOAPBridge::TypeConversions::BadSpecification,
          CORBA::SystemException)
{
    const char *mp, *pn, *ci;
    
    if (spec.methodPath == NULL) {
        mp = "";
    } else {
        mp = (const char *) spec.methodPath;
    }
    if (spec.parameterName == NULL) {
        pn = "";
    } else {
        pn = (const char *) spec.parameterName;
    }
    if (spec.userInfo == NULL) {
        ci = "";
    } else {
        ci = (const char *) spec.userInfo;
    }

    IRPlus *pirp = (IRPlus *) irplusHandle;
    JTCSynchronized synchronized (pirp->monitor);
    DOQuery Q (pirp->pCon);

    CString q;
    q.Format ("delete from irplus where methpath='%s' and param='%s'", mp, pn);
    Q.Query (q);
    if (spec.convUId) {
        q.Format ("insert into irplus(methpath,param,convid,convinfo) values ('%s','%s',%d,'%s')",
            mp, pn, spec.convUId, ci);
        Q.Query (q);
    }
    pirp->IRC.DeleteAllInterfaceMethod ();
    pirp->Init ();
}

CORBA::Boolean
SOAPBridge_TypeConversions_impl::Get(SOAPBridge::TypeConversions::Specification& spec,
                                      CORBA::Boolean getNext)
    throw(CORBA::SystemException)
{
    CORBA::Boolean _r = false;
    char *mp, *pn;
    
    if (spec.methodPath == NULL) {
        mp = "";
    } else {
        mp = (char *) spec.methodPath;
    }
    if (spec.parameterName == NULL) {
        pn = "";
    } else {
        pn = (char *) spec.parameterName;
    }

    CString q;
    q = "select irmeth.methpath as mpath,irparm.param as mparm,convid,convinfo from irmeth,irparm,irplus ";
    q += "where irmeth.methuid=irparm.methuid and (irmeth.irplusid<>0 or irparm.irplusid<>0) ";
    q += "and (irmeth.irplusid=irplus.irplusid or irparm.irplusid=irplus.irplusid) ";
    if (getNext) {
        q += "and irmeth.methpath='";
        q += mp;
        q += "' and irparm.param>'";
        q += pn;
        q += "' ";
    } else {
        q += "and irmeth.methpath='";
        q += mp;
        q += "' and irparm.param='";
        q += pn;
        q += "' ";
    }
    q += "order by irmeth.methpath,irparm.param limit 1";
    IRPlus *pirp = (IRPlus *) irplusHandle;
    JTCSynchronized synchronized (pirp->monitor);
    DOQuery Q (pirp->pCon);
    Q.Query (q);
    if (Q.GetNumRows ()) {
        spec.methodPath = CORBA::string_dup (Q.FindQueryField ("mpath")->GetValue ());
        spec.parameterName = CORBA::string_dup (Q.FindQueryField ("mparm")->GetValue ());
        spec.convUId = atoi (Q.FindQueryField ("convid")->GetValue ());
        spec.userInfo = CORBA::string_dup (Q.FindQueryField ("convInfo")->GetValue ());
        _r = true;
    }
    if (!_r && getNext) {
        q = "select irmeth.methpath as mpath,irparm.param as mparm,convid,convinfo from irmeth,irparm,irplus ";
        q += "where irmeth.methuid=irparm.methuid and (irmeth.irplusid<>0 or irparm.irplusid<>0) ";
        q += "and (irmeth.irplusid=irplus.irplusid or irparm.irplusid=irplus.irplusid) ";
        q += "and irmeth.methpath>'";
        q += mp;
        q += "' ";
        q += "order by irmeth.methpath,irparm.param limit 1";
        Q.Query (q);
        if (Q.GetNumRows ()) {
            spec.methodPath = CORBA::string_dup (Q.FindQueryField ("mpath")->GetValue ());
            spec.parameterName = CORBA::string_dup (Q.FindQueryField ("mparm")->GetValue ());
            spec.convUId = atoi (Q.FindQueryField ("convid")->GetValue ());
            spec.userInfo = CORBA::string_dup (Q.FindQueryField ("convInfo")->GetValue ());
            _r = true;
        }
    }
    return _r;
}

---