[bugfix] fix oracle query table length (apache#7627)

Author: chl-wxp

seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeConverter.java

@@ -173,7 +173,7 @@ public Column convert(BasicTypeDefine typeDefine) {
             case ORACLE_VARCHAR:
             case ORACLE_VARCHAR2:
                 builder.dataType(BasicType.STRING_TYPE);
-                builder.columnLength(typeDefine.getLength());
+                builder.columnLength(TypeDefineUtils.charTo4ByteLength(typeDefine.getLength()));
                 break;
             case ORACLE_NCHAR:
             case ORACLE_NVARCHAR2:

seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeMapper.java

@@ -59,9 +59,6 @@ public Column mappingColumn(ResultSetMetaData metadata, int colIndex) throws SQL
         } else if (Arrays.asList("NVARCHAR2", "NCHAR").contains(nativeType)) {
             long doubleByteLength = TypeDefineUtils.charToDoubleByteLength(precision);
             precision = doubleByteLength;
-        } else if (Arrays.asList("CHAR", "VARCHAR", "VARCHAR2").contains(nativeType)) {
-            long octetByteLength = TypeDefineUtils.charTo4ByteLength(precision);
-            precision = octetByteLength;
         }
 
         BasicTypeDefine typeDefine =

seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeConverterTest.java

@@ -355,7 +355,7 @@ public void testConvertChar() {
 
         Assertions.assertEquals(typeDefine.getName(), column.getName());
         Assertions.assertEquals(BasicType.STRING_TYPE, column.getDataType());
-        Assertions.assertEquals(typeDefine.getLength(), column.getColumnLength());
+        Assertions.assertEquals(typeDefine.getLength() * 4, column.getColumnLength());
         Assertions.assertEquals(typeDefine.getColumnType(), column.getSourceType());
 
         typeDefine =
@@ -383,7 +383,7 @@ public void testConvertChar() {
 
         Assertions.assertEquals(typeDefine.getName(), column.getName());
         Assertions.assertEquals(BasicType.STRING_TYPE, column.getDataType());
-        Assertions.assertEquals(typeDefine.getLength(), column.getColumnLength());
+        Assertions.assertEquals(typeDefine.getLength() * 4, column.getColumnLength());
         Assertions.assertEquals(typeDefine.getColumnType(), column.getSourceType());
 
         typeDefine =
@@ -397,7 +397,7 @@ public void testConvertChar() {
 
         Assertions.assertEquals(typeDefine.getName(), column.getName());
         Assertions.assertEquals(BasicType.STRING_TYPE, column.getDataType());
-        Assertions.assertEquals(typeDefine.getLength(), column.getColumnLength());
+        Assertions.assertEquals(typeDefine.getLength() * 4, column.getColumnLength());
         Assertions.assertEquals(typeDefine.getColumnType(), column.getSourceType());
 
         typeDefine =

seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-6/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcOracleLowercaseTableIT.java

@@ -19,6 +19,7 @@
 package org.apache.seatunnel.connectors.seatunnel.jdbc;
 
 import org.apache.seatunnel.api.table.catalog.CatalogTable;
+import org.apache.seatunnel.api.table.catalog.Column;
 import org.apache.seatunnel.api.table.catalog.TablePath;
 import org.apache.seatunnel.api.table.type.SeaTunnelRow;
 import org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.oracle.OracleCatalog;
@@ -36,6 +37,7 @@
 import org.testcontainers.utility.MountableFile;
 
 import com.google.common.collect.Lists;
+import lombok.SneakyThrows;
 
 import java.math.BigDecimal;
 import java.sql.Date;
@@ -275,6 +277,16 @@ public void testCatalog() {
         Assertions.assertEquals(
                 table.getTableSchema().getColumns().get(1).getComment(),
                 "\"#¥%……&*（）;;',,..``````//'@特殊注释'\\'\"");
+        testTableOfQuery(oracleCatalog);
         oracleCatalog.close();
     }
+
+    @SneakyThrows
+    private void testTableOfQuery(OracleCatalog oracleCatalog) {
+        String querySql = "select * from TESTUSER.E2E_TABLE_SOURCE_LOWER";
+        CatalogTable tableOfQuery = oracleCatalog.getTable(querySql);
+        final List<Column> columns = tableOfQuery.getTableSchema().getColumns();
+        Assertions.assertEquals(columns.get(0).getColumnLength(), 40);
+        Assertions.assertEquals(columns.get(1).getColumnLength(), 40);
+    }
 }