/*
* Copyright (c) 2010 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: SQLite wrapper
*
*/

#include <string>
#include <sqlite3.h>

#include "com_nokia_mj_impl_rms_SQLite.h"
#include "javajniutils.h"
#include "logger.h"

std::string jstringToString(JNIEnv* aEnv, const jstring& aString);

/*
 * Class:     com_nokia_mj_impl_rms_SQLite
 * Method:    sqlite3_open
 * Signature: (Ljava/lang/String;)I
 */
JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_rms_SQLite_sqlite3_1open
(JNIEnv* aEnv, jclass, jstring aFilename)
{
    std::string filename = jstringToString(aEnv, aFilename);
    sqlite3* db = 0;
    int rc = sqlite3_open(filename.c_str(), &db);

    if (rc)
    {
        std::string error = sqlite3_errmsg(db);
        ELOG3(EMidpRms, "sqlite3_open failed (%d): %s (db:%s)",
              rc, error.c_str(), filename.c_str());
        sqlite3_close(db);
        java::util::JniUtils::throwNewException(aEnv,
                                                "javax/microedition/rms/RecordStoreException", error);
        return 0;
    }
    return reinterpret_cast<jint>(db);
}

/*
 * Class:     com_nokia_mj_impl_rms_SQLite
 * Method:    sqlite3_close
 * Signature: (I)I
 */
JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_rms_SQLite_sqlite3_1close
(JNIEnv*, jclass, jint aDbHandle)
{
    sqlite3* db = reinterpret_cast<sqlite3*>(aDbHandle);
    int rc = sqlite3_close(db);
    return rc;
}

/*
 * Class:     com_nokia_mj_impl_rms_SQLite
 * Method:    sqlite3_exec
 * Signature: (ILjava/lang/String;)I
 */
JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_rms_SQLite_sqlite3_1exec
(JNIEnv* aEnv, jclass, jint aDbHandle, jstring aStatement)
{
    sqlite3* db = reinterpret_cast<sqlite3*>(aDbHandle);
    std::string statement = jstringToString(aEnv, aStatement);

    char* errmsg = 0;
    int rc = sqlite3_exec(db, statement.c_str(), 0, 0, &errmsg);
    if (rc)
    {
        ELOG3(EMidpRms, "sqlite3_exec failed (%d): %s (sql:%s)",
              rc , errmsg, statement.c_str());
    }
    sqlite3_free(errmsg);

    return rc;
}

/*
 * Class:     com_nokia_mj_impl_rms_SQLite
 * Method:    sqlite3_prepare_v2
 * Signature: (ILjava/lang/String;)I
 */
JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_rms_SQLite_sqlite3_1prepare_1v2
(JNIEnv* aEnv, jclass, jint aDbHandle, jstring aStatement)
{
    sqlite3* db = reinterpret_cast<sqlite3*>(aDbHandle);
    std::string statement = jstringToString(aEnv, aStatement);

    sqlite3_stmt* ppStmt = 0;
    const char* tail = 0;
    int rc = sqlite3_prepare_v2(db, statement.c_str(), statement.size(), &ppStmt, &tail);

    if (rc)
    {
        ELOG3(EMidpRms, "sqlite3_prepare_v2 failed (%d): %s (sql:%s)",
              rc, sqlite3_errmsg(db), statement.c_str());
    }

    return reinterpret_cast<int>(ppStmt);
}

/*
 * Class:     com_nokia_mj_impl_rms_SQLite
 * Method:    sqlite3_step
 * Signature: (I)I
 */
JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_rms_SQLite_sqlite3_1step
(JNIEnv*, jclass, jint aStmtHandle)
{
    sqlite3_stmt* ppStmt = reinterpret_cast<sqlite3_stmt*>(aStmtHandle);
    int rc = sqlite3_step(ppStmt);
    return rc;
}

/*
 * Class:     com_nokia_mj_impl_rms_SQLite
 * Method:    sqlite3_reset
 * Signature: (I)I
 */
JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_rms_SQLite_sqlite3_1reset
(JNIEnv*, jclass, jint aStmtHandle)
{
    sqlite3_stmt* ppStmt = reinterpret_cast<sqlite3_stmt*>(aStmtHandle);
    int rc = sqlite3_reset(ppStmt);
    return rc;
}

