Code formatting for MappedQueryImpl (#4935)

* Auto format mappedqueryimpl

* Fix kafkasql stapshotting

* Code formatting

Author: EricWittmann

app/src/main/java/io/apicurio/registry/storage/impl/sql/AbstractSqlRegistryStorage.java

@@ -3320,7 +3320,8 @@ public String createSnapshot(String location) throws RegistryStorageException {
         if (!StringUtil.isEmpty(location)) {
             log.debug("Creating internal database snapshot to location {}.", location);
             handles.withHandleNoException(handle -> {
-                handle.createQuery(sqlStatements.createDataSnapshot()).bind(0, location).mapTo(Integer.class);
+                handle.createQuery(sqlStatements.createDataSnapshot()).bind(0, location).mapTo(String.class)
+                        .first();
             });
             return location;
         } else {

app/src/main/java/io/apicurio/registry/storage/impl/sql/jdb/MappedQueryImpl.java

@@ -42,15 +42,12 @@ public T one() {
                 if (resultSet.next()) {
                     throw new RuntimeSqlException("SQL error: Expected only one result but got multiple.");
                 }
-            }
-            else {
+            } else {
                 throw new RuntimeSqlException("SQL error: Expected only one result row but got none.");
             }
-        }
-        catch (SQLException e) {
+        } catch (SQLException e) {
             throw new RuntimeSqlException(e);
-        }
-        finally {
+        } finally {
             close();
         }
         return rval;
@@ -65,15 +62,12 @@ public T first() {
         try (ResultSet resultSet = statement.executeQuery()) {
             if (resultSet.next()) {
                 rval = this.mapper.map(resultSet);
-            }
-            else {
+            } else {
                 throw new RuntimeSqlException("SQL error: Expected AT LEAST one result row but got none.");
             }
-        }
-        catch (SQLException e) {
+        } catch (SQLException e) {
             throw new RuntimeSqlException(e);
-        }
-        finally {
+        } finally {
             close();
         }
         return rval;
@@ -91,15 +85,12 @@ public Optional<T> findOne() {
                 if (resultSet.next()) {
                     throw new RuntimeSqlException("SQL error: Expected only one result but got multiple.");
                 }
-            }
-            else {
+            } else {
                 rval = Optional.empty();
             }
-        }
-        catch (SQLException e) {
+        } catch (SQLException e) {
             throw new RuntimeSqlException(e);
-        }
-        finally {
+        } finally {
             close();
         }
         return rval;
@@ -114,15 +105,12 @@ public Optional<T> findFirst() {
         try (ResultSet resultSet = statement.executeQuery()) {
             if (resultSet.next()) {
                 rval = Optional.of(this.mapper.map(resultSet));
-            }
-            else {
+            } else {
                 rval = Optional.empty();
             }
-        }
-        catch (SQLException e) {
+        } catch (SQLException e) {
             throw new RuntimeSqlException(e);
-        }
-        finally {
+        } finally {
             close();
         }
         return rval;
@@ -141,11 +129,9 @@ public Optional<T> findLast() {
             if (rval == null) {
                 rval = Optional.empty();
             }
-        }
-        catch (SQLException e) {
+        } catch (SQLException e) {
             throw new RuntimeSqlException(e);
-        }
-        finally {
+        } finally {
             close();
         }
         return rval;
@@ -162,11 +148,9 @@ public List<T> list() {
                 T t = this.mapper.map(resultSet);
                 rval.add(t);
             }
-        }
-        catch (SQLException e) {
+        } catch (SQLException e) {
             throw new RuntimeSqlException(e);
-        }
-        finally {
+        } finally {
             close();
         }
         return rval;
@@ -179,8 +163,9 @@ public List<T> list() {
     public Stream<T> stream() {
         try {
             ResultSet resultSet = statement.executeQuery();
-            return StreamSupport.stream(
-                    new Spliterators.AbstractSpliterator<T>(Long.MAX_VALUE, Spliterator.IMMUTABLE | Spliterator.ORDERED | Spliterator.DISTINCT | Spliterator.NONNULL) {
+            return StreamSupport
+                    .stream(new Spliterators.AbstractSpliterator<T>(Long.MAX_VALUE, Spliterator.IMMUTABLE
+                            | Spliterator.ORDERED | Spliterator.DISTINCT | Spliterator.NONNULL) {
                         @Override
                         public boolean tryAdvance(Consumer<? super T> action) {
                             try {
@@ -190,23 +175,20 @@ public boolean tryAdvance(Consumer<? super T> action) {
                                 T t = mapper.map(resultSet);
                                 action.accept(t);
                                 return true;
-                            }
-                            catch (SQLException e) {
+                            } catch (SQLException e) {
                                 throw new RuntimeSqlException(e);
                             }
                         }
 
                     }, false).onClose(() -> {
-                try {
-                    resultSet.close();
-                    close();
-                }
-                catch (SQLException e) {
-                    throw new RuntimeException(e);
-                }
-            });
-        }
-        catch (SQLException e) {
+                        try {
+                            resultSet.close();
+                            close();
+                        } catch (SQLException e) {
+                            throw new RuntimeException(e);
+                        }
+                    });
+        } catch (SQLException e) {
             throw new RuntimeException(e);
         }
     }
@@ -218,8 +200,7 @@ public boolean tryAdvance(Consumer<? super T> action) {
     public void close() {
         try {
             this.statement.close();
-        }
-        catch (SQLException e) {
+        } catch (SQLException e) {
             throw new RuntimeSqlException(e);
         }
     }