X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=tests%2Forg.simantics.db.tests%2Fsrc%2Forg%2Fsimantics%2Fdb%2Ftests%2Fregression%2Fbugs%2FIssue3199Test2.java;fp=tests%2Forg.simantics.db.tests%2Fsrc%2Forg%2Fsimantics%2Fdb%2Ftests%2Fregression%2Fbugs%2FIssue3199Test2.java;h=416279ba9b251a2cac50d43efeaeb55700b55b04;hb=67fd62f9c742337ec80eef658192db198a0efaac;hp=0000000000000000000000000000000000000000;hpb=cde82ba81327d5515fdca362f7f4c70f5103ae80;p=simantics%2Fplatform.git

diff --git a/tests/org.simantics.db.tests/src/org/simantics/db/tests/regression/bugs/Issue3199Test2.java b/tests/org.simantics.db.tests/src/org/simantics/db/tests/regression/bugs/Issue3199Test2.java
new file mode 100644
index 000000000..416279ba9
--- /dev/null
+++ b/tests/org.simantics.db.tests/src/org/simantics/db/tests/regression/bugs/Issue3199Test2.java
@@ -0,0 +1,127 @@
+package org.simantics.db.tests.regression.bugs;
+
+import java.util.UUID;
+
+import org.junit.Test;
+import org.simantics.db.ReadGraph;
+import org.simantics.db.Resource;
+import org.simantics.db.Session;
+import org.simantics.db.WriteGraph;
+import org.simantics.db.WriteOnlyGraph;
+import org.simantics.db.common.request.ReadRequest;
+import org.simantics.db.common.request.WriteOnlyRequest;
+import org.simantics.db.common.request.WriteRequest;
+import org.simantics.db.exception.DatabaseException;
+import org.simantics.db.layer0.util.SessionGarbageCollection;
+import org.simantics.db.service.ClusterControl;
+import org.simantics.db.service.ManagementSupport;
+import org.simantics.db.service.XSupport;
+import org.simantics.db.testing.cases.FreshDatabaseTest;
+import org.simantics.db.testing.common.TestBase;
+import org.simantics.db.testing.impl.Configuration;
+import org.simantics.layer0.Layer0;
+
+public class Issue3199Test2 extends FreshDatabaseTest {
+    static final int RESOURCE_COUNT = Configuration.get().i3199ResourceCount; // 10 * 1000 * 1000;
+    static final int CONSIST_COUNT = 500; // How many resources in the same parent.
+    static final int COMMIT_COUNT = 50 * 1000; // How many resources in the same commit.
+    static final boolean DEBUG = false;
+    static final boolean VERBOSE = false;
+    Session session;
+    Resource testRoot;
+    ClusterControl clusterControl;
+
+    @Test
+    public void testSimanticsIssue3199()
+            throws DatabaseException {
+        session = getSession();
+        session.syncRequest(new Init());
+        long start = System.nanoTime();
+        session.syncRequest(new Create());
+        long duration = System.nanoTime() - start;
+        if (DEBUG)
+            System.out.println("Write done in " + 1e-9 * duration + " seconds.");
+        start = System.nanoTime();
+        session.syncRequest(new Query());
+        long total = duration;
+        if (DEBUG) {
+            duration = System.nanoTime() - start;
+            total += duration;
+            System.out.println("Read done in " + 1e-9 * duration + " seconds.");
+            System.out.println("Both done in " + 1e-9 * total + " seconds.");
+        }
+    }
+
+    class Init extends WriteRequest {
+        @Override
+        public void perform(WriteGraph g) throws DatabaseException {
+            Layer0 l0 = Layer0.getInstance(g);
+            Resource rl = g.getResource(TestBase.ROOT_LIBRARY_URI);
+            testRoot = g.newResource();
+            g.claim(testRoot, l0.InstanceOf, l0.Library);
+            g.claim(rl, l0.ConsistsOf, testRoot);
+        }
+    }
+
+    class Create extends WriteOnlyRequest {
+        @SuppressWarnings("unused")
+        @Override
+        public void perform(WriteOnlyGraph g) throws DatabaseException {
+            Layer0 l0 = Layer0.getInstance(getSession());
+            Resource root = g.newResource();
+            g.claim(testRoot, l0.ConsistsOf, l0.PartOf, root);
+            ManagementSupport ms = g.getService(ManagementSupport.class);
+            XSupport xs = g.getService(XSupport.class);
+            for (int i = 0, j = 1, k = 1; i < RESOURCE_COUNT; i++, j++, k++) {
+                Resource item = g.newResource();
+                g.claim(item, l0.InstanceOf, null, l0.String);
+                g.claim(item, l0.IsWeaklyRelatedTo, null, l0.Abstract);
+                g.claim(item, l0.IsWeaklyRelatedTo, null, l0.Assertion);
+                g.claim(item, l0.IsWeaklyRelatedTo, null, l0.Graph);
+                g.claim(item, l0.IsWeaklyRelatedTo, null, l0.Entity);
+                g.claim(item, l0.IsWeaklyRelatedTo, null, l0.Relation);
+                g.claimValue(item, UUID.randomUUID().toString());
+                if (j == CONSIST_COUNT) {
+                    j = 0;
+                    root = g.newResource();
+                    g.claim(testRoot, l0.ConsistsOf, l0.PartOf, root);
+                }
+                assert (null != root);
+                g.claim(root, l0.ConsistsOf, l0.PartOf, item);
+                if (k == COMMIT_COUNT) {
+                    if (DEBUG && VERBOSE)
+                        System.out.println("resource count=" + (i + 1));
+                    k = 0;
+                    long beg = ms.getHeadRevisionId();
+                    xs.commitAndContinue(g, this);
+                    long end = ms.getHeadRevisionId();
+                    assertTrue(beg + 1 == end);
+                }
+            }
+        }
+    }
+
+    class Query extends ReadRequest {
+        @SuppressWarnings("unused")
+        @Override
+        public void run(ReadGraph g) throws DatabaseException {
+            Layer0 l0 = Layer0.getInstance(g);
+            long count = 0;
+//            ClusterControl cc = g.getService(ClusterControl.class);
+            for (Resource r : g.getObjects(testRoot, l0.ConsistsOf)) {
+                for (Resource rr : g.getObjects(r, l0.ConsistsOf)) {
+                    if (!g.isInstanceOf(rr, l0.String))
+                        fail("Resource " + rr + " is not instance of String.");
+                    if (!g.isInstanceOf(rr, l0.Entity))
+                        fail("Resource " + rr + " is not instance of Entity.");
+                    ++count;
+                    if (DEBUG && VERBOSE && count % 100000 == 0)
+                        System.out.println("resource count=" + count);
+                }
+                // cc.gc(g);
+                SessionGarbageCollection.gc(g, Integer.MAX_VALUE, 0);
+            }
+            assertTrue(count == RESOURCE_COUNT);
+        }
+    }
+}