fix: add precision overwritten to 9 digit if the passed in JSON type is FLOAT or DOUBLE

README.md

@@ -49,7 +49,7 @@ If you are using Maven without BOM, add this to your dependencies:
 If you are using Gradle 5.x or later, add this to your dependencies:
 
 ```Groovy
-implementation platform('com.google.cloud:libraries-bom:26.3.0')
+implementation platform('com.google.cloud:libraries-bom:26.4.0')
 
 implementation 'com.google.cloud:google-cloud-bigquerystorage'
 ```

google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/JsonToProtoMessage.java

@@ -28,6 +28,7 @@
 import com.google.protobuf.Message;
 import com.google.protobuf.UninitializedMessageException;
 import java.math.BigDecimal;
+import java.math.RoundingMode;
 import java.time.LocalDate;
 import java.util.List;
 import java.util.logging.Logger;
@@ -49,6 +50,7 @@
  */
 public class JsonToProtoMessage {
   private static final Logger LOG = Logger.getLogger(JsonToProtoMessage.class.getName());
+  private static int NUMERIC_SCALE = 9;
   private static ImmutableMap<FieldDescriptor.Type, String> FieldTypeToDebugMessage =
       new ImmutableMap.Builder<FieldDescriptor.Type, String>()
           .put(FieldDescriptor.Type.BOOL, "boolean")
@@ -315,10 +317,15 @@ private static void fillField(
                       new BigDecimal(((Number) val).longValue())));
               return;
             } else if (val instanceof Float || val instanceof Double) {
+              // In JSON, the precision passed in is machine dependent. We should round the number
+              // before passing to backend.
+              BigDecimal bigDecimal = new BigDecimal(String.valueOf(val));
+              if (bigDecimal.scale() > 9) {
+                bigDecimal = bigDecimal.setScale(NUMERIC_SCALE, RoundingMode.HALF_UP);
+              }
               protoMsg.setField(
                   fieldDescriptor,
-                  BigDecimalByteStringEncoder.encodeToNumericByteString(
-                      new BigDecimal(String.valueOf(val))));
+                  BigDecimalByteStringEncoder.encodeToNumericByteString(bigDecimal));
               return;
             } else if (val instanceof BigDecimal) {
               protoMsg.setField(
@@ -559,10 +566,13 @@ private static void fillRepeatedField(
                       new BigDecimal(((Number) val).longValue())));
               added = true;
             } else if (val instanceof Float || val instanceof Double) {
+              BigDecimal bigDecimal = new BigDecimal(String.valueOf(val));
+              if (bigDecimal.scale() > 9) {
+                bigDecimal = bigDecimal.setScale(NUMERIC_SCALE, RoundingMode.HALF_UP);
+              }
               protoMsg.addRepeatedField(
                   fieldDescriptor,
-                  BigDecimalByteStringEncoder.encodeToNumericByteString(
-                      new BigDecimal(String.valueOf(val))));
+                  BigDecimalByteStringEncoder.encodeToNumericByteString(bigDecimal));
               added = true;
             } else if (val instanceof BigDecimal) {
               protoMsg.addRepeatedField(

google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/JsonToProtoMessageTest.java

@@ -20,6 +20,7 @@
 
 import com.google.cloud.bigquery.storage.test.JsonTest.*;
 import com.google.cloud.bigquery.storage.test.SchemaTest.*;
+import com.google.common.collect.ImmutableList;
 import com.google.common.collect.ImmutableMap;
 import com.google.protobuf.ByteString;
 import com.google.protobuf.Descriptors.Descriptor;
@@ -685,6 +686,60 @@ public void testDouble() throws Exception {
     assertEquals(expectedProto, protoMsg);
   }
 
+  @Test
+  public void testDoubleHighPrecision() throws Exception {
+    TableSchema tableSchema =
+        TableSchema.newBuilder()
+            .addFields(
+                TableFieldSchema.newBuilder()
+                    .setName("numeric")
+                    .setType(TableFieldSchema.Type.NUMERIC)
+                    .build())
+            .build();
+    TestNumeric expectedProto =
+        TestNumeric.newBuilder()
+            .setNumeric(
+                BigDecimalByteStringEncoder.encodeToNumericByteString(
+                    new BigDecimal("3.400500513")))
+            .build();
+    JSONObject json = new JSONObject();
+    json.put("numeric", 3.400500512978076);
+    DynamicMessage protoMsg =
+        JsonToProtoMessage.convertJsonToProtoMessage(
+            TestNumeric.getDescriptor(), tableSchema, json);
+    assertEquals(expectedProto, protoMsg);
+  }
+
+  @Test
+  public void testDoubleHighPrecision_RepeatedField() throws Exception {
+    TableSchema tableSchema =
+        TableSchema.newBuilder()
+            .addFields(
+                0,
+                TableFieldSchema.newBuilder()
+                    .setName("bignumeric")
+                    .setType(TableFieldSchema.Type.NUMERIC)
+                    .setMode(TableFieldSchema.Mode.REPEATED)
+                    .build())
+            .build();
+    TestBignumeric expectedProto =
+        TestBignumeric.newBuilder()
+            .addBignumeric(
+                BigDecimalByteStringEncoder.encodeToNumericByteString(
+                    new BigDecimal("3.400500513")))
+            .addBignumeric(
+                BigDecimalByteStringEncoder.encodeToNumericByteString(new BigDecimal("0.1")))
+            .addBignumeric(
+                BigDecimalByteStringEncoder.encodeToNumericByteString(new BigDecimal("0.12")))
+            .build();
+    JSONObject json = new JSONObject();
+    json.put("bignumeric", ImmutableList.of(3.400500512978076, 0.10000000000055, 0.12));
+    DynamicMessage protoMsg =
+        JsonToProtoMessage.convertJsonToProtoMessage(
+            TestBignumeric.getDescriptor(), tableSchema, json);
+    assertEquals(expectedProto, protoMsg);
+  }
+
   @Test
   public void testTimestamp() throws Exception {
     TableSchema tableSchema =