7. Java i bazy danych (JDBC)

Java jest doskonałym środowiskiem programowania dostępu do baz danych. Przyjrzymy się więc mechanizmom umożliwiającym pisanie takich programów.

7.1. Przykładowa baza danych

create database if not exists ksidb;
use ksidb;
drop table if exists AUTOR; 
drop table if exists WYDAWCA; 
drop table if exists POZYCJE;

create table AUTOR (
        AUTID integer not null AUTO_INCREMENT,
        NAME varchar(255) not null,
        PRIMARY KEY(AUTID)
        ) ENGINE=INNODB;

create table WYDAWCA (
        WYDID integer not null AUTO_INCREMENT,
        NAME varchar(255) not null,
        PRIMARY KEY(WYDID)
        ) ENGINE=INNODB;



load data infile '../BazySql/ksidb/AUTOR.TXT' replace into table AUTOR;
load data infile '../BazySql/ksidb/WYDAWCA.TXT' replace into table WYDAWCA;

create table POZYCJE (
        ISBN char(13) not null,
        AUTID integer not null,
        TYTUL varchar(255) not null,
        WYDID integer not null,
        ROK integer not null,
        CENA real,
        PRIMARY KEY(ISBN),

        INDEX(AUTID),
        FOREIGN KEY(AUTID) REFERENCES AUTOR(AUTID),

        INDEX(WYDID),
        FOREIGN KEY(WYDID) REFERENCES WYDAWCA(WYDID)


        ) ENGINE=INNODB;

load data infile '../BazySql/ksidb/POZYCJE.TXT' replace into table POZYCJE;

connect 'jdbc:derby:ksidb;create=true';

drop table POZYCJE;
drop table AUTOR;
drop table WYDAWCA;


create table AUTOR (
        AUTID integer not null generated by default as identity,
        NAME varchar(255) not null,
        PRIMARY KEY(AUTID)
        );

create table WYDAWCA (
        WYDID integer not null generated by default as identity,
        NAME varchar(255) not null,
        PRIMARY KEY(WYDID)
        );


CALL SYSCS_UTIL.SYSCS_IMPORT_TABLE (null,'AUTOR','AUTOR.TXT',null,null,null,0);
CALL SYSCS_UTIL.SYSCS_IMPORT_TABLE (null,'WYDAWCA','WYDAWCA.TXT',null,null,null,0);

create table POZYCJE (
        ISBN char(13) not null,
        AUTID integer not null,
        TYTUL varchar(255) not null,
        WYDID integer not null,
        ROK integer not null,
        CENA real,
        PRIMARY KEY(ISBN),
        FOREIGN KEY(AUTID) REFERENCES AUTOR(AUTID),
        FOREIGN KEY(WYDID) REFERENCES WYDAWCA(WYDID)
        );

CALL SYSCS_UTIL.SYSCS_IMPORT_TABLE (null,'POZYCJE','POZYCJE.TXT',null,null,null,0);

7.2. Dlaczego Java?

• jest niezależny od maszyny bazodanowej (RDBMS)
• jest niezależny od platformy sprzętowej
• jest niezależny od systemu operacyjnego

7.3. JDBC

1. Połączenie z bazą danych
2. Wykonywanie instrukcji SQL na bazie danych
3. Otrzymywanie i przetwarzanie wyników instrukcji SQL (np. tabel wynikowych)

• przewijalne i modyfikowalne tabele wynikowe,
• bezpośrednie modyfikowanie tabel wynikowych za pomoc metod klasy Statement
• wsadowe przetwarzanie instrukcji SQL
• obsługę typów danych SQL3
• wspomaganie  JNDI (Java Naming and Directory Services) – czyli możliwość katalogowania i prowadzenia nazw źródeł danych na poziomie logicznym (podobnie jak to jest w hierarchicznym systemie plikowym) 
• pooling połączeń (przechowywanie puli połączeń w pamięci w celu ew. ponownego użycia i przyspieszenia transakcji)
• transakcje rozproszone (przesyłanie danych w sieci do takich klientów jak np. przeglądarki lub laptopy)
• dostęp do praktycznie każdej formy tabularyzowanych danych (w tym arkuszy kalkulacyjnych i zwykłych plików),
• obsługę typu XML.

