1 // Copyright (c) Facebook, Inc. and its affiliates. All Rights Reserved.
2 // Copyright (c) 2014, Vlad Balan (vlad.gm@gmail.com). All rights reserved.
3 // This source code is licensed under both the GPLv2 (found in the
4 // COPYING file in the root directory) and Apache 2.0 License
5 // (found in the LICENSE.Apache file in the root directory).
6 //
7 // This file implements the "bridge" between Java and C++
8 // for ROCKSDB_NAMESPACE::MergeOperator.
9
10 #include <jni.h>
11 #include <stdio.h>
12 #include <stdlib.h>
13 #include <memory>
14 #include <string>
15
16 #include "include/org_rocksdb_StringAppendOperator.h"
17 #include "include/org_rocksdb_UInt64AddOperator.h"
18 #include "rocksdb/db.h"
19 #include "rocksdb/memtablerep.h"
20 #include "rocksdb/merge_operator.h"
21 #include "rocksdb/options.h"
22 #include "rocksdb/slice_transform.h"
23 #include "rocksdb/statistics.h"
24 #include "rocksdb/table.h"
25 #include "rocksjni/portal.h"
26 #include "utilities/merge_operators.h"
27
28 /*
29 * Class: org_rocksdb_StringAppendOperator
30 * Method: newSharedStringAppendOperator
31 * Signature: (C)J
32 */
Java_org_rocksdb_StringAppendOperator_newSharedStringAppendOperator(JNIEnv *,jclass,jchar jdelim)33 jlong Java_org_rocksdb_StringAppendOperator_newSharedStringAppendOperator(
34 JNIEnv* /*env*/, jclass /*jclazz*/, jchar jdelim) {
35 auto* sptr_string_append_op =
36 new std::shared_ptr<ROCKSDB_NAMESPACE::MergeOperator>(
37 ROCKSDB_NAMESPACE::MergeOperators::CreateStringAppendOperator(
38 (char)jdelim));
39 return reinterpret_cast<jlong>(sptr_string_append_op);
40 }
41
42 /*
43 * Class: org_rocksdb_StringAppendOperator
44 * Method: disposeInternal
45 * Signature: (J)V
46 */
Java_org_rocksdb_StringAppendOperator_disposeInternal(JNIEnv *,jobject,jlong jhandle)47 void Java_org_rocksdb_StringAppendOperator_disposeInternal(JNIEnv* /*env*/,
48 jobject /*jobj*/,
49 jlong jhandle) {
50 auto* sptr_string_append_op =
51 reinterpret_cast<std::shared_ptr<ROCKSDB_NAMESPACE::MergeOperator>*>(
52 jhandle);
53 delete sptr_string_append_op; // delete std::shared_ptr
54 }
55
56 /*
57 * Class: org_rocksdb_UInt64AddOperator
58 * Method: newSharedUInt64AddOperator
59 * Signature: ()J
60 */
Java_org_rocksdb_UInt64AddOperator_newSharedUInt64AddOperator(JNIEnv *,jclass)61 jlong Java_org_rocksdb_UInt64AddOperator_newSharedUInt64AddOperator(
62 JNIEnv* /*env*/, jclass /*jclazz*/) {
63 auto* sptr_uint64_add_op =
64 new std::shared_ptr<ROCKSDB_NAMESPACE::MergeOperator>(
65 ROCKSDB_NAMESPACE::MergeOperators::CreateUInt64AddOperator());
66 return reinterpret_cast<jlong>(sptr_uint64_add_op);
67 }
68
69 /*
70 * Class: org_rocksdb_UInt64AddOperator
71 * Method: disposeInternal
72 * Signature: (J)V
73 */
Java_org_rocksdb_UInt64AddOperator_disposeInternal(JNIEnv *,jobject,jlong jhandle)74 void Java_org_rocksdb_UInt64AddOperator_disposeInternal(JNIEnv* /*env*/,
75 jobject /*jobj*/,
76 jlong jhandle) {
77 auto* sptr_uint64_add_op =
78 reinterpret_cast<std::shared_ptr<ROCKSDB_NAMESPACE::MergeOperator>*>(
79 jhandle);
80 delete sptr_uint64_add_op; // delete std::shared_ptr
81 }
82