/*

* Copyright (c) 2008 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:  JavaCommDB class implementation

 *

*/

#include "javacommdb.h"

#include "jstringutils.h"

#include "s60commonutils.h"

#include <e32base.h>

#include <e32debug.h>

#include "logger.h"

#include "javajniutils.h"

using namespace CommsDat;

using namespace java::util;

// CONSTANTS

_LIT(KIAPTable, "IAP");

_LIT(KConnectionPreferencesTable, "ConnectionPreferences");

_LIT(KGlobalSettingsTable, "GlobalSettings");

//_LIT( KNetworkTable, "Network" );

_LIT(KFieldNameRecordId, "RecordId");

_LIT(KFieldNameName, "Name");

JNIEXPORT void JNICALL Java_com_nokia_mid_iapinfo_CommsTable__1destroy(JNIEnv* ,

        jclass,

        jint aHandle)

{

    LOG1(ESOCKET, EInfo, "CJAVACOMMDB + destroy() handle: %D", aHandle);

    JavaCommDB* commdb = reinterpret_cast<JavaCommDB *>(aHandle);

    delete commdb;

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB - destroy()");

}

JNIEXPORT jint JNICALL Java_com_nokia_mid_iapinfo_CommsTable__1construct(JNIEnv* ,

        jclass)

{

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB + construct()");

    JavaCommDB *cdb = new JavaCommDB();

    TInt handle = reinterpret_cast<jint>(cdb);

    LOG1(EJavaIapInfo, EInfo, "CJAVACOMMDB - construct() handle: %D", handle);

    return handle;

}

JNIEXPORT jint JNICALL Java_com_nokia_mid_iapinfo_CommsTable__1open(JNIEnv* aJni,

        jclass, jint aHandle,

        jstring aTableName)

{

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB + open()");

    JavaCommDB* commdb = reinterpret_cast<JavaCommDB *>(aHandle);

    JStringUtils table(*aJni, aTableName);

    //LOG1(EJavaIapInfo,  EInfo,  "CJAVACOMMDB opening table: %S", table );

    TRAPD(error, commdb->OpenL(table));

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB - open()");

    return error;

}

JNIEXPORT void JNICALL Java_com_nokia_mid_iapinfo_CommsTable__1close(JNIEnv* ,

        jclass, jint aHandle)

{

    LOG1(EJavaIapInfo, EInfo, "CJAVACOMMDB + close() handle: %D", aHandle);

    JavaCommDB* commdb = reinterpret_cast<JavaCommDB *>(aHandle);

    TRAP_IGNORE(commdb->Close());

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB - close()");

}

JNIEXPORT jint JNICALL Java_com_nokia_mid_iapinfo_CommsTable__1getRecordCount(JNIEnv* ,

        jclass,

        jint aHandle)

{

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB + getRecordCount()");

    JavaCommDB* commdb = reinterpret_cast<JavaCommDB *>(aHandle);

    TInt count = 0;

    count = commdb->GetRecordCount();

    LOG1(EJavaIapInfo, EInfo, "CJAVACOMMDB returning value: %D", count);

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB - getRecordCount()");

    return count;

}

JNIEXPORT jint JNICALL Java_com_nokia_mid_iapinfo_CommsTable__1readIntFieldValue(JNIEnv* aJni,

        jclass,

        jint aHandle,

        jstring aFieldName,

        jintArray aError)

{

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB + readIntFieldValue()");

    TInt value = 0;

    JavaCommDB* commdb = reinterpret_cast<JavaCommDB *>(aHandle);

    JStringUtils field(*aJni, aFieldName);

    //LOG1(EJavaIapInfo,  EInfo,  "CJAVACOMMDB  reading field value: %S", field );

    TRAPD(err, value = commdb->GetIntFieldValueL(field));

    // Put the native error code into the Java error array

    jint javaError[1] =

        {   err};

    aJni->SetIntArrayRegion(aError, 0, 1, javaError);

    LOG1(EJavaIapInfo, EInfo, "CJAVACOMMDB  returning value: %D", value);

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB - readIntFieldValue()");

    return value;

}

JNIEXPORT jstring JNICALL Java_com_nokia_mid_iapinfo_CommsTable__1readStringFieldValue(JNIEnv* aJni,

        jclass,

        jint aHandle,

        jstring aFieldName,

        jintArray aError)

{

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB + readStringFieldValue()");

    HBufC* value = NULL;

    jstring str = NULL;

    JavaCommDB* commdb = reinterpret_cast<JavaCommDB *>(aHandle);

    JStringUtils field(*aJni, aFieldName);

    //LOG1(EJavaIapInfo,  EInfo,  "CJAVACOMMDB  reading field value: %S", field );

    TRAPD(err, value = commdb->GetStringFieldValueL(field));

    if (NULL != value && KErrNone == err)

    {

        str = S60CommonUtils::NativeToJavaString(*aJni, value->Des());

        //LOG1(EJavaIapInfo, EInfo, "CJAVACOMMDB  returning value: %S", value->Des() );

        delete value;

    }

    // Put the native error code into the Java error array

    jint javaError[1] =

        {   err};

    aJni->SetIntArrayRegion(aError, 0, 1, javaError);

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB - readStringFieldValue()");

    return str;

}

