/*
 * Copyright (c) 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:  update api for contentinfodb 
 *
 */
#include "contentinfodbupdate.h"
#include "contentinfodbparser.h"
#include "contentinfodb.h"
#include "cpixcontentinfodbdef.h"

// ---------------------------------------------------------------------------
// ContentInfoDbUpdate::ContentInfoDbUpdate()
// ---------------------------------------------------------------------------
//
ContentInfoDbUpdate::ContentInfoDbUpdate() :
    iParser(NULL),mdb(NULL)
    {
    mdb = ContentInfoDb::instance();
    iParser = new ContentInfoDbParser();
    if (iParser)
        {
        connect(iParser, SIGNAL(categoryDetails(QMap<QString,QString>)),
                this, SLOT(slotupdateCategoryInfo(QMap<QString,QString>)));
        connect(iParser, SIGNAL(actionUri(QMap<QString,QString>)), this,
                SLOT(slotupdateUri(QMap<QString,QString>)));
        connect(iParser, SIGNAL(filedMapping(QString,QStringList)), this,
                SLOT(slotupdateFieldmapping(QString,QStringList)));
        connect(iParser, SIGNAL(firstLineMapping(QStringList)), this,
                SLOT(slotfirstLineMapping(QStringList)));
        connect(iParser, SIGNAL(relevancyMapping(QString,QString)), this,
                SLOT(slotrelevancyMapping(QString,QString)));
        }
    counter = 0;
    }
// ---------------------------------------------------------------------------
// ContentInfoDbUpdate::~ContentInfoDbUpdate()
// ---------------------------------------------------------------------------
//
ContentInfoDbUpdate::~ContentInfoDbUpdate()
    {
    ContentInfoDb::deleteinstance();
    }
// ---------------------------------------------------------------------------
// ContentInfoDbUpdate::UpdateDb()
// ---------------------------------------------------------------------------
//
bool ContentInfoDbUpdate::UpdateDb(QString xmlpath)
    {
    if (mdb)
       (void)mdb->Open();
    if (iParser)
        {
        primarykey = QString();
        return iParser->parse(xmlpath);
        }
    return false;
    }
// ---------------------------------------------------------------------------
// ContentInfoDbUpdate::UpdateBlacklisted()
// ---------------------------------------------------------------------------
//
bool ContentInfoDbUpdate::UpdateBlacklisted(QString primarykey, int value)
    {
    if (mdb)
        (void)mdb->Open();
    QString query = QString(QUERYUPDATEDATA).arg(MAINTABLENAME).arg(
            BLACKLISTSTATUS).arg(value).arg(TAGPRIMARYKEY).arg(primarykey);
    if (!mdb->writeData(query))
        return false;
    return true;
    }
// ---------------------------------------------------------------------------
// ContentInfoDbUpdate::UpdateIndexStatus()
// ---------------------------------------------------------------------------
//
bool ContentInfoDbUpdate::UpdateIndexStatus(QString primarykey, int value)
    {
    if (mdb)
        (void)mdb->Open();
    QString query = QString(QUERYUPDATEDATA).arg(MAINTABLENAME).arg(
            INDEXINGSTATUS).arg(value).arg(TAGPRIMARYKEY).arg(primarykey);
    if (!mdb->writeData(query))
        return false;
    return true;
    }
// ---------------------------------------------------------------------------
// ContentInfoDbUpdate::InsertPrimaryKey()
// ---------------------------------------------------------------------------
//
QString ContentInfoDbUpdate::InsertPrimaryKey(QString tableName,
        QString tagName, QMap<QString, QString> data)
    {
    QMapIterator<QString, QString> i(data);
    QString query;
    QString p_key;
    while (i.hasNext())
        {
        i.next();
        if (i.key() == tagName)
            {
            p_key = i.value();
            break;
            }
        }
    query = QString(QUERYINSERTROW).arg(tableName).arg(tagName).arg(p_key);
    mdb->writeData(query);
    return p_key;
    }
// ---------------------------------------------------------------------------
// ContentInfoDbUpdate::slotupdateCategoryInfo()
// ---------------------------------------------------------------------------
//
void ContentInfoDbUpdate::slotupdateCategoryInfo(QMap<QString, QString> map)
    {
    QString query;
    QString p_key = InsertPrimaryKey(MAINTABLENAME, TAGPRIMARYKEY, map);
    primarykey = p_key;
    if (p_key.length())
        {
        QMapIterator<QString, QString> i(map);
        while (i.hasNext())
            {
            i.next();
            if (i.key() != TAGPRIMARYKEY)
                {
                query = QString();
                if ((i.key() == TAGACTIONURI) || (i.key() == TAGFIELDMAP)
                        || (i.key() == TAGRELEVANCY) || (i.key()
                        == TAGRESULTFIRSTLINE))
                    {
                    counter++;
                    QString tablename = QString(DYNAMICTABLE).arg(counter);
                    query = QString(QUERYUPDATEDATA).arg(MAINTABLENAME).arg(
                            i.key()).arg(tablename).arg(TAGPRIMARYKEY).arg(
                            p_key);
                    }
                else
                    {
                    query = QString(QUERYUPDATEDATA).arg(MAINTABLENAME).arg(
                            i.key()).arg(i.value()).arg(TAGPRIMARYKEY).arg(
                            p_key);
                    }
                if (!mdb->writeData(query))
                    {
                    
                    }                
                }
            }
        }
    }
