Symfoware Parallel Server JDBCドライバユーザーズガイド

B.2.4 パラメタを指定してデータを追加する

SQL文のパラメタを指定してデータベースにデータを追加するプログラム例を説明します。

// 以下のパッケージをインポートします。
import java.util.*;
import java.sql.*;
import javax.sql.*;
import javax.naming.*;

// クラスを定義します。
public class MyPreparedInsert
{

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();

// PreparedStatementクラスのオブジェクトを生成します。
PreparedStatement pstmt = con.prepareStatement(
"INSERT INTO GENERAL.EMPLOYEE(ID,NAME) VALUES(?,?)");

// パラメタに値を設定します。
pstmt.setInt(1,4);
pstmt.setString(2, "monkey");

// データベースにデータを追加します。
pstmt.executeUpdate();

// PreparedStatementクラスのオブジェクトをクローズします。
pstmt.close();

// 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());

}

// その他のExceptionが発生した場合の処理を記述します。

catch (Exception e)
{

// スタックトレースを出力します。
e.printStackTrace();

}

}

}