[Improve][CDC] Improve read performance when record not contains schema field (#6571)

Hisoka-X · web-flow · commit e60beb28ecde · 2024-04-02T13:35:58.000+08:00
diff --git a/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/utils/SourceRecordUtils.java b/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/utils/SourceRecordUtils.java
@@ -202,10 +202,8 @@ public static TablePath getTablePath(SourceRecord record) {
         String databaseName = sourceStruct.getString(AbstractSourceInfo.DATABASE_NAME_KEY);
         String tableName = sourceStruct.getString(AbstractSourceInfo.TABLE_NAME_KEY);
         String schemaName = null;
-        try {
+        if (sourceStruct.schema().field(AbstractSourceInfo.SCHEMA_NAME_KEY) != null) {
             schemaName = sourceStruct.getString(AbstractSourceInfo.SCHEMA_NAME_KEY);
-        } catch (Throwable e) {
-            // ignore
         }
         return TablePath.of(databaseName, schemaName, tableName);
     }

Original file line number	Diff line number	Diff line change
`@@ -202,10 +202,8 @@ public static TablePath getTablePath(SourceRecord record) {`
`202`	`202`	`String databaseName = sourceStruct.getString(AbstractSourceInfo.DATABASE_NAME_KEY);`
`203`	`203`	`String tableName = sourceStruct.getString(AbstractSourceInfo.TABLE_NAME_KEY);`
`204`	`204`	`String schemaName = null;`
`205`		`- try {`
	`205`	`+ if (sourceStruct.schema().field(AbstractSourceInfo.SCHEMA_NAME_KEY) != null) {`
`206`	`206`	`schemaName = sourceStruct.getString(AbstractSourceInfo.SCHEMA_NAME_KEY);`
`207`		`- } catch (Throwable e) {`
`208`		`- // ignore`
`209`	`207`	`}`
`210`	`208`	`return TablePath.of(databaseName, schemaName, tableName);`
`211`	`209`	`}`