被 JAVA 调用
可以将集算器嵌入到Java应用程序中。使用时类似于用JDBC访问数据库的方式调用集算器网格程序。在过程中，网格程序被包装成存储过程，因此调用方法与调用存储过程相同。
基本使用
集算器JDBC类似一个不带物理表的数据库JDBC驱动，可以把它简单的看成是一个只有存储过程的数据库。另外，集算器JDBC是个完全嵌入式计算引擎，已经在JDBC中完成了所有运算，不象数据库那样JDBC只是个接口，实际运算在独立的数据库服务器完成。
可参考6.3 JDBC部署 先完成程序的部署。
集算器JDBC使用的网格文件
与用call函数跨网格调用时类似，在集算器JDBC中使用的网格代码中，结果集需要通过return语句返回。如下面的网格文件createTable1.dfx：
|
|
A |
B |
|
1 |
=create(ID,Amount) |
|
|
2 |
for 100 |
>A1.insert(0,#A2,rand(100*100)) |
|
3 |
return A1 |
|
这个网格中的计算比较简单：生成一个100条记录的序表，包含顺序设定的ID字段与随机生成的Amount字段。在A3中，用return语句将A1中的序表返回。
下面我们将使用这个网格文件，熟悉在JAVA中调用集算器JDBC的方法。
用JAVA调用的基本方法
在调用集算器执行网格文件前，首先需要按下面步骤配置相关的信息：
1. 加载需要用到的jar包。在启动JAVA应用程序时需要的jar包（6.3 JDBC部署 中有jar包说明），如果在web应用下，可以把这些jar包放在WEB-INF/lib目录下
2. 部署raqsoftConfig.xml
在raqsoftConfig.xml中包含了集算器的基本配置信息，如授权、寻址路径、主目录、数据源配置等，以及集算器的并发数等信息，日志文件信息以及连接池信息，它可以在集算器的[安装目录]\esProc\config路径下找到，其中存储的信息与集算器的选项页面中设定相同。在部署时可以先调整其中的配置。
注意：配置文件需复制后放置在应用项目的类路径下，但名称必须为raqsoftConfig.xml，不能改变。关于配置文件的具体解释，可以参考6.3JDBC部署。
3. 部署dfx文件
将上面的createTable1.dfx放到应用项目的类路径下，也可以放到raqsoftConfig.xml文件的<dfxPathList/>节点指定的寻址路径，或者<mainPath/>指定的主路径中。
4. 在JAVA中调用dfx
public void testDataServer(){
Connection con = null;
java.sql.PreparedStatement st;
try{
//建立连接
Class.forName("com.esproc.jdbc.InternalDriver");
con= DriverManager.getConnection("jdbc:esproc:local://");
//调用存储过程，其中createTable1是dfx的文件名
st =con.prepareCall("call createTable1()");
//执行存储过程
st.execute();
//获取结果集
ResultSet rs = st.getResultSet();
//简单处理结果集，将结果集中的字段名与数据输出
ResultSetMetaData rsmd = rs.getMetaData();
int colCount = rsmd.getColumnCount();
for ( int c = 1; c <= colCount;c++) {
String title = rsmd.getColumnName(c);
if ( c > 1 ) {
System.out.print("\t");
}
else {
System.out.print("\n");
}
System.out.print(title);
}
while (rs.next()) {
for (int c = 1; c<= colCount; c++) {
if ( c > 1 ) {
System.out.print("\t");
}
else {
System.out.print("\n");
}
Object o = rs.getObject(c);
System.out.print(o.toString());
}
}
}
catch(Exception e){
System.out.println(e);
}
finally{
//关闭连接
if (con!=null) {
try {
con.close();
}
catch(Exception e) {
System.out.println(e);
}
}
}
}
在调用集算器文件时，用"call createTable1()"语句，即可运行网格文件createTable1.dfx并将结果返回为ResultSet对象。在后续的程序中，简单将结果集中的数据输出。程序运行后，输出结果如下：
调用不同的网格文件
在1.3用JAVA调用的基本方法中，我们了解了如何在JAVA程序中调用一个网格文件。在这里我们详细了解一下如何调用不同的网格文件。先来看下面的网格文件createTable2.dfx：
|
|
A |
B |
|
1 |
=connect("demo") |
|
|
2 |
=A1.query("select * from EMPLOYEE") |
=A2.select(month(BIRTHDAY)==month(Date)&&day(BIRTHDAY)==day(Date)) |
|
3 |
>A1.close() |
|
|
4 |
if B2.len()>1 |
return B2.new(EID,NAME+ " "+ SURNAME:NAME, GENDER, BIRTHDAY) |
|
5 |
else |
return "None" |
在这个网格文件中，需要从数据源demo中获取数据，同时使用了日期类型的参数Date：
在网格中使用的demo数据源，需要在raqsoftConfig.xml文件中配置，具体方法可以参考6.3JDBC部署。在网格中创建的数据源连接，在使用后应该用db.close() 函数关闭。
在JAVA中调用时，建立连接、输出结果等部分的代码是完全相同的，调用文件部分如下：
//调用存储过程，其中createTable2是dfx的文件名，?代表使用的参数
st =con.prepareCall("call createTable2(?)");
//设置参数
java.util.Calendar calendar = java.util.Calendar.getInstance();
calendar.set(1980, 0, 1);
st.setObject(1, calendar.getTime());
//执行存储过程
st.execute();
//获取结果集
ResultSet rs = st.getResultSet();
这个网格文件包含一个参数，因此调用时使用"call createTable2(?)"，其中的 ? 代表需要输入的参数。在这种情况下需要用st.setObject() 方法输入参数。输入参数时，将按次序设入参数，而与网格中参数的名称无关。网格文件将根据输入的日期列出生日与之在同一天的员工，需要注意的是在Calendar类中设置日期时，月份是从0开始的。结果集输出如下：
在输入参数时，除了直接按照类型输入参数对象，日期类型的参数也可以输入字符串，由集算器自动解析：
//设置参数
st.setObject(1, "1/1/1980");
注意输入字符串需要符合raqsoftConfig.xml文件中设置的日期格式。程序运行的结果和上面是相同的。
除了上面的调用方法，还可以把参数写定在语句中，如：
//调用存储过程，其中createTable2是dfx的文件名，在语句中写定参数
st =con.prepareCall("call createTable2(\"2/29/1980\")");
//执行存储过程
st.execute();
//获取结果集
ResultSet rs = st.getResultSet();
使用这样的调用方法时，不能根据参数类型输入对象，而只能使用数值型参数，或使用字符串型参数交由集算器解析。计算后，结果如下：
由于没有找到2月29日出生的员工，因此在网格的B5格中用return语句返回了字符串None。从上面的结果中我们可以发现，即使从网格返回的数据是单值，也会自动生成结果集中的列名，作为标准ResultSet返回。
无结果集和多个结果集
在调用网格文件时，还允许无返回数据。如下面的网格文件outputData1.dfx：
|
|
A |
|
1 |
$(demo) select * from CITIES |
|
2 |
=A1.select(Arg.pos(left(NAME,1))>0) |
|
3 |
=file("Cities.txt") |
|
4 |
>A3.export@t(A2) |
文件中使用了字符串序列类型的参数Arg：
在A1中，直接调用了demo数据库执行查询，而没有用connect语句创建连接。这种时候，需要raqsoftConfig.xml文件中数据库配置中，demo数据源的autoConnect属性为true：
<property name="autoConnect" value="true"/>
具体配置可以参考6.3JDBC部署。在JAVA中调用网格部分的代码如下：
//调用存储过程，其中outputData1是dfx的文件名
st =con.prepareCall("call outputData1(?)");
//设置参数
com.raqsoft.dm.Sequence seq = new com.raqsoft.dm.Sequence();
seq.add("A");
seq.add("B");
seq.add("C");
st.setObject(1, seq);
//执行存储过程
boolean hasResult = st.execute();
//此时没有结果集，无法获取，hasResult为false
值得注意的是，在网格中使用了序列类型的参数，对于这样的类型，只能生成Sequence对象设入。设入序列参数[A,B,C]后，将首字母为A,B,C的城市信息输出到文件Cities.txt。当网格中使用的文件未指定路径时，将存入主路径中，由raqsoftConfig.xml文件的<mainPath/>节点所指定。文件中数据如下：
一个网格文件也可能返回多个结果集，如下面的网格文件createTable3.dfx：
|
|
A |
B |
|
1 |
$(demo) select EID, NAME+' '+SURNAME FULLNAME, GENDER, STATE, BIRTHDAY from EMPLOYEE |
|
|
2 |
=A1.select(STATE == state && age(BIRTHDAY)<age) |
|
|
3 |
=A2.select(GENDER=="F") |
=A2\A3 |
|
4 |
return A3 |
return B3 |
这个网格将年龄小于设定的age，以及在指定州state的员工，分性别返回为两个序表。网格中使用了两个参数，指定员工的最高年龄与所在州：
此时，网格文件在执行后，将返回多个结果集
//调用存储过程，其中createTable3是dfx的文件名，?代表使用的参数
st =con.prepareCall("call createTable3(?,?)");
//依次设置参数
st.setObject(1, 30);
st.setObject(2, "California");
//执行存储过程
boolean hasResult = st.execute();
//获取多个结果集并输出结果
while (hasResult) {
ResultSet rs = st.getResultSet();
//输出结果
ResultSetMetaData rsmd = rs.getMetaData();
int colCount = rsmd.getColumnCount();
for ( int c = 1; c <= colCount;c++) {
String title = rsmd.getColumnName(c);
if ( c > 1 ) {
System.out.print("\t");
}
else {
System.out.print("\n");
}
System.out.print(title);
}
while (rs.next()) {
for (int c = 1; c<= colCount; c++) {
if ( c > 1 ) {
System.out.print("\t");
}
else {
System.out.print("\n");
}
Object o = rs.getObject(c);
System.out.print(o.toString());
}
}
System.out.println();
//查看是否返回了其它结果集
hasResult = st.getMoreResults();
}
执行后，分别读出California州且30岁以下的女员工与男员工，输出结果如下：
网格文件createTable3.dfx中，两个排列也可以用一条语句返回：return A3,B3，在JAVA中调用的情况和上面是相同的。
直接执行语句
在JAVA程序中使用集算器时，除了调用一个网格文件，还可以直接执行语句。实际上，调用网格文件，也可以作为call语句直接执行。在这里我们详细了解一下如何直接执行其它语句。如：
//直接执行语句，返回结果集
st = con.createStatement();
ResultSet rs1 = st.executeQuery("=age(date(\"1/1/1990\"))");
ResultSet rs2 = st.executeQuery("=5.(~*~)");
这里用executeQuery方法直接执行以=开头的集算器表达式，并将表达式的计算结果返回为结果集，注意表达式中的双引号需要在前面添加转义符。如果仍然用前面类似的代码将结果集输出，结果如下：
可以注意到如果返回的结果为序列，那么在JDBC中会返回1列多行的结果集。也可以用另外的方法调用：
//先判断是否有结果集，再获取结果
boolean hasResult1 = st.execute("=age(date(\"1/1/1990\"))");
ResultSet rs1,rs2;
if (hasResult1) {
rs1 = st.getResultSet();
}
boolean hasResult2 = st.execute("=5.(~*~)");
if (hasResult2) {
rs2 = st.getResultSet();
}
使用execute方法时，会根据执行的语句返回是否有结果集，代码的效果和前面是相同的。
如果需要在语句中使用参数，可以使用(x1, x2,…)操作符，依次计算表达式，并返回最后一个的结果，如：
st =con.createStatement();
ResultSet rs1 = st.executeQuery("=(pi=3.14,r=4,r*r*pi)");
计算圆的面积，输出结果集如下：
在执行语句时，语句中可以使用参数，按照PreparedStatement中的设定顺序，在语句中用固定的名称arg1,arg2,…等调用。如：
PreparedStatement pst = con.prepareStatement("=arg1*arg1*arg2");
pst.setObject(1,3);
pst.setObject(2,3.14);
ResultSet rs = pst.executeQuery();
计算半径为3的圆面积，输出结果集如下：
在集算器JDBC中还可以使用$开头的数据集查询语句。如：
//执行数据库查询语句
st = con.createStatement();
ResultSet rs1 = st.executeQuery("$(demo) select * from CITIES where POPULATION > 2000000");
注意此时使用的数据集demo，需要在配置中设为自动连接。结果如下：
在调用网格文件时，可以使用文件名，而省略call，如：
st =con.createStatement();
boolean hasResult1 = st.execute("createTable3 30,\"California\"");
执行时，会调用网格文件createTable3.dfx。如果文件中需要设入参数，参数需要在语句中写定，且与文件名之间用空格分隔。上面语句执行后，同样能够返回多结果集，结果和前面是相同的：
在JDBC中，还可以执行一片多行多列的网格代码。执行时，需要将代码拼为一个字符串，行之间用\n分隔，同一行的各列之间用\t分隔。如：
ResultSet rs = st.executeQuery("=[1,1]\nfor 10\t>A1=A1|(A1.m(-1)+A1.m(-2))\nreturn A1");");
执行这个字符串时，相当于计算下面的网格：
|
|
A |
B |
|
1 |
=[1,1] |
|
|
2 |
for 10 |
>A1=A1|(A1.m(-1)+A1.m(-2)) |
|
3 |
return A1 |
|
如果将得到的ResultSet输出，则结果如下：
