lenInBytes) {
- SchemaId schemaId = row.get().ReadSchemaId(offset).clone();
+ SchemaId schemaId = row.get().readSchemaId(offset).clone();
lenInBytes.setAndGet(SchemaId.SIZE);
return new TypeArgumentList(schemaId.clone());
}
diff --git a/java/src/test/java/com/azure/data/cosmos/serialization/hybridrow/codecs/DateTimeCodecTest.java b/java/src/test/java/com/azure/data/cosmos/serialization/hybridrow/codecs/DateTimeCodecTest.java
new file mode 100644
index 0000000..935a1ba
--- /dev/null
+++ b/java/src/test/java/com/azure/data/cosmos/serialization/hybridrow/codecs/DateTimeCodecTest.java
@@ -0,0 +1,87 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+package com.azure.data.cosmos.serialization.hybridrow.codecs;
+
+import com.google.common.collect.ImmutableList;
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import org.testng.annotations.DataProvider;
+import org.testng.annotations.Test;
+
+import java.time.OffsetDateTime;
+import java.util.Iterator;
+
+import static org.testng.Assert.assertEquals;
+
+/**
+ * Tests the DateTimeCodec using data generated from C# code
+ *
+ * Test data was generated from code that looks like this:
+ * {@code
+ * var buffer = new byte[8];
+ * var value = DateTime.Now;
+ * MemoryMarshal.Write(buffer, ref value);
+ * Console.WriteLine($"new DateTimeItem(new byte[] {{ (byte) {string.Join(", (byte) ", buffer )} }}, OffsetDateTime.parse(\"{value.ToString("o")}\"))");
+ * }
+ */
+public class DateTimeCodecTest {
+
+ @Test(dataProvider = "dateTimeDataProvider")
+ public void testDecodeByteArray(byte[] buffer, OffsetDateTime value) {
+ OffsetDateTime actual = DateTimeCodec.decode(buffer);
+ assertEquals(actual, value);
+ }
+
+ @Test(dataProvider = "dateTimeDataProvider")
+ public void testDecodeByteBuf(byte[] buffer, OffsetDateTime value) {
+ ByteBuf byteBuf = Unpooled.wrappedBuffer(new byte[DateTimeCodec.BYTES]);
+ OffsetDateTime actual = DateTimeCodec.decode(byteBuf);
+ assertEquals(actual, value);
+ }
+
+ @Test(dataProvider = "dateTimeDataProvider")
+ public void testEncodeByteArray(byte[] buffer, OffsetDateTime value) {
+ byte[] actual = DateTimeCodec.encode(value);
+ assertEquals(actual, buffer);
+ }
+
+ @Test(dataProvider = "dateTimeDataProvider")
+ public void testEncodeByteBuf(byte[] buffer, OffsetDateTime value) {
+ ByteBuf actual = Unpooled.wrappedBuffer(new byte[DateTimeCodec.BYTES]);
+ DateTimeCodec.encode(value, actual);
+ assertEquals(actual.array(), buffer);
+ }
+
+ @DataProvider(name = "dateTimeDataProvider")
+ private Iterator dateTimeData(byte[] buffer, OffsetDateTime value) {
+ ImmutableList items = ImmutableList.of(
+ new DateTimeItem(new byte[] {
+ (byte) 120, (byte) 212, (byte) 106, (byte) 251, (byte) 105, (byte) 48, (byte) 215, (byte) 136 },
+ OffsetDateTime.parse("2019-09-03T12:26:44.3996280-07:00")),
+ new DateTimeItem(new byte[] {
+ (byte) 226, (byte) 108, (byte) 87, (byte) 194, (byte) 164, (byte) 48, (byte) 215, (byte) 72 },
+ OffsetDateTime.parse("2019-09-03T19:27:28.9493730Z"))
+ );
+ return items.stream().map(item -> new Object[] { item.buffer, item.value }).iterator();
+ }
+
+ private static class DateTimeItem {
+
+ private final byte[] buffer;
+ private final OffsetDateTime value;
+
+ DateTimeItem(byte[] buffer, OffsetDateTime value) {
+ this.buffer = buffer;
+ this.value = value;
+ }
+
+ public byte[] buffer() {
+ return this.buffer;
+ }
+
+ public OffsetDateTime value() {
+ return this.value;
+ }
+ }
+}
\ No newline at end of file
diff --git a/java/src/test/java/com/azure/data/cosmos/serialization/hybridrow/codecs/DecimalCodecTest.java b/java/src/test/java/com/azure/data/cosmos/serialization/hybridrow/codecs/DecimalCodecTest.java
new file mode 100644
index 0000000..e56cb09
--- /dev/null
+++ b/java/src/test/java/com/azure/data/cosmos/serialization/hybridrow/codecs/DecimalCodecTest.java
@@ -0,0 +1,112 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+package com.azure.data.cosmos.serialization.hybridrow.codecs;
+
+import com.google.common.collect.ImmutableList;
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import org.testng.annotations.DataProvider;
+import org.testng.annotations.Test;
+
+import java.math.BigDecimal;
+import java.util.Iterator;
+
+import static org.testng.Assert.assertEquals;
+
+/**
+ * Tests the DecimalCodec using data generated from C# code
+ *
+ * Test data was generated from code that looks like this:
+ * {@code
+ * var buffer = new byte[16];
+ * var value = decimal.MaxValue;
+ * MemoryMarshal.Write(buffer, ref value);
+ * Console.WriteLine($"new DecimalItem(new byte[] {{ (byte) {string.Join(", (byte) ", buffer )} }}, new BigDecimal(\"{value.ToString()}\"))"); * }
+ */
+public class DecimalCodecTest {
+
+ @Test(dataProvider = "decimalDataProvider")
+ public void testDecodeByteArray(byte[] buffer, BigDecimal value) {
+ BigDecimal actual = DecimalCodec.decode(buffer);
+ assertEquals(actual, value);
+ }
+
+ @Test(dataProvider = "decimalDataProvider")
+ public void testDecodeByteBuf(byte[] buffer, BigDecimal value) {
+ ByteBuf byteBuf = Unpooled.wrappedBuffer(new byte[DecimalCodec.BYTES]);
+ BigDecimal actual = DecimalCodec.decode(byteBuf);
+ assertEquals(actual, value);
+ }
+
+ @Test(dataProvider = "decimalDataProvider")
+ public void testEncodeByteArray(byte[] buffer, BigDecimal value) {
+ byte[] actual = DecimalCodec.encode(value);
+ assertEquals(actual, buffer);
+ }
+
+ @Test(dataProvider = "decimalDataProvider")
+ public void testEncodeByteBuf(byte[] buffer, BigDecimal value) {
+ ByteBuf actual = Unpooled.wrappedBuffer(new byte[DecimalCodec.BYTES]);
+ DecimalCodec.encode(value, actual);
+ assertEquals(actual.array(), buffer);
+ }
+
+ @DataProvider(name = "decimalDataProvider")
+ private Iterator dateTimeData(byte[] buffer, BigDecimal value) {
+ ImmutableList items = ImmutableList.of(
+ new DecimalItem( // decimal.Zero
+ new byte[] {
+ (byte) 0, (byte) 0, (byte) 0, (byte) 0, // flags
+ (byte) 0, (byte) 0, (byte) 0, (byte) 0, // high
+ (byte) 0, (byte) 0, (byte) 0, (byte) 0, // low
+ (byte) 0, (byte) 0, (byte) 0, (byte) 0, // mid
+ },
+ new BigDecimal("0")),
+ new DecimalItem( // decimal.One
+ new byte[] {
+ (byte) 0, (byte) 0, (byte) 0, (byte) 0, // flags
+ (byte) 0, (byte) 0, (byte) 0, (byte) 0, // high
+ (byte) 1, (byte) 0, (byte) 0, (byte) 0, // low
+ (byte) 0, (byte) 0, (byte) 0, (byte) 0, // mid
+ },
+ new BigDecimal("1")),
+ new DecimalItem( // decimal.MinValue
+ new byte[] {
+ (byte) 0, (byte) 0, (byte) 0, (byte) 128, // flags
+ (byte) 255, (byte) 255, (byte) 255, (byte) 255, // high
+ (byte) 255, (byte) 255, (byte) 255, (byte) 255, // low
+ (byte) 255, (byte) 255, (byte) 255, (byte) 255, // mid
+ },
+ new BigDecimal("-79228162514264337593543950335")),
+ new DecimalItem( // decimal.MaxValue
+ new byte[] {
+ (byte) 0, (byte) 0, (byte) 0, (byte) 0, // flags
+ (byte) 255, (byte) 255, (byte) 255, (byte) 255, // high
+ (byte) 255, (byte) 255, (byte) 255, (byte) 255, // low
+ (byte) 255, (byte) 255, (byte) 255, (byte) 255, // mid
+ },
+ new BigDecimal("79228162514264337593543950335"))
+ );
+ return items.stream().map(item -> new Object[] { item.buffer, item.value }).iterator();
+ }
+
+ private static class DecimalItem {
+
+ private final byte[] buffer;
+ private final BigDecimal value;
+
+ DecimalItem(byte[] buffer, BigDecimal value) {
+ this.buffer = buffer;
+ this.value = value;
+ }
+
+ public byte[] buffer() {
+ return this.buffer;
+ }
+
+ public BigDecimal value() {
+ return this.value;
+ }
+ }
+}
diff --git a/java/src/test/java/com/azure/data/cosmos/serialization/hybridrow/codecs/GuidCodecTest.java b/java/src/test/java/com/azure/data/cosmos/serialization/hybridrow/codecs/GuidCodecTest.java
new file mode 100644
index 0000000..f2ce33c
--- /dev/null
+++ b/java/src/test/java/com/azure/data/cosmos/serialization/hybridrow/codecs/GuidCodecTest.java
@@ -0,0 +1,93 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+package com.azure.data.cosmos.serialization.hybridrow.codecs;
+
+import com.google.common.collect.ImmutableList;
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import org.testng.annotations.DataProvider;
+import org.testng.annotations.Test;
+
+import java.util.Iterator;
+import java.util.UUID;
+
+import static org.testng.Assert.assertEquals;
+
+/**
+ * Tests the GuidCodec using data generated from C# code
+ *
+ * Test data was generated from code that looks like this:
+ * {@code
+ * var buffer = new byte[16];
+ * var value = Guid.NewGuid();
+ * MemoryMarshal.Write(buffer, ref value);
+ * Console.WriteLine($"new GuidItem(new byte[] {{ (byte) {string.Join(", (byte) ", buffer )} }}, UUID.fromString(\"{value.ToString()}\"))");
+ * }
+ */
+public class GuidCodecTest {
+
+ @Test(dataProvider = "guidDataProvider")
+ public void testDecodeByteArray(byte[] buffer, UUID value) {
+ UUID actual = GuidCodec.decode(buffer);
+ assertEquals(actual, value);
+ }
+
+ @Test(dataProvider = "guidDataProvider")
+ public void testDecodeByteBuf(byte[] buffer, UUID value) {
+ ByteBuf byteBuf = Unpooled.wrappedBuffer(new byte[GuidCodec.BYTES]);
+ UUID actual = GuidCodec.decode(byteBuf);
+ assertEquals(actual, value);
+ }
+
+ @Test(dataProvider = "guidDataProvider")
+ public void testEncodeByteArray(byte[] buffer, UUID value) {
+ byte[] actual = GuidCodec.encode(value);
+ assertEquals(actual, buffer);
+ }
+
+ @Test(dataProvider = "guidDataProvider")
+ public void testEncodeByteBuf(byte[] buffer, UUID value) {
+ ByteBuf actual = Unpooled.wrappedBuffer(new byte[GuidCodec.BYTES]);
+ GuidCodec.encode(value, actual);
+ assertEquals(actual.array(), buffer);
+ }
+
+ @DataProvider(name = "guidDataProvider")
+ private Iterator guidData(byte[] buffer, UUID value) {
+ ImmutableList items = ImmutableList.of(
+ new GuidItem(
+ new byte[] {
+ (byte) 0, (byte) 0, (byte) 0, (byte) 0, (byte) 0, (byte) 0, (byte) 0, (byte) 0,
+ (byte) 0, (byte) 0, (byte) 0, (byte) 0, (byte) 0, (byte) 0, (byte) 0, (byte) 0
+ },
+ UUID.fromString("00000000-0000-0000-0000-000000000000")),
+ new GuidItem(
+ new byte[] {
+ (byte) 191, (byte) 17, (byte) 214, (byte) 27, (byte) 22, (byte) 170, (byte) 84, (byte) 69,
+ (byte) 147, (byte) 105, (byte) 195, (byte) 216, (byte) 1, (byte) 81, (byte) 34, (byte) 107
+ },
+ UUID.fromString("1bd611bf-aa16-4554-9369-c3d80151226b"))
+ );
+ return items.stream().map(item -> new Object[] { item.buffer, item.value }).iterator();
+ }
+
+ private static class GuidItem {
+
+ private final byte[] buffer;
+ private final UUID value;
+
+ GuidItem(byte[] buffer, UUID value) {
+ this.buffer = buffer;
+ this.value = value;
+ }
+
+ public byte[] buffer() {
+ return this.buffer;
+ }
+
+ public UUID value() {
+ return this.value;
+ }
+ }
+}