package com.prodb;

import java.sql.*;
import javax.naming.*;
import javax.sql.DataSource;

public class Test1 {
	
	private Statement stmt;
	private ResultSet rs;
	private static Connection con;
	/***************************************************
	*函數名稱：	getCon()<br>
	*函數功能：	獲取數據庫連接<br>
	*返回值：  	Connection<br>
	*參數說明：	無<br>
	*創建：		白偉明	2004年9月22日
	****************************************************/
	public static synchronized Connection getCon()throws Exception{
		Context ctx;
		DataSource ds;
		try{
			ctx = new InitialContext();
			ds = (DataSource)ctx.lookup("java:comp/env/jdbc/Project");
			return ds.getConnection();
		}catch(SQLException e){
			throw e;
		}
		catch(NamingException e){
			throw e;
		}
	}
	/***************************************************
	*函數名稱：	getStmt()<br>
	*函數功能：	獲取數據庫集合<br>
	*返回值：  	Statement
	*			stmt:返回數據庫集合不用于SELECT語句<br>
	*參數說明：	無<br>
	*創建：		白偉明	2004年9月22日
	****************************************************/
	public Statement getStmt(){
		try{
			con=getCon();
			stmt=con.createStatement();
		}catch(Exception e){
			System.out.println("getStmt");
			System.out.println(e.getMessage());
		}
		return stmt;
	}
	/***************************************************
	*函數名稱：	getStmtread()<br>
	*函數功能：	獲取數據庫集合<br>
	*返回值：  	Statement
	*			stmt:返回數據庫集合用于SELECT語句<br>
	*參數說明：	無<br>
	*創建：		白偉明	2004年9月22日
	****************************************************/
	public Statement getStmtread(){
		try{
			con=getCon();
			stmt=con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
		}catch(Exception e){
			System.out.println("getStmtread");
			System.out.println(e.getMessage());
		}
		return stmt;
	}
	/***************************************************
	*函數名稱：	getRs()<br>
	*函數功能：	獲取數據庫表中數據<br>
	*返回值：  	ResultSet
	*			rs:返回數據庫表中數據<br>
	*參數說明：	String sql:為表名[+條件]<br>
	*創建：		白偉明	2004年10月20日
	****************************************************/
	public ResultSet getRs(String sql){
		try{
			stmt=this.getStmtread();
			rs=stmt.executeQuery("SELECT * FROM "+sql);
			return rs;
		}catch(Exception e){
			System.out.println("getRs");
			System.out.println(e.getMessage());
		}
		return null;
	}
	/***************************************************
	*函數名稱：	addData()<br>
	*函數功能：	添加數據<br>
	*返回值：  	無<br>
	*參數說明：	無<br>
	*創建：		白偉明	2004年10月20日
	****************************************************/
	public void addData() throws Exception{
		try{
			con=Test1.getCon();
			PreparedStatement pstmt=con.prepareStatement("INSERT INTO Test VALUES(?,?)");
			pstmt.setInt(1,3);
			pstmt.setString(2,"適然");
			pstmt.execute();
			con.close();
		}catch(SQLException e){
			throw e;
		}
	}
	/***************************************************
	*函數名稱：	delData()<br>
	*函數功能：	刪除數據<br>
	*返回值：  	無<br>
	*參數說明：	無<br>
	*創建：		白偉明	2004年10月20日
	****************************************************/
	public void delData() throws Exception{
		try{
			stmt=this.getStmt();
			stmt.executeUpdate("DELETE FROM Test WHERE id=3");
			this.close();
		}catch(SQLException e){
			throw e;
		}
	}
	/***************************************************
	*函數名稱：close()<br>
	*函數功能：關閉數據庫連接<br>
	*返回值：  void<br>
	*參數說明：無<br>
	*最或修改：白偉明
	*		   2004年9月4日
	****************************************************/
	public void close(){
		try{
			if(rs!=null)rs.close();
		}catch(Exception e){
		}
		try{
			if(stmt!=null)stmt.close();
		}catch(Exception e){
		}
		try{
			if(con!=null)con.close();
		}catch(Exception e){
			System.out.println("close");
			System.out.println(e.getMessage());
		}
	}
}