Programiranje baza podataka

class ProgramName {
    static {
        try {
            Class.forName("com.ibm.db2.jcc.DB2Driver");
        }
        catch (Exception e) {
            e.printStackTrace();

            System.exit(1);
        }
    }
    // ...
}

public static void main(String argv[]) {
    Connection con = null;
    String url = "jdbc:db2://localhost:50000/stud2020";
    
    // Povezivanje na bazu podataka
    con = DriverManager.getConnection(url, "student", "abcdef");

    // Kod programa...

    // Raskidanje konekcije sa bazom podataka
    con.close();
}

Connection con = null;

try {
    // Povezivanje na bazu podataka
    con = DriverManager.getConnection(url, "student", "abcdef");

    // Kod programa...

    // Raskidanje konekcije sa bazom podataka
    con.close();
}
catch (SQLException e) {
    e.printStackTrace();

    System.out.println(
        "SQLCODE: " + e.getErrorCode() + "\n" +
        "SQLSTATE: " + e.getSQLState() + "\n" +
        "PORUKA: " + e.getMessage());

    // Treba da zatvorimo konekciju ka bazi podataka i u slučaju greške.
    // S obzirom da metod close takođe može ispaliti SQLException,
    // potrebno ga je uhvatiti, ali biramo da ga ne obrađujemo dalje.
    try {
        if (null != con) {
            con.close();
        }
    } catch (SQLException e2) {
    }

    System.exit(2);
}
catch (Exception e) {
    e.printStackTrace();

    // Isto kao u catch bloku iznad.
    try {
        if (null != con) {
            con.close();
        }
    } catch (SQLException e2) {
    }

    System.exit(3);
}

public static void main(String argv[]) {
    String url = "jdbc:db2://localhost:50000/stud2020";

    try (
        Connection con = DriverManager.getConnection(url, "student", "abcdef");
    ) {
        // Kod programa...
    } catch (SQLException e) {
        e.printStackTrace();

        System.out.println(
            "SQLCODE: " + e.getErrorCode() + "\n" +
            "SQLSTATE: " + e.getSQLState() + "\n" +
            "PORUKA: " + e.getMessage());

        System.exit(2);
    }
    catch (Exception e) {
        e.printStackTrace();

        System.exit(3);
    }
}

package zadatak_8_1;

import java.sql.*;

