X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.graph.db%2Fsrc%2Forg%2Fsimantics%2Fgraph%2Fdb%2FStreamingTransferableGraphImportProcess.java;h=a043e59f74ab8772d89d6aea2e5620d4bfbb68a0;hb=refs%2Fchanges%2F97%2F197%2F1;hp=3d4b78977af148de732ce03080e329e74d760c3f;hpb=54b3e007b23f516cb3916fd139344b2780e105e8;p=simantics%2Fplatform.git

diff --git a/bundles/org.simantics.graph.db/src/org/simantics/graph/db/StreamingTransferableGraphImportProcess.java b/bundles/org.simantics.graph.db/src/org/simantics/graph/db/StreamingTransferableGraphImportProcess.java
index 3d4b78977..a043e59f7 100644
--- a/bundles/org.simantics.graph.db/src/org/simantics/graph/db/StreamingTransferableGraphImportProcess.java
+++ b/bundles/org.simantics.graph.db/src/org/simantics/graph/db/StreamingTransferableGraphImportProcess.java
@@ -37,6 +37,7 @@ import org.simantics.db.VirtualGraph;
 import org.simantics.db.WriteOnlyGraph;
 import org.simantics.db.common.WriteBindings;
 import org.simantics.db.common.procedure.adapter.TransientCacheAsyncListener;
+import org.simantics.db.common.request.PossibleIndexRoot;
 import org.simantics.db.common.uri.UnescapedChildMapOfResource;
 import org.simantics.db.common.utils.Logger;
 import org.simantics.db.exception.DatabaseException;
@@ -210,7 +211,9 @@ public class StreamingTransferableGraphImportProcess implements TransferableGrap
 	
 	void prepare(ReadGraph graph) throws Exception {
 
-//		indexRoot = graph.syncRequest(new PossibleIndexRoot(((IImportAdvisor2)advisor).getTarget()));
+		Resource target = advisor.getTarget();
+		if(target != null)
+			indexRoot = graph.syncRequest(new PossibleIndexRoot(target));
 		
 		findBuiltins(graph);
 		readIdentities(graph);
@@ -316,7 +319,7 @@ public class StreamingTransferableGraphImportProcess implements TransferableGrap
 	    return resourceUtil.mayHaveResource(type);
 	}
 	
-	void findClusterSet(WriteOnlyGraph graph, Resource rootLibrary, Resource indexRoot, int[] clustering, int[] clusterSets, long[] clusters, int id) throws DatabaseException {
+	void findClusterSet(WriteOnlyGraph graph, Resource rootLibrary, int[] clustering, int[] clusterSets, long[] clusters, int id) throws DatabaseException {
 		ClusteringSupport support = graph.getService(ClusteringSupport.class);
 		if(id == Extensions.ROOT_LIBRARY_CLUSTER_SET || id == Extensions.INDEX_ROOT_CLUSTER_SET) return;
 		for(int pos=0,index=0;index<clustering.length;index++) {
@@ -326,9 +329,12 @@ public class StreamingTransferableGraphImportProcess implements TransferableGrap
 				if(handles[id] == 0) {
 					int csHandle = 0;
 					if(cs == Extensions.ROOT_LIBRARY_CLUSTER_SET) csHandle = builder.handle(rootLibrary);
-					else if(cs == Extensions.INDEX_ROOT_CLUSTER_SET) csHandle = builder.handle(indexRoot);
+					else if(cs == Extensions.INDEX_ROOT_CLUSTER_SET) {
+						if(indexRoot == null) throw new DatabaseException("No index root was available in TG import.");
+						csHandle = builder.handle(indexRoot);
+					}
 					else {
-						findClusterSet(graph, rootLibrary, indexRoot, clustering, clusterSets, clusters, cs);
+						findClusterSet(graph, rootLibrary, clustering, clusterSets, clusters, cs);
 						csHandle = handles[cs];
 					}
 					
@@ -373,7 +379,7 @@ public class StreamingTransferableGraphImportProcess implements TransferableGrap
 				
 				// Create clustering
 				for(int i=0;i<clusterSets.length;i++) {
-					findClusterSet(graph, graph.getRootLibrary(), indexRoot, clustering, clusterSets, clusters, clusterSets[i]);
+					findClusterSet(graph, graph.getRootLibrary(), clustering, clusterSets, clusters, clusterSets[i]);
 				}
 				
 				// Then create all resources
@@ -384,8 +390,10 @@ public class StreamingTransferableGraphImportProcess implements TransferableGrap
 		        	int setHandle = 0;
 					if(s == Extensions.ROOT_LIBRARY_CLUSTER_SET)
 						setHandle = builder.handle(graph.getRootLibrary());
-					else if(s == Extensions.INDEX_ROOT_CLUSTER_SET)
+					else if(s == Extensions.INDEX_ROOT_CLUSTER_SET) {
+						if(indexRoot == null) throw new DatabaseException("No index root was available in TG import.");
 						setHandle = builder.handle(indexRoot);
+					}
 					else setHandle = handles[s];
 					// Preserve clustering only for internal resources
 					if(clusters[j] != 0)