package nmp.dbms.util;
   
   import java.io.*;
   import java.sql.*;
   import nmp.dbms.JDBC.*;
   
   public class InterDB {
   	public static void main( String[] args)
   			throws IOException{
  		if( args == null || ( args.length != 3 && args.length != 4)) {
  			System.err.println( "Usage:\n InterDB url userName userPwd [driver]");
  			return;
  		}
  
  		try {
  			Jdbc_Sql sql = null;
  			if( args.length == 3)
  				sql = new Jdbc_Sql( "sun.jdbc.odbc.JdbcOdbcDriver", args[0], args[1], args[2]);
  			else
  				sql = new Jdbc_Sql( args[3], args[0], args[1], args[2]);
  
  			doit( sql);
  
  			sql.closeAll();
  		}
  		catch( Exception e) {
  			PrintWriter pw;
  			String name = args[0].substring( args[0].lastIndexOf( ':') + 1);
  			try {
  				pw = new PrintWriter( new FileWriter( "ERR_" + name + ".log", true));
  			}
  			catch( FileNotFoundException e0) {
  				pw = new PrintWriter( new FileWriter( "ERR_" + name + ".log"));
  			}
  			e.printStackTrace( pw);
  			pw.println();
  			pw.flush();
  		}
  	}
  
  	static void doit( Jdbc_Sql sql)
  			throws IOException {
  		BufferedReader reader = new BufferedReader( new InputStreamReader( System.in));
  		for( ; ; ) {
  			System.out.print( "? ");
  			System.out.flush();
  			String line = reader.readLine();
  			line = line.trim();
  			if( line.equals( "quit"))
  				break;
  			try {
  				System.out.println( "Native SQL : " + sql.nativeSQL( line));
  				if( line.startsWith( "select"))
  					Utilities.displayResultSet( System.out, sql.executeQuery( line));
  				else
  					System.out.println( sql.executeUpdate( line) + " rows modified");
  			}
  			catch( SQLException e) {
  				e.printStackTrace();
  			}
  		}
  	}
  
  }