/*
 * Class:     com_nokia_mj_impl_rms_SQLite
 * Method:    sqlite3_finalize
 * Signature: (I)I
 */
JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_rms_SQLite_sqlite3_1finalize
(JNIEnv*, jclass, jint aStmtHandle)
{
    sqlite3_stmt* ppStmt = reinterpret_cast<sqlite3_stmt*>(aStmtHandle);
    int rc = sqlite3_finalize(ppStmt);
    return rc;
}

/*
 * Class:     com_nokia_mj_impl_rms_SQLite
 * Method:    sqlite3_changes
 * Signature: (I)I
 */
JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_rms_SQLite_sqlite3_1changes
(JNIEnv *, jclass, jint aDbHandle)
{
    sqlite3* db = reinterpret_cast<sqlite3*>(aDbHandle);
    int rc = sqlite3_changes(db);
    return rc;
}

/*
 * Class:     com_nokia_mj_impl_rms_SQLite
 * Method:    sqlite3_errmsg
 * Signature: (I)Ljava/lang/String;
 */
JNIEXPORT jstring JNICALL Java_com_nokia_mj_impl_rms_SQLite_sqlite3_1errmsg
(JNIEnv* aEnv, jclass, jint aDbHandle)
{
    sqlite3* db = reinterpret_cast<sqlite3*>(aDbHandle);
    const char* errmsg = sqlite3_errmsg(db);
    jstring str = aEnv->NewStringUTF(errmsg);
    return str;
}

/*
 * Class:     com_nokia_mj_impl_rms_SQLite
 * Method:    sqlite3_bind_blob
 * Signature: (II[B)I
 */
JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_rms_SQLite_sqlite3_1bind_1blob
(JNIEnv* aEnv, jclass, jint aStmtHandle, jint aIndex, jbyteArray aArray)
{
    sqlite3_stmt* ppStmt = reinterpret_cast<sqlite3_stmt*>(aStmtHandle);

    int len = 0;
    char* blob = 0;
    if (aArray)
    {
        len = aEnv->GetArrayLength(aArray);
        blob = new char[len];
        if (!blob)
        {
            return SQLITE_NOMEM;
        }
        aEnv->GetByteArrayRegion(aArray, 0, len, reinterpret_cast<jbyte*>(blob));
    }
    int rc = sqlite3_bind_blob(ppStmt, aIndex, blob, len, SQLITE_TRANSIENT);
    delete[] blob;

    return rc;
}

/*
 * Class:     com_nokia_mj_impl_rms_SQLite
 * Method:    sqlite3_bind_int
 * Signature: (III)I
 */
JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_rms_SQLite_sqlite3_1bind_1int
(JNIEnv*, jclass, jint aStmtHandle, jint aIndex, jint aValue)
{
    sqlite3_stmt* ppStmt = reinterpret_cast<sqlite3_stmt*>(aStmtHandle);
    int rc = sqlite3_bind_int(ppStmt, aIndex, aValue);
    return rc;
}

/*
 * Class:     com_nokia_mj_impl_rms_SQLite
 * Method:    sqlite3_bind_int64
 * Signature: (IIJ)I
 */
JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_rms_SQLite_sqlite3_1bind_1int64
(JNIEnv*, jclass, jint aStmtHandle, jint aIndex, jlong aValue)
{
    sqlite3_stmt* ppStmt = reinterpret_cast<sqlite3_stmt*>(aStmtHandle);
    int rc = sqlite3_bind_int64(ppStmt, aIndex, aValue);
    return rc;
}

/*
 * Class:     com_nokia_mj_impl_rms_SQLite
 * Method:    sqlite3_bind_text
 * Signature: (ILjava/lang/String;)I
 */
JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_rms_SQLite_sqlite3_1bind_1text
(JNIEnv* aEnv, jclass, jint aStmtHandle, jint aIndex, jstring aText)
{
    sqlite3_stmt* ppStmt = reinterpret_cast<sqlite3_stmt*>(aStmtHandle);
    std::string text = jstringToString(aEnv, aText);
    int rc = sqlite3_bind_text(ppStmt, aIndex, text.c_str(), text.size(), SQLITE_TRANSIENT);
    return rc;
}