JNIEXPORT jint JNICALL Java_com_nokia_mid_iapinfo_CommsTable__1next(JNIEnv* ,

        jclass, jint aHandle)

{

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB + next()");

    JavaCommDB* commdb = reinterpret_cast<JavaCommDB *>(aHandle);

    TInt rec = commdb->Next();

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB - next()");

    return rec;

}

JNIEXPORT jint JNICALL Java_com_nokia_mid_iapinfo_CommsTable__1previous(JNIEnv* ,

        jclass,

        jint /*aHandle*/)

{

    return 0;

}

JNIEXPORT jint JNICALL Java_com_nokia_mid_iapinfo_CommsTable__1findById(JNIEnv* ,

        jclass,

        jint aHandle,

        jint aId)

{

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB + findById()");

    TInt recId = 0;

    JavaCommDB* commdb = reinterpret_cast<JavaCommDB *>(aHandle);

    recId = commdb->FindById(aId);

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB - findById()");

    return recId;

}

JNIEXPORT jint JNICALL Java_com_nokia_mid_iapinfo_CommsTable__1findByName(JNIEnv* aJni,

        jclass,

        jint aHandle,

        jstring aName)

{

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB + findByName()");

    TInt recId = 0;

    JStringUtils name(*aJni, aName);

    JavaCommDB* commdb = reinterpret_cast<JavaCommDB *>(aHandle);

    TRAP(recId, recId = commdb->FindByNameL(name));

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB - findByName()");

    return recId;

}

/* ---------------------------------------------------------------------------

 *    JavaCommDB class implementation ;

 * ---------------------------------------------------------------------------

 */

// ---------------------------------------------------------------------------

//    Delete allocated member objects.

// -----------------------------------------------------------------------------

JavaCommDB::~JavaCommDB()

{

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB  + ~JavaCommDB()");

    Close();

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB  - ~JavaCommDB()");

}

// ---------------------------------------------------------------------------

//    Delete allocated member objects.

//    @return error code

// -----------------------------------------------------------------------------

TInt JavaCommDB::Close()

{

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB + Close()");

    iCurrentRecord = 0;

    delete iTable;

    iTable = NULL;

    delete iDb;

    iDb = NULL;

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB - Close()");

    return KErrNone;

}

// ---------------------------------------------------------------------------

//    Opens the given table.

//    @param aTablename name of the CommDB table to be opened

//    @return error code

// -----------------------------------------------------------------------------

void JavaCommDB::OpenL(const TDesC& aTableName)

{

    //LOG1(EJavaIapInfo, EInfo, "CJAVACOMMDB + OpenL(): open table: %S",   aTableName);

    iDb = CMDBSession::NewL(KCDVersion1_1);

    iCurrentRecord = 0;

    if (0 == aTableName.Compare(KIAPTable))

    {

        // Create IAP table recordset

        iTable = (CMDBRecordSet<CCDRecordBase> *)(new(ELeave) CMDBRecordSet<

                 CCDIAPRecord> (KCDTIdIAPRecord));

        LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB  OpenL(): IAP table opened.");

    }

    else if (0 == aTableName.Compare(KGlobalSettingsTable))

    {

        iTable = (CMDBRecordSet<CCDRecordBase> *) new(ELeave) CMDBRecordSet<

                 CCDGlobalSettingsRecord> (KCDTIdGlobalSettingsRecord);

        LOG(EJavaIapInfo, EInfo,

            "CJAVACOMMDB  OpenL(): GlobalSettings table opened.");

    }

    else if (0 == aTableName.Compare(KConnectionPreferencesTable))

    {

        iTable = (CMDBRecordSet<CCDRecordBase> *) new(ELeave) CMDBRecordSet<

                 CCDConnectionPrefsRecord> (KCDTIdConnectionPrefsRecord);

        LOG(EJavaIapInfo, EInfo,

            "CJAVACOMMDB  OpenL(): ConnectionPreferences table opened.");

    }

    // Load the table

    iTable->LoadL(*iDb);

    LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB - OpenL()");

}

// ---------------------------------------------------------------------------

//    Get number of records in the current table.

//    @return record count

// -----------------------------------------------------------------------------

TInt JavaCommDB::GetRecordCount()

{

    return iTable->iRecords.Count();

}

// ---------------------------------------------------------------------------

//    Retrieves the value of the given field from the actual record.

//    @param aFieldName name of the field.

//    @return integer value of the field

// -----------------------------------------------------------------------------

TInt JavaCommDB::GetIntFieldValueL(const TDesC& aFieldName)

