RDS - 连接关系型数据库服务

RDS是AWS CC的官方连接适配器，为上层应用场景提供统一的关系型数据库服务访问和管理。

主要功能

支持符合JDBC 2.0规范的SQL调用
提供常见开源和商业数据库驱动，内置数据库连接池
提供CCAPI封装，方便开发者使用
支持CC环境变量
支持SLA服务质量监控和告警通知，提供全局requestId
提供访问日志开关

特别说明

使用该应用要求AWS PaaS平台许可支持CC服务
使用该应用要求AWS PaaS平台版本不低于6.4.1

1.配置

以admin用户登录AWS PaaS控制台进入连接服务 > 连接，新建：数据源选择 RDS，弹出侧边栏填写相关属性，保存，点击测试一下，可进行试。

基本信息

项	说明
名称	RDS适配器的名称
用户名	数据库用户名，支持@公式，如@env(rdsXX)可获取环境中相应变量值
密码	数据库用户名对应口令，支持@公式，如@env(rdsXX)可获取环境中相应变量值
驱动	选择需要连接数据库的驱动类型，该列表可在应用参数中进行配置
URL地址	数据库URL地址，支持@公式，如@env(rdsXX)可获环境中相应变量值
连接池 > 初始化连接数	连接池默认初始化的连接数
连接池 > 最大连接数	连接池提供的最大连接数
描述	RDS描述信息，可在列表显示

相关JDBC驱动程序包存放在%AWS-HOME%/bin/jdbc目录下

不支持同一种数据库多JDBC版本情况

目前AWS PaaS平台支持的数据库类型请参见https://docs.awspaas.com/reference-guide/aws-paas-env-guide/runtime/server.html 如需求修改驱动列表，请保存列表范围为AWS PaaS平台支持的数据库类型

扩展属性

数据库链接的扩展属性，属性名可在应用参数中进行配置，各属性含义自行参考数据库JDBC属性说明。

maxAge 连接存活时间，单位毫秒，默认值为1小时。设置该值用于防止部分数据库例如mysql默认8小时过期时间
maxIdle 最大空闲数，数据库连接的最大空闲时间。超过空闲时间，数据库连接将被标记为不可用，然后被释放。设为0表示无限制
minIdle 最小空闲连接,连接池中容许保持空闲状态的最小连接数量，低于这个数量将创建新的连接，如果设置为0 则不创建
testWhileIdle 空闲时做连接可用性检查，可选值：true、false，默认true。该参数对数据库稳定性要求高的场景可以设为true
timeBetweenEvictionRunsMillis在空闲连接回收器线程运行期间休眠的时间值，以毫秒为单位。如果设置为非正数，则不运行空闲连接回收器线程这个值不应该小于1秒，它决定线程多久验证连接或丢弃连接
testOnBorrow 连接使用前做可用性检查，可选值：true、false，默认false。该参数设置为true会消耗一定资源，但对数据库稳定性要求高的场景可以设为true。
validationInterval (long) 避免过度验证，保证验证不超过这个频率——以毫秒为单位。如果一个连接应该被验证，但上次验证未达到指定间隔，将不再次验证
maxWait 单位毫秒，默认30秒。等待maxWait时间没能从连接池获得连接，抛出异常，避免线程因为等待连接阻塞

有关Tomcat jdbc属性官方说明参见：http://tomcat.apache.org/tomcat-8.5-doc/jdbc-pool.html

2.调用

通过AWS PaaS平台提供的CCAPI，操作连接器。

获取模型ID

在CC连接列表中可获取适配器模型ID。

API代码示例

Java代码中执行外部数据库操作，如select、insert、update。在访问前，我们假设已创建了一个CC RDS技术适配器，其分配的模型Id为00000000


import com.actionsoft.bpms.bpmn.engine.core.delegate.ProcessExecutionContext;
import com.actionsoft.bpms.bpmn.engine.listener.ExecuteListener;
import com.actionsoft.bpms.commons.database.DBUtils.SUPPLY;
import com.actionsoft.bpms.commons.database.RowMap;
import com.actionsoft.bpms.commons.database.tomcat.PoolTrackModel;
import com.actionsoft.sdk.local.SDK;
import com.actionsoft.sdk.local.api.cc.RDSAPI;

import java.sql.Connection;
import java.util.List;


/**
 * 需要在开发环境中引入AWS PaaS平台以下目录下所有jar包：
 * bin/lib目录下
 * bin/jdbc目录下
 * apps/install/com.actionsoft.apps.cc.connector.rds/lib目录下
 */
public class RDSAPITest  extends ExecuteListener {
    @Override
    public void execute(ProcessExecutionContext processExecutionContext) throws Exception {
        //获得一个操作外部数据库的RDSAPI对象
        RDSAPI rdsapi = SDK.getCCAPI().getRDSAPI("00000000");
        Connection conn = rdsapi.open();
        RowMap rowMap =  rdsapi.getMap("select * from orguser where userid = ?","admin");
        String username = rowMap.getString("username");
        String password = rowMap.getString("password");

        //查询sql取第一条数据集的第一列String值，如果没有满足要求的数据，返回空串
        String getstring = rdsapi.getString("select * from orguser", "admin");

        //查询sql取第一条数据集的第一列int值，如果没有满足要求的数据，返回0
        int getint = rdsapi.getInt("select * from orguser", "admin");

        //设置resultSet每次向数据库取的行数
        rdsapi.setFetchSize(-1);

        //设置resultSet最多返回的行数
        rdsapi.setMaxRows(-1);

        //获得当前数据库类型
        SUPPLY getsupply = rdsapi.getSupply();

        //获得当前CC RDS活动连接对象的跟踪信息，详细堆栈需日志参数开启
        List<PoolTrackModel> gettrace = rdsapi.getTrace();

        // 自定义查询
        rdsapi.query.....

        //基于回调接口
        rdsapi.execute......

        //......

        conn.close();
    }
}