set_error(env, code, ejdberrmsg(code));
};
+static void set_ejdb_to_object(JNIEnv *env, jobject obj, EJDB *db) {
+ jclass clazz = (*env)->GetObjectClass(env, obj);
+ jfieldID dbpID = (*env)->GetFieldID(env, clazz, "dbPointer", "J");
+ (*env)->SetLongField(env, obj, dbpID, (jlong)db);
+};
+
+static EJDB *get_ejdb_from_object(JNIEnv *env, jobject obj) {
+ jclass jEJDBQueryClazz = (*env)->FindClass(env, "org/ejdb/driver/EJDBQuery");
+ if ((*env)->IsInstanceOf(env, obj, jEJDBQueryClazz)) {
+ jfieldID collID = (*env)->GetFieldID(env, jEJDBQueryClazz, "coll", "Lorg/ejdb/driver/EJDBCollection;");
+ obj = (*env)->GetObjectField(env, obj, collID);
+ }
+
+ jclass jEJDBCollectionClazz = (*env)->FindClass(env, "org/ejdb/driver/EJDBCollection");
+ if ((*env)->IsInstanceOf(env, obj, jEJDBCollectionClazz)) {
+ jfieldID dbID = (*env)->GetFieldID(env, jEJDBCollectionClazz, "db", "Lorg/ejdb/driver/EJDB;");
+ obj = (*env)->GetObjectField(env, obj, dbID);
+ }
+
+ jclass jEJDBClazz = (*env)->FindClass(env, "org/ejdb/driver/EJDB");
+ if ((*env)->IsInstanceOf(env, obj, jEJDBClazz)) {
+ jfieldID dbpID = (*env)->GetFieldID(env, jEJDBClazz, "dbPointer", "J");
+ return (EJDB *)(*env)->GetLongField(env, obj, dbpID);
+ }
+
+ return (EJDB *)NULL;
+};
+
+static jstring get_coll_name(JNIEnv *env, jobject obj) {
+ jclass jEJDBQueryClazz = (*env)->FindClass(env, "org/ejdb/driver/EJDBQuery");
+ if ((*env)->IsInstanceOf(env, obj, jEJDBQueryClazz)) {
+ jfieldID collID = (*env)->GetFieldID(env, jEJDBQueryClazz, "coll", "Lorg/ejdb/driver/EJDBCollection;");
+ obj = (*env)->GetObjectField(env, obj, collID);
+ }
+
+ jclass jEJDBCollectionClazz = (*env)->FindClass(env, "org/ejdb/driver/EJDBCollection");
+ if ((*env)->IsInstanceOf(env, obj, jEJDBCollectionClazz)) {
+ jfieldID colnameID = (*env)->GetFieldID(env, jEJDBCollectionClazz, "cname", "Ljava/lang/String;");
+ return (*env)->GetObjectField(env, obj, colnameID);
+ }
+
+ return NULL;
+};
+
+static bson *encode_bson(JNIEnv *env, jobject jbson, bson *out) {
+ jclass jBSONClazz = (*env)->FindClass(env, "org/bson/BSON");
+ jmethodID encodeMethodID = (*env)->GetStaticMethodID(env, jBSONClazz, "encode", "(Lorg/bson/BSONObject;)[B");
+
+ jbyteArray bobjdata = (*env)->CallStaticObjectMethod(env, jBSONClazz, encodeMethodID, jbson);
+ jbyte *bdata = (*env)->GetByteArrayElements(env, bobjdata, NULL);
+ jsize blength = (*env)->GetArrayLength(env, bobjdata);
+ if (NULL == out) {
+ out = bson_create_from_buffer(bdata, blength);
+ } else {
+ bson_create_from_buffer2(out, bdata, blength);
+ }
+ (*env)->ReleaseByteArrayElements(env, bobjdata, bdata, 0);
+ (*env)->DeleteLocalRef(env, bobjdata);
+
+ return out;
+};
+
+static jobject decode_bson_from_buffer(JNIEnv *env, const void *buffer, jsize size) {
+ jclass jBSONClazz = (*env)->FindClass(env, "org/bson/BSON");
+ jmethodID decodeMethodID = (*env)->GetStaticMethodID(env, jBSONClazz, "decode", "([B)Lorg/bson/BSONObject;");
+
+ jbyteArray jbsdata = (*env)->NewByteArray(env, size);
+ (*env)->SetByteArrayRegion(env, jbsdata, 0, size, (jbyte*)buffer);
+ jobject result = (*env)->CallStaticObjectMethod(env, jBSONClazz, decodeMethodID, jbsdata);
+ (*env)->DeleteLocalRef(env, jbsdata);
+
+ return result;
+};
+
+static jobject decode_bson(JNIEnv *env, bson *bson) {
+ return decode_bson_from_buffer(env, (void *)bson_data(bson), bson_size(bson));
+};
+
+static TCLIST *get_rs_from_object(JNIEnv *env, jobject obj) {
+ jclass clazz = (*env)->GetObjectClass(env, obj);
+ jfieldID rspID = (*env)->GetFieldID(env, clazz, "rsPointer", "J");
+
+ return (TCLIST *)(*env)->GetLongField(env, obj, rspID);
+};
+
+static void set_rs_to_object(JNIEnv *env, jobject obj, TCLIST *rs) {
+ jclass clazz = (*env)->GetObjectClass(env, obj);
+ jfieldID rspID = (*env)->GetFieldID(env, clazz, "rsPointer", "J");
+
+ (*env)->SetLongField(env, obj, rspID, (jlong)rs);
+};
+
/*
* Class: org_ejdb_driver_EJDB
* Method: openDB
* Signature: (Ljava/lang/String;I)V
*/
-JNIEXPORT void JNICALL Java_org_ejdb_driver_EJDB_openDB
- (JNIEnv *env, jobject obj, jstring path, jint mode) {
- EJDB* db = ejdbnew();
+JNIEXPORT void JNICALL Java_org_ejdb_driver_EJDB_openDB (JNIEnv *env, jobject obj, jstring path, jint mode) {
+ EJDB* db = ejdbnew();
- if (!db) {
- set_error(env, 0, "Could not create EJDB");
- return;
- }
-
- const char *dbpath;
- dbpath = (*env)->GetStringUTFChars(env, path, NULL);
- bool status = ejdbopen(db, dbpath, mode);
- (*env)->ReleaseStringUTFChars(env, path, dbpath);
-
- if (!status) {
- set_ejdb_error(env, db);
- return;
- }
+ if (!db) {
+ set_error(env, 0, "Could not create EJDB");
+ return;
+ }
- jclass clazz = (*env)->GetObjectClass(env, obj);
- jfieldID dbpID = (*env)->GetFieldID(env, clazz, "dbPointer", "J");
- (*env)->SetLongField(env, obj, dbpID, (jlong)db);
+ const char *dbpath = (*env)->GetStringUTFChars(env, path, NULL);
+ bool status = ejdbopen(db, dbpath, mode);
+ (*env)->ReleaseStringUTFChars(env, path, dbpath);
+ if (!status) {
+ set_ejdb_error(env, db);
return;
+ }
+
+ set_ejdb_to_object(env, obj, db);
+ return;
};
/*
* Method: isOpenDB
* Signature: ()Z
*/
-JNIEXPORT jboolean JNICALL Java_org_ejdb_driver_EJDB_isOpenDB
- (JNIEnv *env, jobject obj) {
- jclass clazz = (*env)->GetObjectClass(env, obj);
- jfieldID dbpID = (*env)->GetFieldID(env, clazz, "dbPointer", "J");
- jlong dbp = (*env)->GetLongField(env, obj, dbpID);
-
- return ejdbisopen((EJDB*)dbp);
+JNIEXPORT jboolean JNICALL Java_org_ejdb_driver_EJDB_isOpenDB (JNIEnv *env, jobject obj) {
+ return ejdbisopen(get_ejdb_from_object(env, obj));
};
/*
* Method: closeDB
* Signature: ()V
*/
-JNIEXPORT void JNICALL Java_org_ejdb_driver_EJDB_closeDB
- (JNIEnv *env, jobject obj) {
- jclass clazz = (*env)->GetObjectClass(env, obj);
- jfieldID dbpID = (*env)->GetFieldID(env, clazz, "dbPointer", "J");
- jlong dbp = (*env)->GetLongField(env, obj, dbpID);
-
- EJDB* db = (EJDB*)dbp;
+JNIEXPORT void JNICALL Java_org_ejdb_driver_EJDB_closeDB (JNIEnv *env, jobject obj) {
+ EJDB* db = get_ejdb_from_object(env, obj);
- if (ejdbisopen(db)) {
- if (!ejdbclose(db)) {
- set_ejdb_error(env, db);
- }
- if (NULL != db) {
- ejdbdel(db);
- }
+ if (ejdbisopen(db)) {
+ if (!ejdbclose(db)) {
+ set_ejdb_error(env, db);
}
+ if (NULL != db) {
+ ejdbdel(db);
+ }
+ }
- (*env)->SetLongField(env, obj, dbpID, (jlong)NULL);
+ set_ejdb_to_object(env, obj, NULL);
};
/*
* Method: syncDB
* Signature: ()V
*/
-JNIEXPORT void JNICALL Java_org_ejdb_driver_EJDB_syncDB
- (JNIEnv *env, jobject obj) {
- jclass clazz = (*env)->GetObjectClass(env, obj);
- jfieldID dbpID = (*env)->GetFieldID(env, clazz, "dbPointer", "J");
- jlong dbp = (*env)->GetLongField(env, obj, dbpID);
-
- EJDB* db = (EJDB*)dbp;
- if (!ejdbisopen(db)) {
- set_error(env, 0, "EJDB not opened");
- return;
- }
+JNIEXPORT void JNICALL Java_org_ejdb_driver_EJDB_syncDB (JNIEnv *env, jobject obj) {
+ EJDB* db = get_ejdb_from_object(env, obj);
+ if (!ejdbisopen(db)) {
+ set_error(env, 0, "EJDB not opened");
+ return;
+ }
- if (!ejdbsyncdb(db)) {
- set_ejdb_error(env, db);
- }
+ if (!ejdbsyncdb(db)) {
+ set_ejdb_error(env, db);
+ }
};
/*
* Method: ensureDB
* Signature: (Ljava/lang/Object;)V
*/
-JNIEXPORT void JNICALL Java_org_ejdb_driver_EJDBCollection_ensureDB
- (JNIEnv *env, jobject obj, jobject opts) {
- jclass clazz = (*env)->GetObjectClass(env, obj);
- jfieldID dboID = (*env)->GetFieldID(env, clazz, "db", "Lorg/ejdb/driver/EJDB;");
- jobject dbo = (*env)->GetObjectField(env, obj, dboID);
- jclass dclazz = (*env)->GetObjectClass(env, dbo);
- jfieldID dbpID = (*env)->GetFieldID(env, dclazz, "dbPointer", "J");
- jlong dbp = (*env)->GetLongField(env, dbo, dbpID);
-
- EJDB* db = (EJDB*)dbp;
- if (!ejdbisopen(db)) {
- set_error(env, 0, "EJDB not opened");
- return;
- }
+JNIEXPORT void JNICALL Java_org_ejdb_driver_EJDBCollection_ensureDB (JNIEnv *env, jobject obj, jobject opts) {
+ EJDB* db = get_ejdb_from_object(env, obj);
+ if (!ejdbisopen(db)) {
+ set_error(env, 0, "EJDB not opened");
+ return;
+ }
- jfieldID colnameID = (*env)->GetFieldID(env, clazz, "cname", "Ljava/lang/String;");
- jstring colname = (*env)->GetObjectField(env, obj, colnameID);
+ jstring colname = get_coll_name(env, obj);
- EJCOLLOPTS jcopts;
- memset(&jcopts, 0, sizeof (jcopts));
- // todo: open options
+ EJCOLLOPTS jcopts;
+ memset(&jcopts, 0, sizeof (jcopts));
+ // todo: open options
- const char *cname = (*env)->GetStringUTFChars(env, colname, NULL);
- EJCOLL *coll = ejdbcreatecoll(db, cname, &jcopts);
- (*env)->ReleaseStringUTFChars(env, colname, cname);
+ const char *cname = (*env)->GetStringUTFChars(env, colname, NULL);
+ EJCOLL *coll = ejdbcreatecoll(db, cname, &jcopts);
+ (*env)->ReleaseStringUTFChars(env, colname, cname);
- if (!coll) {
- set_ejdb_error(env, db);
- return;
- }
+ if (!coll) {
+ set_ejdb_error(env, db);
+ return;
+ }
};
* Method: dropDB
* Signature: (Z)V
*/
-JNIEXPORT void JNICALL Java_org_ejdb_driver_EJDBCollection_dropDB
- (JNIEnv *env, jobject obj, jboolean prune) {
- jclass clazz = (*env)->GetObjectClass(env, obj);
- jfieldID dboID = (*env)->GetFieldID(env, clazz, "db", "Lorg/ejdb/driver/EJDB;");
- jobject dbo = (*env)->GetObjectField(env, obj, dboID);
- jclass dclazz = (*env)->GetObjectClass(env, dbo);
- jfieldID dbpID = (*env)->GetFieldID(env, dclazz, "dbPointer", "J");
- jlong dbp = (*env)->GetLongField(env, dbo, dbpID);
-
- EJDB* db = (EJDB*)dbp;
- if (!ejdbisopen(db)) {
- set_error(env, 0, "EJDB not opened");
- return;
- }
+JNIEXPORT void JNICALL Java_org_ejdb_driver_EJDBCollection_dropDB (JNIEnv *env, jobject obj, jboolean prune) {
+ EJDB* db = get_ejdb_from_object(env, obj);
+ if (!ejdbisopen(db)) {
+ set_error(env, 0, "EJDB not opened");
+ return;
+ }
- jfieldID colnameID = (*env)->GetFieldID(env, clazz, "cname", "Ljava/lang/String;");
- jstring colname = (*env)->GetObjectField(env, obj, colnameID);
+ jstring colname = get_coll_name(env, obj);
- const char *cname;
- cname = (*env)->GetStringUTFChars(env, colname, NULL);
- bool status = ejdbrmcoll(db, cname, (prune == JNI_TRUE));
- (*env)->ReleaseStringUTFChars(env, colname, cname);
+ const char *cname = (*env)->GetStringUTFChars(env, colname, NULL);
+ bool status = ejdbrmcoll(db, cname, (prune == JNI_TRUE));
+ (*env)->ReleaseStringUTFChars(env, colname, cname);
- if (!status) {
- set_ejdb_error(env, db);
- return;
- }
+ if (!status) {
+ set_ejdb_error(env, db);
+ return;
+ }
};
/*
* Method: syncDB
* Signature: ()V
*/
-JNIEXPORT void JNICALL Java_org_ejdb_driver_EJDBCollection_syncDB
- (JNIEnv *env, jobject obj) {
- jclass clazz = (*env)->GetObjectClass(env, obj);
- jfieldID dboID = (*env)->GetFieldID(env, clazz, "db", "Lorg/ejdb/driver/EJDB;");
- jobject dbo = (*env)->GetObjectField(env, obj, dboID);
- jclass dclazz = (*env)->GetObjectClass(env, dbo);
- jfieldID dbpID = (*env)->GetFieldID(env, dclazz, "dbPointer", "J");
- jlong dbp = (*env)->GetLongField(env, dbo, dbpID);
-
- EJDB* db = (EJDB*)dbp;
- if (!ejdbisopen(db)) {
- set_error(env, 0, "EJDB not opened");
- return;
- }
+JNIEXPORT void JNICALL Java_org_ejdb_driver_EJDBCollection_syncDB (JNIEnv *env, jobject obj) {
+ EJDB* db = get_ejdb_from_object(env, obj);
+ if (!ejdbisopen(db)) {
+ set_error(env, 0, "EJDB not opened");
+ return;
+ }
- jfieldID colnameID = (*env)->GetFieldID(env, clazz, "cname", "Ljava/lang/String;");
- jstring colname = (*env)->GetObjectField(env, obj, colnameID);
+ jstring colname = get_coll_name(env, obj);
- const char *cname = (*env)->GetStringUTFChars(env, colname, NULL);
- EJCOLL *coll = ejdbgetcoll(db, cname);
- (*env)->ReleaseStringUTFChars(env, colname, cname);
+ const char *cname = (*env)->GetStringUTFChars(env, colname, NULL);
+ EJCOLL *coll = ejdbgetcoll(db, cname);
+ (*env)->ReleaseStringUTFChars(env, colname, cname);
- if (!coll) {
- set_error(env, 0, "Collection not found");
- return;
- }
+ if (!coll) {
+ set_error(env, 0, "Collection not found");
+ return;
+ }
- if (!ejdbsyncoll(coll)) {
- set_ejdb_error(env, db);
- }
+ if (!ejdbsyncoll(coll)) {
+ set_ejdb_error(env, db);
+ }
};
/*
* Method: loadDB
* Signature: ([B)Ljava/lang/Object;
*/
-JNIEXPORT jobject JNICALL Java_org_ejdb_driver_EJDBCollection_loadDB
- (JNIEnv *env, jobject obj, jbyteArray oidArray) {
- jclass clazz = (*env)->GetObjectClass(env, obj);
- jfieldID dboID = (*env)->GetFieldID(env, clazz, "db", "Lorg/ejdb/driver/EJDB;");
- jobject dbo = (*env)->GetObjectField(env, obj, dboID);
- jclass dclazz = (*env)->GetObjectClass(env, dbo);
- jfieldID dbpID = (*env)->GetFieldID(env, dclazz, "dbPointer", "J");
- jlong dbp = (*env)->GetLongField(env, dbo, dbpID);
-
- EJDB* db = (EJDB*)dbp;
- if (!ejdbisopen(db)) {
- set_error(env, 0, "EJDB not opened");
- return NULL;
- }
+JNIEXPORT jobject JNICALL Java_org_ejdb_driver_EJDBCollection_loadDB (JNIEnv *env, jobject obj, jbyteArray oidArray) {
+ EJDB* db = get_ejdb_from_object(env, obj);
+ if (!ejdbisopen(db)) {
+ set_error(env, 0, "EJDB not opened");
+ return NULL;
+ }
- jfieldID colnameID = (*env)->GetFieldID(env, clazz, "cname", "Ljava/lang/String;");
- jstring colname = (*env)->GetObjectField(env, obj, colnameID);
- const char *cname = (*env)->GetStringUTFChars(env, colname, NULL);
- EJCOLL * coll = ejdbgetcoll(db, cname);
- (*env)->ReleaseStringUTFChars(env, colname, cname);
+ jstring colname = get_coll_name(env, obj);
- if (!coll) {
- return NULL;
- }
+ const char *cname = (*env)->GetStringUTFChars(env, colname, NULL);
+ EJCOLL * coll = ejdbgetcoll(db, cname);
+ (*env)->ReleaseStringUTFChars(env, colname, cname);
- bson_oid_t *oid = (void*)(*env)->GetByteArrayElements(env, oidArray, NULL);
- bson* bson = ejdbloadbson(coll, oid);
- (*env)->ReleaseByteArrayElements(env, oidArray, (jbyte*)oid, 0);
+ if (!coll) {
+ return NULL;
+ }
- if (!bson) {
- return NULL;
- }
+ bson_oid_t *oid = (void*)(*env)->GetByteArrayElements(env, oidArray, NULL);
+ bson* bson = ejdbloadbson(coll, oid);
+ (*env)->ReleaseByteArrayElements(env, oidArray, (jbyte*)oid, 0);
+
+ if (!bson) {
+ return NULL;
+ }
- jmethodID method = (*env)->GetStaticMethodID(env, clazz, "handleBSONData", "(Ljava/nio/ByteBuffer;)Ljava/lang/Object;");
- jobject buff = (*env)->NewDirectByteBuffer(env, (void*)bson_data(bson), bson_size(bson));
- jobject result = (*env)->CallStaticObjectMethod(env, clazz, method, buff);
- (*env)->DeleteLocalRef(env, buff);
- bson_del(bson);
+ jobject result = decode_bson(env, bson);
+ bson_del(bson);
- return result;
+ return result;
}
/*
* Method: saveDB
* Signature: ([B)Ljava/lang/Object;
*/
-JNIEXPORT jobject JNICALL Java_org_ejdb_driver_EJDBCollection_saveDB
- (JNIEnv *env, jobject obj, jbyteArray objdata) {
- jclass clazz = (*env)->GetObjectClass(env, obj);
- jfieldID dboID = (*env)->GetFieldID(env, clazz, "db", "Lorg/ejdb/driver/EJDB;");
- jobject dbo = (*env)->GetObjectField(env, obj, dboID);
- jclass dclazz = (*env)->GetObjectClass(env, dbo);
- jfieldID dbpID = (*env)->GetFieldID(env, dclazz, "dbPointer", "J");
- jlong dbp = (*env)->GetLongField(env, dbo, dbpID);
-
- EJDB* db = (EJDB*)dbp;
- if (!ejdbisopen(db)) {
- set_error(env, 0, "EJDB not opened");
- return NULL;
- }
+JNIEXPORT jobject JNICALL Java_org_ejdb_driver_EJDBCollection_saveDB (JNIEnv *env, jobject obj, jbyteArray objdata) {
+ EJDB* db = get_ejdb_from_object(env, obj);
+ if (!ejdbisopen(db)) {
+ set_error(env, 0, "EJDB not opened");
+ return NULL;
+ }
- jfieldID colnameID = (*env)->GetFieldID(env, clazz, "cname", "Ljava/lang/String;");
- jstring colname = (*env)->GetObjectField(env, obj, colnameID);
- const char *cname = (*env)->GetStringUTFChars(env, colname, NULL);
- // todo: check
- EJCOLL * coll = ejdbcreatecoll(db, cname, NULL);
- (*env)->ReleaseStringUTFChars(env, colname, cname);
+ jstring colname = get_coll_name(env, obj);
- if (!coll) {
- set_ejdb_error(env, db);
- return NULL;
- }
+ const char *cname = (*env)->GetStringUTFChars(env, colname, NULL);
+ // todo: check
+ EJCOLL * coll = ejdbcreatecoll(db, cname, NULL);
+ (*env)->ReleaseStringUTFChars(env, colname, cname);
- bson_oid_t oid;
+ if (!coll) {
+ set_ejdb_error(env, db);
+ return NULL;
+ }
- jbyte *bdata = (*env)->GetByteArrayElements(env, objdata, NULL);
- jsize blength = (*env)->GetArrayLength(env, objdata);
- bson *bson = bson_create_from_buffer(bdata, blength);
- bool status = ejdbsavebson(coll, bson, &oid);
- bson_del(bson);
- (*env)->ReleaseByteArrayElements(env, objdata, bdata, 0);
+ bson_oid_t oid;
- if (!status) {
- set_ejdb_error(env, db);
- return NULL;
- }
+ jbyte *bdata = (*env)->GetByteArrayElements(env, objdata, NULL);
+ jsize blength = (*env)->GetArrayLength(env, objdata);
+ bson *bson = bson_create_from_buffer(bdata, blength);
+ bool status = ejdbsavebson(coll, bson, &oid);
+ bson_del(bson);
+ (*env)->ReleaseByteArrayElements(env, objdata, bdata, 0);
- jmethodID method = (*env)->GetStaticMethodID(env, clazz, "handleObjectIdData", "(Ljava/nio/ByteBuffer;)Ljava/lang/Object;");
- jobject buff = (*env)->NewDirectByteBuffer(env, (void*)&oid, sizeof(oid));
- jobject result = (*env)->CallStaticObjectMethod(env, clazz, method, buff);
- (*env)->DeleteLocalRef(env, buff);
+ if (!status) {
+ set_ejdb_error(env, db);
+ return NULL;
+ }
- return result;
+ jclass jObjectIdClazz = (*env)->FindClass(env, "org/bson/types/ObjectId");
+ jmethodID initMethodID = (*env)->GetMethodID(env, jObjectIdClazz, "<init>", "([B)V");
+
+ jbyteArray joiddata = (*env)->NewByteArray(env, sizeof(oid));
+ (*env)->SetByteArrayRegion(env, joiddata, 0, sizeof(oid), (jbyte*)&oid);
+ jobject result = (*env)->NewObject(env, jObjectIdClazz, initMethodID, joiddata);
+
+ (*env)->DeleteLocalRef(env, joiddata);
+
+ return result;
}
/*
* Method: removeDB
* Signature: ([B)V
*/
-JNIEXPORT void JNICALL Java_org_ejdb_driver_EJDBCollection_removeDB
- (JNIEnv *env, jobject obj, jbyteArray oidArray) {
- jclass clazz = (*env)->GetObjectClass(env, obj);
- jfieldID dboID = (*env)->GetFieldID(env, clazz, "db", "Lorg/ejdb/driver/EJDB;");
- jobject dbo = (*env)->GetObjectField(env, obj, dboID);
- jclass dclazz = (*env)->GetObjectClass(env, dbo);
- jfieldID dbpID = (*env)->GetFieldID(env, dclazz, "dbPointer", "J");
- jlong dbp = (*env)->GetLongField(env, dbo, dbpID);
-
- EJDB* db = (EJDB*)dbp;
- if (!ejdbisopen(db)) {
- set_error(env, 0, "EJDB not opened");
- return;
- }
+JNIEXPORT void JNICALL Java_org_ejdb_driver_EJDBCollection_removeDB (JNIEnv *env, jobject obj, jbyteArray oidArray) {
+ EJDB* db = get_ejdb_from_object(env, obj);
+ if (!ejdbisopen(db)) {
+ set_error(env, 0, "EJDB not opened");
+ return;
+ }
- jfieldID colnameID = (*env)->GetFieldID(env, clazz, "cname", "Ljava/lang/String;");
- jstring colname = (*env)->GetObjectField(env, obj, colnameID);
- const char *cname = (*env)->GetStringUTFChars(env, colname, NULL);
- EJCOLL * coll = ejdbgetcoll(db, cname);
- (*env)->ReleaseStringUTFChars(env, colname, cname);
+ jstring colname = get_coll_name(env, obj);
+ const char *cname = (*env)->GetStringUTFChars(env, colname, NULL);
+ EJCOLL * coll = ejdbgetcoll(db, cname);
+ (*env)->ReleaseStringUTFChars(env, colname, cname);
- if (!coll) {
- return;
- }
+ if (!coll) {
+ return;
+ }
- bson_oid_t *oid = (void*)(*env)->GetByteArrayElements(env, oidArray, NULL);
- bool status = ejdbrmbson(coll, oid);
- (*env)->ReleaseByteArrayElements(env, oidArray, (jbyte*)oid, 0);
+ // TODO:
+ bson_oid_t *oid = (void*)(*env)->GetByteArrayElements(env, oidArray, NULL);
+ bool status = ejdbrmbson(coll, oid);
+ (*env)->ReleaseByteArrayElements(env, oidArray, (jbyte*)oid, 0);
- if (!status) {
- set_ejdb_error(env, db);
- return;
- }
+ if (!status) {
+ set_ejdb_error(env, db);
+ return;
+ }
}
/*
* Method: setIndexDB
* Signature: (Ljava/lang/String;I)V
*/
-JNIEXPORT void JNICALL Java_org_ejdb_driver_EJDBCollection_setIndexDB
- (JNIEnv *env, jobject obj, jstring pathstr, jint flags) {
- jclass clazz = (*env)->GetObjectClass(env, obj);
- jfieldID colnameID = (*env)->GetFieldID(env, clazz, "cname", "Ljava/lang/String;");
- jstring colname = (*env)->GetObjectField(env, obj, colnameID);
- jfieldID dboID = (*env)->GetFieldID(env, clazz, "db", "Lorg/ejdb/driver/EJDB;");
- jobject dbo = (*env)->GetObjectField(env, obj, dboID);
- jclass dclazz = (*env)->GetObjectClass(env, dbo);
- jfieldID dbpID = (*env)->GetFieldID(env, dclazz, "dbPointer", "J");
- jlong dbp = (*env)->GetLongField(env, dbo, dbpID);
-
- EJDB* db = (EJDB*)dbp;
- if (!ejdbisopen(db)) {
- set_error(env, 0, "EJDB not opened");
- return;
- }
+JNIEXPORT void JNICALL Java_org_ejdb_driver_EJDBCollection_setIndexDB (JNIEnv *env, jobject obj, jstring pathstr, jint flags) {
+ EJDB* db = get_ejdb_from_object(env, obj);
+ if (!ejdbisopen(db)) {
+ set_error(env, 0, "EJDB not opened");
+ return;
+ }
- const char *cname = (*env)->GetStringUTFChars(env, colname, NULL);
- EJCOLL * coll = ejdbcreatecoll(db, cname, NULL);
- (*env)->ReleaseStringUTFChars(env, colname, cname);
+ jstring colname = get_coll_name(env, obj);
+ const char *cname = (*env)->GetStringUTFChars(env, colname, NULL);
+ EJCOLL * coll = ejdbcreatecoll(db, cname, NULL);
+ (*env)->ReleaseStringUTFChars(env, colname, cname);
- if (!coll) {
- set_ejdb_error(env, db);
- return;
- }
+ if (!coll) {
+ set_ejdb_error(env, db);
+ return;
+ }
- const char * path = (*env)->GetStringUTFChars(env, pathstr, NULL);
- bool status = ejdbsetindex(coll, path, flags);
- (*env)->ReleaseStringUTFChars(env, pathstr, path);
+ const char * path = (*env)->GetStringUTFChars(env, pathstr, NULL);
+ bool status = ejdbsetindex(coll, path, flags);
+ (*env)->ReleaseStringUTFChars(env, pathstr, path);
- if (!status) {
- set_ejdb_error(env, db);
- return;
- }
+ if (!status) {
+ set_ejdb_error(env, db);
+ return;
+ }
};
/*
* Method: executeDB
* Signature: (Lorg/bson/BSONObject;[Lorg/bson/BSONObject;Lorg/bson/BSONObject;I)Lorg/ejdb/driver/EJDBQuery$QResult;
*/
-JNIEXPORT jobject JNICALL Java_org_ejdb_driver_EJDBQuery_executeDB
- (JNIEnv *env, jobject obj, jobject qobj, jobjectArray qorarrobj, jobject hobj, jint flags) {
- jclass clazz = (*env)->GetObjectClass(env, obj);
- jfieldID coID = (*env)->GetFieldID(env, clazz, "coll", "Lorg/ejdb/driver/EJDBCollection;");
- jobject collobj = (*env)->GetObjectField(env, obj, coID);
- jclass cclazz = (*env)->GetObjectClass(env, collobj);
- jfieldID colnameID = (*env)->GetFieldID(env, cclazz, "cname", "Ljava/lang/String;");
- jstring colname = (*env)->GetObjectField(env, collobj, colnameID);
- jfieldID dboID = (*env)->GetFieldID(env, cclazz, "db", "Lorg/ejdb/driver/EJDB;");
- jobject dbo = (*env)->GetObjectField(env, collobj, dboID);
- jclass dclazz = (*env)->GetObjectClass(env, dbo);
- jfieldID dbpID = (*env)->GetFieldID(env, dclazz, "dbPointer", "J");
- jlong dbp = (*env)->GetLongField(env, dbo, dbpID);
-
- jclass jBSONClazz = (*env)->FindClass(env, "org/bson/BSON");
- jmethodID encodeMethodID = (*env)->GetStaticMethodID(env, jBSONClazz, "encode", "(Lorg/bson/BSONObject;)[B");
-
- jclass jQResultClazz = (*env)->FindClass(env, "org/ejdb/driver/EJDBQuery$QResult");
- jmethodID initQResultMethodID = (*env)->GetMethodID(env, jQResultClazz, "<init>", "(IJ)V");
-
- bson *qbson = NULL;
- bson *qorbsons = NULL;
- bson *qhbson = NULL;
-
- EJQ *q = NULL;
-
- jobject qresult = NULL;
-
- EJDB* db = (EJDB*)dbp;
- if (!ejdbisopen(db)) {
- set_error(env, 0, "EJDB not opened");
- goto finish;
- }
+JNIEXPORT jobject JNICALL Java_org_ejdb_driver_EJDBQuery_executeDB (JNIEnv *env, jobject obj, jobject qobj, jobjectArray qorarrobj, jobject hobj, jint flags) {
+ jclass jQResultClazz = (*env)->FindClass(env, "org/ejdb/driver/EJDBQuery$QResult");
+ jmethodID initQResultMethodID = (*env)->GetMethodID(env, jQResultClazz, "<init>", "(IJ)V");
- jsize blength = 0;
- jbyte *bdata = NULL;
- jbyteArray bobjdata;
+ bson *qbson = NULL;
+ bson *qorbsons = NULL;
+ bson *qhbson = NULL;
- bobjdata = (*env)->CallStaticObjectMethod(env, jBSONClazz, encodeMethodID, qobj);
- bdata = (*env)->GetByteArrayElements(env, bobjdata, NULL);
- blength = (*env)->GetArrayLength(env, bobjdata);
- qbson = bson_create_from_buffer(bdata, blength);
- (*env)->ReleaseByteArrayElements(env, bobjdata, bdata, 0);
- (*env)->DeleteLocalRef(env, bobjdata);
+ EJQ *q = NULL;
- // todo: check query bson
- if (!qbson) {
- //
- goto finish;
- }
+ jobject qresult = NULL;
- jsize qorz = NULL != qorarrobj ? (*env)->GetArrayLength(env, qorarrobj) : 0;
- if (qorz > 0) {
- qorbsons = (bson*)malloc(qorz * sizeof(bson));
- // todo: check memory allocation
- if (!qorbsons) {
- set_error(env, 0, "Not enought memory");
- goto finish;
- }
+ EJDB* db = get_ejdb_from_object(env, obj);
+ if (!ejdbisopen(db)) {
+ set_error(env, 0, "EJDB not opened");
+ goto finish;
+ }
- for (jsize i = 0; i < qorz; ++i) {
- jobject qorobj = (*env)->GetObjectArrayElement(env, qorarrobj, i);
+ qbson = encode_bson(env, qobj, NULL);
- bobjdata = (*env)->CallStaticObjectMethod(env, jBSONClazz, encodeMethodID, qorobj);
- bdata = (*env)->GetByteArrayElements(env, bobjdata, NULL);
- blength = (*env)->GetArrayLength(env, bobjdata);
- bson_create_from_buffer2(&qorbsons[i], bdata, blength);
- (*env)->ReleaseByteArrayElements(env, bobjdata, bdata, 0);
- (*env)->DeleteLocalRef(env, bobjdata);
- }
- }
-
- if (NULL != hobj){
- bobjdata = (*env)->CallStaticObjectMethod(env, jBSONClazz, encodeMethodID, hobj);
- bdata = (*env)->GetByteArrayElements(env, bobjdata, NULL);
- blength = (*env)->GetArrayLength(env, bobjdata);
- qhbson = bson_create_from_buffer(bdata, blength);
- (*env)->ReleaseByteArrayElements(env, bobjdata, bdata, 0);
- (*env)->DeleteLocalRef(env, bobjdata);
- }
+ // todo: check query bson
+ if (!qbson) {
+ //
+ goto finish;
+ }
- q = ejdbcreatequery(db, qbson, qorz > 0 ? qorbsons : NULL, qorz, qhbson);
- if (!q) {
- set_ejdb_error(env, db);
+ jsize qorz = NULL != qorarrobj ? (*env)->GetArrayLength(env, qorarrobj) : 0;
+ if (qorz > 0) {
+ qorbsons = (bson*)malloc(qorz * sizeof(bson));
+ if (!qorbsons) {
+ set_error(env, 0, "Not enought memory");
goto finish;
}
- const char *cname = (*env)->GetStringUTFChars(env, colname, NULL);
- EJCOLL *coll = ejdbgetcoll(db, cname);
-
- if (!coll) {
- bson_iterator it;
- //If we are in $upsert mode a new collection will be created
- if (bson_find(&it, qbson, "$upsert") == BSON_OBJECT) {
- coll = ejdbcreatecoll(db, cname, NULL);
- (*env)->ReleaseStringUTFChars(env, colname, cname);
- if (!coll) {
- set_ejdb_error(env, db);
- goto finish;
- }
- }
- } else {
- (*env)->ReleaseStringUTFChars(env, colname, cname);
+ for (jsize i = 0; i < qorz; ++i) {
+ jobject qorobj = (*env)->GetObjectArrayElement(env, qorarrobj, i);
+ encode_bson(env, qorobj, &qorbsons[i]);
}
+ }
+
+ if (NULL != hobj){
+ qhbson = encode_bson(env, hobj, NULL);
+ }
+
+ q = ejdbcreatequery(db, qbson, qorz > 0 ? qorbsons : NULL, qorz, qhbson);
+ if (!q) {
+ set_ejdb_error(env, db);
+ goto finish;
+ }
- uint32_t count = 0;
- TCLIST *qres = NULL;
- if (!coll) { //No collection -> no results
- qres = (flags & JBQRYCOUNT) ? NULL : tclistnew2(1); //empty results
- } else {
- qres = ejdbqryexecute(coll, q, &count, flags, NULL);
- if (ejdbecode(db) != TCESUCCESS) {
+ jstring colname = get_coll_name(env, obj);
+
+ const char *cname = (*env)->GetStringUTFChars(env, colname, NULL);
+ EJCOLL *coll = ejdbgetcoll(db, cname);
+
+ if (!coll) {
+ bson_iterator it;
+ //If we are in $upsert mode a new collection will be created
+ if (bson_find(&it, qbson, "$upsert") == BSON_OBJECT) {
+ coll = ejdbcreatecoll(db, cname, NULL);
+ (*env)->ReleaseStringUTFChars(env, colname, cname);
+ if (!coll) {
set_ejdb_error(env, db);
goto finish;
}
}
-
- qresult = (*env)->NewObject(env, jQResultClazz, initQResultMethodID, (jint)count, (jlong)qres);
+ } else {
+ (*env)->ReleaseStringUTFChars(env, colname, cname);
+ }
+
+ uint32_t count = 0;
+ TCLIST *qres = NULL;
+ if (!coll) { //No collection -> no results
+ qres = (flags & JBQRYCOUNT) ? NULL : tclistnew2(1); //empty results
+ } else {
+ qres = ejdbqryexecute(coll, q, &count, flags, NULL);
+ if (ejdbecode(db) != TCESUCCESS) {
+ set_ejdb_error(env, db);
+ goto finish;
+ }
+ }
+
+ qresult = (*env)->NewObject(env, jQResultClazz, initQResultMethodID, (jint)count, (jlong)qres);
finish:
- // clear
- if (qbson) {
- bson_del(qbson);
- }
- if (qorbsons) {
- for (int i = 0; i < qorz; ++i) {
- bson_destroy(&qorbsons[i]);
- }
- free(qorbsons);
- }
- if (qhbson) {
- bson_del(qhbson);
- }
- if (q) {
- ejdbquerydel(q);
- }
+ // clear
+ if (qbson) {
+ bson_del(qbson);
+ }
+ if (qorbsons) {
+ for (int i = 0; i < qorz; ++i) {
+ bson_destroy(&qorbsons[i]);
+ }
+ free(qorbsons);
+ }
+ if (qhbson) {
+ bson_del(qhbson);
+ }
+ if (q) {
+ ejdbquerydel(q);
+ }
+
+ return qresult;
+};
+
+/*
+* Class: org_ejdb_driver_EJDBResultSet
+* Method: getDB
+* Signature: (I)Lorg/bson/BSONObject;
+*/
+JNIEXPORT jobject JNICALL Java_org_ejdb_driver_EJDBResultSet_getDB (JNIEnv *env, jobject obj, jint indx) {
+ TCLIST *rs = get_rs_from_object(env, obj);
+
+ if (!rs) {
+ set_error(env, 0, "Cursor closed");
+ return NULL;
+ }
- return qresult;
+ if (indx < 0 || indx >= TCLISTNUM(rs)) {
+ set_error(env, 0, "Invalid cursor position");
+ return NULL;
+ }
+
+ int bdatasz;
+ void *bdata;
+
+ TCLISTVAL(bdata, rs, indx, bdatasz);
+
+ return decode_bson_from_buffer(env, bdata, bdatasz);
+};
+
+/*
+* Class: org_ejdb_driver_EJDBResultSet
+* Method: lengthDB
+* Signature: ()I
+*/
+JNIEXPORT jint JNICALL Java_org_ejdb_driver_EJDBResultSet_lengthDB (JNIEnv *env, jobject obj) {
+ TCLIST *rs = get_rs_from_object(env, obj);
+
+ if (!rs) {
+ return 0;
+ }
+
+ return TCLISTNUM(rs);
};
/*
- * Class: org_ejdb_driver_EJDBResultSet
- * Method: getDB
- * Signature: (I)Lorg/bson/BSONObject;
- */
- JNIEXPORT jobject JNICALL Java_org_ejdb_driver_EJDBResultSet_getDB
- (JNIEnv *env, jobject obj, jint indx) {
- jclass clazz = (*env)->GetObjectClass(env, obj);
- jfieldID rspID = (*env)->GetFieldID(env, clazz, "rsPointer", "J");
- jlong rsp = (*env)->GetLongField(env, obj, rspID);
-
- TCLIST *rs = (TCLIST *)rsp;
-
- if (!rs) {
- set_error(env, 0, "Cursor closed");
- return NULL;
- }
-
- if (indx < 0 || indx >= TCLISTNUM(rs)) {
- set_error(env, 0, "Invalid cursor position");
- return NULL;
- }
-
- int bsdatasz;
- void *bsdata;
-
- TCLISTVAL(bsdata, rs, indx, bsdatasz);
-
- // decode BSONObject
- jclass jBSONClazz = (*env)->FindClass(env, "org/bson/BSON");
- jmethodID decodeMethodID = (*env)->GetStaticMethodID(env, jBSONClazz, "decode", "([B)Lorg/bson/BSONObject;");
-
- jbyteArray jbsdata = (*env)->NewByteArray(env, bsdatasz);
- (*env)->SetByteArrayRegion(env, jbsdata, 0, bsdatasz, (jbyte*)bsdata);
- jobject bson = (*env)->CallStaticObjectMethod(env, jBSONClazz, decodeMethodID, jbsdata);
-
- (*env)->DeleteLocalRef(env, jbsdata);
-
- return bson;
- };
-
- /*
- * Class: org_ejdb_driver_EJDBResultSet
- * Method: lengthDB
- * Signature: ()I
- */
- JNIEXPORT jint JNICALL Java_org_ejdb_driver_EJDBResultSet_lengthDB
- (JNIEnv *env, jobject obj) {
- jclass clazz = (*env)->GetObjectClass(env, obj);
- jfieldID rspID = (*env)->GetFieldID(env, clazz, "rsPointer", "J");
- jlong rsp = (*env)->GetLongField(env, obj, rspID);
-
- TCLIST *rs = (TCLIST *)rsp;
-
- if (!rs) {
- return 0;
- }
-
- return TCLISTNUM(rs);
- };
-
- /*
- * Class: org_ejdb_driver_EJDBResultSet
- * Method: closeDB
- * Signature: ()V
- */
- JNIEXPORT void JNICALL Java_org_ejdb_driver_EJDBResultSet_closeDB
- (JNIEnv *env, jobject obj) {
- jclass clazz = (*env)->GetObjectClass(env, obj);
- jfieldID rspID = (*env)->GetFieldID(env, clazz, "rsPointer", "J");
- jlong rsp = (*env)->GetLongField(env, obj, rspID);
-
- TCLIST *rs = (TCLIST *)rsp;
-
- if (!rs) {
- return;
- }
-
- tclistdel(rs);
-
- (*env)->SetLongField(env, obj, rspID, (jlong)0);
- };
+* Class: org_ejdb_driver_EJDBResultSet
+* Method: closeDB
+* Signature: ()V
+*/
+JNIEXPORT void JNICALL Java_org_ejdb_driver_EJDBResultSet_closeDB (JNIEnv *env, jobject obj) {
+ TCLIST *rs = get_rs_from_object(env, obj);
+
+ if (!rs) {
+ return;
+ }
+
+ tclistdel(rs);
+
+ set_rs_to_object(env, obj, NULL);
+};
projects / platform / upstream / ejdb.git / commitdiff