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(); } } }