package accessDB;
import java.util.*;
import java.sql.*;
import javax.sql.*;
import oracle.jdbc.*;
import oracle.jdbc.dbaccess.*;
import oracle.jdbc.driver.*;
public class TableData {
	private Connection conn = 
		new	DBConnection().connectByJdbc(DBConstantVariable.UserName,
				DBConstantVariable.Password);
	private ResultSet dataSet = null;
	public ResultSet getAllTableData(String tableName){
		String tableQuery = "SELECT * FROM " + DBConstantVariable.UserName +"." + tableName;
		try{
			Statement stat = conn.createStatement();
			if( conn == null ){
				System.out.println("Database Connection Error!");
				System.exit(-1);
			}
			dataSet = stat.executeQuery(tableQuery);
			System.out.println("Query OK!");
		}catch(SQLException ex){
			System.out.println("Sql exception  TableData.java 24 "+ex.getMessage()+"!");
			System.exit(-1);
		}
		catch(Exception ex){
			System.out.println("Exception "+ex.getMessage()+"!");
			System.exit(-1);
		}
		return dataSet;
	}
	
	public  boolean ColseResultSet(){
		try{
			if( this.dataSet != null )
				this.dataSet.close();
			if( this.conn.isClosed() == true )
				return true;
			else
			{
				this.conn.close();
				return true;
			}
		}
		catch(SQLException ex){
			System.out.println("Close Connection Error!");
			System.exit(-1);
		}
		catch(Exception ex){
			System.out.println("Unhandle Exception Occurs!");
		}
		return false;
	}

	public boolean UpdateTableData(String sqlState){
		String tableUpdate = sqlState;
		try{
			Statement stat = conn.createStatement();
			if( conn == null ){
				System.out.println("Database Connection Error!");
				return false;
			}
			stat.executeUpdate( tableUpdate );
			stat.close();
			return true;
		}catch(SQLException ex){
			System.out.println("Sql exception  Update TableData "+ex.getMessage()+"!");
		}
		catch(Exception ex){
			System.out.println("Exception "+ex.getMessage()+"!");
		}
		return false;
	}
}