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语句。这么结合这两个程序实现对数据库的批量查询,怎么保存查询的结果?
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语句。这么结合这两个程序实现对数据库的批量查询,怎么保存查询的结果?
2、循环你的ems
3、循环体内执行一次查询,并获得一个结果集
4、每个结果集放到Map中,key=执行的sql value=List结果集
可是具体怎么编啊,我是菜鸟。求教!!!!!1