🐛 Source snowflake: int columns should be discovered as ints (#15314)

* snowflake discovers ints as ints * version bump+changelog * bump version+changelog * auto-bump connector version [ci skip] Co-authored-by: Octavia Squidington III <octavia-squidington-iii@users.noreply.github.com>

Author: edgao

airbyte-config/init/src/main/resources/seed/source_definitions.yaml

@@ -913,7 +913,7 @@
 - name: Snowflake
  sourceDefinitionId: e2d65910-8c8b-40a1-ae7d-ee2416b2bfa2
  dockerRepository: airbyte/source-snowflake
- dockerImageTag: 0.1.15
+ dockerImageTag: 0.1.17
  documentationUrl: https://docs.airbyte.io/integrations/sources/snowflake
  icon: snowflake.svg
  sourceType: database

airbyte-config/init/src/main/resources/seed/source_specs.yaml

@@ -8914,7 +8914,7 @@
  - - "client_secret"
  oauthFlowOutputParameters:
  - - "refresh_token"
-- dockerImage: "airbyte/source-snowflake:0.1.15"
+- dockerImage: "airbyte/source-snowflake:0.1.17"
  spec:
  documentationUrl: "https://docs.airbyte.io/integrations/sources/snowflake"
  connectionSpecification:

airbyte-integrations/connectors/source-snowflake/Dockerfile

@@ -16,5 +16,5 @@ ENV APPLICATION source-snowflake
 
 COPY --from=build /airbyte /airbyte
 
-LABEL io.airbyte.version=0.1.15
+LABEL io.airbyte.version=0.1.17
 LABEL io.airbyte.name=airbyte/source-snowflake

airbyte-integrations/connectors/source-snowflake/src/main/java/io.airbyte.integrations.source.snowflake/SnowflakeSourceOperations.java

@@ -44,7 +44,8 @@ protected void setTimestamp(final PreparedStatement preparedStatement, final int
  public JsonSchemaType getJsonType(JDBCType jdbcType) {
  return switch (jdbcType) {
  case BIT, BOOLEAN -> JsonSchemaType.BOOLEAN;
- case TINYINT, SMALLINT, REAL, FLOAT, DOUBLE, INTEGER, BIGINT, NUMERIC, DECIMAL -> JsonSchemaType.NUMBER;
+ case REAL, FLOAT, DOUBLE, NUMERIC, DECIMAL -> JsonSchemaType.NUMBER;
+ case TINYINT, SMALLINT, INTEGER, BIGINT -> JsonSchemaType.INTEGER;
  case CHAR, NCHAR, NVARCHAR, VARCHAR, LONGVARCHAR -> JsonSchemaType.STRING;
  case DATE -> JsonSchemaType.STRING_DATE;
  case TIME -> JsonSchemaType.STRING_TIME_WITHOUT_TIMEZONE;

airbyte-integrations/connectors/source-snowflake/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/SnowflakeJdbcSourceAcceptanceTest.java

@@ -105,17 +105,17 @@ protected AirbyteCatalog getCatalog(final String defaultNamespace) {
  CatalogHelpers.createAirbyteStream(
  TABLE_NAME,
  defaultNamespace,
- Field.of(COL_ID, JsonSchemaType.NUMBER),
+ Field.of(COL_ID, JsonSchemaType.INTEGER),
  Field.of(COL_NAME, JsonSchemaType.STRING),
  Field.of(COL_UPDATED_AT, JsonSchemaType.STRING_DATE))
  .withSupportedSyncModes(List.of(SyncMode.FULL_REFRESH, SyncMode.INCREMENTAL))
  .withSourceDefinedPrimaryKey(List.of(List.of(COL_ID))),
  CatalogHelpers.createAirbyteStream(
- TABLE_NAME_WITHOUT_PK,
- defaultNamespace,
- Field.of(COL_ID, JsonSchemaType.NUMBER),
- Field.of(COL_NAME, JsonSchemaType.STRING),
- Field.of(COL_UPDATED_AT, JsonSchemaType.STRING_DATE))
+  TABLE_NAME_WITHOUT_PK,
+  defaultNamespace,
+  Field.of(COL_ID, JsonSchemaType.INTEGER),
+  Field.of(COL_NAME, JsonSchemaType.STRING),
+  Field.of(COL_UPDATED_AT, JsonSchemaType.STRING_DATE))
  .withSupportedSyncModes(List.of(SyncMode.FULL_REFRESH, SyncMode.INCREMENTAL))
  .withSourceDefinedPrimaryKey(Collections.emptyList()),
  CatalogHelpers.createAirbyteStream(

docs/integrations/sources/snowflake.md

@@ -122,6 +122,8 @@ To read more please check official [Snowflake documentation](https://docs.snowfl
 
 | Version | Date | Pull Request | Subject |
 |:----------| :--- | :--- | :--- |
+| 0.1.16 | 2022-08-09 | [15314](https://github.com/airbytehq/airbyte/pull/15314) | Discover integer columns as integers rather than floats |
+| 0.1.16 | 2022-08-04 | [15314](https://github.com/airbytehq/airbyte/pull/15314) | (broken, do not use) Discover integer columns as integers rather than floats |
 | 0.1.15 | 2022-07-22 | [14828](https://github.com/airbytehq/airbyte/pull/14828) | Source Snowflake: Source/Destination doesn't respect DATE data type |
 | 0.1.14 | 2022-07-22 | [14714](https://github.com/airbytehq/airbyte/pull/14714) | Clarified error message when invalid cursor column selected |
 | 0.1.13 | 2022-07-14 | [14574](https://github.com/airbytehq/airbyte/pull/14574) | Removed additionalProperties:false from JDBC source connectors |
@@ -135,4 +137,4 @@ To read more please check official [Snowflake documentation](https://docs.snowfl
 | 0.1.4 | 2021-12-30 | [9203](https://github.com/airbytehq/airbyte/pull/9203) | Update connector fields title/description |
 | 0.1.3 | 2021-01-11 | [9304](https://github.com/airbytehq/airbyte/pull/9304) | Upgrade version of JDBC driver |
 | 0.1.2 | 2021-10-21 | [7257](https://github.com/airbytehq/airbyte/pull/7257) | Fixed parsing of extreme values for FLOAT and NUMBER data types |
-| 0.1.1 | 2021-08-13 | [4699](https://github.com/airbytehq/airbyte/pull/4699) | Added json config validator |
+| 0.1.1 | 2021-08-13 | [4699](https://github.com/airbytehq/airbyte/pull/4699) | Added json config validator |