/*

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

*

*/

#include <QSqlQuery>

#include <QVariant>

#include "irdbwrapper.h"

#include "irdb.h"

IRDBWrapper::IRDBWrapper()//: m_BuffFlag(true)

{     

    m_pIRDB = IRDB::getInstance();

}

IRDBWrapper::~IRDBWrapper()

{

    if(m_pIRDB)

    {  	

        m_pIRDB->releaseInstance();

        m_pIRDB = NULL;

    }

} 

/*

* If all parameters are default, all rows in IRDB will return;

*/                       

QList<QVariant*>* IRDBWrapper::getIRDB(const columnMap* const condAND,  

                                 const columnMap* const condOR)

{

    QString condSqlStr;

    QList<QVariant*> *pIRDataSet = NULL;

    combineCondStr(condAND, condOR, colNameView, condSqlStr);

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

    {

        combineCondStr(condAND, condOR, colNameView, condSqlStr);

    }

    pIRDataSet = new QList<QVariant*>();

    if( m_pIRDB->selectRowIRDB(this, condSqlStr, false, NULL, pIRDataSet) )

    {

        delete pIRDataSet;

        pIRDataSet = NULL;

    }

    return pIRDataSet;

}

/*

* If all parameters are default, all cid rows in IRDB will return;

*/                       

QList<uint>* IRDBWrapper::getChannelId(const columnMap* const condAND,  

                                       const columnMap* const condOR)

{

    QString condSqlStr;

    QList<uint>* pQListCIDSet = NULL;

    /*this case is wrong logic*/

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

    {

        return NULL;

    }

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

    {

        combineCondStr(condAND, condOR, colNameView, condSqlStr);

    }

    pQListCIDSet = new QList<uint>();

    if( m_pIRDB->selectRowIRDB(this, condSqlStr, true, pQListCIDSet, NULL) )

    {

        delete pQListCIDSet;

        pQListCIDSet = NULL;

    }

    return pQListCIDSet;

}    

bool IRDBWrapper::loadDataOfChannelIdCB(QSqlQuery& aIRDataSet, QList<uint>* pQListCIDSet)

{

    while(aIRDataSet.next()) 

    {

        *pQListCIDSet<<aIRDataSet.value(0).toUInt(); 

    }

    return true;

}

bool IRDBWrapper::loadDataOfIRDBCB(QSqlQuery& aIRDataSet, QList<QVariant*>* pIRDataSet)

{

    while (aIRDataSet.next()) 

    {

         QVariant* const p = new QVariant[IRDB_CHANNELINFO_COLUMN];

        *pIRDataSet<<p;

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

        {

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

        }

    }

    return true;

}    

bool IRDBWrapper::getIRTableCB(QSqlQuery& aIRDataSet, QList<QVariant*>* p) 

{

    Q_UNUSED(aIRDataSet);

    Q_UNUSED(p);

    return true;

}

void IRDBWrapper::combinePutStr(const columnMap* const RowData,

                                const QString* pArryColName,

                                QString& insSqlStr, 

                                QString& updSqlStr,

                                const logoMap* const logoData,

                                QList<QByteArray>* logoArrayList)

