--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/contentstorage/caclient/stub/src/caclientproxy.cpp Tue Aug 31 15:30:51 2010 +0300
@@ -0,0 +1,1082 @@
+/*
+ * 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 "caclient_defines.h"
+#include "hswidgetregistryservice.h"
+
+const char *DATABASE_CONNECTION_NAME = "CaService";
+const char *DATABASE_TYPE = "QSQLITE";
+const char *DATABASE_NAME = "castorage.db";
+
+static QSqlDatabase dbConnection()
+{
+ return QSqlDatabase::database(DATABASE_CONNECTION_NAME, false);
+}
+
+//----------------------------------------------------------------------------
+//
+//----------------------------------------------------------------------------
+CaClientProxy::CaClientProxy() :
+ mWidgetRegistryPath("private/20022F35/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<HsWidgetComponentDescriptor> widgets = rs->widgets();
+
+ // Read widgets in order to add synchronize the content of the widgets
+ // registry with Content Storage database.
+ foreach(const HsWidgetComponentDescriptor &widgetToken, widgets) {
+ int uid = widgetToken.uid;
+ addWidgetEntry(widgetToken, hsWidgetId(uid));
+ }
+
+ delete rs;
+ qDebug("CaClientProxy::updateWidgets end");
+}
+
+/*!
+ Returns true if a widget with the given uid exists in the database.
+ */
+void CaClientProxy::addWidgetEntry(const HsWidgetComponentDescriptor &widgetToken,
+ int widgetId)
+{
+ QString description = widgetToken.description;
+ QString iconUri = widgetToken.iconUri;
+ QString library = widgetToken.library;
+ QString title = widgetToken.title;
+ int uid = widgetToken.uid;
+ QString uri = widgetToken.uri;
+ QString previewImage = widgetToken.previewImage;
+ QString translationFileName = widgetToken.translationFilename;
+ QSqlDatabase db = dbConnection();
+ QSqlQuery query(db);
+ QString hexUid;
+ hexUid.setNum(uid,16);
+ QDir currentDir = QDir::current();
+ if (widgetId == -1) {
+ // 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();
+ widgetId = query.value(query.record().indexOf("LAST_ID")).toInt();
+ } else {
+ // update entry.
+ QString queryUpdateEntry =
+ "UPDATE CA_ENTRY SET EN_TEXT = ?, EN_DESCRIPTION = ? WHERE ENTRY_ID = ?";
+
+ query.prepare(queryUpdateEntry);
+ query.addBindValue(title);
+ query.addBindValue(description);
+ query.addBindValue(widgetId);
+ query.exec();
+ qDebug() << query.executedQuery();
+
+ QString queryUpdateIcon =
+ "UPDATE CA_ICON SET IC_FILENAME = ? WHERE" \
+ " ICON_ID = (SELECT EN_ICON_ID FROM CA_ENTRY WHERE ENTRY_ID = ?)";
+
+ query.prepare(queryUpdateIcon);
+ query.addBindValue(iconUri);
+ query.addBindValue(widgetId);
+ query.exec();
+ qDebug() << query.executedQuery();
+
+ // delete old attribute
+ query.prepare("DELETE FROM CA_ATTRIBUTE WHERE AT_ENTRY_ID = ?");
+ query.addBindValue(widgetId);
+ query.exec();
+ qDebug() << query.executedQuery();
+ }
+
+ // Add attribute packageuid
+ QString queryAddAttribute1 =
+ "INSERT INTO CA_ATTRIBUTE " \
+ "(AT_ENTRY_ID, AT_NAME, AT_VALUE) " \
+ "VALUES " \
+ "(?, 'packageuid', ?)";
+
+ query.prepare(queryAddAttribute1);
+ query.addBindValue(widgetId);
+ 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(widgetId);
+ 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(widgetId);
+ query.addBindValue(library);
+ query.exec();
+ qDebug() << query.executedQuery();
+
+ // Add attribute preview image
+ if (!previewImage.isEmpty()) {
+ QString queryAddPreviewImage =
+ "INSERT INTO CA_ATTRIBUTE " \
+ "(AT_ENTRY_ID, AT_NAME, AT_VALUE) " \
+ "VALUES " \
+ "(?, 'preview_image_name', ?)";
+
+ query.prepare(queryAddPreviewImage);
+ query.addBindValue(widgetId);
+ query.addBindValue(previewImage);
+ query.exec();
+ qDebug() << query.executedQuery();
+ }
+
+ // Add attribute widget:traslation_file
+ if (!translationFileName.isEmpty()) {
+ QString queryAddWidgetTranslationFile =
+ "INSERT INTO CA_ATTRIBUTE " \
+ "(AT_ENTRY_ID, AT_NAME, AT_VALUE) " \
+ "VALUES " \
+ "(?, 'widget:traslation_file', ?)";
+
+ query.prepare(queryAddWidgetTranslationFile);
+ query.addBindValue(widgetId);
+ query.addBindValue(translationFileName);
+ query.exec();
+ qDebug() << query.executedQuery();
+ }
+}
+
+/*!
+ Returns true if a widget with the given uid exists in the database.
+ */
+int CaClientProxy::hsWidgetId(int uid)
+{
+ int result(-1);
+ 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()) {
+ result = query.value(query.record().indexOf("AT_ENTRY_ID")).toInt();
+ }
+ qDebug() << query.executedQuery();
+
+ return result;
+}
+
+//----------------------------------------------------------------------------
+//
+//----------------------------------------------------------------------------
+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< QSharedPointer<CaEntry> > entryList;
+ getData(entryIdList, entryList);
+ QList<QList<int> > parentsIds;
+ foreach(QSharedPointer<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< QSharedPointer<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_FILENAME, IC_SKIN_ID, IC_APP_ID \
+ 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();
+ QSharedPointer<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.setFilename(query.value(query.record().indexOf(
+ "IC_FILENAME")).toString());
+ icon.setSkinId(query.value(query.record().indexOf(
+ "IC_SKIN_ID")).toString());
+ icon.setApplicationId(query.value(query.record().indexOf(
+ "IC_APP_ID")).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< QSharedPointer<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()));
+
+ 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(") ");
+ }
+
+ QString whereAttributes;
+ if (query.attributes().count()) {
+ QMap<QString, QString> attributes = query.attributes();
+ QMapIterator<QString, QString> atrIt(attributes);
+ int j = 1;
+ while (atrIt.hasNext()) {
+ atrIt.next();
+
+ // at1.AT_NAME = 'Attribute_Name_1' AND at1.AT_VALUE = 'Attribute_VALUE_1'
+ whereAttributes.append(" AND ").append(
+ " at").append(QString().setNum(j)).append(".AT_NAME = \'").append(
+ atrIt.key()).append("\' ").append(
+ " AND ").append(
+ " at").append(QString().setNum(j)).append(".AT_VALUE = \'").append(
+ atrIt.value()).append("\' ");
+
+ j++;
+ }
+ whereStatement.append(whereAttributes);
+
+ }
+
+ whereStatement.append(" GROUP BY ENTRY_ID ");
+
+ QString leftJoins;
+ if (query.attributes().count()) {
+ for (int j=1; j<=query.attributes().count(); j++) {
+ // LEFT JOIN CA_ATTRIBUTE as at1 ON ENTRY_ID = at1.AT_ENTRY_ID
+ leftJoins.append(
+ " LEFT JOIN CA_ATTRIBUTE as at").append(QString().setNum(j)).append(
+ " ON ENTRY_ID = at").append(QString().setNum(j)).append(" .AT_ENTRY_ID ");
+ }
+ }
+
+ QSqlQuery sqlquery(db);
+ if (query.parentId() == 0) {
+ // sort
+ QString queryString("SELECT ENTRY_ID from CA_ENTRY ");
+ queryString.append(leftJoins);
+ queryString.append(" 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 ");
+ QString queryString2(" LEFT JOIN CA_GROUP_ENTRY ON GE_ENTRY_ID = ENTRY_ID WHERE GE_GROUP_ID = ? ");
+ queryString2.append(whereStatement);
+ queryString.append(leftJoins);
+ queryString.append(queryString2);
+
+ 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::touch(const CaEntry &entry)
+{
+ int id = entry.id();
+ if (id <= 0) {
+ const int uid = entry.attribute(
+ QString(APPLICATION_UID_ATTRIBUTE_NAME)).toInt();
+ id = getEntryIdByUid(entry, uid);
+ }
+
+ 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< QSharedPointer<CaEntry> > entryList;
+ if (getData(QList<int>() << id, entryList) == NoErrorCode) {
+ QList<int> parentIds;
+ GetParentsIds(QList<int>() << id, parentIds);
+ CaNotifiers::NotifyTouched(id);
+ }
+ } 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;
+}
+
+//----------------------------------------------------------------------------
+//
+//----------------------------------------------------------------------------
+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 ");
+ }
+
+}
+
+//----------------------------------------------------------------------------
+//
+//----------------------------------------------------------------------------
+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_SKIN_ID = :IC_SKIN_ID"
+ " AND IC_APP_ID = :IC_APP_ID");
+ query.bindValue(":IC_FILENAME",
+ entryClone->iconDescription().filename());
+ query.bindValue(":IC_SKIN_ID",
+ entryClone->iconDescription().filename());
+ query.bindValue(":IC_APP_ID",
+ entryClone->iconDescription().filename());
+
+
+ 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().isEmpty()
+ || !iconDescription.skinId().isEmpty()
+ || !iconDescription.applicationId().isEmpty())) {
+ query.prepare(
+ "INSERT INTO CA_ICON"
+ " (IC_FILENAME, IC_SKIN_ID, IC_APP_ID)"
+ " VALUES ( ? , ? , ? , ? , ? )");
+ query.addBindValue(iconDescription.filename());
+ query.addBindValue(iconDescription.skinId());
+ query.addBindValue(iconDescription.applicationId());
+ success = query.exec();
+ qDebug() << query.executedQuery();
+ iconId = query.lastInsertId().toInt();
+ }
+ CaObjectAdapter::setId(iconDescription, iconId);
+ entryClone->setIconDescription(iconDescription);
+ }
+ return success;
+}
+
+//----------------------------------------------------------------------------
+//
+//----------------------------------------------------------------------------
+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;
+}
+
+//----------------------------------------------------------------------------
+//
+//----------------------------------------------------------------------------
+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;
+}
+
+int CaClientProxy::getEntryIdByUid(const CaEntry &entry, const int uid)
+{
+ int result = -1;
+
+ QSqlQuery query(dbConnection());
+ query.prepare("SELECT ENTRY_ID from CA_ENTRY where EN_UID=?");
+ query.addBindValue(uid);
+ bool success = query.exec();
+
+ if (success && (query.first())) {
+ result = query.value(query.record().indexOf("ENTRY_ID")).toInt();
+ }
+
+ return result;
+}