jprdonnelly/airbyte
1
0
Fork 0
mirror of synced 2025-12-25 02:09:19 -05:00
Code Issues Packages Projects Releases Wiki Activity

Handle invalid numeric values in JDBC source (#1588)

Browse Source
This commit is contained in:
Sherif A. Nada
2021-01-13 13:31:53 -08:00
committed by GitHub
parent 9302150c8d
commit 68ecf991d6
7 changed files with 96 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
airbyte-integrations/connectors/source-mssql/src/test/java/io/airbyte/integrations/source/mssql/MssqlSourceTest.java
View File

@@ -34,15 +34,11 @@ import io.airbyte.commons.json.Jsons;
import io.airbyte.db.Database;
import io.airbyte.db.Databases;
import io.airbyte.protocol.models.AirbyteCatalog;
import io.airbyte.protocol.models.AirbyteMessage;
import io.airbyte.protocol.models.CatalogHelpers;
import io.airbyte.protocol.models.Field;
import io.airbyte.protocol.models.Field.JsonSchemaPrimitive;
import io.airbyte.protocol.models.SyncMode;
import java.sql.SQLException;
import java.util.List;
import java.util.stream.Collectors;
import javax.swing.*;
import org.apache.commons.lang3.RandomStringUtils;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
@@ -114,9 +110,6 @@ class MssqlSourceTest {
final AirbyteCatalog actual = new MssqlSource().discover(config);
assertEquals(CATALOG, actual);
List<AirbyteMessage> read = new MssqlSource().read(config, CatalogHelpers.toDefaultConfiguredCatalog(actual), null).collect(Collectors.toList());
}
private JsonNode getConfig(MSSQLServerContainer<?> db) {