javacommons/javastorage/src.linux/client/javadataaccessimpl.cpp
branchRCL_3
changeset 18 9ac0a0a7da70
parent 17 0fd27995241b
child 19 71c436fe3ce0
--- a/javacommons/javastorage/src.linux/client/javadataaccessimpl.cpp	Tue May 11 16:07:20 2010 +0300
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -1,154 +0,0 @@
-/*
-* Copyright (c) 2008-2009 Nokia Corporation and/or its subsidiary(-ies).
-* All rights reserved.
-* This component and the accompanying materials are made available
-* under the terms of "Eclipse Public License v1.0"
-* which accompanies this distribution, and is available
-* at the URL "http://www.eclipse.org/legal/epl-v10.html".
-*
-* Initial Contributors:
-* Nokia Corporation - initial contribution.
-*
-* Contributors:
-*
-* Description:  JavaDataAccessImpl
-*
-*/
-
-
-#include "commsclientendpoint.h"
-#include "commsmessage.h"
-#include "javacommonutils.h"
-#include "javadataaccessimpl.h"
-#include "javastorageexception.h"
-#include "javastoragemessage.h"
-#include "logger.h"
-
-using namespace java::comms;
-using namespace java::storage;
-using namespace java::util;
-using namespace std;
-
-JavaDataAccessImpl::JavaDataAccessImpl() throw(JavaStorageException)
-        : mConnOpen(false), mCachedSessionID("")
-{
-    JELOG2(EJavaStorage);
-    mConnOpen = false;
-    mCliConn.reset(new CommsClientEndpoint());
-    int resultCode = mCliConn->connect(IPC_ADDRESS_JAVA_STORAGE_C);
-
-    if (resultCode != 0)
-    {
-        ELOG1(EJavaStorage, "Cannot connect via comms: %d", resultCode);
-        throw JavaStorageException(resultCode, "Comms failure",
-                                   __FILE__, __FUNCTION__, __LINE__);
-    }
-}
-
-OS_EXPORT JavaDataAccessImpl::~JavaDataAccessImpl()
-{
-    JELOG2(EJavaStorage);
-
-    // If intance is deleted prior connection is closed do close which triggers
-    // rollback on server side.
-    if (mConnOpen)
-    {
-        string msgID = JavaCommonUtils::intToString(JavaStorageMessage::EClose);
-        string msgIDSize = JavaCommonUtils::intToString(msgID.size());
-        string requestHeaders = msgIDSize + msgID + mCachedSessionID;
-        CommsMessage message;
-        close(requestHeaders, message);
-    }
-
-    int resultCode = mCliConn->disconnect();
-
-    if (resultCode != 0)
-    {
-        LOG1(EJavaStorage, EInfo,
-             "Comms disconnect result code: %d", resultCode);
-    }
-}
-
-OS_EXPORT void JavaDataAccessImpl::open(
-    const std::string& aHeaders,
-    const std::string& aStorageName,
-    CommsMessage& aReceivedMessage) throw(JavaStorageException)
-{
-    JELOG2(EJavaStorage);
-
-    CommsMessage sendStorageMessage;
-    sendStorageMessage.setMessageId(IPC_JS_CONN_REG);
-
-    // Headers contain MsgIdentifier,SessionId
-    sendStorageMessage<<aHeaders;
-    sendStorageMessage<<aStorageName;
-
-    sendReceiveMessage(sendStorageMessage, aReceivedMessage);
-    // SessionID is cached for the case that client deleted storage instance
-    // with open connection. SessionID is required to close open connection.
-    int resultCode = 0;
-    aReceivedMessage>>resultCode;
-    if (resultCode >= 0)
-    {
-        aReceivedMessage>>mCachedSessionID;
-        aReceivedMessage.begin();
-        mConnOpen = true;
-    }
-}
-
-OS_EXPORT void JavaDataAccessImpl::close(const std::string& aHeaders,
-        CommsMessage& aReceivedMessage)
-throw(JavaStorageException)
-{
-    JELOG2(EJavaStorage);
-
-    CommsMessage sendStorageMessage;
-    sendStorageMessage.setMessageId(IPC_JS_CONN_REG);
-
-    // Headers contain MsgIdentifier,SessionId
-    sendStorageMessage<<aHeaders;
-    sendStorageMessage<<"";
-
-    sendReceiveMessage(sendStorageMessage, aReceivedMessage);
-    mConnOpen = false;
-}
-
-OS_EXPORT void JavaDataAccessImpl::execute(const std::string& aHeaders,
-        const std::wstring& aSqlStatement,
-        CommsMessage& aReceivedMessage)
-throw(JavaStorageException)
-{
-    JELOG2(EJavaStorage);
-
-    CommsMessage sendStorageMessage;
-    sendStorageMessage.setMessageId(IPC_JS_CONN_REG);
-
-    // Headers contain MsgIdentifier,SessionId
-    sendStorageMessage<<aHeaders;
-    // Data is pure sqlstatement
-    sendStorageMessage<<aSqlStatement;
-
-    sendReceiveMessage(sendStorageMessage, aReceivedMessage);
-}
-
-void JavaDataAccessImpl::sendReceiveMessage(CommsMessage& aSendMessage,
-        CommsMessage& aReceivedMessage)
-throw(JavaStorageException)
-{
-    JELOG2(EJavaStorage);
-
-    int resultCode = -1;
-
-    aSendMessage.setReceiver(IPC_ADDRESS_JAVA_STORAGE_C);
-    aSendMessage.setModuleId(PLUGIN_ID_JAVASTORAGE_CLIENT_C);
-
-    resultCode = mCliConn->sendReceive(aSendMessage, aReceivedMessage, 10);
-
-    if (resultCode != 0)
-    {
-        ELOG1(EJavaStorage, "Comms result code: %d", resultCode);
-
-        throw JavaStorageException(resultCode, "Comms failure",
-                                   __FILE__, __FUNCTION__, __LINE__);
-    }
-}