基于Java连接池Druid的应用开发

前提条件

• 已安装Java环境，要求安装JDK 1.8及以上版本。

• 已配置白名单，具体操作，请参见设置白名单。

• 宽表引擎的版本为2.3.1及以上版本，如何升级版本，请参见升级小版本。

准备工作

• 通过连接池Druid连接Lindorm宽表引擎前，需要安装连接池Druid和Lindorm JDBC Driver。以Maven项目为例，在pom.xml文件的dependencies中添加以下依赖项。

  <dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>1.2.11</version>
  </dependency>
  <dependency>
    <groupId>com.aliyun.lindorm</groupId>
    <artifactId>lindorm-all-client</artifactId>
    <version>2.2.1.3</version>
  </dependency>

• 当通过druid-spring-boot-starter使用Druid连接池时，需要先排除druid-spring-boot-starter依赖的Druid组件，然后显式依赖Druid组件，如下所示。

  <dependency>
     <groupId>com.alibaba</groupId>
     <artifactId>druid-spring-boot-starter</artifactId>
     <version>1.2.11</version>
     <exclusions>
        <exclusion>
           <groupId>com.alibaba</groupId>
           <artifactId>druid</artifactId>
        </exclusion>
     </exclusions>
  </dependency>
  <dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>1.2.11</version>
  </dependency>
  <dependency>
    <groupId>com.aliyun.lindorm</groupId>
    <artifactId>lindorm-all-client</artifactId>
    <version>2.2.1.3</version>
  </dependency>

操作步骤

1. 配置连接池Druid的参数。在Maven项目的src/main/resources目录中新建druid.properties文件，并在文件中添加以下内容。

   # 驱动类名，无需替换
   driverClassName=com.aliyun.lindorm.table.client.Driver
   # url、username、password需要替换为业务实际的内容，可以在Lindorm控制台上获取
   url=jdbc:lindorm:table:url=http://ld-bp17j28j2y7pm****.lindorm.rds.aliyuncs.com:30060
   username=****
   password=****
   # 连接属性，指定要连接的database，需根据实际情况将****替换为实际的内容
   connectionProperties=database=****
   
   # 初始化连接池即创建连接，建议保持不变
   init=true
   # 初始化连接池时建立连接的个数，可以根据实际情况调整
   initialSize=10
   # 连接池中允许的最小空闲连接数量，可以根据实际情况调整
   minIdle=10
   # 连接池中允许的最大连接数量，可以根据实际情况调整
   maxActive=20
   # 获取连接最大等待时间，单位毫秒，建议保持不变
   maxWait=30000
   
   # 连接保活配置项，建议保持不变，否则可能出现连接断开
   # 异常ConnectionDisconnectedException
   druid.keepAlive=true
   druid.keepAliveBetweenTimeMillis=30000
   minEvictableIdleTimeMillis=600000
   maxEvictableIdleTimeMillis=900000
   timeBetweenEvictionRunsMillis=5000
   
   # 连接验证配置项，建议保持不变
   validationQuery=SELECT 1
   testWhileIdle=true
   testOnBorrow=false
   testOnReturn=false
   
   # PreparedStatement缓存配置项，这里配置为关闭缓存，建议保持不变
   # 否则运行时可能会出现NoSuchStatement异常
   poolPreparedStatements=false
   maxOpenPreparedStatements=-1
   druid.maxPoolPreparedStatementPerConnectionSize=-1

   说明

   • 请根据注释说明替换或者调整以下配置项：

     • url：连接宽表引擎的连接地址，获取方法请参见获取连接地址。

     • username：访问宽表引擎的用户名，通过Lindorm宽表引擎的集群管理系统查看，具体请参见管理用户。

     • password：访问宽表引擎的密码。如果您忘记了密码，可以通过Lindorm宽表引擎的集群管理系统修改密码，具体操作请参见修改用户密码。

   • 更多配置项的说明请参见DruidDataSource配置属性列表。

2. 加载连接池Druid的参数并初始化连接池Druid。

   // 加载参数
   Properties properties = new Properties();
   InputStream inputStream = DruidPoolDemo.class.getClassLoader().getResourceAsStream("druid.properties");
   properties.load(inputStream);
   // 初始化连接池
   DataSource dataSource = DruidDataSourceFactory.createDataSource(properties);

3. 通过连接池Druid获取JDBC的连接信息并访问Lindorm宽表引擎。

   /* -------------- 基于JDBC的访问示例 ----------------- */
   
   String tableName = "sql_table_" + new Random().nextInt(1000);
   // 创建表
   try (Connection connection = dataSource.getConnection()) {
       try (Statement statement = connection.createStatement()) {
           String sql = "create table if not exists " + tableName + "(id VARCHAR, name VARCHAR, primary key(id))";
           int ret = statement.executeUpdate(sql);
           System.out.println(ret);
       }
   }
   
   // 插入数据
   try (Connection connection = dataSource.getConnection()) {
       String sql = "upsert into " + tableName + "(id,name) values(?,?)";
       try (PreparedStatement ps = connection.prepareStatement(sql)) {
           ps.setString(1, "aa");
           ps.setString(2, "bb");
   
           int ret = ps.executeUpdate();
           System.out.println(ret);
       }
   }
   
   // 查询数据
   try (Connection connection = dataSource.getConnection()) {
       String sql = "select * from " + tableName + " where id=?";
       try (PreparedStatement ps = connection.prepareStatement(sql)) {
           ps.setString(1, "aa");
           ResultSet rs = ps.executeQuery();
           while (rs.next()) {
               String id = rs.getString(1);
               String name = rs.getString(2);
               System.out.println("id=" + id);
               System.out.println("name=" + name);
           }
       }
   }
   
   // 删除数据
   try (Connection connection = dataSource.getConnection()) {
       String sql = "delete from " + tableName + " where id=?";
       try (PreparedStatement ps = connection.prepareStatement(sql)) {
           ps.setString(1, "aa");
           ps.executeUpdate();
       }
   }