{

    bool bContinue = false;

    columnMap::const_iterator it;

    logoMap::const_iterator itLogoMap;

    QString escStr;

    insSqlStr += "(";

    if(NULL != RowData)

    {

        bContinue = true;

        it = RowData->begin();

        while(it != RowData->end())

        {

            if(it != RowData->begin())

            {

                insSqlStr += ",";  

            }

            insSqlStr += pArryColName[it.key()];

            ++it;

        }

    }

    if(NULL != logoData)

    {

        itLogoMap = logoData->begin();

        while(itLogoMap != logoData->end())

        {

            if( (false != bContinue)||(itLogoMap != logoData->begin()) )

            {

                     insSqlStr += ",";  

            }

            insSqlStr += colNameLogo[itLogoMap.key()];

            ++itLogoMap;        

        }

    }

    insSqlStr += ") values(";

    if(NULL != RowData)

    {

        it = RowData->begin();

        while(it != RowData->end())

        {

            if(it != RowData->begin())

            {

                insSqlStr += ",";  

            }

            //here for escape char,

            escStr = it.value();

            escStr.replace('\'', "\'\'");

            insSqlStr = insSqlStr + "'"+ escStr+ "'";

            ++it;

        }    

    }    

    if(NULL != logoData)

    {

        itLogoMap = logoData->begin();

        while(itLogoMap != logoData->end())

        {

            if( (false != bContinue)||(itLogoMap != logoData->begin()) )

            {

                 insSqlStr += ",";  

            }

            insSqlStr = insSqlStr + " :"+colNameLogo[itLogoMap.key()];

            *logoArrayList<<itLogoMap.value();

            ++itLogoMap;        

        }

    }    

    insSqlStr += " )";

    //part two, create update string;

    if(NULL != RowData)

    {    

        it = RowData->begin();

        while( it != RowData->end())

        {

            if(it != RowData->begin())

            {

                updSqlStr += ", ";  

            }

            if(pArryColName[it.key()] == "opt")

            {

                updSqlStr = updSqlStr + pArryColName[it.key()] + "=" + "'" + QString::number(IRDB_OPT_TRIGGER) + "'";        

            }

            else

            {

                //here for escape char,

                escStr = it.value();

                escStr.replace('\'', "\'\'");

                updSqlStr = updSqlStr + pArryColName[it.key()] + "=" + "'" + escStr + "'";

            }

            ++it;

        }

    }

    if(NULL != logoData)

    {

        itLogoMap = logoData->begin();

        while(itLogoMap != logoData->end())

        {

            if( (false != bContinue)||(itLogoMap != logoData->begin()) )

            {

                 updSqlStr += ",";  

            }

            updSqlStr = updSqlStr + colNameLogo[itLogoMap.key()] + "=:"+colNameLogo[itLogoMap.key()];

            ++itLogoMap;        

        }

    }    

    return;

}

void IRDBWrapper::combineCondStr(const columnMap* const condAND,  

                                 const columnMap* const condOR,   

                                 const QString* pArryColName,

                                 QString& condSqlStr)

{

    bool bDone = false;

    columnMap::const_iterator it;

    if(NULL != condAND)

    {

        if( true != condAND->empty() )

        {

            it = condAND->begin();

            condSqlStr = " where "; 

            while( it != condAND->end())

            {

                if(it != condAND->begin())

                {

                    condSqlStr += " AND ";

                }

                condSqlStr = condSqlStr + pArryColName[it.key()] + "=" + "'" + it.value()+ "'" ;

                ++it;

            }

            bDone = true;               

        }

    }

    if(true == bDone)

    {

        return;   

    }

    if(NULL != condOR )

    {

        if( true != condOR->empty() )

        {

            it = condOR->begin();

            condSqlStr = " where ";

            while( it != condOR->end())

            {

                if(it != condOR->begin())

                {

                    condSqlStr += " OR ";

                }

                condSqlStr = condSqlStr + pArryColName[it.key()] + "=" + "'" + it.value()+ "'" ;

                ++it;

             }               

        }       

    }

    return;

}

void IRDBWrapper::combineGetStr(const columnMap* const condAND,

                                const columnMap* const condOR,

                                const QString* pArryColName,

                                QString& sltSqlStr)

{

    QString condStr;

    combineCondStr(condAND, condOR, pArryColName, condStr);

    sltSqlStr += condStr;

    return;

} 

void IRDBWrapper::combineDeleteStr(const columnMap* const condAND,

                                   const columnMap* const condOR,

                                   const QString* pArryColName,

                                   QString& dltSqlStr)

{

    QString condStr;

    combineCondStr(condAND, condOR, pArryColName, condStr);

    dltSqlStr += condStr;

    return;    

}