summaryrefslogtreecommitdiffstats
path: root/java/src/rasj/test/TestQuery.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/src/rasj/test/TestQuery.java')
-rw-r--r--java/src/rasj/test/TestQuery.java143
1 files changed, 143 insertions, 0 deletions
diff --git a/java/src/rasj/test/TestQuery.java b/java/src/rasj/test/TestQuery.java
new file mode 100644
index 0000000..362b99f
--- /dev/null
+++ b/java/src/rasj/test/TestQuery.java
@@ -0,0 +1,143 @@
+/*
+* This file is part of rasdaman community.
+*
+* Rasdaman community is free software: you can redistribute it and/or modify
+* it under the terms of the GNU General Public License as published by
+* the Free Software Foundation, either version 3 of the License, or
+* (at your option) any later version.
+*
+* Rasdaman community is distributed in the hope that it will be useful,
+* but WITHOUT ANY WARRANTY; without even the implied warranty of
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+* GNU General Public License for more details.
+*
+* You should have received a copy of the GNU General Public License
+* along with rasdaman community. If not, see <http://www.gnu.org/licenses/>.
+*
+* Copyright 2003, 2004, 2005, 2006, 2007, 2008, 2009 Peter Baumann /
+rasdaman GmbH.
+*
+* For more information please see <http://www.rasdaman.org>
+* or contact Peter Baumann via <baumann@rasdaman.com>.
+*/
+/*************************************************************
+ *
+ *
+ * PURPOSE:
+ * test rasj: simple open/read query/close cycle.
+ * rasj test program for executing a query against some rasdaman database.
+ * Note: database is opened readonly, so send only SELECT queries.
+ *
+ * @param --server s - use server s (default: localhost)
+ * @param --port p - use server port p (default: 7001)
+ * @param --database d - use database d (default: RASBASE)
+ * @param --user u - log in as user u (default: rasguest)
+ * @param --passwd p - log in with password p (default: rasguest)
+ * @param --query q - send SELECT query string q to server (default: "select r from RAS_COLLECTIONNAMES as r"")
+ * @param --count c - execute query c times (default: 1)
+ *
+ *
+ * COMMENTS:
+ * - no parameter line error handling
+ ************************************************************/
+
+import rasj.*;
+import rasj.odmg.*;
+import org.odmg.*;
+import java.util.*;
+import java.io.*;
+
+public class TestQuery
+ {
+
+ public static void main( String[] args )
+ {
+ String server = "localhost";
+ String port = "7001";
+ String base = "RASBASE";
+ String user = "rasguest";
+ String passwd = "rasguest";
+ String query = "select r from RAS_COLLECTIONNAMES as r";
+ int count = 1;
+
+ if (args.length == 0)
+ {
+ System.out.println( "usage: TestQuery [options]" );
+ System.out.println( "options:" );
+ System.out.println( " --server s - use server s (default: localhost)" );
+ System.out.println( " --port p - use server port p (default: 7001)" );
+ System.out.println( " --database d - use database d (default: RASBASE)" );
+ System.out.println( " --user u - log in as user u (default: rasguest)" );
+ System.out.println( " --passwd p - log in with password p (default: rasguest)" );
+ System.out.println( " --query q - send SELECT query string q to server (default: select r from RAS_COLLECTIONNAMES as r)" );
+ System.out.println( " --count c - execute query c times (default: 1)" );
+ return;
+ }
+
+ for (int i=args.length-1; i>=0; i--)
+ {
+ if (args[i].equals("--server"))
+ server = args[i+1];
+ if (args[i].equals("--port"))
+ port = args[i+1];
+ if (args[i].equals("--database"))
+ base = args[i+1];
+ if (args[i].equals("--user"))
+ user = args[i+1];
+ if (args[i].equals("--passwd"))
+ passwd = args[i+1];
+ if (args[i].equals("--query"))
+ query = args[i+1];
+ if (args[i].equals("--count"))
+ count = Integer.parseInt(args[i+1]);
+ }
+
+ System.out.println( "Query test started with server=" + server + ", port=" + port + ", database=" + base + ", user=" + user + ", count=" + count + ", query=" + query );
+
+ try
+ {
+ RasImplementation myApp = new RasImplementation("http://"+server+":"+port);
+ myApp.setUserIdentification(user, passwd);
+
+ System.out.println( "opening database..." );
+ Database myDb = myApp.newDatabase();
+ myDb.open( base, Database.OPEN_READ_WRITE );
+
+ System.out.println( "starting transaction..." );
+ Transaction myTa = myApp.newTransaction();
+ myTa.begin();
+
+ for (int i = 1; i <= count; i++)
+ {
+
+ System.out.print( "sending query #" + i + "..." );
+ OQLQuery myQu = myApp.newOQLQuery();
+ myQu.create(query);
+ DBag result = (DBag) myQu.execute();
+
+ System.out.println( "result is: " + result );
+
+ }
+
+ System.out.println( "closing transaction..." );
+ myTa.commit();
+
+ // System.out.println( "sending query out of TA, must produce an error..." );
+ // OQLQuery myQu2 = myApp.newOQLQuery();
+ // myQu2.create(query);
+ // DBag result2 = (DBag) myQu2.execute();
+
+ System.out.println( "closing database..." );
+ myDb.close();
+
+ }
+ catch(Exception e)
+ {
+ System.err.println( e.getMessage() );
+ }
+
+ System.out.println( "Query test done." );
+
+ } // main()
+
+} // TestQuery