[Improve][[Jdbc]sink sql support custom field.(apache#6515)-fix code …

…style
rtyuy · Mar 20, 2024 · 11b50a4 · 11b50a4
1 parent 0faf4a9
commit 11b50a4
Showing 1 changed file with 20 additions and 6 deletions.
diff --git a/...he/seatunnel/connectors/seatunnel/jdbc/internal/executor/FieldNamedPreparedStatement.java b/...he/seatunnel/connectors/seatunnel/jdbc/internal/executor/FieldNamedPreparedStatement.java
@@ -637,15 +637,29 @@ public static FieldNamedPreparedStatement prepareStatement(
             HashMap<String, List<Integer>> parameterMap = new HashMap<>();
             parsedSQL = parseNamedStatement(sql, parameterMap);
             // currently, the statements must contain all the field parameters
-            parameterMap.keySet().forEach(namedParameter -> {
-                boolean namedParameterExist =  Arrays.asList(fieldNames).stream().anyMatch(field -> field.equals(namedParameter));
-                checkArgument(namedParameterExist, String.format("Named parameters [%s] not in source columns, check SQL: %s", namedParameter, sql));
-            });
+            parameterMap
+                    .keySet()
+                    .forEach(
+                            namedParameter -> {
+                                boolean namedParameterExist =
+                                        Arrays.asList(fieldNames).stream()
+                                                .anyMatch(field -> field.equals(namedParameter));
+                                checkArgument(
+                                        namedParameterExist,
+                                        String.format(
+                                                "Named parameters [%s] not in source columns, check SQL: %s",
+                                                namedParameter, sql));
+                            });
 
             for (int i = 0; i < fieldNames.length; i++) {
                 String fieldName = fieldNames[i];
-                boolean parameterExist = parameterMap.keySet().stream().anyMatch(parameter -> parameter.equals(fieldName));
-                indexMapping[i] = parameterExist ? parameterMap.get(fieldName).stream().mapToInt(v -> v).toArray() : new int[0];
+                boolean parameterExist =
+                        parameterMap.keySet().stream()
+                                .anyMatch(parameter -> parameter.equals(fieldName));
+                indexMapping[i] =
+                        parameterExist
+                                ? parameterMap.get(fieldName).stream().mapToInt(v -> v).toArray()
+                                : new int[0];
             }
         }
         log.info("PrepareStatement sql is:\n{}\n", parsedSQL);