diff --git a/cmd/internal/planetscale_edge_database.go b/cmd/internal/planetscale_edge_database.go index 30c222e..90b8f39 100644 --- a/cmd/internal/planetscale_edge_database.go +++ b/cmd/internal/planetscale_edge_database.go @@ -138,7 +138,7 @@ func getJsonSchemaType(mysqlType string, treatTinyIntAsBoolean bool) PropertyTyp } if strings.HasPrefix(mysqlType, "bigint") { - return PropertyType{Type: "integer", AirbyteType: "big_integer"} + return PropertyType{Type: "string", AirbyteType: "big_integer"} } if strings.HasPrefix(mysqlType, "datetime") { diff --git a/cmd/internal/planetscale_edge_database_test.go b/cmd/internal/planetscale_edge_database_test.go index a952934..f6107e3 100644 --- a/cmd/internal/planetscale_edge_database_test.go +++ b/cmd/internal/planetscale_edge_database_test.go @@ -239,17 +239,17 @@ func TestDiscover_CanPickRightAirbyteType(t *testing.T) { }, { MysqlType: "bigint(16)", - JSONSchemaType: "integer", + JSONSchemaType: "string", AirbyteType: "big_integer", }, { MysqlType: "bigint unsigned", - JSONSchemaType: "integer", + JSONSchemaType: "string", AirbyteType: "big_integer", }, { MysqlType: "bigint zerofill", - JSONSchemaType: "integer", + JSONSchemaType: "string", AirbyteType: "big_integer", }, {