[exo-jcr-commits] exo-jcr SVN: r947 - in jcr/branches/1.12.0-JBC/component/core/src/test/java/org/exoplatform/services/jcr/lab: cluster and 1 other directory.

Tuesday, 8 December 2009


Author: nzamosenchuk
Date: 2009-12-08 09:38:08 -0500 (Tue, 08 Dec 2009)
New Revision: 947

Added:
  
jcr/branches/1.12.0-JBC/component/core/src/test/java/org/exoplatform/services/jcr/lab/cluster/
  
jcr/branches/1.12.0-JBC/component/core/src/test/java/org/exoplatform/services/jcr/lab/cluster/TestQueryAssert.java
  
jcr/branches/1.12.0-JBC/component/core/src/test/java/org/exoplatform/services/jcr/lab/cluster/TestQueryPrepare.java
Log:
EXOJCR-291: Added experimental cluster query tests.

Added:
jcr/branches/1.12.0-JBC/component/core/src/test/java/org/exoplatform/services/jcr/lab/cluster/TestQueryAssert.java
===================================================================
---
jcr/branches/1.12.0-JBC/component/core/src/test/java/org/exoplatform/services/jcr/lab/cluster/TestQueryAssert.java	
                       (rev 0)
+++
jcr/branches/1.12.0-JBC/component/core/src/test/java/org/exoplatform/services/jcr/lab/cluster/TestQueryAssert.java	2009-12-08
14:38:08 UTC (rev 947)
@@ -0,0 +1,132 @@
+/*
+ * Copyright (C) 2009 eXo Platform SAS.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software 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
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.exoplatform.services.jcr.lab.cluster;
+
+import org.exoplatform.services.jcr.JcrAPIBaseTest;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.util.HashSet;
+import java.util.Iterator;
+import java.util.Set;
+
+import javax.jcr.Node;
+import javax.jcr.NodeIterator;
+import javax.jcr.RepositoryException;
+import javax.jcr.Value;
+import javax.jcr.query.Query;
+import javax.jcr.query.QueryManager;
+import javax.jcr.query.QueryResult;
+import javax.jcr.query.Row;
+import javax.jcr.query.RowIterator;
+
+/**
+ * @author <a href="mailto:nikolazius@gmail.com">Nikolay
Zamosenchuk</a>
+ * @version $Id: TestQueryAssert.java 34360 2009-07-22 23:58:59Z nzamosenchuk $
+ *
+ */
+public class TestQueryAssert extends JcrAPIBaseTest
+{
+   public void testAssert() throws RepositoryException, IOException
+   {
+      System.out.println("Press enter to start asserting....");
+
+      BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
+      String sample = br.readLine();
+
+      Node doc1 = root.getNode("document1");
+      Node doc2 = root.getNode("document2");
+
+      // make SQL query
+      QueryManager qman = this.workspace.getQueryManager();
+
+      Query q = qman.createQuery("SELECT * FROM nt:file ", Query.SQL);
+      QueryResult res = q.execute();
+      long sqlsize = res.getNodes().getSize();
+      assertEquals(2, sqlsize);
+      checkResult(res, new Node[]{doc1, doc2});
+
+      //make XPath query
+
+      Query xq = qman.createQuery("//element(*,nt:file)", Query.XPATH);
+      QueryResult xres = xq.execute();
+      long xpathsize = xres.getNodes().getSize();
+      assertEquals(2, xpathsize);
+      checkResult(xres, new Node[]{doc1, doc2});
+      System.out.println("Done! Press enter to finish...");
+      br.readLine();
+   }
+
+   protected void checkResult(QueryResult result, Node[] nodes) throws
RepositoryException
+   {
+      // collect paths
+
+      String[] columnNames = result.getColumnNames();
+      String[][] vals = new
String[(int)result.getNodes().getSize()][result.getColumnNames().length];
+
+      RowIterator rit = result.getRows();
+      int j = 0;
+      while (rit.hasNext())
+      {
+         Row r = rit.nextRow();
+         Value[] v = r.getValues();
+         for (int i = 0; i < v.length; i++)
+         {
+            vals[j][i] = (v[i] != null) ? v[i].getString() : "null";
+         }
+         j++;
+      }
+
+      Set<String> expectedPaths = new HashSet<String>();
+      for (int i = 0; i < nodes.length; i++)
+      {
+         expectedPaths.add(nodes[i].getPath());
+      }
+      Set<String> resultPaths = new HashSet<String>();
+      for (NodeIterator it = result.getNodes(); it.hasNext();)
+      {
+         resultPaths.add(it.nextNode().getPath());
+      }
+
+      comparePaths(expectedPaths, resultPaths, false);
+   }
+
+   private void comparePaths(Set<String> expectedPaths, Set<String>
resultPaths, boolean canContainMore)
+   {
+      // check if all expected are in result
+      for (Iterator<String> it = expectedPaths.iterator(); it.hasNext();)
+      {
+         String path = it.next();
+         assertTrue(path + " is not part of the result set",
resultPaths.contains(path));
+      }
+
+      if (!canContainMore)
+      {
+         // check result does not contain more than expected
+
+         for (Iterator<String> it = resultPaths.iterator(); it.hasNext();)
+         {
+            String path = it.next();
+            assertTrue(path + " is not expected to be part of the result set. "
+ " Total size:" + resultPaths.size(),
+               expectedPaths.contains(path));
+         }
+      }
+   }
+}


