[Source-mssql] : Remove override for queryTableFullRefresh (#37110)

Author: akashkulk

airbyte-integrations/connectors/source-mssql/metadata.yaml

@@ -9,7 +9,7 @@ data:
   connectorSubtype: database
   connectorType: source
   definitionId: b5ea17b1-f170-46dc-bc31-cc744ca984c1
-  dockerImageTag: 4.0.9
+  dockerImageTag: 4.0.10
   dockerRepository: airbyte/source-mssql
   documentationUrl: https://docs.airbyte.com/integrations/sources/mssql
   githubIssueLabel: source-mssql

airbyte-integrations/connectors/source-mssql/src/main/java/io/airbyte/integrations/source/mssql/MssqlSource.java

@@ -23,7 +23,6 @@
 import com.google.common.collect.ImmutableMap;
 import com.google.common.collect.Lists;
 import io.airbyte.cdk.db.factory.DatabaseDriver;
-import io.airbyte.cdk.db.jdbc.AirbyteRecordData;
 import io.airbyte.cdk.db.jdbc.JdbcDatabase;
 import io.airbyte.cdk.db.jdbc.JdbcUtils;
 import io.airbyte.cdk.db.jdbc.streaming.AdaptiveStreamingQueryConfig;
@@ -136,38 +135,6 @@ public AirbyteConnectionStatus check(final JsonNode config) throws Exception {
     return super.check(config);
   }
 
-  @Override
-  public AutoCloseableIterator<AirbyteRecordData> queryTableFullRefresh(final JdbcDatabase database,
-                                                                        final List<String> columnNames,
-                                                                        final String schemaName,
-                                                                        final String tableName,
-                                                                        final SyncMode syncMode,
-                                                                        final Optional<String> cursorField) {
-    LOGGER.info("Queueing query for table: {}", tableName);
-    // This corresponds to the initial sync for in INCREMENTAL_MODE. The ordering of the records matters
-    // as intermediate state messages are emitted.
-    if (syncMode.equals(SyncMode.INCREMENTAL)) {
-      final String quotedCursorField = enquoteIdentifier(cursorField.get(), getQuoteString());
-      final String newIdentifiers = getWrappedColumnNames(database, null, columnNames, schemaName, tableName);
-      final String preparedSqlQuery =
-          String.format("SELECT %s FROM %s ORDER BY %s ASC", newIdentifiers,
-              getFullyQualifiedTableNameWithQuoting(schemaName, tableName, getQuoteString()), quotedCursorField);
-      LOGGER.info("Prepared SQL query for TableFullRefresh is: " + preparedSqlQuery);
-      return AutoCloseableIterators.transform(queryTable(database, preparedSqlQuery, tableName, schemaName),
-          jsonNode -> new AirbyteRecordData(jsonNode, new AirbyteRecordMessageMeta()));
-    } else {
-      // If we are in FULL_REFRESH mode, state messages are never emitted, so we don't care about ordering
-      // of the records.
-      final String newIdentifiers = getWrappedColumnNames(database, null, columnNames, schemaName, tableName);
-      final String preparedSqlQuery =
-          String.format("SELECT %s FROM %s", newIdentifiers, getFullyQualifiedTableNameWithQuoting(schemaName, tableName, getQuoteString()));
-
-      LOGGER.info("Prepared SQL query for TableFullRefresh is: " + preparedSqlQuery);
-      return AutoCloseableIterators.transform(queryTable(database, preparedSqlQuery, tableName, schemaName),
-          jsonNode -> new AirbyteRecordData(jsonNode, new AirbyteRecordMessageMeta()));
-    }
-  }
-
   /**
    * See {@link MssqlQueryUtils#getWrappedColumnNames}
    */

docs/integrations/sources/mssql.md

@@ -327,6 +327,7 @@ WHERE actor_definition_id ='b5ea17b1-f170-46dc-bc31-cc744ca984c1' AND (configura
 
 | Version | Date       | Pull Request                                                                                                      | Subject                                                                                                                                         |
 |:--------|:-----------|:------------------------------------------------------------------------------------------------------------------|:------------------------------------------------------------------------------------------------------------------------------------------------|
+| 4.0.10  | 2024-04-15 | [37110](https://github.com/airbytehq/airbyte/pull/37110)                                                          | Internal cleanup.                                                                                                                               |
 | 4.0.9   | 2024-04-10 | [36919](https://github.com/airbytehq/airbyte/pull/36919)                                                          | Fix a bug in conversion of null values.                                                                                                         |
 | 4.0.8   | 2024-04-05 | [36872](https://github.com/airbytehq/airbyte/pull/36872)                                                          | Update to connector's metadat definition.                                                                                                       |
 | 4.0.7   | 2024-04-03 | [36772](https://github.com/airbytehq/airbyte/pull/36772)                                                          | Adopt latest CDK.                                                                                                                               |