--- 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__);
- }
-}