--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/javacommons/javastorage/src.s60/client/storageconnectionnative.cpp Tue Apr 27 16:30:29 2010 +0300
@@ -0,0 +1,251 @@
+/*
+* 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: storageconnectionnative
+*
+*/
+
+
+#include "com_nokia_mj_impl_storage_StorageConnection.h"
+#include "commsmessage.h"
+#include "javacommonutils.h"
+#include "javadataaccess.h"
+#include "javajniutils.h"
+#include "javastorageexception.h"
+#include "logger.h"
+
+using namespace java::comms;
+using namespace java::storage;
+using namespace java::util;
+
+JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_storage_StorageConnection__1startSession
+(JNIEnv *, jclass)
+{
+ JELOG2(EJavaStorage);
+ JavaDataAccess* dataAccess = JavaDataAccess::createInstance();
+ // Return handle to session. Utilize the fact that in Symbian
+ // all pointer addresses are MOD 4 so the last 2 bits are 0
+ // and can be shifted out. This way the returned handle is
+ // always positive whereas Symbian error codes are always negative.
+ return reinterpret_cast<TUint>(dataAccess)>>2;
+}
+
+JNIEXPORT void JNICALL Java_com_nokia_mj_impl_storage_StorageConnection__1closeSession
+(JNIEnv *, jclass, jint aSessionHandle)
+{
+ JELOG2(EJavaStorage);
+ JavaDataAccess* dataAccess =
+ reinterpret_cast<JavaDataAccess*>(aSessionHandle<<2);
+
+ delete dataAccess;
+ dataAccess = NULL;
+}
+
+JNIEXPORT jstring JNICALL Java_com_nokia_mj_impl_storage_StorageConnection__1open
+(JNIEnv *aEnv, jobject, jint aSessionHandle, jstring aHeaders, jstring aStorageName)
+{
+ JELOG2(EJavaStorage);
+ JavaDataAccess* dataAccess =
+ reinterpret_cast<JavaDataAccess*>(aSessionHandle<<2);
+
+ CommsMessage receivedMessage;
+ const char* tempHeaders = aEnv->GetStringUTFChars(aHeaders, 0);
+ const char* tempStorageName = aEnv->GetStringUTFChars(aStorageName, 0);
+ std::string headers(tempHeaders);
+ std::string storageName(tempStorageName);
+
+ aEnv->ReleaseStringUTFChars(aHeaders, tempHeaders);
+ aEnv->ReleaseStringUTFChars(aStorageName, tempStorageName);
+
+ try
+ {
+ dataAccess->open(headers, storageName, receivedMessage);
+ }
+ catch (JavaStorageException& jse)
+ {
+ JniUtils::throwNewException(
+ aEnv,
+ "com/nokia/mj/impl/storage/StorageException",
+ jse.toString().c_str());
+
+ // Return control to Java side. Otherwise JNI Error occur about
+ // pending exception.
+ return 0;
+ }
+
+ int statusCode = -1;
+ receivedMessage>>statusCode;
+
+ std::string responseBody = "";
+ receivedMessage>>responseBody;
+
+ if (statusCode < 0 || responseBody.length() == 0)
+ {
+ WLOG1(EJavaStorage, "Server error. ErrorCode: %d", statusCode);
+
+ std::string statusStr = "Server error. ErrorCode: ";
+ statusStr.append(JavaCommonUtils::intToString(statusCode));
+
+ JniUtils::throwNewException(
+ aEnv,
+ "com/nokia/mj/impl/storage/StorageException",
+ statusStr.c_str());
+
+ // Return control to Java side. Otherwise JNI Error occur about
+ // pending exception.
+ return 0;
+ }
+
+ return aEnv->NewStringUTF(responseBody.c_str());
+}
+
+JNIEXPORT void JNICALL Java_com_nokia_mj_impl_storage_StorageConnection__1close
+(JNIEnv *aEnv, jobject, jint aSessionHandle, jstring aHeaders)
+{
+ JELOG2(EJavaStorage);
+ JavaDataAccess* dataAccess =
+ reinterpret_cast<JavaDataAccess*>(aSessionHandle<<2);
+
+ CommsMessage receivedMessage;
+ const char* tempHeaders = aEnv->GetStringUTFChars(aHeaders, 0);
+ std::string headers(tempHeaders);
+
+ aEnv->ReleaseStringUTFChars(aHeaders, tempHeaders);
+
+ try
+ {
+ dataAccess->close(headers, receivedMessage);
+ }
+ catch (JavaStorageException& jse)
+ {
+ JniUtils::throwNewException(
+ aEnv,
+ "com/nokia/mj/impl/storage/StorageException",
+ jse.toString().c_str());
+
+ // Return control to Java side. Otherwise JNI Error occur about
+ // pending exception.
+ return;
+ }
+
+ int statusCode = -1;
+ receivedMessage>>statusCode;
+
+ std::string responseBody = "";
+ receivedMessage>>responseBody;
+
+ if (statusCode < 0 || responseBody.length() == 0)
+ {
+ WLOG1(EJavaStorage, "Server error. ErrorCode: %d", statusCode);
+
+ std::string statusStr = "Server error. ErrorCode: ";
+ statusStr.append(JavaCommonUtils::intToString(statusCode));
+
+ JniUtils::throwNewException(
+ aEnv,
+ "com/nokia/mj/impl/storage/StorageException",
+ statusStr.c_str());
+
+ // Return control to Java side. Otherwise JNI Error occur about
+ // pending exception.
+ return;
+ }
+}
+
+JNIEXPORT jstring JNICALL Java_com_nokia_mj_impl_storage_StorageConnection__1execute
+(JNIEnv *aEnv, jobject, jint aSessionHandle, jstring aHeaders, jstring aSqlStatement)
+{
+ JELOG2(EJavaStorage);
+
+ JavaDataAccess* dataAccess =
+ reinterpret_cast<JavaDataAccess*>(aSessionHandle<<2);
+
+ CommsMessage receivedMessage;
+ const char* tempHeaders = aEnv->GetStringUTFChars(aHeaders, 0);
+ std::string headers(tempHeaders);
+
+ aEnv->ReleaseStringUTFChars(aHeaders, tempHeaders);
+
+ const jchar* sqlStmtTemp = aEnv->GetStringChars(aSqlStatement, 0);
+
+ std::wstring sqlStatement(
+ (wchar_t*)sqlStmtTemp, aEnv->GetStringLength(aSqlStatement));
+
+ aEnv->ReleaseStringChars(aSqlStatement, sqlStmtTemp);
+
+ // ########################################################################
+ // LOG1WSTR(EJavaStorage, EInfo, "Java Sql: '%s'", sqlStatement);
+ // ########################################################################
+
+ try
+ {
+ dataAccess->execute(headers, sqlStatement, receivedMessage);
+ }
+ catch (JavaStorageException& jse)
+ {
+ ELOG(EJavaStorage, "Execute failed to storage exception.");
+
+ JniUtils::throwNewException(
+ aEnv,
+ "com/nokia/mj/impl/storage/StorageException",
+ jse.toString().c_str());
+
+ // Return control to Java side. Otherwise JNI Error occur about
+ // pending exception.
+ return 0;
+ }
+ catch (...)
+ {
+ ELOG(EJavaStorage, "Execute failed to unexp exception.");
+
+ JniUtils::throwNewException(
+ aEnv,
+ "com/nokia/mj/impl/storage/StorageException",
+ "Internal error");
+
+ // Return control to Java side. Otherwise JNI Error occur about
+ // pending exception.
+ return 0;
+
+ }
+
+ int statusCode = -1;
+ receivedMessage>>statusCode;
+
+ std::wstring responseBody = L"";
+ receivedMessage>>responseBody;
+
+ // ########################################################################
+ // LOG1WSTR(EJavaStorage, EInfo, "Server response: '%s'", responseBody);
+ // ########################################################################
+
+ if (statusCode < 0 || responseBody.length() == 0)
+ {
+ WLOG1(EJavaStorage, "Server error. ErrorCode: %d", statusCode);
+
+ std::string statusStr = "Server error. ErrorCode: ";
+ statusStr.append(JavaCommonUtils::intToString(statusCode));
+
+ JniUtils::throwNewException(
+ aEnv,
+ "com/nokia/mj/impl/storage/StorageException",
+ statusStr.c_str());
+
+ // Return control to Java side. Otherwise JNI Error occur about
+ // pending exception.
+ return 0;
+ }
+
+ return aEnv->NewString(
+ (const jchar*)responseBody.c_str(), responseBody.length());
+}