7.4. Sterowniki JDBC

7.5. Łączenie z bazą danych

• załadowania sterownika JDBC,
• zażądania od sterownika  połączenia i ew. uzyskania go w postaci obiektu typu Connection.

....
 String driverName = "com.mysql.jdbc.Driver";
 String url = "jdbc:mysql://localhost/ksidb";
 String uid = "jakis";
 String pwd = "haslo";
 Connection con;

 try {
     Class.forName(driverName);
     con = DriverManager.getConnection(url, uid, pwd);
    } catch (ClassNotFoundException  exc)  {  // brak klasy sterownika
        System.out.println("Brak klasy sterownika");
        System.out.println(exc);
        System.exit(1);
    } catch(SQLException exc) {  // nieudane połączenie
       System.out.println("Nieudane połączenie z " + url);
       System.out.println(exc);
       System.exit(1);
}

.....

Connection con = DriverManager.getConnection("jdbc:derby:ksidb"); 

• embedded - SZBD działa w tej samej maszynie wirtualnej co nasza aplikacja i nie wymaga działania serwera,
• klient-serwer (wymaga startu serwera Derby)

java -Dderby.system.home=D:/DerbyDbs -cp "%DERBY_JARS" -Dij.protocol=jdbc:derby: 
org.apache.derby.tools.ij nazwa_skryptu

java -Dderby.system.home=D:/DerbyDbs -cp %DERBY_HOME%/derby.jar App

// dostęp do ksidb w programie:
Connection con = DriverManager.getConnection("jdbc:derby:ksidb");

java -Dderby.system.home=D:/DerbyDbs -cp "%DERBY_JARS" org.apache.derby.drda.NetworkServerControl start

  String driverName = "org.apache.derby.jdbc.ClientDriver";
  String url = "jdbc:derby://localhost/ksidb";
  try {
      Class.forName(driverName).newInstance();
      Connection con = DriverManager.getConnection(url);
      // ...
  }

lub jeśli dostępnym JARem jest tylko derbyclient.jar:

