Przykład UPDATE

src/main/java/p21_jdbc/bazowe/B_PierwszySelect.java

@@ -8,7 +8,7 @@ public class B_PierwszySelect {
         String url = "jdbc:postgresql://vps-2bc225bd.vps.ovh.net/hr";
         try(Connection c = DriverManager.getConnection(url, "alx", "abc123vps")) {
             System.out.println("Połączenie: " + c);
-            try(PreparedStatement stmt = c.prepareStatement("SELECT * FROM employees")) {
+            try(PreparedStatement stmt = c.prepareStatement("SELECT * FROM employees ORDER BY employee_id")) {
                 try(ResultSet rs = stmt.executeQuery()) {
                     System.out.println("ResultSet: " + rs);
                     while(rs.next()) {

src/main/java/p21_jdbc/bazowe/D_Update.java

+package p21_jdbc.bazowe;
+
+import javax.swing.*;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+
+public class D_Update {
+    public static void main(String[] args) {
+        String szukanyJob = JOptionPane.showInputDialog("Podaj kod stanowiska:", "IT_PROG");
+        int zmiana = Integer.parseInt(JOptionPane.showInputDialog("Podaj kwotę podwyżki:"));
+
+        String url = "jdbc:postgresql://vps-2bc225bd.vps.ovh.net/hr";
+        try(Connection c = DriverManager.getConnection(url, "alx", "abc123vps")) {
+            try(PreparedStatement stmt = c.prepareStatement("UPDATE employees SET salary = salary + ? WHERE job_id = ?")) {
+                stmt.setInt(1, zmiana);
+                stmt.setString(2, szukanyJob);
+                int count = stmt.executeUpdate();
+                System.out.println("Zmodyfikowano " + count + " rekordów.");
+            }
+        } catch (SQLException e) {
+            throw new RuntimeException(e);
+        }
+    }
+}

src/main/java/p21_jdbc/bazowe/E_UpdateWTransakcji.java

+package p21_jdbc.bazowe;
+
+import javax.swing.*;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+
+public class E_UpdateWTransakcji {
+    public static void main(String[] args) {
+        String szukanyJob = JOptionPane.showInputDialog("Podaj kod stanowiska:", "IT_PROG");
+        int zmiana = Integer.parseInt(JOptionPane.showInputDialog("Podaj kwotę podwyżki:"));
+
+        String url = "jdbc:postgresql://vps-2bc225bd.vps.ovh.net/hr";
+        try(Connection c = DriverManager.getConnection(url, "alx", "abc123vps")) {
+            // wyłączenie trybu auto-commit, a wejście w tryb transakcji
+            // dopóki nie wykonamy commit, zmiany nie są zapisywane w sposób trwały
+            c.setAutoCommit(false);
+            try(PreparedStatement stmt = c.prepareStatement("UPDATE employees SET salary = salary + ? WHERE job_id = ?")) {
+                stmt.setInt(1, zmiana);
+                stmt.setString(2, szukanyJob);
+                int count = stmt.executeUpdate();
+                System.out.println("Zmodyfikowano " + count + " rekordów.");
+            }
+        } catch (SQLException e) {
+            throw new RuntimeException(e);
+        }
+    }
+}