package ogsadai;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.delivery.DeliverToFile;
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;public class SimpleExample {  // Copyright statement
  public static void main(String[] args) throws Exception {
              String handle = "http://grid1:8080/wsrf/services/ogsadai/DataService";
              String id = "OracleLResource";
              DataService service = GenericServiceFetcher.getInstance().getDataService(handle, id);
              SQLQuery query =
                        new SQLQuery("select * from all_tables");//怎么执行一系列的sql查询?
      WebRowSet rowset = new WebRowSet( query.getOutput() );
      ActivityRequest request = new ActivityRequest();
      DeliverToFile deliver = new DeliverToFile( "/test/myfile.txt" );
      deliver.setInput( query.getOutput());
      request.add( query );
      request.add( rowset );
      
              Response response = service.perform( request );
              System.out.println(response.getAsString());
              
  }
}
//////////////////////////////下面是把读取sql语句的程序
package test;import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
import java.util.ArrayList;public class Sql {
public static  void main(String[] args){
ArrayList<String> sqlList = new ArrayList<String>(); //从文件读放内容到按分号放到sqlFileList
    File fileDirectory=new File("D:/ioExample");//首先定义一个文件夹文件对象
    File streamFile=new File(fileDirectory,"streamFile.sql");//定义一个存放字节流数据的文件
    StringBuffer temp = new StringBuffer();
    try {
    BufferedReader in = new BufferedReader(new FileReader(streamFile));
    String str;
    while ((str = in.readLine()) != null) {
    temp.append(str);
    }
    in.close();
    } 
    catch (IOException e) {
    e.getStackTrace();
    }
    String[] sqls = temp.toString().split(";");
    for (String sql : sqls) {
    sqlList.add(sql);
    }  
    System.out.println("size:" + sqlList.size());    
        for (String sql : sqlList) {    
             System.out.println(sql);  
             
}
}
}
//sqllist中是所要查询的sql语句。这么结合这两个程序实现对数据库的批量查询,怎么保存查询的结果?