/*
 * Class:     com_nokia_mj_impl_rms_SQLite
 * Method:    sqlite3_column_blob
 * Signature: (II)[B
 */
JNIEXPORT jbyteArray JNICALL Java_com_nokia_mj_impl_rms_SQLite_sqlite3_1column_1blob
(JNIEnv* aEnv, jclass, jint aStmtHandle, jint aIndex)
{
    sqlite3_stmt* ppStmt = reinterpret_cast<sqlite3_stmt*>(aStmtHandle);
    const void* blob = sqlite3_column_blob(ppStmt, aIndex);
    int len = sqlite3_column_bytes(ppStmt, aIndex);

    jbyteArray bytes = aEnv->NewByteArray(len);
    aEnv->SetByteArrayRegion(bytes, 0, len, (jbyte*)blob);
    return bytes;
}

/*
 * Class:     com_nokia_mj_impl_rms_SQLite
 * Method:    sqlite3_column_int
 * Signature: (II)I
 */
JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_rms_SQLite_sqlite3_1column_1int
(JNIEnv*, jclass, jint aStmtHandle, jint aIndex)
{
    sqlite3_stmt* ppStmt = reinterpret_cast<sqlite3_stmt*>(aStmtHandle);
    int rc = sqlite3_column_int(ppStmt, aIndex);
    return rc;
}

/*
 * Class:     com_nokia_mj_impl_rms_SQLite
 * Method:    sqlite3_column_int64
 * Signature: (II)J
 */
JNIEXPORT jlong JNICALL Java_com_nokia_mj_impl_rms_SQLite_sqlite3_1column_1int64
(JNIEnv*, jclass, jint aStmtHandle, jint aIndex)
{
    sqlite3_stmt* ppStmt = reinterpret_cast<sqlite3_stmt*>(aStmtHandle);
    jlong rc = sqlite3_column_int64(ppStmt, aIndex);
    return rc;
}

/*
 * Class:     com_nokia_mj_impl_rms_SQLite
 * Method:    sqlite3_column_text
 * Signature: (II)Ljava/lang/String;
 */
JNIEXPORT jstring JNICALL Java_com_nokia_mj_impl_rms_SQLite_sqlite3_1column_1text
(JNIEnv* aEnv, jclass, jint aStmtHandle, jint aIndex)
{
    sqlite3_stmt* ppStmt = reinterpret_cast<sqlite3_stmt*>(aStmtHandle);
    char* text = (char*)sqlite3_column_text(ppStmt, aIndex);

    jstring str = aEnv->NewStringUTF(text);
    return str;
}

/*
 * Class:     com_nokia_mj_impl_rms_SQLite
 * Method:    sqlite3_last_insert_rowid
 * Signature: (I)J
 */
JNIEXPORT jlong JNICALL Java_com_nokia_mj_impl_rms_SQLite_sqlite3_1last_1insert_1rowid
(JNIEnv *, jclass, jint aDbHandle)
{
    sqlite3* db = reinterpret_cast<sqlite3*>(aDbHandle);
    sqlite_int64 rc = sqlite3_last_insert_rowid(db);
    return rc;
}

/*
 * Class:     com_nokia_mj_impl_rms_SQLite
 * Method:    sqlite3_busy_timeout
 * Signature: (II)I
 */
JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_rms_SQLite_sqlite3_1busy_1timeout
(JNIEnv *, jclass, jint aDbHandle, jint aMilliseconds)
{
    sqlite3* db = reinterpret_cast<sqlite3*>(aDbHandle);
    int rc = sqlite3_busy_timeout(db, aMilliseconds);
    return rc;
}

std::string jstringToString(JNIEnv* aEnv, const jstring& aString)
{
    const char* buf = aEnv->GetStringUTFChars(aString, 0);
    std::string result = "";
    if (buf)
    {
        result = buf;
    }
    aEnv->ReleaseStringUTFChars(aString, buf);
    return result;
}