连接池 ExclusiveDBConnectionPool

已有构造方法保持不变：

public ExclusiveDBConnectionPool(
    String host,
    int port,
    String uid,
    String pwd,
    int count,
    boolean loadBalance,
    boolean enableHighAvailability
) throws IOException

public ExclusiveDBConnectionPool(
    String host,
    int port,
    String uid,
    String pwd,
    int count,
    boolean loadBalance,
    boolean enableHighAvailability,
    String[] highAvailabilitySites,
    String initialScript,
    boolean compress,
    boolean useSSL,
    boolean usePython
) throws IOException

参数介绍：

host String 类型，表示主机名。

port int 类型，表示端口。

uid String 类型，可选参数，表示登录的用户名，默认值为空。

pwd String 类型，可选参数，表示登录的密码，默认值为空。

count 正整数，表示固定连接数模式下连接池中的连接数量。当提交的任务数量大于连接数时，部分任务会等待，直到出现空闲连接后再执行。

loadBalance boolean 类型，表示初始化连接时是否开启负载均衡。

enableHighAvailability boolean 类型，可选参数，表示是否针对连接池中的连接开启高可用，默认值为 false。

highAvailabilitySites String 数组类型，可选参数，表示所有可用节点的地址和端口，格式为 ip:port。须开启 enableHighAvailability 后才可使用，默认为 null。

initialScript String 类型，可选参数，表示初始化脚本，默认为空。

compress boolean 类型，可选参数，表示是否在下载时压缩数据，默认值为 false。

useSSL boolean 类型，可选参数，表示是否使用 SSL 连接，默认值为 false。若要开启 SSL 连接，服务器端配置文件须同时配置 enableHTTPS=true。

usePython boolean 类型，可选参数，表示是否开启 Python 解析，默认值为 false。

兼容性说明：

• 自 Java API 3.00.5.2 版本起，已有构造方法中的 count 在内部映射为 minimumPoolSize，同时设置 maximumPoolSize = count，因此仍保持固定连接数行为。使用已有构造方法时，不会触发动态扩容，也不会触发 idleTimeout 空闲回收。

自 Java API 3.00.5.2 版本起，新增以下构造方法：

public ExclusiveDBConnectionPool(
    String host,
    int port,
    String uid,
    String pwd,
    int minimumPoolSize,
    int maximumPoolSize,
    int idleTimeout,
    boolean loadBalance,
    boolean enableHighAvailability
) throws IOException

public ExclusiveDBConnectionPool(
    String host,
    int port,
    String uid,
    String pwd,
    int minimumPoolSize,
    int maximumPoolSize,
    int idleTimeout,
    boolean loadBalance,
    boolean enableHighAvailability,
    String[] highAvailabilitySites,
    String initialScript,
    boolean compress,
    boolean useSSL,
    boolean usePython
) throws IOException

新增参数介绍：

minimumPoolSize 正整数，表示连接池初始化时创建的最小 worker/连接数。空闲回收不会使当前连接数低于该值。默认值为 5；若设置值小于等于 0，则使用默认值 5。

maximumPoolSize 正整数，表示连接池允许扩容到的最大 worker/连接数。默认值为 5；若设置值小于等于 0，则使用默认值 5；若小于 minimumPoolSize，则会被设置为 minimumPoolSize。

idleTimeout int 类型，表示超过 minimumPoolSize 的 worker 保持空闲状态的最长时间，单位为毫秒。超过该时间后，worker 会退出并关闭其独占的 DBConnection。默认值为 600000，即 10 分钟；最小有效值为 10000，即 10 秒；若设置值小于 10000，则使用默认值 600000。

自 Java API 3.00.5.2 版本起，新增 ExclusiveDBConnectionPoolConfig 配置类，用于承载连接参数和弹性连接池参数。

public ExclusiveDBConnectionPool(ExclusiveDBConnectionPoolConfig config) throws IOException

ExclusiveDBConnectionPoolConfig 仅可通过 setXxx 方法配置参数，示例如下：

