diff -r 1a2a00e78665 -r 7feec50967db contentstorage/caclient/stub/src/caclientproxy.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/contentstorage/caclient/stub/src/caclientproxy.cpp	Tue Mar 23 23:17:02 2010 +0200
@@ -0,0 +1,999 @@
+/*
+ * Copyright (c) 2007 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:
+ *
+ */
+
+#include <QList>
+#include <QDebug>
+#include <QString>
+#include <QtSql>
+#include <QMap>
+#include <QMapIterator>
+
+#include "caclientproxy.h"
+#include "caobjectadapter.h"
+
+#include "caentry.h"
+#include "caquery.h"
+#include "cadefs.h"
+#include "canotifier.h"
+#include "canotifier_p.h"
+#include "canotifiers.h"
+
+#include "hswidgetregistryservice.h"
+
+const char* DATABASE_CONNECTION_NAME = "CaService";
+const char* DATABASE_TYPE = "QSQLITE";
+const char* DATABASE_NAME = "castoragedb";
+
+static QSqlDatabase dbConnection()
+{
+    return QSqlDatabase::database(DATABASE_CONNECTION_NAME, false);
+}
+
+//----------------------------------------------------------------------------
+//
+//----------------------------------------------------------------------------
+CaClientProxy::CaClientProxy() :
+    mWidgetRegistryPath("hsresources/import/widgetregistry")
+{
+}
+
+//----------------------------------------------------------------------------
+//
+//----------------------------------------------------------------------------
+CaClientProxy::~CaClientProxy()
+{
+    QSqlDatabase db = dbConnection();
+    if (db.isOpen()) {
+        db.close();
+    }
+    QSqlDatabase::removeDatabase(DATABASE_CONNECTION_NAME);
+}
+
+//----------------------------------------------------------------------------
+//
+//----------------------------------------------------------------------------
+ErrorCode CaClientProxy::connect()
+{
+    ErrorCode errorCode = NotFoundErrorCode;
+    QSqlDatabase db = QSqlDatabase::addDatabase(DATABASE_TYPE,
+        DATABASE_CONNECTION_NAME);
+    if (db.isValid()) {
+        db.setDatabaseName(DATABASE_NAME);
+        if (db.open()) {
+            errorCode = NoErrorCode;
+            updateWidgets();
+        }
+    }
+    if (errorCode) {
+        qDebug("CaClientProxy::CaClientProxy FAILED");
+    }
+    return errorCode;
+}
+
+/*!
+ Updates widgets.
+ */
+void CaClientProxy::updateWidgets()
+{
+    qDebug("CaClientProxy::updateWidgets start");
+    
+    HsWidgetRegistryService *rs =
+        new HsWidgetRegistryService(mWidgetRegistryPath);
+    QList<HsWidgetToken> widgets = rs->widgets();
+    
+    // Read widgets in order to add synchronize the content of the widgets
+    // registry with Content Storage database.
+    foreach (const HsWidgetToken &widgetToken, widgets) {
+        int uid = widgetToken.mUid;
+        
+        if (!hsWidgetExists(uid)) {
+            // The given widget does not have a corresonding entry
+            // in the databse, so such an entry needs do be created.
+            addWidgetEntry(widgetToken);
+        }
+    }
+    
+    delete rs;
+    qDebug("CaClientProxy::updateWidgets end");
+}
+
+/*!
+ Returns true if a widget with the given uid exists in the database.
+ */
+void CaClientProxy::addWidgetEntry(const HsWidgetToken &widgetToken)
+{
+    QString description = widgetToken.mDescription;
+    QString iconUri = widgetToken.mIconUri;
+    QString library = widgetToken.mLibrary;
+    QString title = widgetToken.mTitle;
+    int uid = widgetToken.mUid;
+    QString uri = widgetToken.mUri;
+    QSqlDatabase db = dbConnection();
+    QSqlQuery query(db);
+    QString hexUid;
+    hexUid.setNum(uid,16);
+    QDir currentDir = QDir::current();
+    
+    // Add icon.
+    QString queryAddIcon =
+        "INSERT INTO CA_ICON " \
+            "(IC_FILENAME) " \
+        "VALUES " \
+            "(?)";
+
+    query.prepare(queryAddIcon);
+    query.addBindValue(iconUri);
+    query.exec();
+    qDebug() << query.executedQuery();
+    
+    // Add entry.
+    QString queryAddEntry =
+        "INSERT INTO CA_ENTRY " \
+            "(EN_TEXT, EN_DESCRIPTION, EN_ROLE, EN_TYPE_NAME, EN_ICON_ID) " \
+        "VALUES " \
+            "(?, ?, 1, 'widget', last_insert_rowid())";
+
+    query.prepare(queryAddEntry);    
+    query.addBindValue(title);
+    query.addBindValue(description);
+    query.exec();
+    qDebug() << query.executedQuery();
+    
+    // Get last id 
+    QString queryLastId = "SELECT last_insert_rowid() AS LAST_ID";
+    query.prepare(queryLastId);
+    query.exec();
+    query.next();
+    int lastId = query.value(query.record().indexOf("LAST_ID")).toInt();
+    
+    // Add attribute packageuid
+    QString queryAddAttribute1 =
+        "INSERT INTO CA_ATTRIBUTE " \
+            "(AT_ENTRY_ID, AT_NAME, AT_VALUE) " \
+        "VALUES " \
+            "(?, 'packageuid', ?)";
+
+    query.prepare(queryAddAttribute1);
+    query.addBindValue(lastId);
+    query.addBindValue(hexUid);
+    query.exec();
+    qDebug() << query.executedQuery();
+    
+    // Add attribute widget uri
+    QString queryAddAttribute2 =
+        "INSERT INTO CA_ATTRIBUTE " \
+            "(AT_ENTRY_ID, AT_NAME, AT_VALUE) " \
+        "VALUES " \
+            "(?, 'widget:uri', ?)";
+
+    query.prepare(queryAddAttribute2);
+    query.addBindValue(lastId);
+    query.addBindValue(uri);
+    query.exec();
+    qDebug() << query.executedQuery();
+    
+    // Add attribute widget library
+    QString queryAddAttribute3 =
+        "INSERT INTO CA_ATTRIBUTE " \
+            "(AT_ENTRY_ID, AT_NAME, AT_VALUE) " \
+        "VALUES " \
+            "(?, 'widget:library', ?)";
+
+    query.prepare(queryAddAttribute3);
+    query.addBindValue(lastId);
+    query.addBindValue(library);
+    query.exec();
+    qDebug() << query.executedQuery();
+}
+
+/*!
+ Returns true if a widget with the given uid exists in the database.
+ */
+bool CaClientProxy::hsWidgetExists(int uid)
+{
+    bool exists(false);
+    QSqlDatabase db = dbConnection();
+    QSqlQuery query(db);
+    QString hexUid;    
+    hexUid.setNum(uid,16);
+    
+    QString queryString =
+        "SELECT " \
+            "AT_ENTRY_ID " \
+        "FROM " \
+            "CA_ATTRIBUTE " \
+        "WHERE " \
+            "AT_VALUE LIKE ?";
+    
+    query.prepare(queryString);
+    query.addBindValue(hexUid);
+    
+    if (query.exec() && query.next()) {
+        // Query returned a non empty result.
+        exists = true;
+    } else {
+        // The widget with the given uid was not found.
+        exists = false;
+    }
+    
+    qDebug() << query.executedQuery();
+    
+    return exists;
+}
+
+//----------------------------------------------------------------------------
+//
+//----------------------------------------------------------------------------
+ErrorCode CaClientProxy::addData(const CaEntry &entryToAdd,
+    CaEntry &targetEntry)
+{
+    qDebug() << "CaClientProxy::addData" << "entry id: "
+        << entryToAdd.id();
+
+    targetEntry = entryToAdd;
+    QSqlDatabase db = dbConnection();
+    QSqlQuery query(db);
+    if (entryToAdd.id() == 0) {
+        CaObjectAdapter::setId(targetEntry, 0);
+    }
+    query.exec("begin");
+    bool success = (setIconInDb(&targetEntry)
+        && setEntryInDb(&targetEntry)
+        && setAttributesInDb(&targetEntry));
+    if (success) {
+        query.exec("commit");
+        QList<int> parentIds;
+        GetParentsIds(QList<int>() << targetEntry.id(), parentIds);
+        if (entryToAdd.id() == 0) {
+            CaNotifiers::Notify(targetEntry, AddChangeType, parentIds);
+        } else {
+            CaNotifiers::Notify(targetEntry, UpdateChangeType, parentIds);
+        }
+        return NoErrorCode;
+    } else {
+        query.exec("rollback");
+        return UnknownErrorCode;
+    }
+}
+
+//----------------------------------------------------------------------------
+//
+//----------------------------------------------------------------------------
+ErrorCode CaClientProxy::removeData(const QList<int> &entryIdList)
+{
+    qDebug() << "CaClientProxy::removeData" << "entryIdList: "
+        << entryIdList;
+
+    QList<CaEntry*> entryList;
+    getData(entryIdList, entryList);
+    QList<QList<int> > parentsIds;
+    foreach (CaEntry *entry, entryList) {
+        QList<int> parentIds;
+        GetParentsIds(QList<int>() << entry->id(), parentIds);
+        parentsIds.append(parentIds);
+    }
+
+    QSqlDatabase db = dbConnection();
+    QSqlQuery query(db);
+    //begin transaction
+    bool success(false);
+    query.exec("begin");
+    foreach(int entryId, entryIdList) {
+        query.prepare(
+            "SELECT ENTRY_ID FROM CA_ENTRY WHERE ENTRY_ID = ?");
+        query.addBindValue(entryId);
+        success = query.exec();
+        if (success && query.next()) {
+            success
+                = query.value(query.record().indexOf("ENTRY_ID")).toInt()
+                    > 0;
+        }
+        if (!success) {
+            break;
+        }
+
+        query.prepare(
+            "SELECT EN_ICON_ID FROM CA_ENTRY WHERE ENTRY_ID = ?");
+        query.addBindValue(entryId);
+        int iconId(0);
+        success = query.exec();
+        if (success && query.next()){
+            iconId
+                = query.value(query.record().indexOf("EN_ICON_ID")).toInt();
+        } else {
+            break;
+        }
+
+        query.prepare("DELETE FROM CA_LAUNCH WHERE LA_ENTRY_ID = ?");
+        query.addBindValue(entryId);
+        success = query.exec();
+        if (success) {
+            qDebug() << query.lastQuery() << " rows deleted: "
+                << query.numRowsAffected();
+        } else {
+            break;
+        }
+
+        query.prepare(
+            "DELETE FROM CA_GROUP_ENTRY WHERE GE_ENTRY_ID = ?");
+        query.addBindValue(entryId);
+        success = query.exec();
+        if (success) {
+            qDebug() << query.lastQuery() << " rows deleted: "
+                << query.numRowsAffected();
+        } else {
+            break;
+        }
+
+        query.prepare(
+            "DELETE FROM CA_GROUP_ENTRY WHERE GE_GROUP_ID = ?");
+        query.addBindValue(entryId);
+        success = query.exec();
+        if (success) {
+            qDebug() << query.lastQuery() << " rows deleted: "
+                << query.numRowsAffected();
+        } else {
+            break;
+        }
+
+        query.prepare("DELETE FROM CA_ATTRIBUTE WHERE AT_ENTRY_ID = ?");
+        query.addBindValue(entryId);
+        success = query.exec();
+        if (success) {
+            qDebug() << query.lastQuery() << " rows deleted: "
+                << query.numRowsAffected();
+        } else {
+            break;
+        }
+
+        query.prepare("DELETE FROM CA_ENTRY WHERE ENTRY_ID = ?");
+        query.addBindValue(entryId);
+        success = query.exec();
+        if (success) {
+            qDebug() << query.lastQuery() << " rows deleted: "
+                << query.numRowsAffected();
+        } else {
+            break;
+        }
+
+        if (iconId != 0) {
+            query.prepare("DELETE FROM CA_ICON WHERE ICON_ID = ?");
+            query.addBindValue(iconId);
+            success = query.exec();
+            if (success) {
+                qDebug() << query.lastQuery() << " rows deleted: "
+                    << query.numRowsAffected();
+            } else {
+                // ignore, this means that the icon cannot be removed
+                // because some other entry has the same icon.
+                success = true;
+            }
+        }
+    }
+
+    ErrorCode error(NoErrorCode);
+    if (success) {
+        query.exec("commit");
+        if (parentsIds.count() == entryList.count()) {
+            for (int i = 0; i < entryList.count(); i++) {
+                GetParentsIds(QList<int>() << entryList[i]->id(), parentsIds[i]);
+                CaNotifiers::Notify(*entryList[i], RemoveChangeType, parentsIds[i]);
+            }
+        }
+    } else {
+        query.exec("rollback");
+        error = UnknownErrorCode;
+    }
+
+    return error;
+}
+
+//----------------------------------------------------------------------------
+//
+//----------------------------------------------------------------------------
+ErrorCode CaClientProxy::insertEntriesIntoGroup(int groupId,
+    const QList<int> &entryIdList, int beforeEntryId)
+{
+    qDebug() << "CaClientProxy::insertEntriesIntoGroup" << "groupId: "
+        << groupId << "beforeEntryId: " << beforeEntryId << "entryIdList: "
+        << entryIdList;
+
+    removeEntriesFromGroup(groupId, entryIdList, false);
+    QString queryText;
+    if (beforeEntryId == AfterTheLastEntry) {
+        queryText = QString("INSERT INTO CA_GROUP_ENTRY (GE_GROUP_ID,GE_ENTRY_ID,GE_POSITION) "
+            "VALUES ( ?, ?,(SELECT MAX(DATA) FROM ( SELECT MAX(GE_POSITION)+ 1 AS DATA FROM CA_GROUP_ENTRY "
+            "WHERE GE_GROUP_ID = %1 UNION SELECT 1 AS DATA FROM CA_GROUP_ENTRY ) ) )").arg(groupId);
+    } else if (beforeEntryId == BeforeTheFirstEntry) {
+        queryText = "INSERT INTO CA_GROUP_ENTRY (GE_GROUP_ID,GE_ENTRY_ID,GE_POSITION) VALUES ( ?, ?, 0 ) ";
+    } else {
+        queryText = QString("INSERT INTO CA_GROUP_ENTRY (GE_GROUP_ID,GE_ENTRY_ID,GE_POSITION) VALUES ( "
+            "?, ?, ( SELECT GE_POSITION FROM CA_GROUP_ENTRY WHERE GE_ENTRY_ID = %1 ) ) ").arg(beforeEntryId);
+    }
+
+    bool success = true;
+    QSqlDatabase db = dbConnection();
+    QSqlQuery query(db);
+    query.exec("begin");
+    for (int i = 0; i < entryIdList.count() && success; ++i) {
+        query.prepare(queryText);
+        query.addBindValue(groupId);
+        query.addBindValue(entryIdList.at(i));
+        success = query.exec();
+    }
+
+    ErrorCode error(NoErrorCode);
+    if (success) {
+        query.exec("commit");
+        CaNotifiers::Notify(groupId);
+    } else {
+        query.exec("rollback");
+        error = UnknownErrorCode;
+    }
+    return error;
+}
+
+//----------------------------------------------------------------------------
+//
+//----------------------------------------------------------------------------
+ErrorCode CaClientProxy::removeEntriesFromGroup(int groupId,
+    const QList<int> &entryIdList,
+    bool calledDirectly)
+{
+    qDebug() << "CaClientProxy::removeEntriesFromGroup" << "groupId: "
+        << groupId << "entryIdList: " << entryIdList;
+
+    bool success = true;
+    QSqlDatabase db = dbConnection();
+    QSqlQuery query(db);
+    query.exec("begin");
+    for (int i = 0; i < entryIdList.count() && success; ++i) {
+        query.prepare(
+            "DELETE FROM CA_GROUP_ENTRY WHERE GE_ENTRY_ID = ? AND GE_GROUP_ID = ? ");
+        query.addBindValue(entryIdList.at(i));
+        query.addBindValue(groupId);
+        success = query.exec();
+    }
+
+    ErrorCode error(NoErrorCode);
+    if (success) {
+        query.exec("commit");
+        if (calledDirectly) {
+            CaNotifiers::Notify(groupId);
+        }
+    } else {
+        query.exec("rollback");
+        error = UnknownErrorCode;
+    }
+    return error;
+}
+
+//----------------------------------------------------------------------------
+//
+//----------------------------------------------------------------------------
+ErrorCode CaClientProxy::getData(const QList<int> &entryIdList,
+    QList<CaEntry*> &sourceList)
+{
+    qDebug() << "CaClientProxy::getData" << "entryIdList: "
+        << entryIdList;
+
+    QSqlDatabase db = dbConnection();
+
+    bool success(true);
+    foreach (int i, entryIdList) {
+        QSqlQuery query(db);
+        query.prepare(
+            "SELECT ENTRY_ID, EN_TEXT, EN_DESCRIPTION, EN_TYPE_NAME, EN_FLAGS, EN_ROLE, EN_UID,  \
+                  ICON_ID, IC_BITMAP_ID, IC_MASK_ID, IC_SKINMAJOR_ID, IC_SKINMINOR_ID, IC_FILENAME \
+                  FROM CA_ENTRY LEFT JOIN CA_ICON ON EN_ICON_ID = ICON_ID WHERE ENTRY_ID = ?");
+        query.addBindValue(i);
+
+        success = query.exec();
+        if (success && query.next()) {
+            qDebug() << query.executedQuery();
+            int role =
+                query.value(query.record().indexOf("EN_ROLE")).toInt();
+            CaEntry* entry = new CaEntry((EntryRole) role);
+            CaObjectAdapter::setId(*entry,
+                query.value(query.record().indexOf("ENTRY_ID")).toInt());
+            entry->setText(query.value(
+                query.record().indexOf("EN_TEXT")).toString());
+            entry->setDescription(query.value(
+                query.record().indexOf("EN_DESCRIPTION")).toString());
+            entry->setEntryTypeName(query.value(query.record().indexOf(
+                "EN_TYPE_NAME")).toString());
+            entry->setFlags(static_cast<EntryFlag> (query.value(
+                query.record().indexOf("EN_FLAGS")).toUInt()));
+
+            CaIconDescription icon;
+            CaObjectAdapter::setId(icon,
+                query.value(query.record().indexOf("ICON_ID")).toInt());
+            icon.setBitmapId(query.value(query.record().indexOf(
+                "IC_BITMAP_ID")).toInt());
+            icon.setMaskId(query.value(query.record().indexOf(
+                "IC_MASK_ID")).toInt());
+            icon.setSkinMajorId(query.value(query.record().indexOf(
+                "IC_SKINMAJOR_ID")).toInt());
+            icon.setSkinMinorId(query.value(query.record().indexOf(
+                "IC_SKINMINOR_ID")).toInt());
+            icon.setFilename(query.value(query.record().indexOf(
+                "IC_FILENAME")).toString());
+            entry->setIconDescription(icon);
+
+            // attributes
+            // UID as attribute
+            if (query.value(query.record().indexOf("EN_UID")).toString().length()
+                > 0) {
+                entry->setAttribute("application:uid", query.value(
+                    query.record().indexOf("EN_UID")).toString());
+            }
+
+            // fetch from DB attributes
+            QSqlQuery attributesQuery(db);
+            attributesQuery.prepare(
+                "SELECT AT_NAME, AT_VALUE FROM CA_ATTRIBUTE WHERE AT_ENTRY_ID  = ?");
+            attributesQuery.addBindValue(i);
+            success = attributesQuery.exec();
+            if (success) {
+                while (attributesQuery.next()) {
+                    entry->setAttribute(
+                        attributesQuery.value(0).toString(),
+                        attributesQuery.value(1).toString());
+                }
+                sourceList << entry;
+            }
+        } else {
+            break;
+        }
+    }
+
+    ErrorCode error = NoErrorCode;
+    if (!success) {
+        error = UnknownErrorCode;
+    } else if ((entryIdList.count() != sourceList.count())) {
+        error = NotFoundErrorCode;
+    }
+    return error;
+}
+
+//----------------------------------------------------------------------------
+//
+//----------------------------------------------------------------------------
+ErrorCode CaClientProxy::getData(const CaQuery &query,
+    QList<CaEntry*> &sourceList)
+{
+    QList<int> entryIdList;
+    ErrorCode errorCode = getEntryIds(query, entryIdList);
+    if (errorCode == NoErrorCode) {
+        errorCode = getData(entryIdList, sourceList);
+    }
+    return errorCode;
+}
+
+//----------------------------------------------------------------------------
+//
+//----------------------------------------------------------------------------
+ErrorCode CaClientProxy::getEntryIds(const CaQuery &query,
+    QList<int> &sourceIdList)
+{
+    qDebug() << "CaClientProxy::getEntryIds";
+
+    QSqlDatabase db = dbConnection();
+
+    bool success(true);
+    QString whereStatement;
+    if (query.flagsOn() != 0)
+        whereStatement.append(" AND ").append(QString().setNum(
+            query.flagsOn())).append(" & EN_FLAGS == ").append(
+            QString().setNum(query.flagsOn()));
+    if (query.flagsOff() != 0)
+        whereStatement.append(" AND ").append(QString().setNum(
+            query.flagsOff())).append(" & (~EN_FLAGS) == ").append(
+            QString().setNum(query.flagsOff()));
+    if (query.entryRoles() != 0)
+        whereStatement.append(" AND ").append(QString().setNum(
+            query.entryRoles())) .append(" | EN_ROLE == ").append(
+            QString().setNum(query.entryRoles()));
+    //TODO: by uid???
+
+    if (query.entryTypeNames().count()) {
+        whereStatement.append(" AND EN_TYPE_NAME IN (");
+        for (int i = 0; i < query.entryTypeNames().count(); i++) {
+            whereStatement.append("\'" + query.entryTypeNames()[i] + "\'");
+            if (i < query.entryTypeNames().count() - 1)
+                whereStatement.append(",");
+        }
+        whereStatement.append(") ");
+    }
+
+    QSqlQuery sqlquery(db);
+    if (query.parentId() == 0) {
+        // sort
+        QString queryString("SELECT ENTRY_ID from CA_ENTRY where 1=1 ");
+        queryString.append(whereStatement);
+        modifyQueryForSortOrder(queryString, query, false);
+        if (query.count() > 0)
+            queryString.append(" LIMIT ").append(query.count());
+        qDebug() << "CaServicePrivate::getEntryIds query text: "
+            << queryString;
+        success = sqlquery.prepare(queryString);
+        success = sqlquery.exec();
+        if (success) {
+            while (sqlquery.next()) {
+                sourceIdList << sqlquery.value(sqlquery.record().indexOf(
+                    "ENTRY_ID")).toInt();
+            }
+        }
+    }
+    else {
+        QString
+            queryString(
+                "SELECT ENTRY_ID FROM CA_ENTRY \
+        LEFT JOIN CA_GROUP_ENTRY ON GE_ENTRY_ID = ENTRY_ID WHERE GE_GROUP_ID  = ? ");
+        queryString.append(whereStatement);
+        modifyQueryForSortOrder(queryString, query, true);
+        if (query.count() > 0)
+            queryString.append(" LIMIT ").append(query.count());
+        qDebug() << "CaServicePrivate::getEntryIds query text: "
+            << queryString;
+        sqlquery.prepare(queryString);
+        sqlquery.addBindValue(query.parentId());
+        success = sqlquery.exec();
+        if (success) {
+            while (sqlquery.next()) {
+                sourceIdList << sqlquery.value(sqlquery.record().indexOf(
+                    "ENTRY_ID")).toInt();
+            }
+        }
+    }
+    ErrorCode error = UnknownErrorCode;
+    if (success) {
+            error = NoErrorCode;
+    }
+    return error;
+}
+
+//----------------------------------------------------------------------------
+//
+//----------------------------------------------------------------------------
+ErrorCode CaClientProxy::executeCommand(const CaEntry &entry,
+    const QString &command)
+{
+    qDebug() << "CaClientProxy::executeCommand" << "entry id: "
+        << entry.id() << "command: " << command;
+    return touch(entry);
+}
+
+//----------------------------------------------------------------------------
+//
+//----------------------------------------------------------------------------
+ErrorCode CaClientProxy::touch(const CaEntry &entry)
+{
+    const int id = entry.id();
+
+    qDebug() << "CaClientProxy::touch" << "id: " << id;
+
+    QSqlDatabase db = dbConnection();
+    QSqlQuery query(db);
+    query.exec("begin");
+
+    query.prepare(
+        "INSERT INTO CA_LAUNCH (LA_ENTRY_ID,LA_LAUNCH_TIME) VALUES ( ?,? )");
+    query.addBindValue(id);
+    query.addBindValue(QDateTime::currentDateTime().toTime_t());
+    bool success = query.exec();
+
+    if (success) {
+        query.prepare(
+            "UPDATE CA_ENTRY SET EN_FLAGS = EN_FLAGS | ? WHERE ENTRY_ID = ?");
+        query.addBindValue((int) UsedEntryFlag);
+        query.addBindValue(id);
+        success = query.exec();
+    }
+
+    ErrorCode error = NoErrorCode;
+    if (success) {
+        query.exec("commit");
+        QList<CaEntry *> entryList;
+        if (getData(QList<int>() << id, entryList) == NoErrorCode) {
+            QList<int> parentIds;
+            GetParentsIds(QList<int>() << id, parentIds);
+            CaNotifiers::Notify(*entryList[0], UpdateChangeType, parentIds);
+        }
+    } else {
+        query.exec("rollback");
+        error = UnknownErrorCode;
+    }
+    
+    return error;
+}
+
+//----------------------------------------------------------------------------
+//
+//----------------------------------------------------------------------------
+ErrorCode CaClientProxy::customSort(const QList<int> &entryIdList,
+        int groupId)
+{
+    bool success = true;
+    QSqlDatabase db = dbConnection();
+    QSqlQuery query(db);
+    query.exec("begin");
+    for (int i = 0; i < entryIdList.count(); i++) {
+        int position = i+1;
+        query.prepare(
+            "UPDATE CA_GROUP_ENTRY SET GE_POSITION = ? WHERE GE_ENTRY_ID = ? AND GE_GROUP_ID = ?" );
+        query.addBindValue(position);
+        query.addBindValue(entryIdList.at(i));
+        query.addBindValue(groupId);
+        success = query.exec();
+        if (!success) {
+            break;
+        }
+    }
+
+    ErrorCode error(NoErrorCode);
+    if (success) {
+        query.exec("commit");
+        CaNotifiers::Notify(groupId);
+    } else {
+        query.exec("rollback");
+        error = UnknownErrorCode;
+    }
+    return error;
+}
+
+/*!
+ //TODO:
+ */
+void CaClientProxy::modifyQueryForSortOrder(QString& queryString,
+    const CaQuery &query, bool parent) const
+{
+    SortAttribute sortAttribute;
+    Qt::SortOrder sortOrder;
+    query.getSort(sortAttribute, sortOrder);
+    QString oldQueryString(queryString);
+    queryString.clear();
+
+    if (sortAttribute == NameSortAttribute) {
+        queryString.append(oldQueryString).append(" ORDER BY EN_TEXT ");
+    }
+    else if (sortAttribute == CreatedTimestampSortAttribute) {
+        queryString.append(oldQueryString).append(
+            " ORDER BY EN_CREATION_TIME ");
+    }
+    else if (sortAttribute == MostUsedSortAttribute) {
+        queryString.append("SELECT ENTRY_ID FROM (").append(oldQueryString).append(
+            " \
+                ) LEFT JOIN \
+                (SELECT LA_ENTRY_ID, COUNT(*) AS USAGE_DATA FROM CA_LAUNCH GROUP BY LA_ENTRY_ID) \
+                ON ENTRY_ID = LA_ENTRY_ID ORDER BY USAGE_DATA ");
+    }
+    else if (sortAttribute == LastUsedSortAttribute) {
+        queryString.append("SELECT ENTRY_ID FROM (").append(oldQueryString).append(
+            " \
+                ) LEFT JOIN \
+                (SELECT LA_ENTRY_ID, MAX(LA_LAUNCH_TIME) AS USAGE_DATA FROM CA_LAUNCH GROUP BY LA_ENTRY_ID) \
+                ON ENTRY_ID = LA_ENTRY_ID ORDER BY USAGE_DATA ");
+    }
+    else if (parent && sortAttribute == DefaultSortAttribute) {
+        queryString.append(oldQueryString).append(
+            " ORDER BY GE_GROUP_ID, GE_POSITION ");
+    }
+    else if (!parent && sortAttribute == DefaultSortAttribute) {
+        queryString.append(oldQueryString).append(" ORDER BY ENTRY_ID ");
+    }
+    else {
+        queryString.append(oldQueryString);
+    }
+
+    if (sortAttribute == NameSortAttribute || sortAttribute
+        == CreatedTimestampSortAttribute || sortAttribute
+        == MostUsedSortAttribute || sortAttribute == LastUsedSortAttribute
+        || (sortAttribute == DefaultSortAttribute && parent)) {
+        if (sortOrder == Qt::AscendingOrder)
+            queryString.append(" ASC ");
+        else
+            queryString.append(" DESC ");
+    }
+
+}
+
+/*!
+ //TODO:
+ */
+bool CaClientProxy::setIconInDb(CaEntry *entryClone) const
+{
+    //set icon information into db
+    QSqlQuery query(dbConnection());
+    query.prepare(
+        "SELECT ICON_ID FROM CA_ICON WHERE IC_FILENAME = :IC_FILENAME \
+            AND IC_BITMAP_ID = :IC_BITMAP_ID \
+            AND IC_MASK_ID = :IC_MASK_ID \
+            AND IC_SKINMAJOR_ID = :IC_SKINMAJOR_ID \
+            AND IC_SKINMINOR_ID = :IC_SKINMINOR_ID");
+    query.bindValue(":IC_FILENAME",
+        entryClone->iconDescription().filename());
+    query.bindValue(":IC_BITMAP_ID",
+        entryClone->iconDescription().bitmapId());
+    query.bindValue(":IC_MASK_ID", entryClone->iconDescription().maskId());
+    query.bindValue(":IC_SKINMAJOR_ID",
+        entryClone->iconDescription().skinMajorId());
+    query.bindValue(":IC_SKINMINOR_ID",
+        entryClone->iconDescription().skinMinorId());
+
+    bool success = query.exec();
+    if (success && query.next()) {
+        qDebug() << "query.executedQuery() : " << query.executedQuery();
+        int iconId = query.value(query.record().indexOf("ICON_ID")).toInt();
+        qDebug() << "iconId = " << iconId;
+        CaIconDescription iconDescription = entryClone->iconDescription();
+        if (iconId <= 0 && (iconDescription.filename() != ""
+            || iconDescription.bitmapId() != 0 || iconDescription.maskId() != 0
+            || iconDescription.skinMajorId() != 0
+            || iconDescription.skinMinorId() != 0)) {
+            query.prepare(
+                "INSERT INTO CA_ICON \
+                           (IC_FILENAME,IC_BITMAP_ID,IC_MASK_ID,IC_SKINMAJOR_ID,IC_SKINMINOR_ID) \
+                            VALUES ( ? , ? , ? , ? , ? )");
+            query.addBindValue(iconDescription.filename());
+            query.addBindValue(iconDescription.bitmapId());
+            query.addBindValue(iconDescription.maskId());
+            query.addBindValue(iconDescription.skinMajorId());
+            query.addBindValue(iconDescription.skinMinorId());
+            success = query.exec();
+            qDebug() << query.executedQuery();
+            iconId = query.lastInsertId().toInt();
+        }
+        CaObjectAdapter::setId(iconDescription, iconId);
+        entryClone->setIconDescription(iconDescription);
+    }
+    return success;
+}
+
+/*!
+ //TODO:
+ */
+bool CaClientProxy::setEntryInDb(CaEntry *entryClone) const
+{
+    QSqlQuery query(dbConnection());
+    bool isNewEntry(entryClone->id() <= 0);
+    QString
+        queryText(
+            "INSERT INTO CA_ENTRY \
+        (EN_TEXT,EN_ROLE,EN_TYPE_NAME,EN_FLAGS,EN_ICON_ID ) VALUES ( ?, ?, ?, ?, ");
+    if (!isNewEntry)
+        queryText
+            = "REPLACE INTO CA_ENTRY \
+        (ENTRY_ID,EN_TEXT,EN_ROLE,EN_TYPE_NAME,EN_FLAGS,EN_ICON_ID ) VALUES ( ?, ?, ?, ?, ?, ";
+    if (entryClone->iconDescription().id() > 0) {
+        queryText.append("?");
+    }
+    else {
+        queryText.append("NULL");
+    }
+    queryText.append(")");
+    query.prepare(queryText);
+    if (!isNewEntry)
+        query.addBindValue(entryClone->id());
+    query.addBindValue(entryClone->text());
+    query.addBindValue((int) entryClone->role());
+    query.addBindValue(entryClone->entryTypeName());
+    query.addBindValue((int) entryClone->flags());
+    if (entryClone->iconDescription().id() > 0) {
+        query.addBindValue(entryClone->iconDescription().id());
+    }
+
+    bool success = query.exec();
+    if (success) {
+        qDebug() << query.executedQuery();
+        int newEntryId(0);
+        //set entry creation time if new entry
+        if (isNewEntry) {
+            newEntryId = query.lastInsertId().toInt();
+
+            CaObjectAdapter::setId(*entryClone, newEntryId);
+            uint timestamp = QDateTime::currentDateTime().toTime_t();
+            query.prepare(
+                "UPDATE CA_ENTRY SET EN_CREATION_TIME = ? WHERE ENTRY_ID = ?");
+            query.addBindValue(timestamp);
+            query.addBindValue(newEntryId);
+            success = query.exec();
+            qDebug() << "CaServicePrivate::setEntryInDb"
+                << query.executedQuery();
+        }
+    }
+    return success;
+}
+
+/*!
+ //TODO:
+ */
+bool CaClientProxy::setAttributesInDb(CaEntry *entryClone) const
+{
+    bool success = true;
+    QSqlQuery query(dbConnection());
+    if (entryClone->attributes().count() > 0) {
+        QMap<QString, QString> attributesMap = entryClone->attributes();
+        foreach (QString key, attributesMap.keys()) {
+                query.prepare(
+                    "REPLACE INTO CA_ATTRIBUTE (AT_ENTRY_ID,AT_NAME,AT_VALUE) VALUES ( \
+                :AT_ENTRY_ID,\
+                :AT_NAME,\
+                :AT_VALUE )");
+                query.bindValue(":AT_ENTRY_ID", entryClone->id());
+                query.bindValue(":AT_NAME", key);
+                query.bindValue(":AT_VALUE", attributesMap.value(key));
+                success = query.exec();
+                if (!success) {
+                    break;
+                }
+                qDebug() << "CaServicePrivate::setAttributesInDb"
+                    << query.boundValues();
+            }
+    }
+     return success;
+}
+
+
+void CaClientProxy::CreateGetParentsIdsQuery(
+    const QList<int> &entryIds,
+    const QList<int> &parentIds,
+    QString &query)
+{
+    QString entryIdList;
+    int lastItemIndex = entryIds.count()-1;
+    for (int i = 0; i < lastItemIndex; i++) {
+        entryIdList.append(QString::number(entryIds[i]));
+        entryIdList.append(",");
+    }
+    if (lastItemIndex >= 0) {
+        entryIdList.append(QString::number(entryIds[lastItemIndex]));
+    }
+    query = QString("SELECT GE_GROUP_ID FROM CA_GROUP_ENTRY "
+        "WHERE GE_ENTRY_ID IN ( %1 )").arg(entryIdList);
+
+    int lastParentIndex = parentIds.count()-1;
+    if (lastParentIndex >= 0) {
+        QString parentIdList;
+        for (int i = 0; i < lastParentIndex; i++) {
+            parentIdList.append(QString::number(parentIds[i]));
+            parentIdList.append(",");
+        }
+        parentIdList.append(QString::number(parentIds[lastParentIndex]));
+        query.append(QString(" AND GE_GROUP_ID NOT IN( %1 )").arg(parentIdList));
+    }
+}
+
+
+bool CaClientProxy::GetParentsIds( const QList<int> &entryIds,
+    QList<int> &parentIds)
+{
+    QString getParentIdsQuery;
+    CreateGetParentsIdsQuery(entryIds, parentIds, getParentIdsQuery);
+    QSqlQuery query(dbConnection());
+    bool success = query.exec(getParentIdsQuery);
+
+    if (success && query.next()) {
+        QList<int> newParentIds;
+        do {
+            newParentIds << query.value(query.record().indexOf("GE_GROUP_ID")).toInt();
+        } while (query.next());
+        parentIds.append(newParentIds);
+        GetParentsIds(newParentIds, parentIds);
+    }
+    return success;
+}