diff --git a/airbyte-config/config-models/src/test/java/io/airbyte/config/DataTypeEnumTest.java b/airbyte-config/config-models/src/test/java/io/airbyte/config/DataTypeEnumTest.java index f4257c550a88..d15b232b2598 100644 --- a/airbyte-config/config-models/src/test/java/io/airbyte/config/DataTypeEnumTest.java +++ b/airbyte-config/config-models/src/test/java/io/airbyte/config/DataTypeEnumTest.java @@ -18,7 +18,7 @@ class DataTypeEnumTest { @Test void testConversionFromJsonSchemaPrimitiveToDataType() { assertEquals(5, DataType.class.getEnumConstants().length); - assertEquals(17, JsonSchemaPrimitive.class.getEnumConstants().length); + assertEquals(16, JsonSchemaPrimitive.class.getEnumConstants().length); assertEquals(DataType.STRING, DataType.fromValue(JsonSchemaPrimitive.STRING.toString().toLowerCase())); assertEquals(DataType.NUMBER, DataType.fromValue(JsonSchemaPrimitive.NUMBER.toString().toLowerCase())); diff --git a/airbyte-config/init/src/main/resources/seed/source_definitions.yaml b/airbyte-config/init/src/main/resources/seed/source_definitions.yaml index 805ea649afb1..be244313d271 100644 --- a/airbyte-config/init/src/main/resources/seed/source_definitions.yaml +++ b/airbyte-config/init/src/main/resources/seed/source_definitions.yaml @@ -45,7 +45,7 @@ - name: AlloyDB for PostgreSQL sourceDefinitionId: 1fa90628-2b9e-11ed-a261-0242ac120002 dockerRepository: airbyte/source-alloydb - dockerImageTag: 1.0.49 + dockerImageTag: 1.0.51 documentationUrl: https://docs.airbyte.com/integrations/sources/alloydb icon: alloydb.svg sourceType: database @@ -1462,7 +1462,7 @@ - name: Postgres sourceDefinitionId: decd338e-5647-4c0b-adf4-da0e75f5a750 dockerRepository: airbyte/source-postgres - dockerImageTag: 1.0.50 + dockerImageTag: 1.0.51 documentationUrl: https://docs.airbyte.com/integrations/sources/postgres icon: postgresql.svg sourceType: database diff --git a/airbyte-config/init/src/main/resources/seed/source_specs.yaml b/airbyte-config/init/src/main/resources/seed/source_specs.yaml index a62157824844..e32e503a3185 100644 --- a/airbyte-config/init/src/main/resources/seed/source_specs.yaml +++ b/airbyte-config/init/src/main/resources/seed/source_specs.yaml @@ -370,7 +370,7 @@ supportsNormalization: false supportsDBT: false supported_destination_sync_modes: [] -- dockerImage: "airbyte/source-alloydb:1.0.49" +- dockerImage: "airbyte/source-alloydb:1.0.51" spec: documentationUrl: "https://docs.airbyte.com/integrations/sources/postgres" connectionSpecification: @@ -11633,7 +11633,7 @@ supportsNormalization: false supportsDBT: false supported_destination_sync_modes: [] -- dockerImage: "airbyte/source-postgres:1.0.50" +- dockerImage: "airbyte/source-postgres:1.0.51" spec: documentationUrl: "https://docs.airbyte.com/integrations/sources/postgres" connectionSpecification: diff --git a/airbyte-integrations/bases/debezium-v1-9-6/src/main/java/io/airbyte/integrations/debezium/internals/PostgresConverter.java b/airbyte-integrations/bases/debezium-v1-9-6/src/main/java/io/airbyte/integrations/debezium/internals/PostgresConverter.java index 5b9bf475312b..1cea6b7d8eca 100644 --- a/airbyte-integrations/bases/debezium-v1-9-6/src/main/java/io/airbyte/integrations/debezium/internals/PostgresConverter.java +++ b/airbyte-integrations/bases/debezium-v1-9-6/src/main/java/io/airbyte/integrations/debezium/internals/PostgresConverter.java @@ -13,8 +13,6 @@ import static org.apache.kafka.connect.data.Schema.OPTIONAL_FLOAT64_SCHEMA; import static org.apache.kafka.connect.data.Schema.OPTIONAL_STRING_SCHEMA; -import com.fasterxml.jackson.core.JsonProcessingException; -import com.fasterxml.jackson.databind.ObjectMapper; import io.airbyte.db.jdbc.DateTimeConverter; import io.debezium.spi.converter.CustomConverter; import io.debezium.spi.converter.RelationalColumn; @@ -55,8 +53,6 @@ public class PostgresConverter implements CustomConverter s.equalsIgnoreCase(field.typeName()))) { registerNumber(field, registration); } else if (Arrays.stream(ARRAY_TYPES).anyMatch(s -> s.equalsIgnoreCase(field.typeName()))) { @@ -82,19 +76,6 @@ public void converterFor(final RelationalColumn field, final ConverterRegistrati } } - private void registerJsonb(RelationalColumn field, ConverterRegistration registration) { - registration.register(SchemaBuilder.string().optional(), x -> { - if (x == null) { - return DebeziumConverterUtils.convertDefaultValue(field); - } - try { - return objectMapper.readTree(x.toString()).toString(); - } catch (JsonProcessingException e) { - throw new RuntimeException("Could not parse 'jsonb' value:" + e); - } - }); - } - private void registerArray(RelationalColumn field, ConverterRegistration registration) { final String fieldType = field.typeName().toUpperCase(); final SchemaBuilder arraySchema = switch (fieldType) { diff --git a/airbyte-integrations/connectors/source-alloydb-strict-encrypt/Dockerfile b/airbyte-integrations/connectors/source-alloydb-strict-encrypt/Dockerfile index 3b163f4b14f2..f3448b5efa09 100644 --- a/airbyte-integrations/connectors/source-alloydb-strict-encrypt/Dockerfile +++ b/airbyte-integrations/connectors/source-alloydb-strict-encrypt/Dockerfile @@ -16,5 +16,5 @@ ENV APPLICATION source-alloydb-strict-encrypt COPY --from=build /airbyte /airbyte -LABEL io.airbyte.version=1.0.49 +LABEL io.airbyte.version=1.0.51 LABEL io.airbyte.name=airbyte/source-alloydb-strict-encrypt diff --git a/airbyte-integrations/connectors/source-alloydb/Dockerfile b/airbyte-integrations/connectors/source-alloydb/Dockerfile index 298a8d72caa9..fd7f8f0a2c9a 100644 --- a/airbyte-integrations/connectors/source-alloydb/Dockerfile +++ b/airbyte-integrations/connectors/source-alloydb/Dockerfile @@ -16,5 +16,5 @@ ENV APPLICATION source-alloydb COPY --from=build /airbyte /airbyte -LABEL io.airbyte.version=1.0.49 +LABEL io.airbyte.version=1.0.51 LABEL io.airbyte.name=airbyte/source-alloydb diff --git a/airbyte-integrations/connectors/source-postgres-strict-encrypt/Dockerfile b/airbyte-integrations/connectors/source-postgres-strict-encrypt/Dockerfile index c93814496265..a27756ef9ecd 100644 --- a/airbyte-integrations/connectors/source-postgres-strict-encrypt/Dockerfile +++ b/airbyte-integrations/connectors/source-postgres-strict-encrypt/Dockerfile @@ -16,5 +16,5 @@ ENV APPLICATION source-postgres-strict-encrypt COPY --from=build /airbyte /airbyte -LABEL io.airbyte.version=1.0.50 +LABEL io.airbyte.version=1.0.51 LABEL io.airbyte.name=airbyte/source-postgres-strict-encrypt diff --git a/airbyte-integrations/connectors/source-postgres/Dockerfile b/airbyte-integrations/connectors/source-postgres/Dockerfile index d10a30fd656c..a0a99bf8fc92 100644 --- a/airbyte-integrations/connectors/source-postgres/Dockerfile +++ b/airbyte-integrations/connectors/source-postgres/Dockerfile @@ -16,5 +16,5 @@ ENV APPLICATION source-postgres COPY --from=build /airbyte /airbyte -LABEL io.airbyte.version=1.0.50 +LABEL io.airbyte.version=1.0.51 LABEL io.airbyte.name=airbyte/source-postgres diff --git a/airbyte-integrations/connectors/source-postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresSourceOperations.java b/airbyte-integrations/connectors/source-postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresSourceOperations.java index 2a6c5ab61a09..b3986ee46ce2 100644 --- a/airbyte-integrations/connectors/source-postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresSourceOperations.java +++ b/airbyte-integrations/connectors/source-postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresSourceOperations.java @@ -173,7 +173,6 @@ public void copyToJsonField(final ResultSet resultSet, final int colIndex, final case "path" -> putObject(json, columnName, resultSet, colIndex, PGpath.class); case "point" -> putObject(json, columnName, resultSet, colIndex, PGpoint.class); case "polygon" -> putObject(json, columnName, resultSet, colIndex, PGpolygon.class); - case "jsonb" -> putJsonb(json, columnName, resultSet, colIndex); case "_varchar", "_char", "_bpchar", "_text", "_name" -> putArray(json, columnName, resultSet, colIndex); case "_int2", "_int4", "_int8", "_oid" -> putLongArray(json, columnName, resultSet, colIndex); case "_numeric", "_decimal" -> putBigDecimalArray(json, columnName, resultSet, colIndex); @@ -187,7 +186,6 @@ public void copyToJsonField(final ResultSet resultSet, final int colIndex, final case "_timestamp" -> putTimestampArray(json, columnName, resultSet, colIndex); case "_timetz" -> putTimeTzArray(json, columnName, resultSet, colIndex); case "_time" -> putTimeArray(json, columnName, resultSet, colIndex); - case "_jsonb" -> putJsonbArray(json, columnName, resultSet, colIndex); default -> { switch (columnInfo.columnType) { case BOOLEAN -> json.put(columnName, value.equalsIgnoreCase("t")); @@ -211,33 +209,6 @@ public void copyToJsonField(final ResultSet resultSet, final int colIndex, final } } - private void putJsonbArray(ObjectNode node, String columnName, ResultSet resultSet, int colIndex) throws SQLException { - final ArrayNode arrayNode = Jsons.arrayNode(); - final ResultSet arrayResultSet = resultSet.getArray(colIndex).getResultSet(); - - while (arrayResultSet.next()) { - final PGobject object = getObject(arrayResultSet, colIndex, PGobject.class); - final JsonNode value; - try { - value = new ObjectMapper().readTree(object.getValue()); - } catch (JsonProcessingException e) { - throw new RuntimeException("Could not parse 'jsonb' value:" + e); - } - arrayNode.add(value); - } - node.set(columnName, arrayNode); - } - - private void putJsonb(ObjectNode node, String columnName, ResultSet resultSet, int colIndex) throws SQLException { - final PGobject object = getObject(resultSet, colIndex, PGobject.class); - - try { - node.put(columnName, new ObjectMapper().readTree(object.getValue())); - } catch (JsonProcessingException e) { - throw new RuntimeException("Could not parse 'jsonb' value:" + e); - } - } - private void putTimeArray(final ObjectNode node, final String columnName, final ResultSet resultSet, final int colIndex) throws SQLException { final ArrayNode arrayNode = Jsons.arrayNode(); final ResultSet arrayResultSet = resultSet.getArray(colIndex).getResultSet(); @@ -422,13 +393,11 @@ public PostgresType getDatabaseFieldType(final JsonNode field) { case "_time" -> PostgresType.TIME_ARRAY; case "_date" -> PostgresType.DATE_ARRAY; case "_bytea" -> PostgresType.BYTEA_ARRAY; - case "_jsonb" -> PostgresType.JSONB_ARRAY; case "bool", "boolean" -> PostgresType.BOOLEAN; // BYTEA is variable length binary string with hex output format by default (e.g. "\x6b707a"). // It should not be converted to base64 binary string. So it is represented as JDBC VARCHAR. // https://www.postgresql.org/docs/14/datatype-binary.html case "bytea" -> PostgresType.VARCHAR; - case "jsonb" -> PostgresType.JSONB; case TIMESTAMPTZ -> PostgresType.TIMESTAMP_WITH_TIMEZONE; case TIMETZ -> PostgresType.TIME_WITH_TIMEZONE; default -> PostgresType.valueOf(field.get(INTERNAL_COLUMN_TYPE).asInt(), POSTGRES_TYPE_DICT); @@ -527,10 +496,7 @@ public JsonSchemaType getAirbyteType(final PostgresType jdbcType) { case DATE_ARRAY -> JsonSchemaType.builder(JsonSchemaPrimitive.ARRAY) .withItems(JsonSchemaType.STRING_DATE) .build(); - case JSONB_ARRAY -> JsonSchemaType.builder(JsonSchemaPrimitive.ARRAY) - .withItems(JsonSchemaType.JSONB) - .build(); - case JSONB -> JsonSchemaType.JSONB; + case DATE -> JsonSchemaType.STRING_DATE; case TIME -> JsonSchemaType.STRING_TIME_WITHOUT_TIMEZONE; case TIME_WITH_TIMEZONE -> JsonSchemaType.STRING_TIME_WITH_TIMEZONE; @@ -625,7 +591,6 @@ private ColumnInfo getColumnInfo(final int colIndex, final PgResultSetMetaData m } private static class ColumnInfo { - public String columnTypeName; public PostgresType columnType; diff --git a/airbyte-integrations/connectors/source-postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresType.java b/airbyte-integrations/connectors/source-postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresType.java index 411e4ba2c2d8..65d65a47da44 100644 --- a/airbyte-integrations/connectors/source-postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresType.java +++ b/airbyte-integrations/connectors/source-postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresType.java @@ -70,9 +70,7 @@ public enum PostgresType implements SQLType { OID_ARRAY(Types.ARRAY), FLOAT4_ARRAY(Types.ARRAY), FLOAT8_ARRAY(Types.ARRAY), - BYTEA_ARRAY(Types.ARRAY), - JSONB_ARRAY(Types.ARRAY), - JSONB(Types.JAVA_OBJECT); + BYTEA_ARRAY(Types.ARRAY); /** * The Integer value for the JDBCType. It maps to a value in {@code Types.java} @@ -124,7 +122,7 @@ public Integer getVendorTypeNumber() { * {@code Types} value * @see Types */ - public static PostgresType valueOf(final int type, final Map postgresTypeMap) { + public static PostgresType valueOf(final int type, final Map postgresTypeMap) { if (postgresTypeMap.containsKey(type)) { return postgresTypeMap.get(type); } @@ -132,7 +130,7 @@ public static PostgresType valueOf(final int type, final Map postgresTypeMap) { + public static PostgresType safeGetJdbcType(final int columnTypeInt, final Map postgresTypeMap) { try { return PostgresType.valueOf(columnTypeInt, postgresTypeMap); } catch (final Exception e) { diff --git a/airbyte-integrations/connectors/source-postgres/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/AbstractPostgresSourceDatatypeTest.java b/airbyte-integrations/connectors/source-postgres/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/AbstractPostgresSourceDatatypeTest.java index 6412b622d70a..1b1288ba352c 100644 --- a/airbyte-integrations/connectors/source-postgres/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/AbstractPostgresSourceDatatypeTest.java +++ b/airbyte-integrations/connectors/source-postgres/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/AbstractPostgresSourceDatatypeTest.java @@ -46,18 +46,6 @@ public boolean testCatalog() { return true; } - protected String getValueFromJsonNode(final JsonNode jsonNode) { - if (jsonNode != null) { - if (jsonNode.isArray() || jsonNode.isObject()) { - return jsonNode.toString(); - } - - String value = jsonNode.asText(); - return (value != null && value.equals("null") ? null : value); - } - return null; - } - // Test cases are sorted alphabetically based on the source type // See https://www.postgresql.org/docs/14/datatype.html @Override @@ -265,12 +253,9 @@ protected void initTests() { addDataTypeTestData( TestDataHolder.builder() .sourceType("jsonb") - .airbyteType(JsonSchemaType.builder(JsonSchemaPrimitive.JSONB) - .withLegacyAirbyteTypeProperty("json") - .build()) - .addInsertValues("null", "'10000'::jsonb", "'true'::jsonb", "'[1,2,3]'::jsonb", - "'{\"Janet\": 1, \"Melissa\": {\"loves\": \"trees\", \"married\": true}}'::jsonb") - .addExpectedValues(null, "10000", "true", "[1,2,3]", "{\"Janet\":1,\"Melissa\":{\"loves\":\"trees\",\"married\":true}}") + .airbyteType(JsonSchemaType.STRING) + .addInsertValues("null", "'[1, 2, 3]'::jsonb") + .addExpectedValues(null, "[1, 2, 3]") .build()); addDataTypeTestData( @@ -593,23 +578,6 @@ protected void initTests() { addTimeWithTimeZoneTest(); addArraysTestData(); - addJsonbArrayTest(); - } - - protected void addJsonbArrayTest() { - - addDataTypeTestData( - TestDataHolder.builder() - .sourceType("jsonb_array") - .fullSourceDataType("JSONB[]") - .airbyteType(JsonSchemaType.builder(JsonSchemaPrimitive.ARRAY) - .withItems(JsonSchemaType.JSONB) - .build()) - .addInsertValues( - "ARRAY['[1,2,1]', 'false']::jsonb[]", - "ARRAY['{\"letter\":\"A\", \"digit\":30}', '{\"letter\":\"B\", \"digit\":31}']::jsonb[]") - .addExpectedValues("[[1,2,1],false]", "[{\"digit\":30,\"letter\":\"A\"},{\"digit\":31,\"letter\":\"B\"}]") - .build()); } protected void addTimeWithTimeZoneTest() { diff --git a/airbyte-integrations/connectors/source-postgres/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/CdcInitialSnapshotPostgresSourceDatatypeTest.java b/airbyte-integrations/connectors/source-postgres/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/CdcInitialSnapshotPostgresSourceDatatypeTest.java index 17e54d12d1be..c7c3e62184d8 100644 --- a/airbyte-integrations/connectors/source-postgres/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/CdcInitialSnapshotPostgresSourceDatatypeTest.java +++ b/airbyte-integrations/connectors/source-postgres/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/CdcInitialSnapshotPostgresSourceDatatypeTest.java @@ -11,11 +11,8 @@ import io.airbyte.db.factory.DSLContextFactory; import io.airbyte.db.factory.DatabaseDriver; import io.airbyte.db.jdbc.JdbcUtils; -import io.airbyte.integrations.standardtest.source.TestDataHolder; import io.airbyte.integrations.standardtest.source.TestDestinationEnv; import io.airbyte.integrations.util.HostPortResolver; -import io.airbyte.protocol.models.JsonSchemaPrimitiveUtil; -import io.airbyte.protocol.models.JsonSchemaType; import java.util.List; import org.jooq.SQLDialect; import org.testcontainers.containers.PostgreSQLContainer; @@ -98,24 +95,6 @@ protected void tearDown(final TestDestinationEnv testEnv) { container.close(); } - @Override - protected void addJsonbArrayTest() { - - addDataTypeTestData( - TestDataHolder.builder() - .sourceType("jsonb_array") - .fullSourceDataType("JSONB[]") - .airbyteType(JsonSchemaType.builder(JsonSchemaPrimitiveUtil.JsonSchemaPrimitive.ARRAY) - .withItems(JsonSchemaType.JSONB) - .build()) - .addInsertValues( - "ARRAY['[1,2,1]', 'false']::jsonb[]", - "ARRAY['{\"letter\":\"A\", \"digit\":30}', '{\"letter\":\"B\", \"digit\":31}']::jsonb[]") - .addExpectedValues("[\"[1, 2, 1]\",\"false\"]", - "[\"{\\\"digit\\\": 30, \\\"letter\\\": \\\"A\\\"}\",\"{\\\"digit\\\": 31, \\\"letter\\\": \\\"B\\\"}\"]") - .build()); - } - public boolean testCatalog() { return true; } diff --git a/airbyte-integrations/connectors/source-postgres/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/CdcWalLogsPostgresSourceDatatypeTest.java b/airbyte-integrations/connectors/source-postgres/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/CdcWalLogsPostgresSourceDatatypeTest.java index 206626ab8508..85b14df9f41f 100644 --- a/airbyte-integrations/connectors/source-postgres/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/CdcWalLogsPostgresSourceDatatypeTest.java +++ b/airbyte-integrations/connectors/source-postgres/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/CdcWalLogsPostgresSourceDatatypeTest.java @@ -14,7 +14,6 @@ import io.airbyte.integrations.standardtest.source.TestDataHolder; import io.airbyte.integrations.standardtest.source.TestDestinationEnv; import io.airbyte.integrations.util.HostPortResolver; -import io.airbyte.protocol.models.JsonSchemaPrimitiveUtil; import io.airbyte.protocol.models.JsonSchemaType; import io.airbyte.protocol.models.v0.AirbyteMessage; import io.airbyte.protocol.models.v0.AirbyteStateMessage; @@ -187,22 +186,4 @@ protected void addTimestampWithInfinityValuesTest() { } } - @Override - protected void addJsonbArrayTest() { - - addDataTypeTestData( - TestDataHolder.builder() - .sourceType("jsonb_array") - .fullSourceDataType("JSONB[]") - .airbyteType(JsonSchemaType.builder(JsonSchemaPrimitiveUtil.JsonSchemaPrimitive.ARRAY) - .withItems(JsonSchemaType.JSONB) - .build()) - .addInsertValues( - "ARRAY['[1,2,1]', 'false']::jsonb[]", - "ARRAY['{\"letter\":\"A\", \"digit\":30}', '{\"letter\":\"B\", \"digit\":31}']::jsonb[]") - .addExpectedValues("[\"[1, 2, 1]\",\"false\"]", - "[\"{\\\"digit\\\": 30, \\\"letter\\\": \\\"A\\\"}\",\"{\\\"digit\\\": 31, \\\"letter\\\": \\\"B\\\"}\"]") - .build()); - } - } diff --git a/connectors.md b/connectors.md index e52a1a4262d1..3a724a9b2dd5 100644 --- a/connectors.md +++ b/connectors.md @@ -9,7 +9,7 @@ | **Adjust** | Adjust icon | Source | airbyte/source-adjust:0.1.0 | alpha | [link](https://docs.airbyte.com/integrations/sources/adjust) | [code](https://github.com/airbytehq/airbyte/tree/master/airbyte-integrations/connectors/source-adjust) | `d3b7fa46-111b-419a-998a-d7f046f6d66d` | | **Aha** | Aha icon | Source | airbyte/source-aha:0.1.0 | alpha | [link](https://docs.airbyte.com/integrations/sources/aha) | [code](https://github.com/airbytehq/airbyte/tree/master/airbyte-integrations/connectors/source-aha) | `81ca39dc-4534-4dd2-b848-b0cfd2c11fce` | | **Airtable** | Airtable icon | Source | airbyte/source-airtable:2.0.3 | beta | [link](https://docs.airbyte.com/integrations/sources/airtable) | [code](https://github.com/airbytehq/airbyte/tree/master/airbyte-integrations/connectors/source-airtable) | `14c6e7ea-97ed-4f5e-a7b5-25e9a80b8212` | -| **AlloyDB for PostgreSQL** | AlloyDB for PostgreSQL icon | Source | airbyte/source-alloydb:1.0.49 | generally_available | [link](https://docs.airbyte.com/integrations/sources/alloydb) | [code](https://github.com/airbytehq/airbyte/tree/master/airbyte-integrations/connectors/source-alloydb) | `1fa90628-2b9e-11ed-a261-0242ac120002` | +| **AlloyDB for PostgreSQL** | AlloyDB for PostgreSQL icon | Source | airbyte/source-alloydb:1.0.51 | generally_available | [link](https://docs.airbyte.com/integrations/sources/alloydb) | [code](https://github.com/airbytehq/airbyte/tree/master/airbyte-integrations/connectors/source-alloydb) | `1fa90628-2b9e-11ed-a261-0242ac120002` | | **Alpha Vantage** | Alpha Vantage icon | Source | airbyte/source-alpha-vantage:0.1.1 | alpha | [link](https://docs.airbyte.com/integrations/sources/alpha-vantage) | [code](https://github.com/airbytehq/airbyte/tree/master/airbyte-integrations/connectors/source-alpha-vantage) | `db385323-9333-4fec-bec3-9e0ca9326c90` | | **Amazon Ads** | Amazon Ads icon | Source | airbyte/source-amazon-ads:1.0.0 | generally_available | [link](https://docs.airbyte.com/integrations/sources/amazon-ads) | [code](https://github.com/airbytehq/airbyte/tree/master/airbyte-integrations/connectors/source-amazon-ads) | `c6b0a29e-1da9-4512-9002-7bfd0cba2246` | | **Amazon SQS** | Amazon SQS icon | Source | airbyte/source-amazon-sqs:0.1.0 | alpha | [link](https://docs.airbyte.com/integrations/sources/amazon-sqs) | [code](https://github.com/airbytehq/airbyte/tree/master/airbyte-integrations/connectors/source-amazon-sqs) | `983fd355-6bf3-4709-91b5-37afa391eeb6` | @@ -174,7 +174,7 @@ | **PokeAPI** | PokeAPI icon | Source | airbyte/source-pokeapi:0.1.5 | alpha | [link](https://docs.airbyte.com/integrations/sources/pokeapi) | [code](https://github.com/airbytehq/airbyte/tree/master/airbyte-integrations/connectors/source-pokeapi) | `6371b14b-bc68-4236-bfbd-468e8df8e968` | | **Polygon Stock API** | Polygon Stock API icon | Source | airbyte/source-polygon-stock-api:0.1.1 | alpha | [link](https://docs.airbyte.com/integrations/sources/polygon-stock-api) | [code](https://github.com/airbytehq/airbyte/tree/master/airbyte-integrations/connectors/source-polygon-stock-api) | `5807d72f-0abc-49f9-8fa5-ae820007032b` | | **PostHog** | PostHog icon | Source | airbyte/source-posthog:0.1.8 | beta | [link](https://docs.airbyte.com/integrations/sources/posthog) | [code](https://github.com/airbytehq/airbyte/tree/master/airbyte-integrations/connectors/source-posthog) | `af6d50ee-dddf-4126-a8ee-7faee990774f` | -| **Postgres** | Postgres icon | Source | airbyte/source-postgres:1.0.50 | generally_available | [link](https://docs.airbyte.com/integrations/sources/postgres) | [code](https://github.com/airbytehq/airbyte/tree/master/airbyte-integrations/connectors/source-postgres) | `decd338e-5647-4c0b-adf4-da0e75f5a750` | +| **Postgres** | Postgres icon | Source | airbyte/source-postgres:1.0.51 | generally_available | [link](https://docs.airbyte.com/integrations/sources/postgres) | [code](https://github.com/airbytehq/airbyte/tree/master/airbyte-integrations/connectors/source-postgres) | `decd338e-5647-4c0b-adf4-da0e75f5a750` | | **Postmark App** | Postmark App icon | Source | airbyte/source-postmarkapp:0.1.0 | alpha | [link](https://docs.airbyte.com/integrations/sources/postmarkapp) | [code](https://github.com/airbytehq/airbyte/tree/master/airbyte-integrations/connectors/source-postmarkapp) | `cde75ca1-1e28-4a0f-85bb-90c546de9f1f` | | **PrestaShop** | PrestaShop icon | Source | airbyte/source-prestashop:0.3.0 | beta | [link](https://docs.airbyte.com/integrations/sources/prestashop) | [code](https://github.com/airbytehq/airbyte/tree/master/airbyte-integrations/connectors/source-prestashop) | `d60a46d4-709f-4092-a6b7-2457f7d455f5` | | **Primetric** | Primetric icon | Source | airbyte/source-primetric:0.1.0 | alpha | [link](https://docs.airbyte.com/integrations/sources/primetric) | [code](https://github.com/airbytehq/airbyte/tree/master/airbyte-integrations/connectors/source-primetric) | `f636c3c6-4077-45ac-b109-19fc62a283c1` | diff --git a/deps.toml b/deps.toml index 9f67d21bec00..dde9364fa182 100644 --- a/deps.toml +++ b/deps.toml @@ -1,5 +1,5 @@ [versions] -airbyte-protocol = "1.0.1" +airbyte-protocol = "1.0.0" commons_io = "2.7" connectors-destination-testcontainers-clickhouse = "1.17.3" connectors-destination-testcontainers-elasticsearch = "1.17.3" diff --git a/docs/integrations/sources/alloydb.md b/docs/integrations/sources/alloydb.md index 079c3f43680c..d15c5be9255b 100644 --- a/docs/integrations/sources/alloydb.md +++ b/docs/integrations/sources/alloydb.md @@ -321,8 +321,9 @@ According to Postgres [documentation](https://www.postgresql.org/docs/14/datatyp | Version | Date | Pull Request | Subject | |:--------|:-----------|:---------------------------------------------------------|:------------------------------------------------------------------------------------------------------------------------------------------| -| 1.0.49 | 2022-02-27 | [21695](https://github.com/airbytehq/airbyte/pull/21695) | Support JSONB datatype for Standard sync mode | | -| 1.0.48 | 2022-02-24 | [23383](https://github.com/airbytehq/airbyte/pull/23383) | Fixed bug with non readable double-quoted values within a database name or column name | | +| 1.0.51 | 2022-03-02 | [23642](https://github.com/airbytehq/airbyte/pull/23642) | Revert : Support JSONB datatype for Standard sync mode | | +| 1.0.49 | 2022-02-27 | [21695](https://github.com/airbytehq/airbyte/pull/21695) | Support JSONB datatype for Standard sync mode | | +| 1.0.48 | 2022-02-24 | [23383](https://github.com/airbytehq/airbyte/pull/23383) | Fixed bug with non readable double-quoted values within a database name or column name | | | 1.0.47 | 2022-02-22 | [22221](https://github.com/airbytehq/airbyte/pull/23138) | Fix previous versions which doesn't verify privileges correctly, preventing CDC syncs to run. | | 1.0.46 | 2022-02-21 | [23105](https://github.com/airbytehq/airbyte/pull/23105) | Include log levels and location information (class, method and line number) with source connector logs published to Airbyte Platform. | | 1.0.45 | 2022-02-09 | [22221](https://github.com/airbytehq/airbyte/pull/22371) | Ensures that user has required privileges for CDC syncs. | diff --git a/docs/integrations/sources/postgres.md b/docs/integrations/sources/postgres.md index 2ef1a599ecbb..697973628aaf 100644 --- a/docs/integrations/sources/postgres.md +++ b/docs/integrations/sources/postgres.md @@ -408,9 +408,10 @@ The root causes is that the WALs needed for the incremental sync has been remove | Version | Date | Pull Request | Subject | |:--------|:-----------|:---------------------------------------------------------|:---------------------------------------------------------------------------------------------------------------------------------------------------------------------------| -| 1.0.50 | 2022-02-27 | [21695](https://github.com/airbytehq/airbyte/pull/21695) | Support JSONB datatype for Standard sync mode | | -| 1.0.49 | 2022-02-24 | [23383](https://github.com/airbytehq/airbyte/pull/23383) | Fixed bug with non readable double-quoted values within a database name or column name | | -| 1.0.48 | 2022-02-23 | [22623](https://github.com/airbytehq/airbyte/pull/22623) | Increase max fetch size of JDBC streaming mode | | +| 1.0.51 | 2022-03-02 | [23642](https://github.com/airbytehq/airbyte/pull/23642) | Revert : Support JSONB datatype for Standard sync mode | | +| 1.0.50 | 2022-02-27 | [21695](https://github.com/airbytehq/airbyte/pull/21695) | Support JSONB datatype for Standard sync mode | | +| 1.0.49 | 2022-02-24 | [23383](https://github.com/airbytehq/airbyte/pull/23383) | Fixed bug with non readable double-quoted values within a database name or column name | | +| 1.0.48 | 2022-02-23 | [22623](https://github.com/airbytehq/airbyte/pull/22623) | Increase max fetch size of JDBC streaming mode | | | 1.0.47 | 2022-02-22 | [22221](https://github.com/airbytehq/airbyte/pull/23138) | Fix previous versions which doesn't verify privileges correctly, preventing CDC syncs to run. | | | 1.0.46 | 2022-02-21 | [23105](https://github.com/airbytehq/airbyte/pull/23105) | Include log levels and location information (class, method and line number) with source connector logs published to Airbyte Platform. | | 1.0.45 | 2022-02-09 | [22221](https://github.com/airbytehq/airbyte/pull/22371) | Ensures that user has required privileges for CDC syncs. |