Add new list and map operations.

somil-jain-fk · Feb 10, 2018 · af781ca · af781ca
1 parent 9736c18
commit af781ca
Show file tree

Hide file tree

Showing 13 changed files with 1,109 additions and 368 deletions.
diff --git a/client/src/com/aerospike/client/cdt/CDT.java b/client/src/com/aerospike/client/cdt/CDT.java
@@ -0,0 +1,120 @@
+/*
+ * Copyright 2012-2018 Aerospike, Inc.
+ *
+ * Portions may be licensed to Aerospike, Inc. under one or more contributor
+ * license agreements WHICH ARE COMPATIBLE WITH THE APACHE LICENSE, VERSION 2.0.
+ *
+ * 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.
+ */
+package com.aerospike.client.cdt;
+
+import java.util.List;
+
+import com.aerospike.client.Operation;
+import com.aerospike.client.Value;
+import com.aerospike.client.util.Packer;
+
+public abstract class CDT {
+
+	protected static Operation createOperation(int command, Operation.Type type, String binName) {
+		Packer packer = new Packer();
+		packer.packRawShort(command);
+		return new Operation(type, binName, Value.get(packer.toByteArray()));
+	}
+
+	protected static Operation createOperation(int command, Operation.Type type, String binName, int v1) {
+		Packer packer = new Packer();
+		packer.packRawShort(command);
+		packer.packArrayBegin(1);
+		packer.packInt(v1);
+		return new Operation(type, binName, Value.get(packer.toByteArray()));
+	}
+
+	protected static Operation createOperation(int command, Operation.Type type, String binName, int v1, int v2) {
+		Packer packer = new Packer();
+		packer.packRawShort(command);
+		packer.packArrayBegin(2);
+		packer.packInt(v1);
+		packer.packInt(v2);
+		return new Operation(type, binName, Value.get(packer.toByteArray()));
+	}
+
+	protected static Operation createOperation(int command, Operation.Type type, String binName, int v1, int v2, int v3) {
+		Packer packer = new Packer();
+		packer.packRawShort(command);
+		packer.packArrayBegin(3);
+		packer.packInt(v1);
+		packer.packInt(v2);
+		packer.packInt(v3);
+		return new Operation(type, binName, Value.get(packer.toByteArray()));
+	}
+
+	protected static Operation createOperation(int command, Operation.Type type, String binName, int v1, Value v2) {
+		Packer packer = new Packer();
+		packer.packRawShort(command);
+		packer.packArrayBegin(2);
+		packer.packInt(v1);
+		v2.pack(packer);		
+		return new Operation(type, binName, Value.get(packer.toByteArray()));
+	}
+
+	protected static Operation createOperation(int command, Operation.Type type, String binName, int v1, Value v2, int v3, int v4) {
+		Packer packer = new Packer();
+		packer.packRawShort(command);
+		packer.packArrayBegin(4);
+		packer.packInt(v1);
+		v2.pack(packer);
+		packer.packInt(v3);
+		packer.packInt(v4);
+		return new Operation(type, binName, Value.get(packer.toByteArray()));
+	}
+
+	protected static Operation createOperation(int command, Operation.Type type, String binName, int v1, List<Value> v2) {
+		Packer packer = new Packer();
+		packer.packRawShort(command);
+		packer.packArrayBegin(2);
+		packer.packInt(v1);
+		packer.packValueList(v2);
+		return new Operation(type, binName, Value.get(packer.toByteArray()));
+	}
+
+	protected static Operation createOperation(int command, Operation.Type type, String binName, Value v1, Value v2, int v3) {
+		Packer packer = new Packer();
+		packer.packRawShort(command);		
+		packer.packArrayBegin(3);
+		v1.pack(packer);
+		v2.pack(packer);
+		packer.packInt(v3);
+		return new Operation(type, binName, Value.get(packer.toByteArray()));
+	}
+
+	protected static Operation createRangeOperation(int command, Operation.Type type, String binName, Value begin, Value end, int returnType) {
+		Packer packer = new Packer();
+		packer.packRawShort(command);
+
+		if (begin == null) {
+			begin = Value.getAsNull();
+		}
+
+		if (end == null) {
+			packer.packArrayBegin(2);
+			packer.packInt(returnType);
+			begin.pack(packer);		
+		}
+		else {
+			packer.packArrayBegin(3);
+			packer.packInt(returnType);
+			begin.pack(packer);		
+			end.pack(packer);		
+		}
+		return new Operation(type, binName, Value.get(packer.toByteArray()));
+	}
+}