连接池 ExclusiveDBConnectionPool

Java API 提供了 BasicDBTask 对象帮助用户创建一个任务。BasicDBTask 包装了需要执行的脚本、参数、执行的状态和结果。以下为 BasicDBTask 构造方法：

public BasicDBTask(String script)

参数介绍：

script 表示要执行的脚本。

示例代码：

@Test
public void testBasicDBTask() {
    BasicDBTask task = new BasicDBTask("x=1;");
}

创建好任务后，您可以使用 excute 方法向连接池提交一个任务，execute 方法参数如下：

task 任务对象。

tasks 批量任务对象，当需要提交多个任务时，使用 tasks 替代 task。

timeOut 超时时间，单位毫秒数，可选参数；默认值为-1，表示一直等待任务结束。

代码示例如下，执行一个简单脚本任务，并设置超时时间为 10000：

@Test
public void testExclusiveDBConnectionPool() throws IOException {
    ExclusiveDBConnectionPool pool = new ExclusiveDBConnectionPool("192.168.0.68",8848,"admin","123456",5,false,false);
    DBTask task = new BasicDBTask("x=1; x;");
    pool.execute(task, 10000);
    pool.shutdown();
}

当需要同时提交多个任务时，为避免逐个提交的复杂性，用户可以声明一个泛型为BasicDBTask 的 List 以实现一次提交多个任务的目的。示例代码如下（其中 DBTask 为BasicDBTask 类的接口）：

@Test
public void testExclusiveDBConnectionPool() throws IOException {
    DBConnectionPool pool = new ExclusiveDBConnectionPool("192.168.0.68",8848,"admin","123456",5,false,false);
    List<DBTask> dbTaskList = new ArrayList<>();
    dbTaskList.add(new BasicDBTask("select * from loadTable(\"dfs://test\",`tb1)"));
    dbTaskList.add(new BasicDBTask("x = 1; x;"));
    dbTaskList.add(new BasicDBTask("sum(1 2 3 NULL 4);"));
    pool.execute(dbTaskList);
    pool.shutdown();
}

可以通过 BasicDBTask 类的以下方法获取任务执行的返回值和信息：

• boolean isSuccessful() ：返回一个 boolean 类型，以查询是否执行成功。
• Entity getResult() ：返回一个 Entity 对象，以获取 Task 执行的返回值。
• String getErrorMsg()：返回一个 String 类型变量，以查询执行期间的错误信息。

使用示例：

@Test
public void testExclusiveDBConnectionPool() throws IOException {
    DBConnectionPool pool = new ExclusiveDBConnectionPool("192.168.0.68",8848,"admin","123456",5,false,false);
    DBTask task = new BasicDBTask("sum(1 2 3 NULL 4);");
    pool.execute(task);

    // 打印 task 是否执行成功
    System.out.println(task.isSuccessful());

    // 获取 task 执行结果
    System.out.println(task.getResult());

    // 获取 task 错误信息
    System.out.println(task.getErrorMsg());
}

执行结果：

Connect to 192.168.0.68:8848.
Connect to 192.168.0.68:8848.
Connect to 192.168.0.68:8848.
Connect to 192.168.0.68:8848.
Connect to 192.168.0.68:8848.
true
10
null

用户可通过调用线程池的 shutdown 方法来关闭一个线程池。示例代码如下：

dbConnectionPool.shutdown()

调用 shutdown() 会等待全部的连接池任务都执行完后再释放连接。