/*

* 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.

*

* Description: 

*

*/

#include <QSqlQuery>

#include <QVariant>

#include "channelhistorywrapper.h"

#include "irdb.h"

channelHistoryWrapper::channelHistoryWrapper()

{

}

channelHistoryWrapper::~channelHistoryWrapper()

{

} 

bool channelHistoryWrapper::deleteChannelHistory(const columnMap* const condAND,

                                                 const columnMap* const condOR)

{

    QString deleteSqlStr;

    if( (NULL != condAND)&&(NULL != condOR) )

    {

        return false;

    }

    if(condAND)

    {

        if(condAND->isEmpty())

        {

            return false;

        }

    }

    if(condOR)

    {

        if(condOR->isEmpty())

        {

            return false;

        }

    }

    deleteSqlStr = "delete from channelHistory ";   

    combineDeleteStr(condAND, condOR, colNameView, deleteSqlStr);

    return m_pIRDB->deleteRow(deleteSqlStr)?false:true;

}

bool channelHistoryWrapper::getIRTableCB(QSqlQuery& aIRDataSet, QList<QVariant*>* pQListDataSet)

{

    while (aIRDataSet.next()) 

    {

        QVariant* const p = new QVariant[IRDB_CHANNELHISTORY_COLUMN];

        *pQListDataSet<<p;

        for(int i = 0; i < IRDB_CHANNELHISTORY_COLUMN; i++)

        {

            *(p+i) = aIRDataSet.value(i);

        }

    }

    return true;

}

uint channelHistoryWrapper::srhChannelId(QString& condUserCidStr,

                                         const columnMap* const condAND,

                                         const columnMap* const condOR)

{

    uint srhCID = 0;

    //if condAND or condOR has channeld,

    if(condAND != NULL)

    {

        srhCID = (condAND->value(channelId)).toUInt();         

    } 

    else if(condOR != NULL)

    {

        srhCID = (condOR->value(channelId)).toUInt();         

    }

    if(srhCID)

    {

        return srhCID ;

    }

    //channelId column is false

    //only one case, go to station view, channelUrl and channelNickName

    //search channelId according to urlinof and channelNickName;

    QString srhStr;

    if(condAND != NULL)

    {

        if( ( !(condAND->value(channelUrl).isEmpty())  )&&( !(condAND->value(channelNickName).isEmpty()) ) )

        {

            srhStr = "where "+ colNameView[channelUrl] + " = ";

            srhStr = srhStr + "'" + condAND->value(channelUrl) + "' AND " ;

            srhStr = srhStr + colNameView[channelNickName] + " = ";

            srhStr = srhStr + "'" + condAND->value(channelNickName) + "'";

        }

        condUserCidStr = srhStr;

    }

    return srhCID;

}

/*

* this fuction don't suport "update" operation for mutliple records ;

* if condAND != NULL AND condOR != NULL, illegal operation;

* if condAND != NULL or condOR != NULL, it must be "update" operation.

* if condAND == NULL AND condOR == NULL, it is "insert" or "update" operation;

* 

*/

bool channelHistoryWrapper::putChannelHistory(const columnMap* const RowData,

                                              uint* const cidUserDefined,

                                              const logoMap*   const logoData,

                                              const columnMap* const condAND,

                                              const columnMap* const condOR)

{

    uint uCid = 0;

    QString insSqlStr;

    QString updSqlStr;

    QString condSqlStr;       

    QString condUserCidStr;

    columnMap* const RowDataAppend = const_cast<columnMap*>(RowData);

    QList<QByteArray>* pImgList = NULL;

    bool ret = true;

    if( NULL == RowData )

    {

        return false;

    }

    if(RowData->isEmpty())

    {

        return false;

    }

    if( (NULL != condAND)&&(NULL != condOR) )

    {

        return false;

    }

    if(condAND)

    {

        if(condAND->isEmpty())

        {

            return false;

        }

    }

    if(condOR)

    {

        if(condOR->isEmpty())

        {

            return false;

        }

    }

    if(cidUserDefined)

    {

        *cidUserDefined = 0;	

    }

    insSqlStr = "insert into IRBuff ";   

    updSqlStr = "update IRBuff set ";

    RowDataAppend->insert(opt, QString::number(IRDB_OPT_INSERT));    

    RowDataAppend->insert(dataSource, QString::number(DATA_OF_CHANNELHISTORY));

    if(NULL != logoData)

    {

        pImgList = new QList<QByteArray>();

        combinePutStr(RowDataAppend, colNameView, insSqlStr, updSqlStr, logoData, pImgList); 

        *pImgList=logoData->values();

    }

    else

    {

        combinePutStr(RowDataAppend, colNameView, insSqlStr, updSqlStr);

    }    

    if( (NULL == condAND)&&(NULL == condOR) )

    {

        uCid = srhChannelId(condUserCidStr,RowData);

    }

    else //here it must be "update" operation; condition string 

    {

        uCid = srhChannelId(condUserCidStr,condAND, condOR);

        combineCondStr(condAND, condOR, colNameView, condSqlStr);

    }

    if(uCid)

    {

        //updSqlStr += condSqlStr;

        m_pIRDB->chgRowIRDB(insSqlStr, updSqlStr, uCid, condSqlStr, pImgList)? ret = false:true;

    }

    else //here deliver the updSqlstr and condSqlStr seperately.

    {

        m_pIRDB->chgRowIRDB(insSqlStr, updSqlStr, cidUserDefined, condSqlStr, condUserCidStr, pImgList)?ret = false:true;

    }  

    if(pImgList)

    {

        delete pImgList;

        pImgList = NULL;

    }

    return ret;

}    

QList<QVariant*>* channelHistoryWrapper::getChannelHistory(const columnMap* const condAND,  

                                                     const columnMap* const condOR)

{

    QString sltSqlStr;

    QList<QVariant*> *pDataSet = NULL;

    if( (NULL != condAND)&&(NULL != condOR) )

    {

        return NULL;

    }

    if(condAND)

    {

        if(condAND->isEmpty())

        {

            return NULL;

        }

    }

    if(condOR)

    {

        if(condOR->isEmpty())

        {

            return NULL;

        }

    }

    sltSqlStr = "select * from IRView_channelinfo ";

    combineGetStr(condAND, condOR, colNameView,sltSqlStr);

    pDataSet = new QList<QVariant*>();

    if( m_pIRDB->selectRow(this, sltSqlStr, pDataSet) )

    {

        delete pDataSet;

        pDataSet = NULL;

    }

    return pDataSet;

}