ExclusiveDBConnectionPoolConfig config = new ExclusiveDBConnectionPoolConfig();
config.setHostName(HOST);
config.setPort(PORT);
config.setUserId(USER);
config.setPassword(PASSWORD);
config.setMinimumPoolSize(1);
config.setMaximumPoolSize(3);
config.setIdleTimeout(10000);
config.setLoadBalance(false);
config.setEnableHighAvailability(false);

ExclusiveDBConnectionPool pool = new ExclusiveDBConnectionPool(config);

ExclusiveDBConnectionPoolConfig 支持的参数如下：

hostName String 类型，表示主机名，默认值为 localhost。

port int 类型，表示端口，默认值为 8848。

userId String 类型，表示登录的用户名，默认值为空。

password String 类型，表示登录的密码，默认值为空。

minimumPoolSize 正整数，表示连接池中最小 worker/连接数，默认值为 5。

maximumPoolSize 正整数，表示连接池中允许同时存在的最大 worker/连接数，默认值为 5。

idleTimeout int 类型，表示超过 minimumPoolSize 的 worker 可保持空闲状态的最长时间，单位为毫秒，默认值为 600000。

initialScript String 类型，表示初始化脚本，默认为空。

compress boolean 类型，表示是否在下载时压缩数据，默认值为 false。

useSSL boolean 类型，表示是否使用 SSL 连接，默认值为 false。

usePython boolean 类型，表示是否开启 Python 解析，默认值为 false。

loadBalance boolean 类型，表示是否开启负载均衡，默认值为 false。

enableHighAvailability boolean 类型，表示是否开启高可用，默认值为 false。

highAvailabilitySites String 数组类型，表示开启高可用情况下指定的主机名和端口号数组，默认为 null。

自 Java API 3.00.5.2 版本起，count 与新增参数的关系如下：

注意：已有构造方法中的 count 对外含义不变，仍表示固定连接数。它不会因为新增了 minimumPoolSize、maximumPoolSize、idleTimeout 而自动变成弹性连接池。

Java API 提供 BasicDBTask 对象帮助用户创建任务。BasicDBTask 包装了需要执行的脚本、参数、执行状态和结果。

构造方法：

public BasicDBTask(String script)

参数介绍：

script String 类型，表示要执行的脚本。

示例代码：

public void demoBasicDBTask() {
    BasicDBTask task = new BasicDBTask("x=1; x;");
}

创建任务后，可以使用 execute 方法向连接池提交任务。

task DBTask 类型，表示单个任务对象。

tasks List<DBTask> 类型，表示批量任务对象。

timeOut int 类型，表示等待任务结束的超时时间，单位为毫秒。默认值为 -1，表示一直等待任务结束。

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

public void demoExclusiveDBConnectionPool() throws IOException {
    ExclusiveDBConnectionPool pool = new ExclusiveDBConnectionPool(
        HOST,
        PORT,
        USER,
        PASSWORD,
        5,
        false,
        false
    );

    DBTask task = new BasicDBTask("x=1; x;");
    pool.execute(task, 10000);
    pool.shutdown();
}

当需要同时提交多个任务时，可以声明一个泛型为 DBTask 的 List，实现一次提交多个任务。

public void demoExclusiveDBConnectionPool() throws IOException {
    DBConnectionPool pool = new ExclusiveDBConnectionPool(
        HOST,
        PORT,
        USER,
        PASSWORD,
        5,
        false,
        false
    );

    List<DBTask> dbTaskList = new ArrayList<>();
    dbTaskList.add(new BasicDBTask("1 + 1"));
    dbTaskList.add(new BasicDBTask("x = 1; x;"));
    dbTaskList.add(new BasicDBTask("sum(1 2 3 NULL 4);"));

    pool.execute(dbTaskList);
    pool.shutdown();
}

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

使用示例：

public void demoExclusiveDBConnectionPool() throws IOException {
    DBConnectionPool pool = new ExclusiveDBConnectionPool(
        HOST,
        PORT,
        USER,
        PASSWORD,
        5,
        false,
        false
    );

    DBTask task = new BasicDBTask("sum(1 2 3 NULL 4);");
    pool.execute(task);

    System.out.println(task.isSuccessful());
    System.out.println(task.getResult());
    System.out.println(task.getErrorMsg());

    pool.shutdown();
}

执行结果：

true
10
null