diff --git a/dnet-ariadneplus-graphdb-publisher/src/main/java/eu/dnetlib/ariadneplus/graphdb/GraphDBClient.java b/dnet-ariadneplus-graphdb-publisher/src/main/java/eu/dnetlib/ariadneplus/graphdb/GraphDBClient.java
index 7ae2d9f..2d7e8f9 100644
--- a/dnet-ariadneplus-graphdb-publisher/src/main/java/eu/dnetlib/ariadneplus/graphdb/GraphDBClient.java
+++ b/dnet-ariadneplus-graphdb-publisher/src/main/java/eu/dnetlib/ariadneplus/graphdb/GraphDBClient.java
@@ -379,6 +379,7 @@ public class GraphDBClient {
 		List <String> identifiers = Collections.emptyList();
 		try {
 			log.info("Select "+resourceType+" Identifiers from "+ datasource + " " + collectionId);
+			runSPQRLQuery.setupConnection( getWriterUser(), getWriterPwd(), this.graphDBServerUrl, getRepository());
 			if (resourceType.equals("COLLECTION")) {
 				identifiers = runSPQRLQuery.selectCollectionIds(datasource, collectionId);
 				log.info(String.format("Found %d collections for datasource %s - %s", identifiers.size(), datasource, collectionId));