diff -r 2e8eeb919028 -r b538b70cbe51 configlib/dbmsjdbc/src/native/DbmsStatement.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/configlib/dbmsjdbc/src/native/DbmsStatement.cpp	Thu Mar 11 18:20:56 2010 +0200
@@ -0,0 +1,138 @@
+// Copyright (c) 1998-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 <jni.h>
+#include "DbmsStatement.h"
+#include "DbmsConnection.h"
+#include "DbmsResultSet.h"
+#include "Utils.h"
+#include "dbmsjni/com_symbian_dbms_jdbc_DbmsStatement.h"
+#include <stdlib.h>
+
+// //
+// DbmsStatement peer
+// //
+
+DbmsStatement::DbmsStatement(DbmsConnection* aConnection){
+	iConnection = aConnection;
+}
+
+DbmsStatement::~DbmsStatement(){
+}
+
+void DbmsStatement::Close(){
+	iView.Close();
+}
+
+// //
+// JNI
+// //
+
+/*
+ * Class:     com_symbian_dbms_jdbc_DbmsStatement
+ * Method:    _create
+ * Signature: (I)I
+ */
+JNIEXPORT jint JNICALL Java_com_symbian_dbms_jdbc_DbmsStatement__1create
+  (JNIEnv *, jobject, jint aPeer){
+	DbmsConnection* connection = (DbmsConnection*) aPeer;
+	DbmsStatement* statement = new DbmsStatement(connection);
+	return (jint) statement;
+}
+
+/*
+ * Class:     com_symbian_dbms_jdbc_DbmsStatement
+ * Method:    _executeUpdate
+ * Signature: (ILjava/lang/String;)I
+ */
+JNIEXPORT jint JNICALL Java_com_symbian_dbms_jdbc_DbmsStatement__1executeUpdate
+  (JNIEnv *aEnv, jobject, jint aPeer, jstring aString){
+	DbmsStatement* statement = (DbmsStatement*) aPeer;
+	RJString sql(*aEnv, aString);
+	RDbNamedDatabase& db = statement->iConnection->iDatabase;
+	TInt res = db.Execute(sql);
+	return res;
+}
+
+/*
+ * Class:     com_symbian_dbms_jdbc_DbmsStatement
+ * Method:    _executeQuery
+ * Signature: (ILjava/lang/String;)I
+ */
+JNIEXPORT jint JNICALL Java_com_symbian_dbms_jdbc_DbmsStatement__1executeQuery
+  (JNIEnv *aEnv, jobject, jint aPeer, jstring aString){
+	DbmsStatement* statement = (DbmsStatement*) aPeer;
+	RJString sql(*aEnv, aString);
+	TDbQuery query (sql);
+	TInt res = statement->iView.Prepare(statement->iConnection->iDatabase, query, RDbRowSet::EReadOnly);
+	if ( res < 0 ) {
+		return (jint) res;
+	} else {
+		res = statement->iView.EvaluateAll();
+		if ( res < 0 ) {
+			return (jint) res;
+		} else {
+			DbmsResultSet* resultSet = new DbmsResultSet(statement);
+			return (jint) resultSet;
+		}
+	}
+}
+
+/*
+ * Class:     com_symbian_dbms_jdbc_DbmsStatement
+ * Method:    _close
+ * Signature: (I)V
+ */
+JNIEXPORT void JNICALL Java_com_symbian_dbms_jdbc_DbmsStatement__1close
+  (JNIEnv *, jobject, jint aPeer){
+	DbmsStatement* statement = (DbmsStatement*) aPeer;
+	statement->Close();
+	delete statement;
+}
+
+/*
+ * Class:     com_symbian_dbms_jdbc_DbmsStatement
+ * Method:    _begin
+ * Signature: (I)V
+ */
+JNIEXPORT jint JNICALL Java_com_symbian_dbms_jdbc_DbmsStatement__1begin
+  (JNIEnv *, jobject, jint aPeer) {
+	DbmsStatement* statement = (DbmsStatement*) aPeer;
+	return statement->iConnection->iDatabase.Begin();
+}
+
+/*
+ * Class:     com_symbian_dbms_jdbc_DbmsStatement
+ * Method:    _commit
+ * Signature: (I)V
+ */
+JNIEXPORT jint JNICALL Java_com_symbian_dbms_jdbc_DbmsStatement__1commit
+  (JNIEnv *, jobject, jint aPeer) {
+	DbmsStatement* statement = (DbmsStatement*) aPeer;
+	return statement->iConnection->iDatabase.Commit();
+}
+
+/*
+ * Class:     com_symbian_dbms_jdbc_DbmsStatement
+ * Method:    _rollback
+ * Signature: (I)V
+ */
+JNIEXPORT void JNICALL Java_com_symbian_dbms_jdbc_DbmsStatement__1rollback
+  (JNIEnv *, jobject, jint aPeer) {
+	DbmsStatement* statement = (DbmsStatement*) aPeer;
+	statement->iConnection->iDatabase.Rollback();
+}
+
+