private OracleExtractNode buildOracleExtractNode() {
        List<FieldInfo> fields = Arrays.asList(
                new FieldInfo("ID", new LongFormatInfo()),
                new FieldInfo("NAME", new StringFormatInfo()),
                new FieldInfo("AGE", new IntFormatInfo()),
                new MetaFieldInfo("proctime", MetaField.PROCESS_TIME),
                new MetaFieldInfo("database_name", MetaField.DATABASE_NAME),
                new MetaFieldInfo("table_name", MetaField.TABLE_NAME),
                new MetaFieldInfo("op_ts", MetaField.OP_TS),
                new MetaFieldInfo("schema_name", MetaField.SCHEMA_NAME));
        Map<String, String> properties = new HashMap<>();
        properties.put("scan.incremental.snapshot.enabled", "true");
        return new OracleExtractNode("1", "oracle_input", fields,
                null, properties, "ID", "localhost",
                "flinkuser", "flinkpw", "xE",
                "flinkuser", "flinkuser.table", 1521, null);
    }
Build oracle extract node

@return The oracle extract node
inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/OracleExtractSqlParseTest.java