Lindorm：基於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();
       }
   }