// 以下のパッケージをインポートします。
import java.sql.*;
// クラスを定義します。
public class MyURLAccess
{
public static void main(String args[])
{
try
{
// JDBCドライバを指定します。
Class.forName("com.fujitsu.symfoware.jdbc.SYMDriver");
// データベースと接続します。
Connection con =
DriverManager.getConnection("jdbc:symford://myhost:2050/COMPANY",
"UID", "PWD");
// 自動コミットの設定
con.setAutoCommit(false);
// Statementインタフェースのオブジェクトを生成します。
Statement stmt = con.createStatement();
// SQL文を実行し、ResultSetの
// オブジェクトを生成します。
ResultSet rs = stmt.executeQuery("SELECT ID,NAME FROM GENERAL.EMPLOYEE");
int iID = 0;
String sName = null;
while(rs.next())
{
// ResultSetの列に対応する
// データを取得します。
iID = rs.getInt(1);
sName = rs.getString(2);
// 取得した情報を表示します。
System.out.println("ID = " + iID);
System.out.println("NAME = " + sName);
}
// ResultSetのオブジェクトをクローズします。
rs.close();
// Statementのオブジェクトをクローズします。
stmt.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());
e.printStackTrace();
}
// その他のExceptionが発生した場合の処理を記述します。
catch (Exception e)
{
// スタックトレースを出力します。
System.out.println("ERROR MESSAGE : " + e.getMessage());
e.printStackTrace();
}
}
} |