| /* //device/libs/android_runtime/android_database_SQLiteCursor.cpp |
| ** |
| ** Copyright 2006, The Android Open Source Project |
| ** |
| ** Licensed under the Apache License, Version 2.0 (the "License"); |
| ** you may not use this file except in compliance with the License. |
| ** You may obtain a copy of the License at |
| ** |
| ** http://www.apache.org/licenses/LICENSE-2.0 |
| ** |
| ** Unless required by applicable law or agreed to in writing, software |
| ** distributed under the License is distributed on an "AS IS" BASIS, |
| ** WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| ** See the License for the specific language governing permissions and |
| ** limitations under the License. |
| */ |
| |
| #undef LOG_TAG |
| #define LOG_TAG "SQLiteStatementCpp" |
| |
| #include "android_util_Binder.h" |
| |
| #include <jni.h> |
| #include <JNIHelp.h> |
| #include <android_runtime/AndroidRuntime.h> |
| |
| #include <sqlite3.h> |
| |
| #include <cutils/ashmem.h> |
| #include <utils/Log.h> |
| |
| #include <fcntl.h> |
| #include <stdio.h> |
| #include <string.h> |
| #include <unistd.h> |
| #include <sys/mman.h> |
| #include <sys/types.h> |
| #include <sys/stat.h> |
| |
| #include "sqlite3_exception.h" |
| |
| namespace android { |
| |
| |
| sqlite3_stmt * compile(JNIEnv* env, jobject object, |
| sqlite3 * handle, jstring sqlString); |
| |
| static jfieldID gHandleField; |
| static jfieldID gStatementField; |
| |
| |
| #define GET_STATEMENT(env, object) \ |
| (sqlite3_stmt *)env->GetIntField(object, gStatementField) |
| #define GET_HANDLE(env, object) \ |
| (sqlite3 *)env->GetIntField(object, gHandleField) |
| |
| |
| static jint native_execute(JNIEnv* env, jobject object) |
| { |
| int err; |
| sqlite3 * handle = GET_HANDLE(env, object); |
| sqlite3_stmt * statement = GET_STATEMENT(env, object); |
| int numChanges = -1; |
| |
| // Execute the statement |
| err = sqlite3_step(statement); |
| |
| // Throw an exception if an error occurred |
| if (err == SQLITE_ROW) { |
| throw_sqlite3_exception(env, |
| "Queries can be performed using SQLiteDatabase query or rawQuery methods only."); |
| } else if (err != SQLITE_DONE) { |
| throw_sqlite3_exception_errcode(env, err, sqlite3_errmsg(handle)); |
| } else { |
| numChanges = sqlite3_changes(handle); |
| } |
| |
| // Reset the statement so it's ready to use again |
| sqlite3_reset(statement); |
| return numChanges; |
| } |
| |
| static jlong native_executeInsert(JNIEnv* env, jobject object) |
| { |
| sqlite3 * handle = GET_HANDLE(env, object); |
| jint numChanges = native_execute(env, object); |
| if (numChanges > 0) { |
| return sqlite3_last_insert_rowid(handle); |
| } else { |
| return -1; |
| } |
| } |
| |
| static jlong native_1x1_long(JNIEnv* env, jobject object) |
| { |
| int err; |
| sqlite3 * handle = GET_HANDLE(env, object); |
| sqlite3_stmt * statement = GET_STATEMENT(env, object); |
| jlong value = -1; |
| |
| // Execute the statement |
| err = sqlite3_step(statement); |
| |
| // Handle the result |
| if (err == SQLITE_ROW) { |
| // No errors, read the data and return it |
| value = sqlite3_column_int64(statement, 0); |
| } else { |
| throw_sqlite3_exception_errcode(env, err, sqlite3_errmsg(handle)); |
| } |
| |
| // Reset the statment so it's ready to use again |
| sqlite3_reset(statement); |
| |
| return value; |
| } |
| |
| static jstring native_1x1_string(JNIEnv* env, jobject object) |
| { |
| int err; |
| sqlite3 * handle = GET_HANDLE(env, object); |
| sqlite3_stmt * statement = GET_STATEMENT(env, object); |
| jstring value = NULL; |
| |
| // Execute the statement |
| err = sqlite3_step(statement); |
| |
| // Handle the result |
| if (err == SQLITE_ROW) { |
| // No errors, read the data and return it |
| char const * text = (char const *)sqlite3_column_text(statement, 0); |
| value = env->NewStringUTF(text); |
| } else { |
| throw_sqlite3_exception_errcode(env, err, sqlite3_errmsg(handle)); |
| } |
| |
| // Reset the statment so it's ready to use again |
| sqlite3_reset(statement); |
| |
| return value; |
| } |
| |
| static jobject createParcelFileDescriptor(JNIEnv * env, int fd) |
| { |
| // Create FileDescriptor object |
| jobject fileDesc = jniCreateFileDescriptor(env, fd); |
| if (fileDesc == NULL) { |
| // FileDescriptor constructor has thrown an exception |
| close(fd); |
| return NULL; |
| } |
| |
| // Wrap it in a ParcelFileDescriptor |
| jobject parcelFileDesc = newParcelFileDescriptor(env, fileDesc); |
| if (parcelFileDesc == NULL) { |
| // ParcelFileDescriptor constructor has thrown an exception |
| close(fd); |
| return NULL; |
| } |
| |
| return parcelFileDesc; |
| } |
| |
| // Creates an ashmem area, copies some data into it, and returns |
| // a ParcelFileDescriptor for the ashmem area. |
| static jobject create_ashmem_region_with_data(JNIEnv * env, |
| const void * data, int length) |
| { |
| // Create ashmem area |
| int fd = ashmem_create_region(NULL, length); |
| if (fd < 0) { |
| LOGE("ashmem_create_region failed: %s", strerror(errno)); |
| jniThrowIOException(env, errno); |
| return NULL; |
| } |
| |
| if (length > 0) { |
| // mmap the ashmem area |
| void * ashmem_ptr = |
| mmap(NULL, length, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0); |
| if (ashmem_ptr == MAP_FAILED) { |
| LOGE("mmap failed: %s", strerror(errno)); |
| jniThrowIOException(env, errno); |
| close(fd); |
| return NULL; |
| } |
| |
| // Copy data to ashmem area |
| memcpy(ashmem_ptr, data, length); |
| |
| // munmap ashmem area |
| if (munmap(ashmem_ptr, length) < 0) { |
| LOGE("munmap failed: %s", strerror(errno)); |
| jniThrowIOException(env, errno); |
| close(fd); |
| return NULL; |
| } |
| } |
| |
| // Make ashmem area read-only |
| if (ashmem_set_prot_region(fd, PROT_READ) < 0) { |
| LOGE("ashmem_set_prot_region failed: %s", strerror(errno)); |
| jniThrowIOException(env, errno); |
| close(fd); |
| return NULL; |
| } |
| |
| // Wrap it in a ParcelFileDescriptor |
| return createParcelFileDescriptor(env, fd); |
| } |
| |
| static jobject native_1x1_blob_ashmem(JNIEnv* env, jobject object) |
| { |
| int err; |
| sqlite3 * handle = GET_HANDLE(env, object); |
| sqlite3_stmt * statement = GET_STATEMENT(env, object); |
| jobject value = NULL; |
| |
| // Execute the statement |
| err = sqlite3_step(statement); |
| |
| // Handle the result |
| if (err == SQLITE_ROW) { |
| // No errors, read the data and return it |
| const void * blob = sqlite3_column_blob(statement, 0); |
| if (blob != NULL) { |
| int len = sqlite3_column_bytes(statement, 0); |
| if (len >= 0) { |
| value = create_ashmem_region_with_data(env, blob, len); |
| } |
| } |
| } else { |
| throw_sqlite3_exception_errcode(env, err, sqlite3_errmsg(handle)); |
| } |
| |
| // Reset the statment so it's ready to use again |
| sqlite3_reset(statement); |
| |
| return value; |
| } |
| |
| static void native_executeSql(JNIEnv* env, jobject object, jstring sql) |
| { |
| char const* sqlString = env->GetStringUTFChars(sql, NULL); |
| sqlite3 * handle = GET_HANDLE(env, object); |
| int err = sqlite3_exec(handle, sqlString, NULL, NULL, NULL); |
| if (err != SQLITE_OK) { |
| throw_sqlite3_exception(env, handle); |
| } |
| env->ReleaseStringUTFChars(sql, sqlString); |
| } |
| |
| static JNINativeMethod sMethods[] = |
| { |
| /* name, signature, funcPtr */ |
| {"native_execute", "()I", (void *)native_execute}, |
| {"native_executeInsert", "()J", (void *)native_executeInsert}, |
| {"native_1x1_long", "()J", (void *)native_1x1_long}, |
| {"native_1x1_string", "()Ljava/lang/String;", (void *)native_1x1_string}, |
| {"native_1x1_blob_ashmem", "()Landroid/os/ParcelFileDescriptor;", (void *)native_1x1_blob_ashmem}, |
| {"native_executeSql", "(Ljava/lang/String;)V", (void *)native_executeSql}, |
| }; |
| |
| int register_android_database_SQLiteStatement(JNIEnv * env) |
| { |
| jclass clazz; |
| |
| clazz = env->FindClass("android/database/sqlite/SQLiteStatement"); |
| if (clazz == NULL) { |
| LOGE("Can't find android/database/sqlite/SQLiteStatement"); |
| return -1; |
| } |
| |
| gHandleField = env->GetFieldID(clazz, "nHandle", "I"); |
| gStatementField = env->GetFieldID(clazz, "nStatement", "I"); |
| |
| if (gHandleField == NULL || gStatementField == NULL) { |
| LOGE("Error locating fields"); |
| return -1; |
| } |
| |
| return AndroidRuntime::registerNativeMethods(env, |
| "android/database/sqlite/SQLiteStatement", sMethods, NELEM(sMethods)); |
| } |
| |
| } // namespace android |