You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
109 lines
3.1 KiB
Java
109 lines
3.1 KiB
Java
package org.gcube.contentmanager.storageclient.test;
|
|
|
|
import static org.gcube.resources.discovery.icclient.ICFactory.queryFor;
|
|
import static org.gcube.resources.discovery.icclient.ICFactory.*;
|
|
import java.util.ArrayList;
|
|
import java.util.List;
|
|
import org.gcube.common.resources.gcore.GenericResource;
|
|
import org.gcube.common.resources.gcore.ServiceEndpoint;
|
|
import org.gcube.common.resources.gcore.utils.XPathHelper;
|
|
import org.gcube.common.scope.api.ScopeProvider;
|
|
import org.gcube.contentmanager.storageclient.wrapper.ISClientConnector;
|
|
import org.gcube.resources.discovery.client.api.DiscoveryClient;
|
|
import org.gcube.resources.discovery.client.queries.api.SimpleQuery;
|
|
import org.junit.Before;
|
|
import org.junit.Test;
|
|
import org.w3c.dom.Element;
|
|
import org.w3c.dom.NamedNodeMap;
|
|
import org.w3c.dom.Node;
|
|
import org.w3c.dom.NodeList;
|
|
|
|
public class FwsQueryTest {
|
|
|
|
String scope="/gcube/devsec";
|
|
|
|
@Before
|
|
public void setscope(){
|
|
ScopeProvider.instance.set(scope);
|
|
}
|
|
|
|
// @Test
|
|
public void getServerFws(){
|
|
SimpleQuery query = queryFor(GenericResource.class);
|
|
DiscoveryClient<GenericResource> client = clientFor(GenericResource.class);
|
|
List<GenericResource> resources = client.submit(query);
|
|
List<GenericResource> filteredResources = new ArrayList<GenericResource>();
|
|
for (GenericResource gr:resources) {
|
|
String serviceName = gr.profile().name();
|
|
if (serviceName.equalsIgnoreCase("MongoDBServer")) {
|
|
XPathHelper helper = new XPathHelper(gr.profile().body());
|
|
List<String> list= helper.evaluate("server_list/server/@ip");
|
|
String[] server=new String[list.size()];
|
|
int i=0;
|
|
for(String s : list){
|
|
System.out.println("string founded: "+s);
|
|
server[i]=s;
|
|
i++;
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
@Test
|
|
public void getServerFwsWithoutXPATh(){
|
|
SimpleQuery query = queryFor(GenericResource.class);
|
|
DiscoveryClient<GenericResource> client = clientFor(GenericResource.class);
|
|
List<GenericResource> resources = client.submit(query);
|
|
List<GenericResource> filteredResources = new ArrayList<GenericResource>();
|
|
String[] server=new String[3];
|
|
for (GenericResource gr:resources) {
|
|
String serviceName = gr.profile().name();
|
|
if (serviceName.equalsIgnoreCase("MongoDBServer")) {
|
|
|
|
Element body=gr.profile().body();
|
|
NodeList nodes=body.getChildNodes();
|
|
Node node=nodes.item(0);
|
|
NodeList serversNode = node.getChildNodes();
|
|
int i=0;
|
|
Node s=serversNode.item(i);
|
|
while(s!=null){
|
|
NamedNodeMap maps=s.getAttributes();
|
|
if(maps==null)
|
|
break;
|
|
Node ip1=maps.getNamedItem("ip");
|
|
server[i]=ip1.getNodeValue();
|
|
i++;
|
|
s=serversNode.item(i);
|
|
}
|
|
|
|
|
|
|
|
for(int j=0; j<server.length; j++){
|
|
System.out.println("s" +j+" = "+server[j]);
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
@Test
|
|
public void getRR() throws Exception{
|
|
System.out.println("retrieve server from RuntimeResource");
|
|
ISClientConnector isConnector= new ISClientConnector();
|
|
ServiceEndpoint resource = isConnector.getStorageEndpoint(scope);
|
|
String[] server=isConnector.retrieveConnectionInfo(resource);
|
|
for(int j=0; j<server.length; j++){
|
|
System.out.println("s" +j+" = "+server[j]);
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|