{

    TPtrC fieldName(aFieldName);

    TInt valueType;

    TUint32 value = 0;

    // If the field is the RecordId we have to use RecordId() function

    if (0 == aFieldName.Compare(KFieldNameRecordId))

    {

        value

        = (static_cast<CCDRecordBase*>(iTable->iRecords[iCurrentRecord]))->RecordId();

        LOG1(EJavaIapInfo, EInfo,

             "CJAVACOMMDB  GetIntFieldValueL(): getting RecordId: %D", value);

        return value;

    }

    // Get reference to the field by its name

    CMDBField<TUint32>

    * field =

        (CMDBField<TUint32> *)(static_cast<CCDRecordBase*>(iTable->iRecords[iCurrentRecord]))->GetFieldByNameL(

            fieldName, valueType);

    if (field->IsNull())

    {

        // The field is not initialized with a value

        LOG(EJavaIapInfo, EInfo,

            "CJAVACOMMDB  GetIntFieldValueL(): CMDBField is NULL!");

    }

    else

    {

        value = *field;

        LOG1(EJavaIapInfo, EInfo,

             "CJAVACOMMDB  GetIntFieldValueL(): getting int value: %D",

             value);

    }

    return value;

}

// ---------------------------------------------------------------------------

//    Retrieves the value of the given field from the actual record.

//    @param aFieldName name of the field.

//    @return String value of the field

// -----------------------------------------------------------------------------

HBufC* JavaCommDB::GetStringFieldValueL(const TDesC& aFieldName)

{

    TPtrC fieldName(aFieldName);

    HBufC* strValue = NULL;

    TInt valueType;

    // Get reference to the field by its name

    CMDBField<TDesC>

    * descField =

        (CMDBField<TDesC> *)(static_cast<CCDRecordBase*>(iTable->iRecords[iCurrentRecord]))->GetFieldByNameL(

            fieldName, valueType);

    if (descField->IsNull())

    {

        LOG(EJavaIapInfo, EInfo,

            "CJAVACOMMDB  GetStringFieldValueL(): CMDBField is NULL!");

    }

    else

    {

        TPtrC value = descField->GetL();

        strValue = value.AllocL();

        //LOG1(EJavaIapInfo, EInfo,"CJAVACOMMDB  GetStringFieldValue(): getting string value: %S", value);

    }

    return strValue;

}

// ---------------------------------------------------------------------------

//    Changes the actual record pointer to the next record.

//    @return number of the actual record

// -----------------------------------------------------------------------------

TInt JavaCommDB::Next()

{

    if (iCurrentRecord < GetRecordCount() - 1)

    {

        ++iCurrentRecord;

        return iCurrentRecord;

    }

    else

    {

        return KErrEof;

    }

}

// ---------------------------------------------------------------------------

//    Changes the actual record pointer to the previous record.

//    @return number of the actual record

// -----------------------------------------------------------------------------

TInt JavaCommDB::Previous()

{

    return NULL;

}

// ---------------------------------------------------------------------------

//    Finds a record in the current table by its name. The search is case

//    sensitive. If the record exists the current record will be changed to

//    this record.

//    @param aName name of the record

//    @return with the RecordId of the found record, KErrNotFound if no record

//    found with the given name.

// -----------------------------------------------------------------------------

TInt JavaCommDB::FindByNameL(const TDesC& aName)

{

    TInt ret = KErrNotFound;

    TInt count = GetRecordCount();

    TInt i = 0;

    HBufC* strValue = NULL;

    TPtrC FName(KFieldNameName);

    TInt valueType;

    while ((i < count) && (ret == KErrNotFound))

    {

        // Get reference to the field by its name

        CMDBField<TDesC>

        * descField =

            (CMDBField<TDesC> *)(static_cast<CCDRecordBase*>(iTable->iRecords[i]))->GetFieldByNameL(

                FName, valueType);

        if (!(descField->IsNull()))

        {

            TPtrC value = descField->GetL();

            strValue = value.AllocL();

            //LOG1(EJavaIapInfo, EInfo, "CJAVACOMMDB  FindByName(): getting string value: %S", value);

            if (0 == aName.Compare(strValue->Des()))

            {

                LOG(EJavaIapInfo, EInfo,

                    "CJAVACOMMDB  FindByName(): record found.");

                iCurrentRecord = i;

                ret

                = (static_cast<CCDRecordBase*>(iTable->iRecords[i])->RecordId());

            }

            delete strValue;

        }

        i++;

    }

    return ret;

}

// ---------------------------------------------------------------------------

//    Finds a record in the current table by its RecordId. If the record exists

//    the current record will be changed to this record.

//    @param aId RecordId of the record

//    @return with the RecordId of the found record, KErrNotFound if no record

//    found with the given RecordId.

// -----------------------------------------------------------------------------

TInt JavaCommDB::FindById(TInt aId)

{

    TInt ret = KErrNotFound;

    TInt count = GetRecordCount();

    TInt i = 0;

    while ((i < count) && (ret == KErrNotFound))

    {

        if (aId

                == (static_cast<CCDRecordBase*>(iTable->iRecords[i])->RecordId()))

        {

            LOG(EJavaIapInfo, EInfo, "CJAVACOMMDB  FindById(): record found.");

            iCurrentRecord = i;

            ret

            = (static_cast<CCDRecordBase*>(iTable->iRecords[i])->RecordId());

        }

        i++;

    }

    return ret;

}