JDBCによる更新処理の実行：Javaデータアクセスの基礎（3）

// Javaデータアクセスの基礎 サンプル・コード(2)
// DML文を実行するJavaアプリケーション
import java.sql.*;
class JavaDataAccess02 {
  public static void main (String args[]) {
  Connection conn = null;
  Statement stmt = null;
  String sql_str = null;
  try {
    Class.forName("oracle.jdbc.driver.OracleDriver");
    System.out.println("JDBCドライバをロードしました...");
    conn = DriverManager.getConnection
      ("jdbc:oracle:thin:@localhost:1521:ORCL", "scott", "tiger");
    System.out.println("データベースに接続しました...");
    // ステートメントを作成
    stmt = conn.createStatement();
    sql_str =
    "create table EMPLOYEE ( " +
    " EMPNO NUMERIC(4) primary key, " +
    " ENAME VARCHAR(10), " +
    " JOB VARCHAR(9), " +
    " MGR NUMBER(4), " +
    " HIREDATE DATE, " +
    " SAL NUMERIC(7,2), " +
    " COMM NUMERIC(7,2), " +
    " DEPTNO NUMERIC(2) " +
    ")";
    stmt.executeUpdate(sql_str);
    System.out.println("EMPLOYEE表を作成しました...");
    sql_str =
     "create or replace procedure RAISE_SAL ( " +
    " p_deptno in numeric, " +
    " p_percent in numeric " +
    ") " +
    "is " +
    "begin " +
    " update EMPLOYEE " +
    " set SAL = SAL + (SAL * p_percent * .01) " +
    " where deptno = p_deptno; " +
    " commit; " +
    "end RAISE_SAL; ";
    stmt.executeUpdate(sql_str);
    System.out.println("RAISE_SALプロシージャを作成しました...");
    // ステートメントをクローズ
    stmt.close();
    conn.close();
    System.out.println("接続をクローズしました...");
    // 例外を処理
  } catch (Exception ex) {
    System.out.println("Exceptionが発生しました...");
    // エラー・メッセージを出力
    System.out.print(ex.toString());
    // SQLExceptionの場合、エラー・コードを出力
    if (ex instanceof SQLException) {
      System.out.println("エラー・コード: " +
      ((SQLException)ex).getErrorCode());
    }
      try {
        // ステートメントがクローズされていない場合、
        // それをクローズ
        if (stmt != null) {
          stmt.close();
        }
        // 接続がクローズされていない場合、それをクローズ
        if (conn != null) {
          conn.close();
          System.out.println("接続をクローズしました...");
        }
      } catch (SQLException se) {}
    }
  }
}

sql_str = "create table EMPLOYEE ...";
stmt.executeUpdate(sql_str);
...
sql_str = "create or replace procedure RAISE_SAL ...";
stmt.executeUpdate(sql_str);

