SQL文のパラメタに行識別子を指定してデータを操作するプログラム例について説明します。
以下のサンプルアプリケーションでは、ネーミングサービスを起動しているホスト名に、“myhost”を指定しています。サンプルアプリケーションを実行する環境に合わせて、ホスト名の値を修正してください。
// 以下のパッケージをインポートします。 import java.util.*; import java.sql.*; import javax.sql.*; import javax.naming.*; // クラスを定義します。 public class MyRowIdSelect { public static void main(String args[]) { try { // JNDI環境を指定します。 Hashtable env = new Hashtable(); env.put(Context.INITIAL_CONTEXT_FACTORY, "com.fujitsu.symfoware.jdbc2.jndisp.SYMContextFactory"); env.put(Context.PROVIDER_URL,"SYM://myhost:26600"); InitialContext ctx = new InitialContext(env); // JDBCデータソースを取得します。 DataSource ds = (DataSource)ctx.lookup("jdbc/ds1"); // データベースと接続します。 Connection con = ds.getConnection(); // 自動コミットモードの無効化 con.setAutoCommit(false); // Statementのオブジェクトを生成します。 Statement stmt = con.createStatement(); // SQL文を実行し、ResultSetの // オブジェクトを生成します。 // IDが 3のデータを参照します。 ResultSet rs = stmt.executeQuery("SELECT NAME,ROW_ID FROM GENERAL.EMPLOYEE WHERE ID=3"); String sName = null; RowId rowid = null; while(rs.next()) { // ResultSetの列に対応する // データを取得します。 sName = rs.getString(1); // 行識別子データを取得します。 rowid = rs.getRowId(2); // 取得した情報を表示します。 System.out.println("NAME = " + sName); } // PreparedStatementの // オブジェクトを生成します。 // 取得した行識別子の行(IDが 3の行)に対して、UPDATE文を実行します。 // NAMEを'Tiger'に変更します。 PreparedStatement pstmt = con.prepareStatement( "UPDATE GENERAL.EMPLOYEE SET NAME= 'Tiger' WHERE ROW_ID=?"); // パラメタに値を設定します。 pstmt.setRowId(1, rowid); // データベースのデータを更新します。 pstmt.executeUpdate(); // ResultSetのオブジェクトをクローズします。 rs.close(); // PreparedStatementの // オブジェクトをクローズします。 pstmt.close(); // Statementのオブジェクトをクローズします。 stmt.close(); //トランザクションのコミット con.commit(); // Connectionのオブジェクトをクローズします。 con.close(); } // SQLExceptionが発生した場合の処理を記述します。 catch (SQLException e) { // エラー情報を出力します。 System.out.println("ERROR MESSAGE : " + e.getMessage()); System.out.println("SQLSTATE : " + e.getSQLState()); System.out.println("ERROR CODE : " + e.getErrorCode()); e.printStackTrace(); } // その他のExceptionが発生した場合の処理を記述します。 catch (Exception e) { // スタックトレースを出力します。 System.out.println("ERROR MESSAGE : " + e.getMessage()); e.printStackTrace(); } } }