[Improve][Connector-V2][MongoDB] A BsonInt32 will be convert to a long type (#7567)

loustler · Dongyeon · web-flow · commit adf26c20c55a · 2024-09-04T11:32:40.000+08:00
Co-authored-by: Dongyeon &lt;loustler@naverz-corp.com&gt;
diff --git a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/serde/BsonToRowDataConverters.java b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/serde/BsonToRowDataConverters.java
@@ -401,7 +401,7 @@ private static byte[] convertToBinary(BsonValue bsonValue) {
     }
 
     private static long convertToLong(BsonValue bsonValue) {
-        if (bsonValue.isInt64()) {
+        if (bsonValue.isInt64() || bsonValue.isInt32()) {
             return bsonValue.asNumber().longValue();
         }
         throw new MongodbConnectorException(

Original file line number	Diff line number	Diff line change
`@@ -401,7 +401,7 @@ private static byte[] convertToBinary(BsonValue bsonValue) {`
`401`	`401`	`}`
`402`	`402`
`403`	`403`	`private static long convertToLong(BsonValue bsonValue) {`
`404`		`- if (bsonValue.isInt64()) {`
	`404`	`+ if (bsonValue.isInt64() \|\| bsonValue.isInt32()) {`
`405`	`405`	`return bsonValue.asNumber().longValue();`
`406`	`406`	`}`
`407`	`407`	`throw new MongodbConnectorException(`