package test;

import java.io.*;
import java.sql.*;

public class Conndb
{
	private String DBDriver = "sun.jdbc.odbc.JdbcOdbcDriver";
	private String ConnStr ="jdbc:odbc:conndb";
	private String Uid = "";
	private String Pwd = "";
	private Connection conn = null;
	private ResultSet rs = null;
	
	public void setDBDriver(String DBDriver)
	{
			this.DBDriver = DBDriver;
	}
	
	public String getDBDriver()
	{
		return DBDriver;	
	}
	
	public void setConnStr(String ConnStr)
	{
			this.ConnStr = ConnStr;
	}
	
	public String getConnStr()
	{
		return ConnStr;	
	}
	
	public void setUid(String Uid)
	{
			this.Uid = Uid;
	}
	
	public String getUid()
	{
		return Uid;	
	}
	public void setPwd(String Pwd)
	{
			this.Pwd = Pwd;
	}
	
	public String getPwd()
	{
		return Pwd;	
	}
	
	public ResultSet query(String rssql)throws Exception
	{
		try
		{
			//rssql = getStr(rssql);----因為傳過來的rssql已經被轉換過了，所以再轉換一下就不好使了
			Class.forName(DBDriver);
			conn = DriverManager.getConnection(ConnStr,Uid,Pwd);
			Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
			rs = stmt.executeQuery(rssql);
			return rs;
		}
		catch(SQLException ex)
		{
			System.out.println("sql.executeQuery:"+ex.getMessage());
		}
	return null;
	}
	
	public void update(String rssql)throws Exception
	{
		//rssql = getStr(rssql);
		
		try
		{
			Class.forName(DBDriver);
			conn = DriverManager.getConnection(ConnStr,Uid,Pwd);
			Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
			stmt.executeUpdate(rssql);
			conn.close();
			stmt.close();
		}
		catch(SQLException ex)
		{
			System.out.println("sql.executeUpdate:"+ex.getMessage());	
		}	
	}
	
	public String getStr(String str)
	{
		try
		{
			byte[] temp = str.getBytes("ISO8859-1");
			String temp2 = new String(temp);
			return temp2; 	
		}catch(Exception e){}
		return "null";	
	}
}