修改oracle

seatunnel-datasource/seatunnel-datasource-plugins/datasource-influxdb/src/main/java/org/apache/seatunnel/datasource/plugin/influxdb/InfluxdbDataSourceChannel.java

@@ -80,11 +80,14 @@ public class InfluxdbDataSourceChannel implements DataSourceChannel {
             List<QueryResult.Result> results = showMeasurements.getResults();
             List<String> table = new ArrayList<>();
             for (QueryResult.Result result : results) {
-                List<List<Object>> values = result.getSeries().get(0).getValues();
+                List<QueryResult.Series> series = result.getSeries();
+                if (series != null) {
+                    List<List<Object>> values = series.get(0).getValues();
                     for (List<Object> value : values) {
                         table.add(String.valueOf(value.get(0)));
                     }
                 }
+            }
             return table;
         } catch (Exception e) {
             throw new RuntimeException(e);
@@ -108,8 +111,13 @@ public class InfluxdbDataSourceChannel implements DataSourceChannel {
         List<QueryResult.Result> results = showDatabases.getResults();
         List<String> database = new ArrayList<>();
         for (QueryResult.Result result : results) {
-            String name = result.getSeries().get(0).getName();
-            database.add(name);
+            List<QueryResult.Series> series = result.getSeries();
+            if (series != null) {
+                List<List<Object>> values = series.get(0).getValues();
+                for (List<Object> value : values) {
+                    database.add(String.valueOf(value.get(0)));
+                }
+            }
         }
         return database;
     }
@@ -158,13 +166,16 @@ public class InfluxdbDataSourceChannel implements DataSourceChannel {
             List<QueryResult.Result> results = showDatabases.getResults();
             List<TableField> fields = new ArrayList<>();
             for (QueryResult.Result result : results) {
-                List<String> columns = result.getSeries().get(0).getColumns();
+                List<QueryResult.Series> series = result.getSeries();
+                if (series != null) {
+                    List<String> columns = series.get(0).getColumns();
                     for (String column : columns) {
                         TableField tableField = new TableField();
                         tableField.setName(column);
                         fields.add(tableField);
                     }
                 }
+            }
             return fields;
         } catch (Exception ex) {
             throw new DataSourcePluginException("Get table fields failed", ex);
@@ -192,13 +203,16 @@ public class InfluxdbDataSourceChannel implements DataSourceChannel {
             List<QueryResult.Result> results = showDatabases.getResults();
             List<TableField> fields = new ArrayList<>();
             for (QueryResult.Result result : results) {
-                List<String> columns = result.getSeries().get(0).getColumns();
+                List<QueryResult.Series> series = result.getSeries();
+                if (series != null) {
+                    List<String> columns = series.get(0).getColumns();
                     for (String column : columns) {
                         TableField tableField = new TableField();
                         tableField.setName(column);
                         fields.add(tableField);
                     }
                 }
+            }
             tableFields.put(table, fields);
         }
         return tableFields;