import java.io.*;


public class QueryTest extends Object 
{
  
public static void main(String[] args)
  {
    QueryTest dummy = new QueryTest();
  }
public QueryTest()
  {
    DataInputStream in = new DataInputStream(System.in);
    boolean done = false;
    String query;
    try {
      PGConnection conn = new PGConnection("localhost", "5432", "",
					   "", "foo");
      System.out.println("Connected to database " + conn.db() +
			 " on " + conn.host() + " port " +
conn.port()
			 + " tty " + conn.tty() + ".");
      while (!done)
	{
	  System.out.println("Enter a Query (q to quit):");
	  query = in.readLine();
	  if (query.equalsIgnoreCase("q"))
	    {
	      done = true;
	    }
	  else
	    {
	      try {
		PGResult res = conn.exec(query);
		if (res.resultStatus() == PGResult.PGRES_TUPLES_OK)
		  System.out.println("\n" +
				     res.formatTuples(true, " ",
true,
						      false));
		else
		  System.out.println("\nExec Returned Status: "
+
				     res.resultStatus());
		res.resClear();
	      }
	      catch (PostgresException p)
		{
		  System.out.println(p);
		}
	    }
	}
    }
    catch (Exception e)
      {
	//	System.err.println(e);
	e.printStackTrace();
      }
  }

}

Back to article