E-MapReduce:Optimize StarRocks access performance with SLB and client connection pools

Maven dependencies

Add the following dependencies to the pom.xml file of your project.

<dependency>
    <groupId>com.zaxxer</groupId>
    <artifactId>HikariCP</artifactId>
    <version>5.0.1</version>
</dependency>
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.33</version>
</dependency>

Starting from version 8.0.31, Oracle renamed the MySQL JDBC driver artifact from mysql:mysql-connector-java to com.mysql:mysql-connector-j. Version 8.0.33 is published under both artifact IDs. For new projects, use the updated coordinates:

<groupId>com.mysql</groupId>
<artifactId>mysql-connector-j</artifactId>
<version>8.0.33</version>

HikariCP connection pool configuration

import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

public class StarRocksConnectionPoolExample {
    public static void main(String[] args) {
        // Configure the HikariCP connection pool
        HikariConfig config = new HikariConfig();

        // Use the internal same-region SLB endpoint. Replace the placeholder
        // with the endpoint shown in the Gateway Information section.
        config.setJdbcUrl("jdbc:mysql://fe-c-xxx-internal.starrocks.aliyuncs.com:9030/<yourDatabase>");
        config.setUsername("<yourUsername>");
        config.setPassword("<yourPassword>");

        // --- Core pool parameters ---

        // Maximum connections in the pool. Start with 20 for typical OLAP workloads.
        // StarRocks queries are longer-running than OLTP queries, so fewer
        // connections are usually sufficient.
        config.setMaximumPoolSize(20);

        // Keep at least 5 idle connections warm to avoid cold-start latency
        // when traffic resumes after a quiet period.
        config.setMinimumIdle(5);

        // Wait up to 30 seconds for a connection from the pool.
        // If exceeded, an exception is thrown.
        config.setConnectionTimeout(30000);

        // Close idle connections after 10 minutes.
        // Frees resources when traffic drops.
        config.setIdleTimeout(600000);

        // Force-close and recreate every connection after 30 minutes.
        // This ensures connections rotate across SLB backends and
        // prevents stale connections after FE node changes.
        config.setMaxLifetime(1800000);

        // Validate connections before use. StarRocks supports SELECT 1
        // as a lightweight health check.
        config.setConnectionTestQuery("SELECT 1");

        // Allow up to 5 seconds for the validation query to complete.
        config.setValidationTimeout(5000);

        // Log a warning if a connection is checked out for more than
        // 1 minute. Helps detect connection leaks in application code.
        config.setLeakDetectionThreshold(60000);

        // Create the data source
        HikariDataSource dataSource = new HikariDataSource(config);

        // Use the connection pool to execute a query
        try (Connection conn = dataSource.getConnection();
             PreparedStatement stmt = conn.prepareStatement("SELECT count(*) FROM your_table");
             ResultSet rs = stmt.executeQuery()) {

            if (rs.next()) {
                System.out.println("Count: " + rs.getLong(1));
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}