1 files changed, 143 insertions, 0 deletions
diff --git a/java/rasj/test/TestQuery.java b/java/rasj/test/TestQuery.java
new file mode 100644
index 0000000..362b99f
--- /dev/null
+++ b/java/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