jprdonnelly/airbyte
1
0
Fork 0
mirror of synced 2025-12-19 18:14:56 -05:00
Code Issues Packages Projects Releases Wiki Activity

derp

Browse Source
This commit is contained in:
Edward Gao
2025-12-18 16:16:08 -08:00
parent 7218a2a520
commit 3f8ef034d3
1 changed files with 14 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
airbyte-cdk/bulk/core/load/src/testFixtures/kotlin/io/airbyte/cdk/load/component/SchemaMapperSuite.kt
View File

@@ -18,40 +18,35 @@ interface SchemaMapperSuite {
get() = "table" get() = "table"
fun `simple table name`(expectedTableName: TableName) { fun `simple table name`(expectedTableName: TableName) {
val namespace = TableOperationsFixtures.generateTestNamespace("namespace-test")
val name = TableOperationsFixtures.generateTestNamespace("table-test")
val tableName = val tableName =
tableSchemaMapper.toFinalTableName(DestinationStream.Descriptor(namespace, name)) tableSchemaMapper.toFinalTableName(
DestinationStream.Descriptor("namespace-test", "table-test")
)
assertEquals(expectedTableName, tableName) assertEquals(expectedTableName, tableName)
} }
fun `funky chars in table name`(expectedTableName: TableName) { fun `funky chars in table name`(expectedTableName: TableName) {
val namespace =
TableOperationsFixtures.generateTestNamespace(
"namespace-test- -`~!@#$%^&*()-=_+[]\\{}|o'O\",./<>?"
)
val name =
TableOperationsFixtures.generateTestNamespace(
"table-test- -`~!@#$%^&*()-=_+[]\\{}|o'O\",./<>?"
)
val tableName = val tableName =
tableSchemaMapper.toFinalTableName(DestinationStream.Descriptor(namespace, name)) tableSchemaMapper.toFinalTableName(
DestinationStream.Descriptor(
"namespace-test- -`~!@#$%^&*()-=_+[]\\{}|;':\",./<>?",
"table-test- -`~!@#$%^&*()-=_+[]\\{}|;':\",./<>?"
)
)
assertEquals(expectedTableName, tableName) assertEquals(expectedTableName, tableName)
} }
fun `table name starts with non-letter character`(expectedTableName: TableName) { fun `table name starts with non-letter character`(expectedTableName: TableName) {
val namespace = TableOperationsFixtures.generateTestNamespace("1foo")
val name = TableOperationsFixtures.generateTestNamespace("1foo")
val tableName = val tableName =
tableSchemaMapper.toFinalTableName(DestinationStream.Descriptor(namespace, name)) tableSchemaMapper.toFinalTableName(DestinationStream.Descriptor("1foo", "1foo"))
assertEquals(expectedTableName, tableName) assertEquals(expectedTableName, tableName)
} }
fun `table name is reserved keyword`(expectedTableName: TableName) { fun `table name is reserved keyword`(expectedTableName: TableName) {
val namespace = TableOperationsFixtures.generateTestNamespace(reservedKeyword)
val name = TableOperationsFixtures.generateTestNamespace(reservedKeyword)
val tableName = val tableName =
tableSchemaMapper.toFinalTableName(DestinationStream.Descriptor(namespace, name)) tableSchemaMapper.toFinalTableName(
DestinationStream.Descriptor(reservedKeyword, reservedKeyword)
)
assertEquals(expectedTableName, tableName) assertEquals(expectedTableName, tableName)
} }
@@ -70,7 +65,7 @@ interface SchemaMapperSuite {
fun `column name with funky chars`(expectedColumnName: String) { fun `column name with funky chars`(expectedColumnName: String) {
val columnName = val columnName =
tableSchemaMapper.toColumnName("column-test- -`~!@#$%^&*()-=_+[]\\{}|o'O\",./<>?") tableSchemaMapper.toColumnName("column-test- -`~!@#$%^&*()-=_+[]\\{}|;':\",./<>?")
assertEquals(expectedColumnName, columnName) assertEquals(expectedColumnName, columnName)
} }