// 以下のパッケージをインポートします。
import java.util.*;
import java.sql.*;
import javax.sql.*;
import javax.naming.*;
// クラスを定義します。
public class MyDatabaseUpdate
{
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:10326");
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();
// IDが1の行に対して、UPDATE文を実行します。
// NAMEを'gorilla'に変更します。
stmt.executeUpdate("UPDATE GENERAL.EMPLOYEE SET NAME= 'gorilla' WHERE ID=1");
// 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();
}
}
} |