Property changes on:
jcr/branches/1.12.0-JBC/component/core/src/test/java/org/exoplatform/services/jcr/lab/cluster/TestQueryAssert.java
___________________________________________________________________
Name: svn:mime-type
   + text/plain

Added:
jcr/branches/1.12.0-JBC/component/core/src/test/java/org/exoplatform/services/jcr/lab/cluster/TestQueryPrepare.java
===================================================================
---
jcr/branches/1.12.0-JBC/component/core/src/test/java/org/exoplatform/services/jcr/lab/cluster/TestQueryPrepare.java	
                       (rev 0)
+++
jcr/branches/1.12.0-JBC/component/core/src/test/java/org/exoplatform/services/jcr/lab/cluster/TestQueryPrepare.java	2009-12-08
14:38:08 UTC (rev 947)
@@ -0,0 +1,68 @@
+/*
+ * Copyright (C) 2009 eXo Platform SAS.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software 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
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.exoplatform.services.jcr.lab.cluster;
+
+import org.exoplatform.services.jcr.JcrAPIBaseTest;
+import org.exoplatform.services.jcr.impl.core.NodeImpl;
+
+import java.io.BufferedReader;
+import java.io.ByteArrayInputStream;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.util.Calendar;
+
+import javax.jcr.Node;
+import javax.jcr.RepositoryException;
+
+/**
+ * @author <a href="mailto:nikolazius@gmail.com">Nikolay
Zamosenchuk</a>
+ * @version $Id: TestQueryPrepare.java 34360 2009-07-22 23:58:59Z nzamosenchuk $
+ *
+ */
+public class TestQueryPrepare extends JcrAPIBaseTest
+{
+   public void testPrepareNodes() throws RepositoryException, IOException
+   {
+      System.out.println("Press enter to start preparing....");
+      
+      BufferedReader br = new BufferedReader(new InputStreamReader(System.in) );
+      String sample = br.readLine();
+      
+      root.addNode("simplenode", "nt:unstructured");
+
+      Node doc1 = root.addNode("document1", "nt:file");
+      NodeImpl cont = (NodeImpl)doc1.addNode("jcr:content",
"nt:resource");
+      cont.setProperty("jcr:mimeType", "text/plain");
+      cont.setProperty("jcr:lastModified", Calendar.getInstance());
+      cont.setProperty("jcr:encoding", "UTF-8");
+      cont.setProperty("jcr:data", new
ByteArrayInputStream("".getBytes()));
+
+      Node doc2 = root.addNode("document2", "nt:file");
+      cont = (NodeImpl)doc2.addNode("jcr:content", "nt:resource");
+      cont.setProperty("jcr:mimeType", "text/plain");
+      cont.setProperty("jcr:lastModified", Calendar.getInstance());
+      cont.setProperty("jcr:encoding", "UTF-8");
+      cont.setProperty("jcr:data", new
ByteArrayInputStream("".getBytes()));
+
+      session.save();
+      
+      System.out.println("Done! Press enter to finish...");
+      br.readLine();
+   }
+}


Property changes on:
jcr/branches/1.12.0-JBC/component/core/src/test/java/org/exoplatform/services/jcr/lab/cluster/TestQueryPrepare.java
___________________________________________________________________
Name: svn:mime-type
   + text/plain


    

2026

2025

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

[exo-jcr-commits] exo-jcr SVN: r947 - in jcr/branches/1.12.0-JBC/component/core/src/test/java/org/exoplatform/services/jcr/lab: cluster and 1 other directory.