// ---------------------------------------------------------------------------
// ContentInfoDbUpdate::slotupdateUri()
// ---------------------------------------------------------------------------
//
void ContentInfoDbUpdate::slotupdateUri(QMap<QString, QString> map)
    {
    //get actionuri table name
    QString query = QString(QUERYDATARETRIVAL).arg(TAGACTIONURI).arg(
            MAINTABLENAME).arg(TAGPRIMARYKEY).arg(primarykey);
    QString actionuritablename = mdb->readStringData(query);

    if (actionuritablename.length())
        {
        query = QString();
        query = QString(QUERYCREATEACTIONURITABLE).arg(actionuritablename);
        mdb->createTable(actionuritablename, query);
        QString p_key = InsertPrimaryKey(actionuritablename,
                TAGACTIONURISTRING, map);
        if (p_key.length())
            {
            QMapIterator<QString, QString> i(map);
            while (i.hasNext())
                {
                i.next();
                if (i.key() != TAGACTIONURISTRING)
                    {
                    query = QString();
                    query
                            = QString(QUERYUPDATEDATA).arg(actionuritablename).arg(
                                    i.key()).arg(i.value()).arg(
                                    TAGACTIONURISTRING).arg(p_key);
                    if (!mdb->writeData(query))
                        {
                        
                        }   
                    }
                }
            }
        }
    }
// ---------------------------------------------------------------------------
// ContentInfoDbUpdate::slotupdateFieldmapping()
// ---------------------------------------------------------------------------
//
void ContentInfoDbUpdate::slotupdateFieldmapping(QString key,
        QStringList value)
    {
    //get fieldmap table name from maintable
    QString query = QString(QUERYDATARETRIVAL).arg(TAGFIELDMAP).arg(
            MAINTABLENAME).arg(TAGPRIMARYKEY).arg(primarykey);
    QString fieldtablename = mdb->readStringData(query);

    if (fieldtablename.length())
        {
        // create a table for fieldmap 
        query = QString();
        query = QString(QUERYCREATEFIELDMAPTABLE).arg(fieldtablename);
        mdb->createTable(fieldtablename, query);

        // insert the field in filedmap table
        query = QString();
        query
                = QString(QUERYINSERTROW).arg(fieldtablename).arg(TAGFIELD).arg(
                        key);
        mdb->writeData(query);
            {
            
            }

        counter++;
        query = QString();

        QString tablename = QString(DYNAMICTABLE).arg(counter);

        // enter the value as table name second column in field map will refer to another table
        query
                = QString(QUERYUPDATEDATA).arg(fieldtablename).arg(TAGURILIST).arg(
                        tablename).arg(TAGFIELD).arg(key);
        if (!mdb->writeData(query))
            {
            
            }

        query = QString();
        // creating a table for the field map values 
        query = QString(QUERYCREATEFIELDMAPSUBTABLE).arg(tablename);
        mdb->createTable(tablename, query);

        for (int i = 0; i < value.count(); i++)
            {
            query = QString();
            // inserting the uri list mapped for a particular field
            query = QString(QUERYINSERTROW).arg(tablename).arg(TAGAURI).arg(
                    value[i]);
            if (!mdb->writeData(query))
                {
            
                }
            }
        }
    }
// ---------------------------------------------------------------------------
// ContentInfoDbUpdate::slotfirstLineMapping()
// ---------------------------------------------------------------------------
//
void ContentInfoDbUpdate::slotfirstLineMapping(QStringList list)
    {
    //get actionuri table name
    QString query = QString(QUERYDATARETRIVAL).arg(TAGRESULTFIRSTLINE).arg(
            MAINTABLENAME).arg(TAGPRIMARYKEY).arg(primarykey);
    QString firstlinetablename = mdb->readStringData(query);

    if (firstlinetablename.length())
        {
        query = QString();
        query = QString(QUERYCREATEFIRSTLINETABLE).arg(firstlinetablename);
        mdb->createTable(firstlinetablename, query);

        for (int i = 0; i < list.count(); i++)
            {
            query = QString();
            // inserting the uri list mapped for a particular field
            query = QString(QUERYINSERTROW).arg(firstlinetablename).arg(
                    TAGFIELD).arg(list[i]);
            if (!mdb->writeData(query))
                {
                
                }
            }
        }
    }
// ---------------------------------------------------------------------------
// ContentInfoDbUpdate::slotrelevancyMapping()
// ---------------------------------------------------------------------------
//
void ContentInfoDbUpdate::slotrelevancyMapping(QString field,
        QString boostvalue)
    {
    QString query = QString(QUERYDATARETRIVAL).arg(TAGRELEVANCY).arg(
            MAINTABLENAME).arg(TAGPRIMARYKEY).arg(primarykey);
    QString relevancytablename = mdb->readStringData(query);
    if (relevancytablename.length())
        {
        query = QString();
        query = QString(QUERYCREATERELEVANCYTABLE).arg(relevancytablename);
        mdb->createTable(relevancytablename, query);

        query = QString();
        // inserting field name as a primary key
        query
                = QString(QUERYINSERTROW).arg(relevancytablename).arg(
                        TAGFIELD).arg(field);

        if (!mdb->writeData(query))
            {

            }
        query = QString();
        // updating the row with boostvalue
        query = QString(QUERYUPDATEDATA).arg(relevancytablename).arg(
                TAGBOOSTVALUE).arg(boostvalue).arg(TAGFIELD).arg(field);
        if (!mdb->writeData(query))
            {

            }
        }
    }
// ---------------------------------------------------------------------------
// ContentInfoDbUpdate::slotrelevancyMapping()
// ---------------------------------------------------------------------------
//
void ContentInfoDbUpdate::deleteCategory(QString Key)
    {
    if (mdb)
        (void)mdb->Open();
    mdb->writeData(QString(QUERYDELETE).arg(Key));
    }