public static void main (String args[])
   throws SQLException, ClassNotFoundException { 

try {
...
// 例外を処理
} catch (Exception ex) {
  System.out.println("Exceptionが発生しました...");
  // エラー・メッセージを出力
  System.out.print(ex.toString());
  // SQLExceptionの場合、エラー・コードを出力
  if (ex instanceof SQLException) {
      System.out.println("エラー・コード: " +
    ((SQLException)ex).getErrorCode());
  }

// Javaデータアクセスの基礎 サンプル・コード(3)
// EMPLOYEE表を更新するJavaアプリケーション
// JDBC APIをインポート
import java.sql.*;
class JavaDataAccess03 {
  public static void main (String args[]) {
   Connection conn = null;
  Statement stmt = null;
  ResultSet rset = null;
  String sql_str = null;
  int count = 0;
  try {
    Class.forName("oracle.jdbc.driver.OracleDriver");
    System.out.println("JDBCドライバをロードしました...");
    conn = DriverManager.getConnection
    ("jdbc:oracle:thin:@localhost:1521:ORCL", "scott", "tiger");
    System.out.println("データベースに接続しました...");
    // 自動コミット・モードを設定
    conn.setAutoCommit(false);
    // ステートメントを作成
    stmt = conn.createStatement();
    sql_str = "delete from EMPLOYEE";
    count = stmt.executeUpdate(sql_str);
    System.out.println("delete文を実行しました...");
    System.out.println(" 行数: " + count);
    sql_str =
    "insert into EMPLOYEE (EMPNO, ENAME, SAL, DEPTNO) " +
    "values (1, 'NAOKI', 10000, 10)";
    count =stmt.executeUpdate(sql_str);
    System.out.println("insert文を実行しました...");
    System.out.println(" 行数: " + count);
    // トランザクションをコミット
    conn.commit();
    System.out.println("コミットしました...");
    sql_str =
    "select ENAME, SAL from EMPLOYEE " +
    "where EMPNO = 1";
    rset = stmt.executeQuery(sql_str);
    System.out.println("select文を実行しました...");
    // 結果セットの1行目を取り出す
    rset.next();
    System.out.println(" " + rset.getString("ENAME") +
    "\t" + rset.getInt("SAL"));
    sql_str =
    "update EMPLOYEE set SAL = 20000 " +
    "where EMPNO = 1";
    count = stmt.executeUpdate(sql_str);
    System.out.println("update文を実行しました...");
    System.out.println(" 行数: " + count);
    sql_str =
    "select ENAME, SAL from EMPLOYEE " +
    "where EMPNO = 1";
    rset = stmt.executeQuery(sql_str);
    System.out.println("select文を実行しました...");
    // 結果セットの1行目を取り出す
    rset.next();
    System.out.println(" " + rset.getString("ENAME") +
    "\t" + rset.getInt("SAL"));
    // トランザクションをロールバック
    conn.rollback();
    System.out.println("ロールバックしました...");
    rset = stmt.executeQuery(sql_str);
    System.out.println("select文を実行しました...");
    // 結果セットの1行目を取り出す
    rset.next();
    System.out.println(" " + rset.getString("ENAME") +
    "\t" + rset.getInt("SAL"));
    // ステートメントをクローズ
    stmt.close();
    // 接続をクローズ
    conn.close();
    System.out.println("接続をクローズしました...");
    // 例外を処理
    } catch (Exception ex) {
    System.out.println("Exceptionが発生しました...");
    // エラー・メッセージを出力
    System.out.print(ex.toString());
    try {
      // ステートメントがクローズされていない場合、
      // それをクローズ
      if (stmt != null) {
        stmt.close();
      }
      // 接続がクローズされていない場合、
      // ロールバックしてから、接続をクローズ
      if (conn != null) {
        conn.rollback();
        System.out.println("ロールバックしました...");
        conn.close();
        System.out.println("接続をクローズしました...");
      }
      } catch (SQLException se) {}
    }
  }
}

sql_str = "delete from EMPLOYEE";
count = stmt.executeUpdate(sql_str);
...
sql_str = "insert into EMPLOYEE ...";
count = stmt.executeUpdate(sql_str);
...
sql_str = "update EMPLOYEE ...";
count = stmt.executeUpdate(sql_str);

// 自動コミット・モードを設定
conn.setAutoCommit(false);

// トランザクションをコミット
conn.commit();
..
.// トランザクションをロールバック
conn.rollback();

sql_str = "update EMPLOYEE ...";
count = stmt.executeUpdate(sql_str);
...
sql_str = "select ENAME, SAL ...";
rset = stmt.executeQuery(sql_str);
...
// トランザクションをロールバック
conn.rollback();
...
sql_str = "select ENAME, SAL ...";
rset = stmt.executeQuery(sql_str);

try {
  ...
  // トランザクションをコミット
  conn.commit();
  ...
  // 例外を処理
} catch (Exception ex) {
  ...
  // 接続がクローズされていない場合、
  // ロールバックしてから、接続をクローズ
  if (conn != null) {
    conn.rollback();
    ...
    conn.close();