/*****************************************************
 * 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;
        }
}