ApsaraDB RDS:Druid 接続プールを使用してデータベースに接続する

Druid を依存関係として追加する

pom.xml の dependencies セクションに以下を追加します。Druid 1.2.13 以降を使用してください。

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>1.2.19</version>
</dependency>

druid-spring-boot-starter を使用する場合、それがもたらす推移的な Druid 依存関係を除外し、バージョンが制御されるように Druid を明示的に再追加します。

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid-spring-boot-starter</artifactId>
    <version>1.2.19</version>
    <exclusions>
        <exclusion>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
        </exclusion>
    </exclusions>
</dependency>
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>1.2.19</version>
</dependency>

ステップ 1: 接続プール構成ファイルを作成する

src/main/resources に druid.properties を以下の内容で作成します。

ご利用の RDS インスタンスのエンドポイントとポートを見つけるには、「インスタンスのエンドポイントとポートの表示と管理」をご参照ください。

# Driver class — do not modify
driverClassName=com.mysql.jdbc.Driver

# Replace with your RDS endpoint, database name, username, and password
url=jdbc:mysql://rm-bp**************.mysql.rds.aliyuncs.com:3306/database
username=****
password=****

# Connection pool sizing
initialSize=20
minIdle=20
maxActive=100

# Connection lifecycle
phyTimeoutMillis=3600000

# Wait and timeout settings
maxWait=5000
connectTimeout=20000
socketTimeout=60000

# Idle connection validation
testWhileIdle=true
testOnBorrow=false
testOnReturn=false

# PreparedStatement cache
poolPreparedStatements=true
maxPoolPreparedStatementPerConnectionSize=100

ステップ 2: 接続プールを初期化し、データベースにアクセスする

src/main/java に DruidPoolDemo クラスを作成します。これはクラスパスから druid.properties をロードし、DruidDataSourceFactory でプールを初期化し、その後のデータベース操作のために DataSource を公開します。

package com.aliyun.rdsfinops.collector.impl;

import com.alibaba.druid.pool.DruidDataSourceFactory;
import javax.sql.DataSource;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;

public class DruidPoolDemo {
    private static DataSource dataSource = null;
    String tableName = "sql_table_test";

    // Load druid.properties and initialize the connection pool at class load time
    static {
        Properties properties = new Properties();
        InputStream inputStream = DruidPoolDemo.class.getClassLoader()
                .getResourceAsStream("druid.properties");
        try {
            properties.load(inputStream);
            dataSource = DruidDataSourceFactory.createDataSource(properties);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /*
      Database operations are defined in the following methods:
        Create a table: public void createTable()
        Insert data:    public void insertData()
        Query data:     public void selectData()
        Delete data:    public void deleteData()
    */
}