javaextensions/midppush/javasrc/com/nokia/mj/impl/push/PushRuntimeDbHandler.java
branchRCL_3
changeset 19 04becd199f91
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/javaextensions/midppush/javasrc/com/nokia/mj/impl/push/PushRuntimeDbHandler.java	Tue Apr 27 16:30:29 2010 +0300
@@ -0,0 +1,85 @@
+/*
+* Copyright (c) 2008 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:
+*
+*/
+
+package com.nokia.mj.impl.push;
+
+import java.io.IOException;
+import com.nokia.mj.impl.utils.Uid;
+import com.nokia.mj.impl.storage.*;
+import java.lang.Integer;
+import java.lang.String;
+import com.nokia.mj.impl.utils.Logger;
+
+
+/**
+ * This class is used by PushRegistryImpl class(i.e. Runtime process) to read and manipulate
+ * push data in the Storage.
+ */
+final class PushRuntimeDbHandler
+{
+
+    /**
+     * @return null if push reg by connection URI did not match to any push reg.
+     */
+    public static PushRegData getPushRegByConnection(String aUri,StorageSession aSession)
+    {
+        Logger.LOG(Logger.EJavaPush, Logger.EInfo, "PushRuntimeDbHandler.getUidAndRegTypeOfPushReg()");
+
+        StorageEntry query = new StorageEntry();
+        query.addAttribute(new StorageAttribute(StorageNames.URL,aUri));
+        StorageEntry[] entries = aSession.search(StorageNames.PUSH_REGISTRATIONS_TABLE,query);
+        PushRegData[] pushInfoTable = mapStorageEntryToPushInfo(entries);
+        if (null == pushInfoTable)
+            return null;
+        //There can be only one push registration because Uri is only one in the primary key.
+        //Null is returned by mapStorageEntryToPushInfo() operation if size of the 'entries'
+        //table is zero.
+        return pushInfoTable[0];
+    }//end getPushRegByConnection
+
+    /**
+     *
+     */
+    public static PushRegData[] mapStorageEntryToPushInfo(StorageEntry[] aEntries)
+    {
+        Logger.LOG(Logger.EJavaPush, Logger.EInfo, "PushRuntimeDbHandler.mapStorageEntryToPushInfo() +");
+        if (null == aEntries)
+            return null;
+        Logger.LOG(Logger.EJavaPush, Logger.EInfo, "PushRuntimeDbHandler.mapStorageEntryToPushInfo() #2");
+        if (0 == aEntries.length)
+            return null;
+        Logger.LOG(Logger.EJavaPush, Logger.EInfo, "PushRuntimeDbHandler.mapStorageEntryToPushInfo() #3");
+        PushRegData[] pushInfoTable = new PushRegData[aEntries.length];
+
+        for (int i = 0; i < aEntries.length; i++)
+        {
+            StorageAttribute attr = aEntries[i].getAttribute(StorageNames.ID);
+            Uid newUid = Uid.createUid(attr.getValue());
+            attr = aEntries[i].getAttribute(StorageNames.REGISTRATION_TYPE);
+            int regType = Integer.parseInt(attr.getValue());
+            PushRegData infoObj = new PushRegData(newUid,regType);
+            pushInfoTable[i] = infoObj;
+        }//end for
+
+        Logger.LOG(Logger.EJavaPush, Logger.EInfo, "PushRuntimeDbHandler.mapStorageEntryToPushInfo() -");
+        return pushInfoTable;
+    }//end mapStorageEntryToPushInfo
+
+}//end final class PushRuntimeDbHandler
+
+
+