diff options
| author | Sven Eisenhauer <sven@sven-eisenhauer.net> | 2023-11-10 15:11:48 +0100 |
|---|---|---|
| committer | Sven Eisenhauer <sven@sven-eisenhauer.net> | 2023-11-10 15:11:48 +0100 |
| commit | 33613a85afc4b1481367fbe92a17ee59c240250b (patch) | |
| tree | 670b842326116b376b505ec2263878912fca97e2 /Bachelor/Datenbanken 2/MyJdbcStatement.java | |
| download | Studium-master.tar.gz Studium-master.tar.bz2 | |
Diffstat (limited to 'Bachelor/Datenbanken 2/MyJdbcStatement.java')
| -rw-r--r-- | Bachelor/Datenbanken 2/MyJdbcStatement.java | 141 |
1 files changed, 141 insertions, 0 deletions
diff --git a/Bachelor/Datenbanken 2/MyJdbcStatement.java b/Bachelor/Datenbanken 2/MyJdbcStatement.java new file mode 100644 index 0000000..6f016f2 --- /dev/null +++ b/Bachelor/Datenbanken 2/MyJdbcStatement.java @@ -0,0 +1,141 @@ +package oraJdbc;
+
+import java.sql.*;
+import java.util.*;
+
+/**
+ * @author schestag
+ *
+ * Diese Klasse enthält Beispiele für alle wichtigen Statement-Klassen
+ * der SQL-API auf der Datenbank flugdb des Teil I der Vorlesung
+ * sowie Beisiele für Objekte vom Typ ResultSetMetaData und DatabaseMetaData
+ */
+public class MyJdbcStatement {
+
+ static private Connection con;
+
+ static private Statement stmt;
+ static private String query;
+ static private PreparedStatement pStmt;
+ static private CallableStatement cStmt;
+
+ static private ResultSet rs;
+
+ public static void main(String args[])
+ throws SQLException {
+
+ // 1. Treiber-Klasse für JdbcOdbcDriver laden und registrieren
+ String driverClass =
+ "sun.jdbc.odbc.JdbcOdbcDriver";
+ try {
+ Class.forName(driverClass);
+ }
+ catch (ClassNotFoundException exc) {
+ System.out.println("c1: "+exc.getMessage());
+ System.exit(1);
+ }
+
+ // Wieviele Elemente sind derzeit bei der Klasse DriverManager
+ // registriert?
+ Enumeration e = DriverManager.getDrivers();
+ while (e.hasMoreElements())
+ System.out.println("Beim DriverManager registriert: " +
+ e.nextElement() + "\n");
+
+ // 2. Connection aufbauen
+ try {
+ String url = "jdbc:odbc:MyORA9";
+ con = DriverManager.getConnection(url,"ischestag","inge");
+ System.out.println("Jetzt ist die Connection da");
+ // Transaktionsmanagement: AutoCommit off
+ con.setAutoCommit(false);
+ // Isolationlevel setzen
+ con.setTransactionIsolation(Connection.TRANSACTION_SERIALIZABLE);
+ con.commit();
+ }
+ catch (SQLException exc) {
+ System.out.println("c2: "+exc.getMessage());
+ }
+
+ // Database Metadaten
+ try {
+ DatabaseMetaData dbm = con.getMetaData();
+ ResultSet rsm = dbm.getTableTypes();
+ while (rsm.next())
+ System.out.println(rsm.getString(1));
+ } catch(SQLException exc) {
+ System.out.println("c2a: "+exc.getMessage());
+ }
+
+ // 3. SLQ-Anweisungen ausführen
+ // Javavariablen zum Auslesen der Daten
+ int vPerNr, vPStd;
+
+ try {
+ stmt =con.createStatement();
+
+ // PILOT-Tabelle lesen
+ rs = stmt.executeQuery("Select per_nr, p_std from pilot");
+ while (rs.next()) {
+ vPerNr=rs.getInt(1);
+ vPStd =rs.getInt(2);
+ System.out.println("Ergebnis: " + vPerNr + " " + vPStd);
+ }
+ ResultSetMetaData rsm = rs.getMetaData();
+ int anzCol = rsm.getColumnCount();
+ for (int i=1; i<=anzCol; i++) {
+ String cn = rsm.getColumnName(i);
+ String ctn = rsm.getColumnTypeName(i);
+ System.out.println(cn + " " + ctn);
+ }
+ rs.close();
+ }
+ catch(SQLException exc) {
+ System.out.println("c3: "+exc.getMessage());
+ }
+
+ // 4. PreparedStatement
+ try {
+ pStmt = con.prepareStatement("insert into flug values (?,?,?,?,?)");
+ pStmt.setString(1,"LH-999");
+ pStmt.setString(2,"Frankfurt");
+ pStmt.setString(3,"Hamburg");
+ pStmt.setDouble(4,0.5);
+ pStmt.setInt(5,400);
+ pStmt.executeUpdate();
+ con.commit();
+ } catch(SQLException exc) {
+ con.rollback();
+ System.out.println("c4: "+exc.getMessage());
+ }
+
+ // 5. StoredProcedure-Aufruf (CallableStatement)
+ boolean type;
+ try {
+ cStmt = con.prepareCall("{call neugehalt(?,?)}");
+ cStmt.setDouble(1, 1.01);
+ cStmt.setDouble(2, 1.02);
+ // Type == true <=> ResultSet, Type == fals <=> nur Updates
+ type = cStmt.execute();
+ con.commit();
+
+ while (true) {
+ System.out.println("so viele Updates: "+cStmt.getUpdateCount());
+ type = cStmt.getMoreResults();
+ if (cStmt.getUpdateCount() == -1)
+ break;
+ }
+ } catch(SQLException exc) {
+ con.rollback();
+ System.out.println("c5: "+exc.getMessage());
+ }
+
+ // 6. Connection schliessen
+ try {
+ con.close();
+ }
+ catch(SQLException exc) {
+ System.out.println("close connection: "+exc.getMessage());
+ }
+ }
+}
|