Метод для обновления бд

package com.simbirsoft.ivanov;
 
import java.sql.*;
import java.util.HashSet;
import java.util.Set;
 
public class ConnectionToDB {
    String url = "jdbc:postgresql://localhost:5432/pizzeria";
    String name = "user";
    String password = "123456user";
    Connection connection = null;
    Statement statement = null;
    ResultSet rs = null;
    // boolean isConnected = false;
 
   /* public boolean isDbConnected() {
        final String CHECK_SQL_QUERY = "SELECT 1";
        try {
            statement = db.prepareStatement(CHECK_SQL_QUERY);
            isConnected = true;
        } catch (SQLException | NullPointerException e) {
            LogWriter.getLog().error(e);
        }
        return isConnected;
    }*/
 
    public void createDB() {
        try {
           // Class.forName("org.postgresql.Driver");
            connection = DriverManager.getConnection(url, name, password);
            statement = connection.createStatement();
            rs = statement.executeQuery("CREATE TABLE public."IngredientStore"\n" +
                    "(\n" +
                    "  "Id" INTEGER NOT NULL DEFAULT nextval('"IngredientStore_Id_seq"'::REGCLASS),\n" +
                    "  "Name" TEXT,\n" +
                    "  "Quantity" BIGINT,\n" +
                    "  CONSTRAINT "IngredientStore_pkey" PRIMARY KEY ("Id")\n" +
                    ")\n" +
                    "WITH (\n" +
                    "  OIDS=FALSE\n" +
                    ");\n" +
                    "ALTER TABLE public."IngredientStore"\n" +
                    "  OWNER TO "user";\n" +
                    "INSERT INTO public."IngredientStore"\n (Name, Quantity) VALUES ('сыр', '5000');" +
                    "INSERT INTO public."IngredientStore"\n (Name, Quantity) VALUES ('лук', '5000');" +
                    "INSERT INTO public."IngredientStore"\n (Name, Quantity) VALUES ('помидор', '5000');" +
                    "INSERT INTO public."IngredientStore"\n (Name, Quantity) VALUES ('грибы', '5000');" +
                    "INSERT INTO public."IngredientStore"\n (Name, Quantity) VALUES ('майонез', '5000');" +
                    "INSERT INTO public."IngredientStore"\n (Name, Quantity) VALUES ('колбаса', '5000')");
 
        } catch (Exception ex) {
            LogWriter.getLog().error(ex);
        } finally {
            if (connection != null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    LogWriter.getLog().error(e);
                }
            }
        }
    }
 
    public Set<Ingredient> selectDB(Set<Ingredient> store) {
        try {
           // Class.forName("org.postgresql.Driver");
            connection = DriverManager.getConnection(url, name, password);
            statement = connection.createStatement();
            rs = statement.executeQuery("SELECT * FROM IngredientStore");
            while (rs.next()) {
                store.add(new Ingredient(rs.getInt(0), rs.getString(1), rs.getLong(2)));
            }
        } catch (Exception ex) {
            LogWriter.getLog().error(ex);
        } finally {
            if (connection != null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    LogWriter.getLog().error(e);
                }
            }
        }
        return store;
    }
 
    public void updateDB(HashSet<Ingredient> store) {
        try {
           // Class.forName("org.postgresql.Driver");
            connection = DriverManager.getConnection(url, name, password);
           // statement = connection.prepareStatement();
            PreparedStatement pst = connection.prepareStatement("UPDATE IngredientStore SET Name = ?, Quantity = ?");
 
            for (Ingredient ingr : store) {
                pst.setString(1, ingr.getName());
                pst.setLong(2, ingr.getQuantity());
            }
            pst.executeQuery();
        } catch (Exception ex) {
            LogWriter.getLog().error(ex);
        } finally {
            if (connection != null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    LogWriter.getLog().error(e);
                }
            }
        }
    }
 
}