/**
 *  This program is to execute a simple query
 *  select count(*) from SCOP.cla 
 */

import uk.org.ogsadai.client.toolkit.GenericServiceFetcher;
import uk.org.ogsadai.client.toolkit.Response;
import uk.org.ogsadai.client.toolkit.activity.ActivityRequest;
import uk.org.ogsadai.client.toolkit.activity.sql.SQLQuery;
import uk.org.ogsadai.client.toolkit.activity.sql.WebRowSet;
import uk.org.ogsadai.client.toolkit.service.DataService;
import uk.org.ogsadai.client.toolkit.ResourceID;
import uk.org.ogsadai.client.toolkit.activity.* ;

public class SimpleClient 
{
    public static void main(String[] args) throws Exception 
    {
	// URL of data service
	String handle = "http://romeo.urz.tu-dresden.de:8080/wsrf/services/ogsadai/MyService";
	String id = "MySCOP";
	DataService service = GenericServiceFetcher.getInstance().getDataService(handle,id);

	// to get all the data resources that are available under this data service
	ResourceID[] resources = service.getResourceIDs();

	//Print all data resources offered by this data service
	for (int i =0; i < resources.length; i++)
	{
	    System.out.println(resources[i].getName());
	}
      
        // you can tell the service to use the particular resource of a data service
	// service.setResourceID(resources[0]);

	// construct the SQL query
	SQLQuery query =  new SQLQuery("select count(*) from cla;");
	System.out.println(query.getExpression()); 
       
	// Connect the output of the SQLQuery activity to a WebRowSet actovoty tp encode 
	// it as am XML document
	WebRowSet rowset = new WebRowSet( query.getOutput() );
	
	ActivityRequest request = new ActivityRequest();
        request.add( query );
        request.add( rowset );
	System.out.println("OK1") ;
	
	service.setResourceID(resources[1]);
	Response response = service.perform( request );
	System.out.println("OK2") ;
	System.out.println(response.getAsString());
    }
}