public class Main {
    // Staticki blok koji sluzi za ucitavanje JDBC DB2 drajvera.
    // Izvrsava se kada se prvi put instancira objekat ove klase,
    // ili kada se prvi put pozove staticki metod.
    static {
        try {
            Class.forName("com.ibm.db2.jcc.DB2Driver");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static void main(String argv[]) {
        // URL za JDBC konekciju tipa 4
        String url = "jdbc:db2://localhost:50000/stud2020";

        // Objekat koji ce sadrzati konekciju
        // Kreiramo konekciju na bazi podataka zadatoj u promenljivoj url,
        // koriscenjem metoda DriverManager.getConnection.
        // Argumenti za korisnicko ime i lozinku su obavezni!
        // try-with-resources vodi racuna o otvorenim resursima
        // i zatvara ih na kraju try-catch bloka
        try (Connection con = DriverManager.getConnection(url, "student", "abcdef")) {
            // Kreiramo objekat naredbe (Statement)
            Statement stmt = con.createStatement();

            // SQL upit ili naredbu koju zelimo da izvrsimo
            // zapisujemo kao nisku <-> DINAMICKI SQL
            String queryStr = 
                "SELECT OZNAKA, " + 
                "       NAZIV " + 
                "FROM   DA.PREDMET " + 
                "WHERE  ESPB > 20";
            // Za izvrsavanje upita koristimo Statement.executeQuery metod.
            // Ovaj metod vraca objekat klase ResultSet,
            // koji sadrzi rezultate upita (kursor).
            ResultSet rs = stmt.executeQuery(queryStr);

            // Ispisujemo zaglavlje
            System.out.printf("%-15s %-50S\n\n", "OZNAKA", "NAZIV");

            // Metodom ResultSet.next pozicioniramo kursor na naredni red.
            // Ako vise nema redova, metod ce vratiti vrednost false.
            // Inace, vratice true, pa mozemo da ga koristimo kao uslov u petlji
            while (rs.next()) {
                // Izdvajamo podatke koriscenjem familije metoda
                // ResultSet.getXXX,
                // gde je XXX neki tip podataka,
                // a argument je broj kolone koja se dohvata iz projekcije
                // upita.
                String oznaka = rs.getString(1);
                String naziv = rs.getString(2);

                System.out.printf("%-15s %-50S\n", oznaka.trim(), naziv.trim());
            }

            // Zatvaramo kursor
            rs.close();
            // Zatvaramo naredbu
            stmt.close();
        }
        // Obrada SQL gresaka
        catch (SQLException e) {
            // Ispisujemo sve informacije na standardni izlaz
            e.printStackTrace();

            System.out.println("SQLCODE: " + e.getErrorCode() + "\n" + "SQLSTATE: " + e.getSQLState() + "\n"
                    + "PORUKA: " + e.getMessage());

            // Signaliziramo neuspesan zavrsetak programa
            System.exit(1);
        }
        // Obrada drugih gresaka
        catch (Exception e) {
            e.printStackTrace();
            
            // Signaliziramo neuspesan zavrsetak programa
            System.exit(2);
        }
    }
}

package zadatak_8_2;

import java.sql.*;

public class Main {
    static {
        try {
            Class.forName("com.ibm.db2.jcc.DB2Driver");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static void main(String argv[]) {
        String url = "jdbc:db2://localhost:50000/stud2020";

        try (Connection con = DriverManager.getConnection(url, "student", "abcdef")) {
            // Zelimo da izvrsimo INSERT naredbu
            // u kojoj su sve informacije poznate.
            // To znaci da mozemo koristiti kombinaciju
            // interfejsa Statement i metoda executeUpdate().
            String sql = 
                "INSERT INTO DA.PREDMET " +
                "VALUES (2001, 'Pred1', 'Predmet 1', 5)";

            Statement stmt = con.createStatement();

            System.out.println("Unosim podatke u tabelu PREDMET...");

            // Metod executeUpdate() se koristi ne samo za azuriranje,
            // vec i za unos, brisanje, i slicne naredbe.
            int insertCount = stmt.executeUpdate(sql);

            System.out.println("Broj unetih redova: " + insertCount);

            stmt.close();
        } catch (SQLException e) {
            e.printStackTrace();

            System.out.println("SQLCODE: " + e.getErrorCode() + "\n" + "SQLSTATE: " + e.getSQLState() + "\n"
                    + "PORUKA: " + e.getMessage());

            System.exit(1);
        } catch (Exception e) {
            e.printStackTrace();

            System.exit(2);
        }
    }
}

PreparedStatement prepareStatement(String sql) throws SQLException

package zadatak_8_3;

import java.sql.*;
import java.util.Scanner;

public class Main {
    static {
        try {
            Class.forName("com.ibm.db2.jcc.DB2Driver");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static void main(String argv[]) {
        String url = "jdbc:db2://localhost:50000/stud2020";

        try (
                Connection con = DriverManager.getConnection(url, "student", "abcdef");
                Scanner ulaz = new Scanner(System.in);
            ) {
            // JDBC koristi iskljucivo dinamicke SQL naredbe,
            // tako da se u JDBC ne koriste maticne promenljive.
            // S obzirom da su vrednosti za bodove u klauzama SET i WHERE
            // nepoznate do faze izvrsavanja,
            // potrebno je da koristimo parametarske oznake na tim mestima.
            String updateStr = 
                "UPDATE DA.PREDMET " + 
                "SET    ESPB = ? " + 
                "WHERE  ESPB = ?";
            // Zbog toga moramo da koristimo interfejs PreparedStatement,
            // jer interfejs Statement ne radi sa parametarskim oznakama.
            PreparedStatement pUpd = con.prepareStatement(updateStr);

            // Postavljamo odgovarajuce vrednosti za parametarske oznake
            // na osnovu procitanih vrednosti sa standardnog ulaza.
            int x, y;
            System.out.println("Unesite X:");
            x = ulaz.nextInt();
            System.out.println("Unesite Y:");
            y = ulaz.nextInt();
            
            // Prvu parametarsku oznaku menjamo celim brojem y.
            pUpd.setInt(1, y);

            // Drugu parametarsku oznaku menjamo celim brojem x.
            pUpd.setInt(2, x);

            // Izvrsavamo naredbu metodom executeUpdate() 
            // koji vraca broj azuriranih redova.
            int numRows = pUpd.executeUpdate();
            System.out.println("Broj azuriranih redova: " + numRows);

            pUpd.close();
        } catch (SQLException e) {
            e.printStackTrace();

            System.out.println("SQLCODE: " + e.getErrorCode() + "\n" + "SQLSTATE: " + e.getSQLState() + "\n"
                    + "PORUKA: " + e.getMessage());

            System.exit(1);
        } catch (Exception e) {
            e.printStackTrace();

            System.exit(2);
        }
    }
}

package zadatak_8_4;

import java.io.File;
import java.io.FileNotFoundException;
import java.sql.*;
import java.util.Scanner;

public class Main {
    static {
        try {
            Class.forName("com.ibm.db2.jcc.DB2Driver");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static void main(String argv[]) {
        String url = "jdbc:db2://localhost:50000/stud2020";

        try (Connection con = DriverManager.getConnection(url, "student", "abcdef")) {
            
            ispitiStudenteIIspite(con);
            
        } catch (SQLException e) {
            e.printStackTrace();

            System.out.println("SQLCODE: " + e.getErrorCode() + "\n" + "SQLSTATE: " + e.getSQLState() + "\n"
                    + "PORUKA: " + e.getMessage());

            System.exit(1);
        } catch (Exception e) {
            e.printStackTrace();

            System.exit(2);
        }
    }

    private static void ispitiStudenteIIspite(Connection con) throws FileNotFoundException, SQLException {
        String sql = ucitajSqlIzDatoteke();
        int brojPredmeta = ucitajBrojPredmeta();

        PreparedStatement pstmt = con.prepareStatement(sql.toString());
        pstmt.setInt(1, brojPredmeta);

        ResultSet result = pstmt.executeQuery();
        int brojRedova = 0;

        int indeks = 0;
        
        while (result.next()) {
            // Ispisujemo informacije o studentu
            // samo kad naidjemo na novog studenta
            if (indeks != result.getInt(1)) {
                if (indeks != 0) {
                    System.out.print("\n\n\n");
                }

                System.out.println("Indeks: " + result.getInt(1) + "\n" + "Ime: " + result.getString(2).trim()
                        + "\n" + "Prezime: " + result.getString(3).trim() + "\n" + "Studijski program: "
                        + result.getString(4).trim() + "\n");

                brojRedova = 1;
            }

            // Ispisujemo informacije o i-tom predmetu
            System.out.println(brojRedova + ". predmet: " + result.getString(5).trim() + "\n\t" + "ocena: "
                    + result.getInt(6));

            // Uvecavamo broj reda
            ++brojRedova;
            // Pamtimo tekuci indeks za narednu iteraciju
            indeks = result.getInt(1);
        }

        pstmt.close();
    }

    private static int ucitajBrojPredmeta() {
        int brojPredmeta;
        
        System.out.println("Unesite broj predmeta:");
        try (Scanner ulaz = new Scanner(System.in)) {
            brojPredmeta = ulaz.nextInt();
        }
        return brojPredmeta;
    }

    private static String ucitajSqlIzDatoteke() throws FileNotFoundException {
        // Eclipse aplikacije se pokrecu iz direktorijuma projekta,
        // dakle, u podrazumevanom slucaju,
        // ~/IBM/rationalsdp/workspace/poglavlje_8/.
        // Mozemo koristiti sistemsko svojstvo
        // System.getProperty("user.dir")
        // da dohvatimo putanju u kojoj se pokrece aplikacija.
        // Takodje, prilikom kompiliranja .java datoteka u .class datoteke,
        // Eclipse alat ce kopirati sve druge datoteke iz src/ direktorijuma u bin/ direktorijum.
        String putanja = "./bin/zadatak_8_4/upit.sql";
        StringBuilder sql = new StringBuilder("");
        String linija = null;
        
        try (Scanner skenerFajla = new Scanner(new File(putanja), "utf-8")) {
            while (skenerFajla.hasNextLine()) {
                linija = skenerFajla.nextLine();
                sql.append(linija);
                sql.append("\n");
            }
        }

        return sql.toString();
    }
}

ResultSet res = ...

while (res.next()) {
    // Vrednosti u ovoj koloni ne mogu biti NULL,
    // pa nemamo ni proveru za nju.
    int kolona1_notnull = res.getInt(1);

    // Vrednosti u ovoj koloni mogu biti NULL,
    // pa zato odmah nakon dohvatanja vrednosti,
    // pozivamo metod wasNull() da proverimo da li je NULL.
    int kolona2_nullable = res.getInt(2);
    boolean kol2IsNull = res.wasNull();

    // Vrednosti u ovoj koloni mogu biti NULL,
    // pa zato odmah nakon dohvatanja vrednosti,
    // pozivamo metod wasNull() da proverimo da li je NULL.
    // Ovaj poziv metoda wasNull() se odnosi na kolonu 3, a ne na 2.
    Date kolona3_nullable = res.getDate(3);
    boolean kol3IsNull = res.wasNull();
    
    ...
}

package zadatak_8_5;

import java.sql.*;

public class Main {
    static {
        try {
            Class.forName("com.ibm.db2.jcc.DB2Driver");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static void main(String argv[]) {
        String url = "jdbc:db2://localhost:50000/stud2020";

        try (Connection con = DriverManager.getConnection(url, "student", "abcdef")) {
            
            Statement stmt = con.createStatement();
            String queryStr = 
                "SELECT IME, " + 
                "       PREZIME, " + 
                "       DATDIPLOMIRANJA " + 
                "FROM   DA.DOSIJE " + 
                "WHERE  POL = 'z' AND " + 
                "       IDPROGRAMA=202";
            ResultSet rs = stmt.executeQuery(queryStr);

            System.out.printf("%-25s %-25s %-15s \n\n", "IME", "PREZIME", "DATUM DIPLOMIRANJA");

            while (rs.next()) {
                String ime = rs.getString(1).trim();
                String prezime = rs.getString(2).trim();
                String datum = rs.getString(3);
                // Ukoliko je u tekucem redu kursora datum bio NULL,
                // onda ce rs.wasNull() biti true
                boolean datumIsNull = rs.wasNull();

                System.out.printf("%-25s %-25s %-15s \n", ime, prezime, (datumIsNull) ? "Nije diplomirala" : datum.trim());
            }

            rs.close();
            stmt.close();
        } catch (SQLException e) {
            e.printStackTrace();

            System.out.println("SQLCODE: " + e.getErrorCode() + "\n" + "SQLSTATE: " + e.getSQLState() + "\n"
                    + "PORUKA: " + e.getMessage());

            System.exit(1);
        } catch (Exception e) {
            e.printStackTrace();

            System.exit(2);
        }
    }
}

package zadatak_8_6;

import java.sql.*;

public class Main {
    static {
        try {
            Class.forName("com.ibm.db2.jcc.DB2Driver");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static void main(String argv[]) {
        String url = "jdbc:db2://localhost:50000/stud2020";

        try (Connection con = DriverManager.getConnection(url, "student", "abcdef")) {
            
            String sql = 
                "SELECT     * " + 
                "FROM       DA.ISPITNIROK " + 
                "ORDER BY   NAZIV";
            Statement stmt = con.createStatement(
                // Podesavamo da je kursor bidirekcioni i nesenzitivni,
                // sto znaci da moze da se krece kroz njega u oba smera,
                // i da izmene u bazi podataka nece biti vidljive tokom
                // prolazenja kroz kursora
                ResultSet.TYPE_SCROLL_INSENSITIVE,
                // Podesavamo da se kursor koristi samo za citanje
                ResultSet.CONCUR_READ_ONLY);
            ResultSet res = stmt.executeQuery(sql);

            System.out.printf("%-10s %-15s %-20s %-20s %-20s\n\n", 
                "GODINA", "OZNAKA", "NAZIV", "DATUM POCETKA", "DATUM KRAJA");

            // Pozicioniranje na kraj kursora
            res.afterLast();

            // Citanje unazad
            while (res.previous()) {
                int godina = res.getInt(1);
                String oznaka = res.getString(2).trim();
                String naziv = res.getString(3).trim();
                Date datumPocetka = res.getDate(4);
                Date datumKraja = res.getDate(5);

                System.out.printf("%-10d %-15s %-20s %-20s %-20s\n", 
                    godina, oznaka, naziv, datumPocetka.toString(), datumKraja.toString());
            }

            res.close();
            stmt.close();
        } catch (SQLException e) {
            e.printStackTrace();

            System.out.println("SQLCODE: " + e.getErrorCode() + "\n" + "SQLSTATE: " + e.getSQLState() + "\n"
                    + "PORUKA: " + e.getMessage());

            System.exit(1);
        } catch (Exception e) {
            e.printStackTrace();

            System.exit(2);
        }
    }
}

String upit =
    "SELECT OZNAKA, " +
    "       NAZIV, " + 
    "       ESPB " +
    "FROM   DA.PREDMET " +
    "FOR    UPDATE OF ESPB";

Statement stmt = con.createStatement();
ResultSet rs = stmt.executeQuery(upit);

String nazivKursora = rs.getCursorName();
String azuriranje =
    "UPDATE DA.PREDMET " +
    "SET    ESPB = ? " +
    "WHERE  CURRENT OF " + nazivKursora;
PreparedStatement ps = con.prepareStatement(nazivKursora);

try (Scanner scanner = new Scanner(System.in)) {
    while (rs.next()) {
        System.out.println("Unesite nove ESPB bodove za predmet " + rs.getString(2));
        int newESPB = scanner.nextInt();

        ps.setInt(1, newESPB);
        ps.executeUpdate();
    }
}

package zadatak_8_7;

import java.sql.*;
import java.util.Scanner;

public class Main {
    static {
        try {
            Class.forName("com.ibm.db2.jcc.DB2Driver");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static void main(String argv[]) {
        String url = "jdbc:db2://localhost:50000/stud2020";

        try (Connection con = DriverManager.getConnection(url, "student", "abcdef")) {

            int[] ucitaniESPB = ucitajStareINoveESPB();
            ispisiIAzurirajPredmete(con, ucitaniESPB[0], ucitaniESPB[1]);

        } catch (SQLException e) {
            e.printStackTrace();

            System.out.println("SQLCODE: " + e.getErrorCode() + "\n" + "SQLSTATE: " + e.getSQLState() + "\n"
                    + "PORUKA: " + e.getMessage());

            System.exit(1);
        } catch (Exception e) {
            e.printStackTrace();

            System.exit(2);
        }
    }

    private static void ispisiIAzurirajPredmete(Connection con, int X, int Y) throws SQLException {
        String sql = 
            "SELECT * " + 
            "FROM   DA.PREDMET";
        Statement stmt = con.createStatement( 
                // Dovoljan nam je kursor koji prolazi unapred kroz redove.
                ResultSet.TYPE_FORWARD_ONLY,
                // Definisemo da je kursor azurirajuci,
                // pa su nam dostupni metodi
                // ResultSet.updateXXX i ResultSet.updateRow
                // koje cemo koristiti za azuriranje tekuceg reda
                ResultSet.CONCUR_UPDATABLE);
        ResultSet rs = stmt.executeQuery(sql);

        while (rs.next()) {
            System.out.println("Oznaka: " + rs.getString(2).trim() + ", " + "Naziv:" + rs.getString(3).trim() + ", "
                    + "ESPB: " + rs.getInt(4));

            if (rs.getInt(4) == X) {
                // Azuriramo vrednost u koloni broj 5 (ESPB) iz upita iznad.
                rs.updateInt(4, Y);
                // Kada zavrsimo sa azuriranjem svih kolona,
                // pozivamo metod updateRow
                // da bi se sve promene odmah oslikale.
                // Ako zaboravimo da pozovemo ovaj metod,
                // izmene se nece propagirati i bice izgubljene.
                rs.updateRow();

                // Sada kada zahtevamo vrednosti u kolonama,
                // dobicemo azurirane vrednosti:
                System.out.println("------> Izvrsena je naredna promena:");
                System.out.println("        Oznaka: " + rs.getString(2).trim() + ", " + "Naziv:" + rs.getString(3).trim()
                        + ", " + "ESPB: "
                        + rs.getInt(4) /* azurirana vrednost */ + "\n");
            }
        }

        rs.close();
        stmt.close();
    }
    
    private static int[] ucitajStareINoveESPB() {
        int[] rezultat = new int[2];
        
        try (Scanner ulaz = new Scanner(System.in)) {
            System.out.println("Unesite stare ESPB:");
            rezultat[0] = ulaz.nextInt();
            System.out.println("Unesite nove ESPB:");
            rezultat[1] = ulaz.nextInt();
        }
        
        return rezultat;
    }
}

package zadatak_8_8;

import java.sql.*;
import java.util.ArrayList;
import java.util.Scanner;

public class Main {
    static {
        try {
            Class.forName("com.ibm.db2.jcc.DB2Driver");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    
    private static class StatistikaPolaganja {
        public int idPredmeta;
        public int brojPolaganja;
        
        public StatistikaPolaganja(int idPredmeta, int brojPolaganja) {
            this.idPredmeta = idPredmeta;
            this.brojPolaganja = brojPolaganja;
        }
    }

    public static void main(String argv[]) {
        String url = "jdbc:db2://localhost:50000/stud2020";
        ArrayList<StatistikaPolaganja> statistike = new ArrayList<>();

        try (Connection con = DriverManager.getConnection(url, "student", "abcdef")) {
            
            kreirajTabelu(con);
            sakupiStatistiku(con, statistike);
            unesiPredmeteIzStatistike(con, statistike);

        } catch (SQLException e) {
            e.printStackTrace();

            System.out.println("SQLCODE: " + e.getErrorCode() + "\n" + "SQLSTATE: " + e.getSQLState() + "\n"
                    + "PORUKA: " + e.getMessage());

            System.exit(1);
        } catch (Exception e) {
            e.printStackTrace();

            System.exit(2);
        }
    }
    
    private static void kreirajTabelu(Connection con) throws SQLException {
        String sql = "CREATE TABLE DA.UNETIPREDMETI ( "
                + "IDPREDMETA INTEGER NOT NULL, "
                + "BROJPOLOZENIH INTEGER NOT NULL, "
                + "PRIMARY KEY (IDPREDMETA), "
                + "FOREIGN KEY (IDPREDMETA) REFERENCES DA.PREDMET "
                + ")";
        Statement stmt = con.createStatement();
        try {
            stmt.executeUpdate(sql);
        } catch (SQLException e) {
            // Ignorisemo gresku samo ako je u pitanju greska da tabela vec postoji (-601).
            // Sve ostale ispaljujemo main metodu.
            if (e.getErrorCode() != -601) {
                throw e;
            }
        }
        stmt.close();
    }

    private static void sakupiStatistiku(Connection con, ArrayList<StatistikaPolaganja> statistike) throws SQLException {
        String sql = "SELECT  IDPREDMETA, COUNT(OCENA) " +
            "FROM    DA.ISPIT " +
            "WHERE   OCENA > 5 AND " +
            "        STATUS = 'o' AND " +
            "        IDPREDMETA NOT IN (SELECT IDPREDMETA FROM DA.UNETIPREDMETI) " +
            "GROUP BY IDPREDMETA";
        Statement stmt = con.createStatement();
        ResultSet kursor = stmt.executeQuery(sql);
        while (kursor.next()) {
            int idPredmeta = kursor.getInt(1);
            int brojPolaganja = kursor.getInt(2); 
            statistike.add(new StatistikaPolaganja(idPredmeta, brojPolaganja));
        }
        kursor.close();
        stmt.close();
    }
    
    private static void unesiPredmeteIzStatistike(Connection con, ArrayList<StatistikaPolaganja> statistike) throws SQLException {
        String sql = 
            "SELECT * " + 
            "FROM   DA.UNETIPREDMETI";
        Statement stmt = con.createStatement( 
                // Dovoljan nam je kursor koji prolazi unapred kroz redove.
                ResultSet.TYPE_FORWARD_ONLY,
                // Definisemo da je kursor azurirajuci,
                // pa su nam dostupni metodi
                // ResultSet.updateXXX i ResultSet.insertRow
                // koje cemo koristiti za konstrukciju i unos novog reda
                ResultSet.CONCUR_UPDATABLE);
        ResultSet kursor = stmt.executeQuery(sql);
        Scanner ulaz = new Scanner(System.in);
        
        for (StatistikaPolaganja statistika : statistike) {
            // Pozicioniramo kursor na "slog za unos"
            kursor.moveToInsertRow();
            // Konstruisemo "slog za unos" navodjenjem vrednost za svaku kolonu
            kursor.updateInt(1, statistika.idPredmeta);
            kursor.updateInt(2, statistika.brojPolaganja);
            // Izvrsavamo ili ponistavamo unos u zavisnosti od korisnikovog odgovora
            System.out.println("Da li zelite da unete statistiku za predmet " + statistika.idPredmeta + "? [da/ne]");
            String odgovor = ulaz.nextLine();
            if (odgovor.equalsIgnoreCase("da")) {
                kursor.insertRow();
                System.out.println("\tUneta je statistika: " + statistika.idPredmeta + " (" + statistika.brojPolaganja + ")");
            }
            else {
                System.out.println("\tPonistili ste unos!");
            }
            // Vracamo kursor na zapamceni tekuci red
            kursor.moveToCurrentRow();
        }
        
        ulaz.close();
        kursor.close();
        stmt.close();
    }
}

String upit =
    "SELECT OZNAKA, " +
    "       NAZIV, " + 
    "       ESPB " +
    "FROM   DA.PREDMET";

Statement stmt = con.createStatement();
ResultSet rs = stmt.executeQuery(upit);

String nazivKursora = rs.getCursorName();
String brisanje =
    "DELETE FROM DA.PREDMET " +
    "WHERE  CURRENT OF " + nazivKursora;
Statement ps = con.prepareStatement();

while (rs.next()) {
    String nazivPredmeta = rs.getString(2);

    ps.executeUpdate(brisanje);
    System.out.println("Obrisan je predmet " + nazivPredmeta);
}

package zadatak_8_9;

import java.sql.*;
import java.util.Scanner;

public class Main {
    static {
        try {
            Class.forName("com.ibm.db2.jcc.DB2Driver");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static void main(String argv[]) {
        String url = "jdbc:db2://localhost:50000/stud2020";

        try (Connection con = DriverManager.getConnection(url, "student", "abcdef")) {
            
            izbrisiNepolozeneIspite(con);

        } catch (SQLException e) {
            e.printStackTrace();

            System.out.println("SQLCODE: " + e.getErrorCode() + "\n" + "SQLSTATE: " + e.getSQLState() + "\n"
                    + "PORUKA: " + e.getMessage());

            System.exit(1);
        } catch (Exception e) {
            e.printStackTrace();

            System.exit(2);
        }
    }

    private static void izbrisiNepolozeneIspite(Connection con) throws SQLException {
        int godina = ucitajGodinu();
        
        String selectSql = 
            "SELECT INDEKS, " + 
            "       OZNAKAROKA, " + 
            "       IDPREDMETA " +
            "FROM   DA.ISPIT " +
            "WHERE  SKGODINA = ? AND " +   
            "       OCENA = 5 AND " +  
            "       STATUS = 'o'";    
        PreparedStatement stmt = con.prepareStatement(selectSql,
            ResultSet.TYPE_FORWARD_ONLY,
            // Podesavamo kursor da bude za menjanje,
            // da bi smo mogli da brisemo redove metodom deleteRow() .
            ResultSet.CONCUR_UPDATABLE);
        stmt.setInt(1, godina);
        ResultSet ispiti = stmt.executeQuery();
        
        while(ispiti.next()) {
            int indeks = ispiti.getInt(1);
            String oznakaRoka = ispiti.getString(2).trim();
            int idPredmeta = ispiti.getInt(3);
            
            ispiti.deleteRow();
            
            System.out.printf("Obrisan je ispit %-10d %-10s %-5d %-10d\n", 
                indeks, oznakaRoka, godina, idPredmeta);
        }
        
        ispiti.close();
        stmt.close();
    }
    
    private static int ucitajGodinu() {
        int godina;
        
        try (Scanner ulaz = new Scanner(System.in)) {
            System.out.println("Unesite godinu roka za koju zelite da budu obrisani nepolozeni ispiti:");
            godina = ulaz.nextInt();
        }
        
        return godina;
    }
}

package zadatak_8_10;

import java.io.File;
import java.io.FileNotFoundException;
import java.sql.*;
import java.util.Scanner;

public class Main {
    static {
        try {
            Class.forName("com.ibm.db2.jcc.DB2Driver");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static void main(String argv[]) {
        String url = "jdbc:db2://localhost:50000/stud2020";

        try (Connection con = DriverManager.getConnection(url, "student", "abcdef")) {
            
            prodjiKrozSpoljasnjiKursor(con);
            
        } catch (SQLException e) {
            e.printStackTrace();

            System.out.println("SQLCODE: " + e.getErrorCode() + "\n" + "SQLSTATE: " + e.getSQLState() + "\n"
                    + "PORUKA: " + e.getMessage());

            System.exit(1);
        } catch (Exception e) {
            e.printStackTrace();

            System.exit(2);
        }
    }

    private static void prodjiKrozSpoljasnjiKursor(Connection con) throws SQLException, FileNotFoundException {
        int ukupnoPredmeta = ucitajBrojPredmeta();

        PreparedStatement pstmt;

        String sql = ucitajSqlIzDatoteke("ispiti.sql");
        pstmt = con.prepareStatement(sql);

        pstmt.setInt(1, ukupnoPredmeta);
        ResultSet ispiti = pstmt.executeQuery();

        while (ispiti.next()) {
            System.out.printf("\n\nIndeks: %-10d\nIme: %-10s\nPrezime: %-20s\nNaziv smera: %-30s\n\n", ispiti.getInt(1),
                    ispiti.getString(2), ispiti.getString(3), ispiti.getString(4));

            int indeks = ispiti.getInt(1);
            prodjiKrozUnutrasnjiKursor(con, indeks);
        }

        ispiti.close();
        pstmt.close();
    }

    private static void prodjiKrozUnutrasnjiKursor(Connection con, int indeks) throws SQLException, FileNotFoundException {
        PreparedStatement pstmt;

        String sql = ucitajSqlIzDatoteke("predmeti.sql");
        pstmt = con.prepareStatement(sql);

        pstmt.setInt(1, indeks);
        ResultSet predmeti = pstmt.executeQuery();

        int redniBr = 1;

        while (predmeti.next()) {
            System.out.printf("\t%d. predmet: %s\n\t\tOcena: %d\n", redniBr, predmeti.getString(1),
                    predmeti.getShort(2));

            ++redniBr;
        }

        predmeti.close();
        pstmt.close();
    }

    private static int ucitajBrojPredmeta() {
        int godina;

        try (Scanner ulaz = new Scanner(System.in)) {
            System.out.println("Unesite broj predmeta N:");
            godina = ulaz.nextInt();
        }

        return godina;
    }
    
    private static String ucitajSqlIzDatoteke(String nazivDatoteke) throws FileNotFoundException {
        String putanja = "./bin/zadatak_8_10/" + nazivDatoteke;
        StringBuilder sql = new StringBuilder("");
        String linija = null;
        
        try (Scanner skenerFajla = new Scanner(new File(putanja), "utf-8")) {
            while (skenerFajla.hasNextLine()) {
                linija = skenerFajla.nextLine();
                sql.append(linija);
                sql.append("\n");
            }
        }

        return sql.toString();
    }
}