handle int/long correctly

airbytehq · Jul 20, 2022 · 0219384 · 0219384
1 parent ad8f875
commit 0219384
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/airbyte-db/db-lib/src/main/java/io/airbyte/db/jdbc/JdbcSourceOperations.java b/airbyte-db/db-lib/src/main/java/io/airbyte/db/jdbc/JdbcSourceOperations.java
@@ -107,7 +107,7 @@ public JsonSchemaType getJsonType(final JDBCType jdbcType) {
       case BIT, BOOLEAN -> JsonSchemaType.BOOLEAN;
       case TINYINT, SMALLINT -> JsonSchemaType.INTEGER;
       case INTEGER -> JsonSchemaType.INTEGER;
-      case BIGINT -> JsonSchemaType.INTEGER;
+      case BIGINT -> JsonSchemaType.NUMBER_BIGINT;
       case FLOAT, DOUBLE -> JsonSchemaType.NUMBER;
       case REAL -> JsonSchemaType.NUMBER;
       case NUMERIC, DECIMAL -> JsonSchemaType.NUMBER;

diff --git a/...tgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresSourceOperations.java b/...tgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresSourceOperations.java
@@ -244,7 +244,8 @@ public JDBCType getFieldType(final JsonNode field) {
   public JsonSchemaType getJsonType(final JDBCType jdbcType) {
     return switch (jdbcType) {
       case BOOLEAN -> JsonSchemaType.BOOLEAN;
-      case TINYINT, SMALLINT, INTEGER, BIGINT -> JsonSchemaType.INTEGER;
+      case TINYINT, SMALLINT, INTEGER -> JsonSchemaType.INTEGER;
+      case BIGINT -> JsonSchemaType.NUMBER_BIGINT;
       case FLOAT, DOUBLE, REAL, NUMERIC, DECIMAL -> JsonSchemaType.NUMBER;
       case BLOB, BINARY, VARBINARY, LONGVARBINARY -> JsonSchemaType.STRING_BASE_64;
       case ARRAY -> JsonSchemaType.ARRAY;