JDBC/ODBC

Grundlagen der Informatik, FB Informatik, FH Heidelberg, Dr. Peter Misch
//
//
//
//
//
Aufgabe: Eine Datenbank mit Java bearbeiten
Das Programm legt eine Tabelle "KUNDEN" an,
trägt einige Datensätze ein, und zeigt den Inhalt an.
Voraussetzung: in Systemsteuerung – ODBC Datenquellen
Textdatenbank als System-DSN mit Namen Kunden angelegt
import java.sql.*;
// Alle JDBC-Klassen importieren
public class jdbcKunden1 {
Connection con=null; // Verbindungsobjekt
// Aufbau der Verbindung zur Datenbank
public void connect () throws SQLException, ClassNotFoundException {
String URL = "jdbc:odbc:kunden";
String username = "";
String password = "";
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver"); // Laden des Treibers
// Aufbau der Verbindung zur Datenbank
con = DriverManager.getConnection (URL, username, password);
}
// Aufbau der Tabelle - falls noch nicht vorhanden
public void createTable () throws SQLException {
Statement stmt = con.createStatement();
stmt.execute ("drop table KUNDEN");
stmt.execute ("CREATE TABLE KUNDEN (Name VARCHAR (50), Nr INTEGER)");
}
// Eintragen von Datensätzen in die Tabelle KUNDEN
public void insertRecords () throws SQLException {
String name;
int nr;
Statement stmt = con.createStatement();
for(int i=0; i < 3; i++) {
Out.println("Name: ");
name = In.readLine();
Out.println("Nr: ");
nr= In.readInt();
stmt.executeUpdate ("INSERT INTO KUNDEN VALUES ('" + name + " ', "+ nr+")");
//stmt.executeUpdate ("INSERT INTO KUNDEN VALUES ('koenig', 1002)");
}
}
// Abfrage
public void executeQuery (String query) throws SQLException {
System.out.println ("Ergebnis der Abfrage ");
Statement stmt = con.createStatement();
ResultSet rs = stmt.executeQuery (query);
printRecords (rs);
}
// Anzeige von Datensätzen
public void printRecords (ResultSet rs) throws SQLException {
while (rs.next ()) {
String Name = rs.getString ("Name");
int
Nr
= rs.getInt ("Nr");
Out.println ("Name : " + Name + " Nr : " + Nr);
}
13.04.17
Grundlagen der Informatik, FB Informatik, FH Heidelberg, Dr. Peter Misch
}
// Steuerrahmen
public void demo () {
try {
connect ();
createTable ();
insertRecords ();
executeQuery ("SELECT * FROM KUNDEN");
con.close ();
} catch (SQLException e) {
System.err.println (e);
} catch (ClassNotFoundException e) {
System.err.println (e);
}
}
public static void main(String[] args) {
jdbcKunden1 test = new jdbcKunden1 ();
test.demo ();
In.stop();
}
}
13.04.17