try { 
     Connection con = DriverManager.getConnection(jdbc:derby://localhost/ksidb);
// ...
}

Connection con = DriverManager.getConnection(jdbc:derby:D:/DerbyDbs/ksidb);

Po zakończeniu operacji na bazie danych warto zwolnić uzyskane zasoby (takie jak Statement) oraz  połączenie, wywołując odpowiednie  metody close() na rzecz obiektów reprezentujących zasoby/ połączenie.
Nie zawsze jest to obowiązkowe, bo zwykle zasoby są zwalniane automatycznie przy zakończeniu programu, ale należy do dobrej praktyki programistycznej, mogą się bowiem zdarzyć takie sytuacje, kiedy zasoby nie zostaną automatycznie zwolnione.

7.6. Uzyskiwanie metainformacji o bazie danych (przykład)

 Connection con;
 DatabaseMetaData md;  // metadane

 // ... uzyskane połączenie
// reprezentuje obiekt con

// uzyskanie metadanych
 md = con.getMetaData();  

 // odpytywanie metadanych o różne
 // informacje
 md.getDatabaseProductName();
 md.getDatabaseProductVersion();
 md.getDriverName();
 md.getURL();
 md.getUserName();
 md.supportsAlterTableWithAddColumn();
 md.supportsAlterTableWithDropColumn();
 md.supportsANSI92FullSQL();
 md.supportsBatchUpdates();
 md.supportsMixedCaseIdentifiers();
 md.supportsMultipleTransactions();
 md.supportsPositionedDelete();
 md.supportsPositionedUpdate();
 md.supportsSchemasInDataManipulation();
 md.supportsTransactions();
 md.supportsResultSetType(ResultSet.TYPE_SCROLL_INSENSITIVE);
 md.supportsResultSetType(ResultSet.TYPE_SCROLL_SENSITIVE);
 md.insertsAreDetected(ResultSet.TYPE_SCROLL_INSENSITIVE);
 md.updatesAreDetected(ResultSet.TYPE_SCROLL_INSENSITIVE);

• podtrzymywanych przez RDBMS typach danych
• zestawie tabel w bazie danych.

7.7. Wykonywanie instrukcji SQL

Statement stmt;
...
String[] creTab = { "CREATE TABLE  A (ID INTEGER, NAME CHAR(30))",
                                "CREATE TABLE  B (ID INTEGER, ADR CHAR(30))",
                             };
...
for (int i = 0; i < creTab.length; i++) {
      stmt.executeUpdate(creTab[i]);
}
stmt.executeUpdate("INSERT INTO A VALUES(1, 'Pies')");
stmt.executeUpdate("INSERT INTO B VALUES(1, 'Buda')");
....

7.8. Obsługa wyjątków SQLException

Connection con;
Statement stmt;
try {
     Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
     con = DriverManager.getConnection("jdbc:odbc:ksidb");
     stmt = con.createStatement();
   } catch (Exception exc)  {
     System.out.println(exc);
     System.exit(1);
   }

   String crestmt = "CREATE TABLE WYDAWCA ( " +
                    "    ID  INTEGER,      " +
                    "    NAME VARCHAR(120), " +
                    "    CONSTRAINT WYDPK PRIMARY KEY(ID) )";
   try  {
     stmt.executeUpdate(crestmt);
     System.out.println("Table created.");
   } catch (SQLException exc)  {
     // różne informacje, które można uzyskać o wyjątku SQLException
     System.out.println("SQL except.: " + exc.getMessage());  // komunikat
     System.out.println("SQL state  : " + exc.getSQLState()); // kod standardowy
     System.out.println("Vendor errc: " + exc.getErrorCode()); // kod zależny od RDBMS
     System.exit(1);
   } finally {       // klauzula finally wykona się zawsze
      try {          // wykorzystujemy to do prawidłowego zwolnienia zasobów
        stmt.close();
        con.close();
      } catch(SQLException exc) {
        System.out.println(exc);
        System.exit(1);
      }
   }

7.9. Instrukcja SQL SELECT, tabele wynikowe, ResultSet i kursory

• ResultSet możemy przeglądać za pomocą kursora,
• kursor inicjalnie jest ustawiony przed pierwszym rekordem tabeli wynikowej,
• w zależności od typu ResultSet możemy przemieszczać kursor tylko w kierunku od początku tabeli wynikowej do końca (typ: ResultSet.TYPE_FORWAD_ONLY) lub  w obu kierunkach (typy ResultSet.TYPE_SCROLL_INSENSITIVE lub ResultSet.TYPE_SCROLL_SENSITIVE).
• interfejs ResultSet zawiera metody przemieszczające kursor, z których korzystamy przy przeglądaniu tabeli wynikowej.
• metody przemieszczające kursor zwracają wartość logiczną false, gdy żądane przemieszczenie kursora nie jest możliwe np. polecenie przejścia do następnego rekordu wyprowadza nas poza tabelę,
• jeśli kursor ustawiony jest na jakimś rekordzie tabeli wynikowej, to możemy pobrać wartości jego pól za pomocą odpowiednich metod interfejsu ResultSet; metody te zapewniają automatyczne przekształcenie typów SQL do odpowiadających im typów Javy

7.10. Przemieszczanie kursora

int count = 0;
while (rs.next()) count++;

rs.last();
int count = rs.getRow() // numer bieżącego rekordu

7.11. Odpowiedniość typów danych SQL i Javy. Pobieranie wartości pól

String sel = "select tytul, cena from pozycje where cena > 40";
   try  {
      Statement stmt = con.createStatement();
      ResultSet rs = stmt.executeQuery(sel);
      while (rs.next())  {                     //  można też użyć:
         String tytul = rs.getString(3);       //   rs.getString("tytul");
         float cena  = rs.getFloat(6);         //   rs.getFloat("cena");
         float usd = cena/4;
         System.out.println("Tytul: " + tytul);
         System.out.println("Cena : " + cena + " PLN");
         System.out.println("USD  : " + usd + " USD");
         System.out.println("-----------------");
      }
      rs.close();
      stmt.close();
      con.close();
   } catch (SQLException exc)  {
     System.out.println(exc.getMessage());
   }

7.12. Modyfikowalny ResultSet

// Np. usuwanie rekordu 5
ResultSet rs;
...
rs.absolute(5);
rs.deleteRow();

7.13. Metainformacje o tabeli wynikowej

 String sel ="SELECT AUTOR.ID, AUTOR.AUTOR, POZYCJE.TYTUL,"
                   "WYDAWCA.NAME AS WYDAWCA " +
                   "FROM POZYCJE,AUTOR, WYDAWCA " +
                   "WHERE WYDAWCA.ID = POZYCJE.WYDID " +
                   "AND AUTOR.ID = POZYCJE.AUTID " +
                   "ORDER BY AUTOR ASC;";
   try  {
      Statement stmt = con.createStatement();
      ResultSet rs = stmt.executeQuery(sel);
      ResultSetMetaData rsmd = rs.getMetaData();
      int cc = rsmd.getColumnCount();               // liczba kolumn
     for (int i = 1; i <= cc; i++)  {               // i-ta kolumna:
        say('\n'+ rsmd.getColumnName(i));           // - nazwa
        say(" " + rsmd.getColumnDisplaySize(i));    // - szerokość
        say(" " + rsmd.getColumnClassName(i));      // - klasa Javy
        say(" " + rsmd.getColumnType(i));           // - typ SQL
        say(" " + rsmd.getColumnTypeName(i));       // - typ RDBMS
      }
      stmt.close();
      con.close();

   } catch (SQLException exc)  {
     System.out.println(exc.getMessage());
   }

7.14. Instrukcje prekompilowane

Connection con;
PreparedStatement stmt;
...
  String[] wyd =  { "PWN", "PWE", "Czytelnik", "Amber", "HELION",
                            "MIKOM" };
  int beginKey = 10,
  try  {
     stmt = con.prepareStatement("INSERT INTO WYDAWCA VALUES(?,?)");
     for (int i=0; i < wyd.length; i++)   {
       stmt.setInt(1, beginKey + i);
       stmt.setString(2, wyd[i]);
       stmt.executeUpdate();     //         Uwaga: inna forma executeUpdate()
 }
     con.close();
   } catch(SQLException exc)  {
      System.out.println(exc);
   }

7.15. Obsługa transakcji

7.16. Zastosowanie architektury "Model-View-Controller" przy tworzeniu graficznych interfejsów BD za pomocą komponentów Swingu

// Model danych dla tabeli pokazującej dowolny ResultSet

import java.util.*;
import java.sql.*;
import javax.swing.*;
import javax.swing.table.*;
import javax.swing.event.*;

public class DbTable extends AbstractTableModel  {
    private Connection con;
    private ResultSet rs;
    private String[]  columnNames;
    private int[]  columnTypes;
    private boolean[] readOnly;
    private String tableName = "";
    private List  rows;
    private ResultSetMetaData   md;
    private boolean editable = false;

public DbTable(Connection conn, String query, ResultSet resultSet, boolean ed)  {
   rs = resultSet;
   editable = ed;
   con = conn;
   tableName = getTableName(query);
   try {
     md = rs.getMetaData();
     int cc =  md.getColumnCount();
     columnNames = new String[cc];
     columnTypes = new int[cc];
     readOnly = new boolean[cc];
     for(int col = 0; col < cc; col++) {
       columnNames[col] = md.getColumnName(col+1);
       columnTypes[col] = md.getColumnType(col+1);
       readOnly[col] = md.isReadOnly(col+1);
     }

     rows = new ArrayList();
     while (rs.next()) {
        List row = new ArrayList();
        for (int i = 1; i <= getColumnCount(); i++) {
          row.add(rs.getObject(i));
        }
        rows.add(row);
     }
     rs.close();
     fireTableChanged(null); // Nowa tabela
   } catch (SQLException ex) {
            System.out.println(ex.getMessage());
     }
}

// Niedoskonala wersja
private String getTableName(String q)  {
   if (q == null || q.equals("")) return "";
   StringTokenizer st = new StringTokenizer(q);
   while (st.hasMoreTokens())  {
     String w = st.nextToken();
     w = w.toUpperCase();
     if (w.equals("FROM")) {
         String t = st.nextToken();
         if (t.indexOf(',') == -1) return t;
         break;
     }
   }
   return "";
}

// Obowiązkowe metody interfejsu TableModel
public String getColumnName(int column) {
    if (columnNames[column] != null) return columnNames[column];
     else return "";
}

public Class getColumnClass(int column) {
   String type;
   Class c = null;
   try {
     type = md.getColumnClassName(column+1);
     c = Class.forName(type);
     }
     catch (Exception e) {
       return super.getColumnClass(column);
   }
   return c;
}

public boolean isCellEditable(int row, int column) {
    if (!editable) return false;
    if (tableName.equals("")) return false;
    return !readOnly[column];
}

public int getColumnCount() {
   return columnNames.length;
}

public int getRowCount() {
   return rows.size();
}

public Object getValueAt(int r, int c) {
    List row = (List)rows.get(r);
    return row.get(c);
}

 public String dbValue(int col, Object value) {
    int type;
    if (value == null) return "null";
    type = columnTypes[col];

    switch(type) {
        case Types.CHAR:
        case Types.VARCHAR:
        case Types.LONGVARCHAR:
             return "\'"+value.toString()+"\'";
        case Types.BIT:
            return ((Boolean)value).booleanValue() ? "1" : "0";
        default:
            return value.toString();
        }
}


 public void setValueAt(Object value, int r, int c) {
    List row = (List) rows.get(r);
    String oldval = row.get(c).toString();
    if (oldval.equals(value.toString())) return;
    String colName = getColumnName(c);
    String query = " update " + tableName +
                   " set " + colName + " = " + dbValue(c, value) +
                   " where ";
    for(int j = 0; j < getColumnCount(); j++) {
      colName = getColumnName(j);
      if (colName.equals("")) continue;
      if (j != 0)  query += " and ";
      query += colName +" = "+  dbValue(j, getValueAt(r, j));
    }
    query +=  ";";
    try {
       Statement s = con.createStatement();
       int updCount = s.executeUpdate(query);
       row.set(c, value);
       System.out.println("Zmieniono rekordów: " + updCount);
    } catch (SQLException e) {
        System.out.println(query);
        System.out.println(e.getMessage());
   }
 }


}

// Testowy interfejs SQL

import java.sql.*;
import javax.swing.*;
import javax.swing.text.*;
import java.awt.event.*;
import java.awt.*;
import java.util.*;

public class TestSQL extends JFrame implements ActionListener {

   private Connection con = null;
   private Statement stmt;
   private ResultSet rs = null;
   private String query;
   private JTable table = new JTable();
   private JTextArea ta = new JTextArea(3,40);
   private DefaultListModel history = new DefaultListModel();
   private JList hlis = new JList(history);
   private JWindow wh = new JWindow();


   public TestSQL(String URL, String driver, String user,
                         String passwd) {
        super("Baza danych książki");
        setDefaultCloseOperation(3);

        try {
           Class.forName(driver);
           con = DriverManager.getConnection(URL);
           stmt = con.createStatement();
        } catch (Exception exc)  {
           System.out.println(exc.getMessage());
           System.exit(1);
        }

        JScrollPane scrollpane = new JScrollPane(table);
        scrollpane.setPreferredSize(new Dimension(600, 400));
        JPanel p = new JPanel();
        p.setLayout(new BorderLayout());
        ta.setLineWrap(true);

        JScrollPane tsp = new JScrollPane(ta);
        p.add(tsp, "Center");
        JButton b = new JButton("Execute");
        b.setMnemonic('E');
        b.addActionListener(this);

        p.add(b, "East");
        p.setBorder(BorderFactory.createLineBorder(Color.blue));
        getContentPane().add(scrollpane, "Center");
        getContentPane().add(p, "South");

        createHistoryList();

        pack();
        setVisible(true);
    }

   public void actionPerformed(ActionEvent e)  {
      String new_query = ta.getText();
      if (new_query.equals(query)) return;
      query = new_query;
      if (!history.contains(query)) history.addElement(query);
      execute(query);
   }

   void execute(String query)  {
      try  {
        rs = stmt.executeQuery(query);
        DbTable dbt = new DbTable(con, query, rs, true);
        table.setModel(dbt);
      } catch(SQLException exc)  {
         System.out.println(exc.getMessage());
      }
   }

  void createHistoryList()  {

    ta.addMouseListener(new MouseAdapter()  {
        public void mouseReleased(MouseEvent e)  {
          if (e.isPopupTrigger())  {
             wh.pack();
             wh.show();
          }
        }
    });

    hlis.addMouseListener(new MouseAdapter()  {
        public void mouseClicked(MouseEvent e)  {
          if (e.getClickCount() == 2)   {
             String s = (String) hlis.getSelectedValue();
             if (s != null) ta.setText(s);
             wh.setVisible(false);
          }
        }
    });

    JScrollPane hsp = new JScrollPane(hlis);
    hsp.setPreferredSize(new Dimension(200, 300));
    JPanel hp = new JPanel(new BorderLayout());
    hp.setBorder(BorderFactory.createLoweredBevelBorder());
    hp.add(hsp, "Center");
    JPanel bhp = new JPanel();

    ActionListener hlHandler = new ActionListener()  {
      public void actionPerformed(ActionEvent e)  {
          String cmd = e.getActionCommand();
          if (cmd.equals("Cancel")) wh.setVisible(false);
          else if (cmd.equals("Clear all")) history.clear();
          else  {
            int index = hlis.getSelectedIndex();
            if (index == -1) return;
            if (cmd.equals("Clear")) history.remove(index);
            else if (cmd.equals("Execute"))  {
              String new_query = (String) hlis.getSelectedValue();
              if (new_query.equals(query)) return;
              query = new_query;
              wh.setVisible(false);
              execute(query);
              ta.setText(query);
            }
          }
      }
    };

    JButton  b = new JButton("Cancel");
    b.addActionListener(hlHandler);
    bhp.add(b);
    b = new JButton("Clear");
    b.addActionListener(hlHandler);
    bhp.add(b);
    b = new JButton("Clear all");
    b.addActionListener(hlHandler);
    bhp.add(b);
    b = new JButton("Execute");
    b.addActionListener(hlHandler);
    bhp.add(b);
    hp.add(bhp, "South");

    wh.getContentPane().add(hp);
    ta.addMouseListener(new MouseAdapter()  {
       public void mouseReleased(MouseEvent e)  {
          if (e.isPopupTrigger())  {
            wh.setLocation( getX()+10, getY()+50);
            wh.pack();
            wh.show();
          }
       }
     });
  }


  public static void main(String[] args) {
    String driverName = "com.mysql.jdbc.Driver";
    String url = "jdbc:mysql:///ksidb";
    String uid = "pies";
    String pwd = "kuba";
    new TestSQL(url, driverName, uid, pwd);
  }
}

7.17 Zadania i ćwiczenia

create database if not exists ksidb;
use ksidb;
drop table if exists AUTOR, WYDAWCA, POZYCJE;

create table if not exists AUTOR (
        ID integer not null AUTO_INCREMENT,
        NAME varchar(255) not null,
        PRIMARY KEY(ID)
        );
load data infile 'AUTOR.TXT' replace into table AUTOR;


create table if not exists WYDAWCA (
        ID integer not null AUTO_INCREMENT,
        NAME varchar(255) not null,
        PRIMARY KEY(ID)
        );
load data infile 'WYDAWCA.TXT' replace into table WYDAWCA;


create table if not exists POZYCJE (
        ISBN char(13) not null,
        AUTID integer not null,
        TYTUL varchar(255) not null,
        WYDID integer not null,
        ROK int not null,
        CENA real,
        PRIMARY KEY(ISBN),
        FOREIGN KEY(AUTID) REFERENCES AUTOR(ID),
        FOREIGN KEY(WYDID) REFERENCES WYDAWCA(ID),
        );
load data infile 'POZYCJE.TXT' replace into table POZYCJE;

import java.sql.*;
import java.lang.reflect.*;


public class Con1  {


 // .... tu czegoś brakuje

 public Con1()  {
   // ... i tu rownież
 }

// Metoda raportująca informacje zebrane w DatabaseMetaData
// w wywołaniach metody info podano jako argumenty nazwy metod tego interfejsu
// a w metodzie info korszystamy z metod refleksji;
// ten sposób oprogramowania jest zaawansowany, ale wygodny, bo dużo mniej pisania
// i kod jest bardziej klarowny
// klauzula throws SQLException mówi o tym, że w trakcie działania reportInfo może powstać wyjątek
// SQLException, ale nie będziemy go tu obsługiwać, obsługę przekażemy do miejsca wywołania
// czyli bloku try w konstruktorze

void reportInfo() throws SQLException {

   info("getDatabaseProductName");
   info("getDatabaseProductVersion");
   info("getDriverName");
   info("getURL");
   info("getUserName");

   info("supportsAlterTableWithAddColumn");
   info("supportsAlterTableWithDropColumn");
   info("supportsANSI92FullSQL");
   info("supportsBatchUpdates");
   info("supportsMixedCaseIdentifiers");
   info("supportsMultipleTransactions");
   info("supportsPositionedDelete");
   info("supportsPositionedUpdate");
   info("supportsSchemasInDataManipulation");
   info("supportsTransactions");

   System.out.println("ResultSet  TYPE_SCROLL_INSENSITIVE :" +
       md.supportsResultSetType(ResultSet.TYPE_SCROLL_INSENSITIVE));
   System.out.println("ResultSet  TYPE_SCROLL_SENSITIVE :" +
       md.supportsResultSetType(ResultSet.TYPE_SCROLL_SENSITIVE));
   System.out.println("insertsAreDetected :" +
       md.insertsAreDetected(ResultSet.TYPE_SCROLL_INSENSITIVE));
   System.out.println("updatesAreDetected :" +
       md.updatesAreDetected(ResultSet.TYPE_SCROLL_INSENSITIVE));
 }

// Metoda info korzysta z metod refleksji do wywołania metod podanych "przez" nazwy.
 void info(String metName) {
   Class mdc  = DatabaseMetaData.class;
   Class[] paramTypes =  { };
   Object[] params =  { };
   String infoTyp;
   if (metName.startsWith("get"))
     infoTyp = metName.substring(3,metName.length());
   else infoTyp = metName;
   try  {
     Method m = mdc.getDeclaredMethod(metName, paramTypes);
     System.out.println(infoTyp + ": " + m.invoke(md, params));  // dynamiczne wywołanie metody
   } catch(Exception exc)  {   // Możliwe powody wyjątków: nie ma takiej metody, niewłaściwe wywołanie
     System.out.println(exc);
   }
 }

  public static void main(String[] args)  {
   new Con1();
 }

import java.sql.*;

public class Cre1 {

  static public void main(String[] args) {
    new Cre1();
  }

Statement stmt; 

Cre1()  {
   Connection con = null;
   try {
      // łączenie z bazą i utworzenie obiektu typu Statement
   } catch (Exception exc)  {
     System.out.println(exc);
     System.exit(1);
   }

   // metoda dropTable jest naszą własną metodą napisaną dla skrócenia programu
   // usuwa ona tabelę podaną jako argument
   // Aby w każdych okolicznościach stworzyć nową tabelę WYDAWCA
   // musimy usunąć ew.  już istniejącą tabelę WYDAWCA
   dropTable("POZYCJE"); // usunięcie tabeli pochodnej, będącej w relacji z tabelą WYDAWCA
   dropTable("WYDAWCA"); // usinięcie tabeli WYDAWCA

   String crestmt = ...

   try  {
     ....                  // wykonanie polecenia zapisanego w crestmt

   } catch (SQLException exc)  {                      // przechwycenie wyjątku:
      System.out.println("SQL except.: " + exc.getMessage());
      System.out.println("SQL state  : " + exc.getSQLState());
      System.out.println("Vendor errc: " + exc.getErrorCode());
      System.exit(1);
   } finally {
      try {
        stmt.close();
        con.close();
      } catch(SQLException exc) {
        System.out.println(exc);
        System.exit(1);
      }
   }
}

private void dropTable(String tname  )  {
   // ....

}

1. przywrócić bazę danych do postaci wyjściowej
2. skompilować i wykonać program bez odwołania dropTable("POZYCJE")
3. obejrzeć dokładnie komunikaty o wyjątkach

import java.sql.*;

public class Ins1 {

  static public void main(String[] args) {
    new Ins1();
  }

Statement stmt;

Ins1()  {
   Connection con = null;
   try {
     //...
   } catch (Exception exc)  {
     System.out.println(exc);
     System.exit(1);
   }

   String[] ins =  { "INSERT INTO WYDAWCA VALUES (1, \'Wyd 1\')",
                             "INSERT INTO WYDAWCA VALUES (2, \'Wyd 2\')",
                             "INSERT INTO WYDAWCA VALUES (3, \'Wyd 3\')",
                   };
   int insCount = 0;   // ile rekordów wpisano
   try  {
     for (int i=0; i < ins.length; i++) // wpisywanie rekordów
     // ...
   }
//...
}
} 

   // ...
   String[] wyd =  { "PWN", "PWE", "Czytelnik", "Amber", "HELION", "MIKOM" };
   int beginKey = 10,
       insCount =  0;
   try  {
     // przygotowanie instrukcji prekompilowanej
     stmt = con.prepareStatement("INSERT INTO WYDAWCA VALUES(?,?)");
     for (int i=0; i < wyd.length; i++)   {
       // ... ?
     }
     con.close();
   } catch(SQLException exc)  {
      System.out.println(exc);
   }

   // ...

   String sel = "SELECT AUTOR, TYTUL, CENA FROM POZYCJE WHERE CENA > 40";
   try  {
      Statement stmt = con.createStatement();
      ResultSet rs = stmt.executeQuery(sel);
      while (rs.next())  {
         String tytul = // ... ?
         float cena  = //  ... ?
         float usd = cena/4;
         System.out.println("Tytul: " + tytul);
         System.out.println("Cena : " + cena + " PLN");
         System.out.println("USD  : " + usd + " USD");
         System.out.println("-----------------");
      }
      stmt.close();
      con.close();
   } catch (SQLException exc)  {
     System.out.println(exc.getMessage());
   }

  String sel = // ... ?
   try  {
      Statement stmt = con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
                                           ResultSet.CONCUR_READ_ONLY);
      ResultSet rs = stmt.executeQuery(sel);
      ResultSetMetaData rsmd = rs.getMetaData();
      int cc = rsmd.getColumnCount();
      for (int i = 1; i <= cc; i++)
        System.out.print(rsmd.getColumnLabel(i) + "     ");

      System.out.println("\n------------------------------ przewijanie do góry");

      // ... ?
 
      System.out.println("\n----------------------------- pozycjonowanie abs.");
      int[] poz =  { 3, 7, 9  };
      for (int p = 0; p < poz.length; p++)  {
         System.out.print("[ " + poz[p] + " ] ");
         // ... ?
         for (int i = 1; i <= cc; i++) System.out.print(rs.getString(i) + ", ");
         System.out.println("");
      }
      stmt.close();
      con.close();
   } catch (SQLException exc)  {
     System.out.println(exc.getMessage());
   }

• DbTable.java – odzwierciedla dowolny  ResultSet w modelu danych tabeli Swingowej (JTable),
• TestSQL.java – jest graficznym interfejsem, umożliwiającym uzyskiwanie wyników zapytań SELECT w postaci tabeli JTable, dla której modelem jest klasa DbTable.

1. Model danych tabeli (plik DbTable.java) jest dość uniwersalny – pozwala przedstawić dowolny ResultSet w postaci tabeli Swingowej
2.  Konkretne GUI ( TestSQL) może być dowolnie zmieniane bez ingerencji w związki DB – Swing table model
3.  Realizacja  tego GUI zajęła mało czasu: okazuje się, że program w Javie o zaawansowanych możliwościach  może liczyć mniej niż 200 wierszy (tzn. niezwykle krótki). Nb. większość kodu tego programu zajmuje się obsługą listy historii.