/***************************************************** * DB関連の操作 * Copyright(C) 2001 A-tak, Japan * * @since 2001.05.14 * @author A-tak * ****************************************************/ package db; import java.sql.*; /** * DB関連クラス * クラスの詳細説明 * Copyright(C) 2001 A-tak, Japan * * @see 主に関連するクラス * @version 1.0 * @since 2001.05.14 * @author A-tak */ public class DbAccess { Connection con = null; //データベースコネクションの変数 /** * DBとの接続 * DB名だけ指定すれば、JDBC経由でPostgresqlに接続を行う * JDBCドライバ名が違う場合はここで修正する * * @param String dbName 接続するDBの名前 * @return void * @throws SQLException DB接続失敗など */ public void dbConnect(String dbName) throws ClassNotFoundException, SQLException { Class.forName("org.postgresql.Driver"); String url = "jdbc:postgresql:"+ dbName; String user = "DBユーザー名"; String pwd = "DBパスワード"; con = DriverManager.getConnection(url, user, pwd); } /** * SELECT文の実行 * * * @param String query SQL文 * @return ResultSet selectの結果のレコードセット * @throws SQLException アクセスエラー */ public ResultSet getRecord(String query) throws SQLException { Statement stmt = con.createStatement(); ResultSet rs = stmt.executeQuery(query); stmt.close(); return rs; } /** * INSERT文の実行 * * * @param String query SQL文 * @return int insertした件数 * @throws SQLException アクセスエラー */ public int setRecord(String query) throws SQLException { Statement stmt = con.createStatement(); int NumOfUp = stmt.executeUpdate(query); stmt.close(); return NumOfUp; } }