package wrappers;

import java.io.BufferedReader;
import java.io.Console;
import java.io.IOException;
import java.io.InputStreamReader;
import java.sql.Date;
import java.sql.Time;
import java.sql.Timestamp;

public class Client {
    static boolean    	 DEBUG = true;
    static final Console c = System.console();
    static JdbcInterface jdi = null;
   
	public static void main(String[] args) {
		int rc, n, ncol, i = 0, fsize = 0;
		boolean scrollable = false;
		String  s;
		String[] parms = new String[4];
		
	    if (args.length > 0)
	         try {
	             i = Integer.parseInt(args[i]);
	         } catch (NumberFormatException e) {
	             i = 0;
	         } // end try/catch
	    
	    switch (i) {
	    case 1:
	    	jdi = new ApacheInterface(DEBUG);
	    	break;
	    case 2:
	    	jdi = new MysqlInterface(DEBUG);
	    	break;
	    case 3:
	    	jdi = new MariadbInterface(DEBUG);
	    	break;
	    case 4:
	    	jdi = new OracleInterface(DEBUG);
	    	break;
	    case 5:
	    	jdi = new PostgresqlInterface(DEBUG);
	    	break;
	    default:
			jdi = new JdbcInterface(DEBUG);
	    } // endswitch i
		
		parms[0] = getLine("Driver: ", false);
		parms[1] = getLine("URL: ", false);
		parms[2] = getLine("User: ", false);
		parms[3] = getLine("Password: ", true);
		s = getLine("Fsize: ", false);
		fsize = (s != null) ? Integer.parseInt(s) : 0;
		s = getLine("Scrollable: ", false);
		scrollable = (s != null) ? s.toLowerCase().charAt(0) != 'n' : false;
		
		rc = jdi.JdbcConnect(parms, fsize, scrollable);
		
		if (rc == 0) {
		  String query;
		  System.out.println("Successfully connected to " + parms[1]);
		  
		  s = jdi.GetQuoteString();
		  System.out.println("Qstr = '" + s + "'");
		  
		  while ((query = getLine("Query: ", false)) != null) {
		    n = jdi.Execute(query);
		    System.out.println("Returned n = " + n);
		    
		    if ((ncol = jdi.GetResult()) > 0)
  		      PrintResult(ncol);
		    else
		      System.out.println("Affected rows = " + n);
		    
		  } // endwhile
		  
		  rc = jdi.JdbcDisconnect();
		  System.out.println("Disconnect returned " + rc);
		} else
		  System.out.println(jdi.GetErrmsg() + " rc=" + rc);
		
	} // end of main

	private static void PrintResult(int ncol) {
    	// Get result set meta data
    	int i;
    	Date date = new Date(0);
    	Time time = new Time(0);
    	Timestamp tsp = new Timestamp(0);
    	String columnName;
		Object job;

    	// Get the column names; column indices start from 1
    	for (i = 1; i <= ncol; i++) {
    		columnName = jdi.ColumnName(i);
    		
    		if (columnName == null)
    			return;

    		// Get the name of the column's table name
    		//String tableName = rsmd.getTableName(i);
    		
    		if (i > 1)
		    	System.out.print("\t");
    		
    		System.out.print(columnName);
    	} // endfor i
    	
    	System.out.println();
	    
	    // Loop through the result set
	    while (jdi.ReadNext() > 0) {
	    	for (i = 1; i <= ncol; i++) {
	    		if (i > 1)
			    	System.out.print("\t");
	    		
	    		if (DEBUG)
	    			System.out.print("(" + jdi.ColumnType(i, null) + ")");
	    		
	    		switch (jdi.ColumnType(i, null)) {
	    		case java.sql.Types.VARCHAR:
	    		case java.sql.Types.LONGVARCHAR:
	    		case java.sql.Types.CHAR:
				case 1111:
			    	System.out.print(jdi.StringField(i, null));
	    			break;
	    		case java.sql.Types.INTEGER:
			    	System.out.print(jdi.IntField(i, null));
	    			break;
	    		case java.sql.Types.BIGINT:
			    	System.out.print(jdi.BigintField(i, null));
	    			break;
	    		case java.sql.Types.TIME:
	    			time.setTime((long)jdi.TimeField(i, null) * 1000);
			    	System.out.print(time);
	    			break;
	    		case java.sql.Types.DATE:
	    			date.setTime((long)jdi.DateField(i, null) * 1000);
			    	System.out.print(date);
	    			break;
	    		case java.sql.Types.TIMESTAMP:
	    			tsp.setTime((long)jdi.TimestampField(i, null) * 1000);
			    	System.out.print(tsp);
	    			break;
	    		case java.sql.Types.SMALLINT:
			    	System.out.print(jdi.IntField(i, null));
	    			break;
	    		case java.sql.Types.DOUBLE:
	    		case java.sql.Types.REAL:
	    		case java.sql.Types.FLOAT:
	    		case java.sql.Types.DECIMAL:
	    			System.out.print(jdi.DoubleField(i, null));
	    			break;
	    		case java.sql.Types.BOOLEAN:
	    			System.out.print(jdi.BooleanField(i, null));
	    		default:
					job = jdi.ObjectField(i, null);
					System.out.print(job.toString());
	    			break;
	    		} // endswitch Type
	    		
	    	} // endfor i
	    	
	    	System.out.println();
	    } // end while rs

	} // end of PrintResult

	  // ==================================================================
	  private static String getLine(String p, boolean b) {
	    String response;
	    
	    if (c != null) {
	      // Standard console mode
	      if (b) {
	        response = new String(c.readPassword(p));
	      } else
	        response = c.readLine(p);

	    } else {
	      // For instance when testing from Eclipse
	      BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
	      
	      System.out.print(p);
	      
	      try {
	    	// Cannot suppress echo for password entry
	    	response = in.readLine();
	      } catch (IOException e) {
	    	response = "";
	      } // end of try/catch
	      
	    } // endif c

	    return (response.isEmpty()) ? null : response;
	  } // end of getLine

} // end of class Client