运行 run/tryRun

只传入 script，即要执行的脚本。

@Test
public void test_run_script() throws IOException {
    DBConnection dbConnection = new DBConnection();
    dbConnection.connect("192.168.0.68", 8848);
    Entity entiry = dbConnection.run("x = 1; x;");
    System.out.println(entiry.getString());
}

执行结果：

1

public Entity run(String function, List<Entity> arguments)

以下为通过 run 方法执行 tableInsert 函数的代码示例：

public void test_run_function_tableInsert() throws Exception {
    DBConnection dbConnection = new DBConnection();
    dbConnection.connect("192.168.0.68", 8848);
    int n=5000000;
    List<String> colNames = new ArrayList<>();
    colNames.add("date");
    colNames.add("val");
    int[] time = new int[n*2];
    double[] val = new double[n*2];

    int baseTime = Utils.countDays(2000,1,1);
    for (int i = 0; i < n*2; i++) {
        time[i] = baseTime + (i % 15);
        val[i] = rand.nextDouble();
    }
    List<Vector> colVectors = new ArrayList<>();
    BasicDateVector dateVector = new BasicDateVector(time);
    colVectors.add(dateVector);
    dateVector.setCompressedMethod(1);
    BasicDoubleVector valVector = new BasicDoubleVector(val);
    valVector.setCompressedMethod(2);
    colVectors.add(valVector);

    BasicTable table = new BasicTable(colNames, colVectors);

    List<Entity> args = Arrays.asList(table);
    conn.run("t = table(100000:0,`date`val,[DATE,DOUBLE])" +
            "share t as st");
            
    // 执行 tableInsert
    conn.run("tableInsert{st}", args);
}

这里指定表名 ts，返回值能够获取对应的表结构。

@Test
public void testRun() throws IOException {
    DBConnection dbConnection = new DBConnection();
    dbConnection.connect("192.168.0.68", 8848);
    dbConnection.run("ts = table(1..100 as a,take(`a`b`c,100) as b)");
    BasicTableSchema tableSchema = (BasicTableSchema) dbConnection.run("select * from ts", "ts");
    System.out.println(tableSchema.getString());
}

执行结果：

cols :2
rows :100
name            typeString      typeInt         colIndex        
a               DT_INT          4               0               
b               DT_STRING       18              1  

使用 run 方法时，有时为减少内存占用，希望 server 能在执行完毕后自动释放 run 语句中创建的变量。此时可通过设置 clearMemory = true 来实现。

以下测试 case 执行一个脚本，并设置 priority 优先级为4，同时开启 clearSessionMemory 功能。

@Test
public void testRun3() throws IOException {
    DBConnection dbConnection = new DBConnection();
    dbConnection.connect("192.168.0.68", 8848);
    dbConnection.run("x=1;", 4, true);
    Entity entity = dbConnection.run("x;");
    System.out.println(entity.getString());
}

执行结果：

java.io.IOException: 192.168.0.68:8848 Server response: 'Syntax Error: [line #1] Cannot recognize the token x' script: 'x;'

由于 x 在第一次 run 执行完毕后被清除，所以再次执行 run("x") 会抛上述异常。

对于大数据量的表，Java API 提供了分段读取方法。（仅适用于 DolphinDB 1.20.5 及以上版本）

下例在 Java 客户端创建一个数据量大小为 22486 的表，并设置 fetchSize 为10000 来进行分块获取数据。在 run 方法中使用参数 fetchSize 指定分块大小 ，会返回一个 EntityBlockReader 对象，可通过 read() 方法一段段的读取数据。需要注意的是，fetchSize 取值不能小于 8192（记录条数）。

@Test
public void TestRun() throws IOException {
    DBConnection dbConnection = new DBConnection();
    dbConnection.connect("192.168.0.68", 8848);
    EntityBlockReader blockReader = (EntityBlockReader) dbConnection.run("table(1..22486 as id)", (ProgressListener) null, 4, 4, 10000);
    while (blockReader.hasNext()) {
        System.out.println(data.rows());
        BasicTable t = (BasicTable) blockReader.read();
        // 对读出来的数据进行处理
        // ...
    }
}

执行结果：

10000
20000
2486

注意，使用上述分段读取的方法时，若数据未读取完毕，需要调用 skipAll() 方法来放弃读取后续数据，才能继续执行后续代码。否则会导致套接字缓冲区滞留数据，引发后续数据的反序列化失败。示例代码如下：

@Test
public void testFetchDataInt() throws IOException {
    DBConnection dbConnection = new DBConnection();
    dbConnection.connect("192.168.0.68", 8848);
    EntityBlockReader blockReader = (EntityBlockReader) dbConnection.run("table(1..22486 as id)", (ProgressListener) null, 4, 4, 10000);
    // Only read 10000.
    BasicTable data = (BasicTable) blockReader.read();

    // Skip remain data.
    blockReader.skipAll();
    // After skip remain data, follow-up code could run. If not, it would throw exception.
    dbConnection.run("1==1;");
}

可以设置脚本执行期间使用的监听器 listener，在脚本执行时 server 端会返回用户打印的信息，示例如下：

@Test
public void testRun5() throws IOException{
    DBConnection dbConnection = new DBConnection();
    dbConnection.connect("192.168.1.167", 18921);

    ProgressListener listener = new ProgressListener() {
        @Override
        public void progress(String message) {
            System.out.println("message: \n" + message);
        }
    };
    Entity entity = dbConnection.run("t = table(1..5 as id, rand(100, 5) as price); print t; select * from t where id=4;", listener);
    System.out.println("select one record: \n" + entity.getString());
}

执行结果：

Connect to 192.168.1.167:18921.
message: 
id price
-- -----
1  9    
2  11   
3  81   
4  78   
5  1    

select one record: 
id price
-- -----
4  78