/*********************************************************************
 *
 *  ConnectDB.java  a class for connecting to databases using jdbc
 *
 *  Using ConnectDB :
 * 
 *  import ConnectDB.*;
 *  ...
 *  ConnectDB connect = new ConnectDB( "999.999.999.999", "1526", "orcl"
 *                                     "scott", "tiger", "ORACLE" , true );
 *  if( connect.ifConnected() ){
 *	try {  ...
 *	connect.rs = connect.stmt.executeQuery("SELECT USER FROM DUAL");
 *	while( connect.rs.next() ) 
 *		System.out.println( connect.rs.getString(1) );
 *	...
 *      connect.disConnect();
 *      } catch ( Exception e) { ... }
 *  }
 *
 * kishan@hackorama.com  www.hackorama.com  20000
 *
 **********************************************************************/

import java.io.*;
import java.sql.*;
import oracle.sql.*;
 
class ConnectDB {

	private Connection con;
	public Statement stmt;
	private boolean status = false;
	public ResultSet rs;
	private OutputStream sout = System.out ;

	/* by fefault prints all exception details  */
	private boolean MESSAGES = true; 

	private String USER_ID;
	private String PASS_WD;
	private String DB_IP;
	private String DB_PORT;
	private String DB_ID;
	private String DB_TYPE;


	public ConnectDB( String IP  , String PORT, String ID , String USER , String PASS, String  TYPE, boolean SILENT)
	{
		USER_ID = USER;
		PASS_WD = PASS;
		DB_IP   = IP ;
		DB_PORT = PORT ;
		DB_ID   = ID ;
		DB_TYPE = TYPE;
		MESSAGES = SILENT ;	

		getConnected();
  	}

  	private void getConnected()
  	{ 
		String url;

    		try {
 
			if ( ORACLE()  ){

				DriverManager.registerDriver (new oracle.jdbc.driver.OracleDriver());
        			url = "jdbc:oracle:thin:@"+DB_IP+":"+DB_PORT+":"+DB_ID;

			} else if ( MYSQL() ) {

				//DriverManager.registerDriver (new gwe.sql.gweMysqlDriver());
				DriverManager.registerDriver (new org.gjt.mm.mysql.Driver());
        			url = "jdbc:mysql://"+DB_IP+":"+DB_PORT+"/"+DB_ID;

			} else {
				status = false;
				return;
			}
   			printMsg("CONNECTING TO : "+url );
        		con = DriverManager.getConnection(url, USER_ID , PASS_WD );
        		stmt = con.createStatement();
			status = true;

    		} catch( Exception e ) {
			handleEx( e );
   		}
  	}

	public boolean ORACLE()
	{
		if( DB_TYPE.equals("ORACLE") ) return true ;
		else return false;
	}	
	
	public boolean MYSQL()
	{
		if( DB_TYPE.equals("MYSQL") ) return true ;
		else return false;
	}	
	
	public void disConnect()
        {
		if ( status ){
                	try {
                        	stmt.close();
                        	con.close();
                        	status = false;
 
                	} catch( Exception e ) {
				handleEx( e );
                	}
		} else {
			printMsg( "ConnectDB.disConnect(): Not connected to disconnect \n" ); 
		}
        }            


	public void handleEx( Exception e )
	{
		status = false;
   		printMsg("ConnectDB.getConnected(): There was an exception, details follow ..." );
		printEx( e );
	}

	public void  printEx( Exception e )
	{
		if( MESSAGES ){
   			printMsg( e.getMessage() );
     			e.printStackTrace();
		}
	}
	
	public void  printMsg( String  e  )
	{
		if( MESSAGES )
   			System.out.println("\n" + e + "\n");
	}

	public Statement  getStatement( )
	{
   		return( stmt );
	}

	public Connection  getConnection( )
	{
   		return( con );
	}

	public boolean  ifConnected( )
	{
		return status;
	}

}