Lucio Lelii 2016-12-13 19:03:00 +00:00
parent 8501fde466
commit 997eb495d0
2 changed files with 9 additions and 13 deletions

View File

@ -184,7 +184,7 @@ public class Helper {
String functionContainsDeclaration =" declare namespace functx = \"http://www.functx.com\"; declare function functx:is-value-in-sequence "+ String functionContainsDeclaration =" declare namespace functx = \"http://www.functx.com\"; declare function functx:is-value-in-sequence "+
" ( $value as xs:anyAtomicType? , $seq as xs:anyAtomicType* ) as xs:boolean { $value = $seq } ; \n"; " ( $value as xs:anyAtomicType? , $seq as xs:anyAtomicType* ) as xs:boolean { $value = $seq } ; \n";
Pattern declarePattern=Pattern.compile("(declare namespace .*;)*", Pattern.DOTALL); Pattern declarePattern=Pattern.compile("(\\s*declare namespace[^;]*;)*");
Matcher declareMat=declarePattern.matcher(queryFiltered); Matcher declareMat=declarePattern.matcher(queryFiltered);
boolean declareFound = declareMat.find(0); boolean declareFound = declareMat.find(0);
@ -194,7 +194,6 @@ public class Helper {
queryFiltered = queryFiltered.substring(0, declareIndex)+functionContainsDeclaration+queryFiltered.substring(declareIndex); queryFiltered = queryFiltered.substring(0, declareIndex)+functionContainsDeclaration+queryFiltered.substring(declareIndex);
} else } else
queryFiltered= functionContainsDeclaration +queryFiltered; queryFiltered= functionContainsDeclaration +queryFiltered;
log.trace("submitting filtered query: {}",queryFiltered); log.trace("submitting filtered query: {}",queryFiltered);
return queryFiltered; return queryFiltered;

View File

@ -33,18 +33,15 @@ public class StubClient {
CollectorStub proxy = stubFor(collector).at(URI.create(address)); CollectorStub proxy = stubFor(collector).at(URI.create(address));
SimpleQuery query = queryFor(GCoreEndpoint.class); //SimpleQuery query = queryFor(GCoreEndpoint.class);
/*
String queryString ="declare namespace ic = 'http://gcube-system.org/namespaces/informationsystem/registry'; declare namespace functx = \"http://www.functx.com\"; "+ String queryString ="declare namespace ic = 'http://gcube-system.org/namespaces/informationsystem/registry'; "+
"declare function functx:is-value-in-sequence "+ "for $profiles in collection('/db/Profiles/GenericResource')//Document/Data/ic:Profile/Resource "+
" ( $value as xs:anyAtomicType? , $seq as xs:anyAtomicType* ) as xs:boolean { $value = $seq } ;"; " let $scopes := string-join( $profiles/Scopes//Scope/text(), ';') "+
" let $subtype := $profiles/Profile/SecondaryType/text() "+
queryString+=" for $entry0ValueAuth in collection('/db/Profiles/RunningInstance')//Document/Data/ic:Profile/Resource/Scopes "+ " return $profiles";
" where functx:is-value-in-sequence('/gcube/devNext/NextNext',$entry0ValueAuth/child::*[local-name()='Scope']/text()) or functx:is-value-in-sequence('/gcube/devNext',$entry0ValueAuth/child::*[local-name()='Scope']/text()) and ( ($entry0ValueAuth/../Profile/ServiceClass/text() eq 'DataAccess') and ($entry0ValueAuth/../Profile/DeploymentData/Status/text() eq 'ready') and ($entry0ValueAuth/../Profile/ServiceName/text() eq 'CkanConnector') ) "+
" return $entry0ValueAuth/../Profile/AccessPoint/RunningInstanceInterfaces//Endpoint[@EntryName/string() eq \"org.gcube.data.access.ckanconnector.CkanConnector\"]/text()";
*/
//Query query = new QueryBox(queryString); Query query = new QueryBox(queryString);