Proxool 串連池串連 OceanBase 資料庫樣本程式

點擊下載 proxool-mysql-client 樣本工程

前提條件

• 您已安裝 OceanBase 資料庫並且建立了 MySQL 模式租戶。

• 您已安裝 JDK 1.8 和 Maven。

• 您已安裝 IntelliJ IDEA。

  說明

  本文檔運行代碼使用的工具是 IntelliJ IDEA Community Edition 2021.3.2 版本，您也可以根據個人喜好選擇適合自己的工具啟動並執行範例程式碼。

操作步驟

1. 將proxool-mysql-client專案匯入到 IntelliJ IDEA 中。

2. 擷取 OceanBase 資料庫 URL。

3. 修改proxool-mysql-client專案中的資料庫連接資訊。

4. 運行proxool-mysql-client專案。

步驟一：將 proxool-mysql-client 專案匯入到 IntelliJ IDEA 中

1. 開啟 IntelliJ IDEA。

2. 在歡迎介面上，點擊 Open 選項，導航到您的專案目錄，選擇專案的根目錄，點擊 OK。

   

3. IntelliJ IDEA 會自動檢測項目類型並附加元件目。

   說明

   當使用 IntelliJ IDEA 匯入 Maven 專案時，IntelliJ IDEA 會自動檢測專案中的pom.xml檔案，並根據檔案中描述的依賴關係自動下載所需的依賴庫，並將它們添加到專案中。

   

4. （可選）手動匯入未解析的依賴項。

   如果pom.xml檔案中對應的依賴項都自動匯入到了專案中，請忽略此步驟。

   通過 IntelliJ IDEA 的 Sync 視窗的提示，可以發現proxool-cglib和proxool依賴項未解析。proxool-mysql-client專案根目錄下的lib的檔案夾中有proxool-cglib和proxool的jar檔案，將其添加到專案，步驟如下：

   1. 在 IntelliJ IDEA 中，點擊 File->Project Structure 進入專案結構設定。

   2. 在左側面板中，選擇 Modules。

   3. 在右側的模組列表中，選擇 Dependencies 選項卡，點擊此頁面上的+表徵圖，選擇 JARs or directories。

   4. 在彈出的對話方塊中，導航到存放jar檔案的lib目錄，選中jar檔案，點擊 OK。

   5. 在 Dependencies 選項卡下，會看到新加入的jar檔案出現在列表中。

   6. 點擊 Apply 或 OK 儲存更改。

   

步驟二：擷取 OceanBase 資料庫 URL

1. 聯絡 OceanBase 資料庫部署人員或者管理員擷取相應的資料庫連接串。

   樣本如下：

   obclient -hxxx.xxx.xxx.xxx -P3306 -utest_user001 -p****** -Dtest -A

   更多串連串的資訊，請參見 擷取串連參數。

2. 根據 OceanBase 資料庫連接串資訊填寫下面 URL 的對應資訊。

   jdbc:mysql://$host:$port/$database_name?user=$user_name&password=$password

   參數說明：

   • $host：OceanBase 資料庫連接的網域名稱。

   • $port：OceanBase 資料庫連接連接埠，MySQL 模式租戶預設是 3306。

   • $database_name：需要訪問的資料庫名稱。

   • $user_name：租戶的串連帳號。

   • $password：提供賬戶密碼。

   更多有關 MySQL Connector/J 串連屬性資訊，請參見 Configuration Properties。

   樣本如下：

   jdbc:mysql://xxx.xxx.xxx.xxx:3306/test?user=test_user001&password=******

步驟三：修改 proxool-mysql-client 專案中的資料庫連接資訊

根據 步驟二：擷取 OceanBase 資料庫 URL 中擷取的資訊修改檔案proxool-mysql-client/src/main/resources/db.properties中的資料庫連接資訊。

樣本如下：

• OBServer 節點的 IP 位址為xxx.xxx.xxx.xxx。

• 訪問連接埠使用的是 3306。

• 需要訪問的資料庫名稱為test。

• 租戶的串連賬戶是test_user001。

• 密碼是******。

代碼如下：

...
jdbc-1.proxool.driver-url=jdbc:mysql://xxx.xxx.xxx.xxx:3306/test?useSSL=false
jdbc-1.user=test_user
jdbc-1.password=******
...

步驟四：運行 proxool-mysql-client 專案

1. 在專案導覽列中，找到並展開 src/main/java/com.example 目錄。

2. 右鍵點擊 Main 檔案，選擇 Run 'Main.main()'。

3. IntelliJ IDEA 會自動編譯和運行該專案，並在運行面板中顯示輸出結果。

   

4. 也可以在 OceanBase 用戶端（OBClient）中執行以下 SQL 陳述式查看結果。

   obclient [(none)]> SELECT * FROM test.test_proxool;

   返回結果如下：

   +------+---------------+
   | c1   | c2            |
   +------+---------------+
   |    6 | test_update   |
   |    7 | test_insert7  |
   |    8 | test_insert8  |
   |    9 | test_insert9  |
   |   10 | test_insert10 |
   +------+---------------+
   5 rows in set

專案代碼介紹

點擊 proxool-mysql-client 下載專案代碼，是一個名稱為proxool-mysql-client.zip的壓縮包。

解壓後，得到一個名為proxool-mysql-client的檔案夾。目錄結構如下所示：

proxool-mysql-client
├── lib
│    ├── proxool-0.9.1.jar
│    └── proxool-cglib.jar
├── src
│   └── main
│       ├── java
│       │   └── com
│       │       └── example
│       │           └── Main.java
│       └── resources
│           └── db.properties
└── pom.xml

檔案說明：

• lib：存放專案所需的依賴庫檔案。

• proxool-0.9.1.jar：Proxool 串連池庫檔案。

• proxool-cglib.jar：用於支援 Proxool 串連池的 CGLib 庫檔案。

• src：原始碼根目錄。

• main：主代碼目錄，包含應用程式的主要邏輯。

• java：Java 原始碼目錄。

• com：Java 包目錄。

• example：樣本專案的包目錄。

• Main.java：主類程式樣本檔案，包含建立表、插入、刪除、更新和查詢資料等邏輯。

• resources：資源檔目錄，包含設定檔等。

• db.properties：串連池的設定檔，包含了資料庫連接的相關參數。

• pom.xml：Maven 專案的設定檔，用於管理專案的依賴和構建設定。

pom.xml 代碼介紹

pom.xml檔案是 Maven 專案的設定檔，定義了專案的依賴項、外掛程式和構建規則等資訊。Maven 是一個 Java 專案管理工具，可以自動下載依賴項、編譯和打包專案等操作。

本文pom.xml檔案的代碼主要包括以下幾個部分：

1. 檔案聲明語句。

   聲明本檔案是一個 XML 檔案，使用的 XML 版本是1.0，字元編碼方式是UTF-8。

   代碼如下：

   <?xml version="1.0" encoding="UTF-8"?>

2. 配置 POM 的命名空間和 POM 模型版本。

   1. 通過xmlns指定 POM 的命名空間為http://maven.apache.org/POM/4.0.0。

   2. 通過xmlns:xsi指定 XML 命名空間http://www.w3.org/2001/XMLSchema-instance。

   3. 通過xsi:schemaLocation指定 POM 的命名空間為http://maven.apache.org/POM/4.0.0和 POM 的 XSD 檔案的位置為http://maven.apache.org/xsd/maven-4.0.0.xsd。

   4. 通過<modelVersion>元素指定了該 POM 檔案使用的 POM 模型版本為4.0.0。

   代碼如下：

   <project xmlns="http://maven.apache.org/POM/4.0.0"
            xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
            xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
   
    <!-- 其他配置 -->
   
   </project>

3. 配置基本資料。

   1. 通過<groupId>指定專案所屬組織為com.example。

   2. 通過<artifactId>指定專案的名稱為proxool-mysql-client。

   3. 通過<version>專案的版本號碼為1.0-SNAPSHOT。

   代碼如下：

       <groupId>com.example</groupId>
       <artifactId>proxool-mysql-client</artifactId>
       <version>1.0-SNAPSHOT</version>

4. 設定項目源檔案的屬性。

   指定 Maven 的編譯器外掛程式為maven-compiler-plugin，並設定了原始碼和目標 Java 版本都為 8。這意味著專案的原始碼使用 Java 8 特性編寫，且編譯後的位元組碼也將相容 Java 8 運行時環境。這樣設定可以確保專案在編譯和運行時能夠正確地處理 Java 8 的文法和特性。

   說明

   Java 1.8 和 Java 8 是同一個版本的不同命名方式。

   代碼如下：

       <build>
           <plugins>
               <plugin>
                   <groupId>org.apache.maven.plugins</groupId>
                   <artifactId>maven-compiler-plugin</artifactId>
                   <configuration>
                       <source>8</source>
                       <target>8</target>
                   </configuration>
               </plugin>
           </plugins>
       </build>

5. 設定項目所相依元件。

   通過<dependency>定義依賴項：

   1. 添加mysql-connector-java庫，用於串連和操作資料庫：

      1. 通過<groupId>指定依賴項所屬的組織為mysql。

      2. 通過<artifactId>指定依賴項的名稱為mysql-connector-java。

      3. 通過<version>指定依賴項的版本號碼為5.1.47。

      代碼如下：

              <dependency>
                  <groupId>mysql</groupId>
                  <artifactId>mysql-connector-java</artifactId>
                  <version>5.1.47</version>
              </dependency>

   2. 添加proxool-cglib依賴庫，用於支援 Proxool 串連池的 CGLib 庫：

      1. 通過<groupId>指定依賴項所屬的組織為proxool。

      2. 通過<artifactId>指定依賴項的名稱為proxool-cglib。

      3. 通過<version>指定依賴項的版本號碼為0.9.1。

      代碼如下：

              <dependency>
                  <groupId>proxool</groupId>
                  <artifactId>proxool-cglib</artifactId>
                  <version>0.9.1</version>
              </dependency>

   3. 添加proxool依賴庫，Proxool 串連池的核心庫：

      1. 通過<groupId>指定依賴項所屬的組織為proxool。

      2. 通過<artifactId>指定依賴項的名稱為proxool。

      3. 通過<version>指定依賴項的版本號碼為0.9.1。

      代碼如下：

              <dependency>
                  <groupId>proxool</groupId>
                  <artifactId>proxool</artifactId>
                  <version>0.9.1</version>
              </dependency>

   4. 添加commons-logging依賴庫，用於在應用程式中進行日誌記錄的通用日誌庫：

      1. 通過<groupId>指定依賴項所屬的組織為commons-logging。

      2. 通過<artifactId>指定依賴項的名稱為commons-logging。

      3. 通過<version>指定依賴項的版本號碼為1.2。

      代碼如下：

              <dependency>
                  <groupId>commons-logging</groupId>
                  <artifactId>commons-logging</artifactId>
                  <version>1.2</version>
              </dependency>

db.properties 代碼介紹

db.properties是本文樣本的串連池設定檔，其中包含了串連池的配置屬性。

本文db.properties檔案是一個屬性檔案的樣本，用於配置一個名為jdbc-1的資料來源的串連池屬性。主要包括以下幾個部分：

1. 設定資料來源的別名為TEST。

   代碼如下：

   jdbc-1.proxool.alias=TEST

2. 設定資料庫串連參數。

   1. 設定驅動程式的類名，這裡是 MySQL JDBC 驅動的類名com.mysql.jdbc.Driver。

   2. 設定資料庫連接的 URL，包括主機 IP、連接埠號碼、需要訪問的資料庫和額外的串連屬性。

   3. 設定資料庫使用者名稱。

   4. 設定資料庫密碼。

   代碼如下：

   jdbc-1.proxool.driver-class=com.mysql.jdbc.Driver
   jdbc-1.proxool.driver-url=jdbc:mysql://$host:$port/$database_name?useSSL=false
   jdbc-1.user=$user_name
   jdbc-1.password=$password

   參數解釋：

   • $host：OceanBase 資料庫連接的網域名稱。

   • $port：OceanBase 資料庫連接連接埠，MySQL 模式租戶預設是 3306。

   • $database_name：需要訪問的資料庫名稱。

   • $user_name：租戶的串連帳號。

   • $password：提供賬戶密碼。

3. 配置其他 Proxool 串連池的參數。

   1. 設定串連池的最大串連數為 8。

   2. 設定串連池的最小串連數為 5。

   3. 設定串連池中可用的串連數量為 4。

   4. 設定串連池的詳細模式為開啟，即顯示更多的日誌資訊。

   5. 設定串連池的統計資訊記錄周期為 10 秒、1 分鐘和 1 天。

   6. 設定串連池統計資訊記錄的記錄層級為錯誤層級。

   代碼如下：

   jdbc-1.proxool.maximum-connection-count=8
   jdbc-1.proxool.minimum-connection-count=5
   jdbc-1.proxool.prototype-count=4
   jdbc-1.proxool.verbose=true
   jdbc-1.proxool.statistics=10s,1m,1d
   jdbc-1.proxool.statistics-log-level=error

常用配置參數說明：

Main.java 代碼介紹

Main.java檔案是樣本程式的一部分，用於示範通過 Proxool 串連池擷取資料庫連接，並執行一系列資料庫操作，包括建立表、插入資料、刪除資料、更新資料、查詢資料，並將查詢結果列印出來。

本文Main.java檔案的代碼主要包括以下幾個部分：

1. 匯入所需的類和介面。

   定義代碼所在的包，並匯入 Proxool 和 JDBC 相關的類。這些類用於實現資料庫連接池的配置和管理，以及執行 SQL 陳述式。通過使用 Proxool 串連池，可以提高資料庫操作的效能和可靠性。具體步驟如下：

   1. 定義了代碼所在的包為com.example，該包用於存放當前 Java 類。

   2. 匯入 Proxool 的配置類org.logicalcobwebs.proxool.configuration.PropertyConfigurator。

   3. 匯入用於讀取設定檔的輸入資料流類java.io.InputStream。

   4. 匯入 JDBC 的 Connection 類java.sql.Connection。

   5. 匯入 JDBC 的 DriverManager 類java.sql.DriverManager。

   6. 匯入 JDBC 的 ResultSet 類java.sql.ResultSet。

   7. 匯入 JDBC 的 Statement 類java.sql.Statement。

   8. 匯入用於載入設定檔的 Properties 類java.util.Properties。

   代碼如下：

   package com.example;
   
   import org.logicalcobwebs.proxool.configuration.PropertyConfigurator;
   import java.io.InputStream;
   import java.sql.Connection;
   import java.sql.DriverManager;
   import java.sql.ResultSet;
   import java.sql.Statement;
   import java.util.Properties;

2. 定義類名和方法。

   定義一個 Java 程式的入口方法，其中通過讀取設定檔擷取資料庫連接資訊，在使用 Proxool 驅動程式建立資料庫連接後，依次調用定義好的方法執行 DDL 語句、DML 語句和查詢語句。捕獲並列印可能發生的異常資訊。這段代碼的目的是執行資料庫相關的操作，並通過日誌記錄器進行日誌記錄。具體步驟如下：

   1. 定義了一個名為 Main 的公用類。

      1. 定義了一個名為DB_PROPERTIES_FILE的私人靜態常量，表示資料庫配置（屬性）檔案的路徑。這個常量可以在代碼中引用，以便載入和讀取屬性檔案。

      2. 定義一個公用靜態方法main，作為程式的起始執行點。

         1. 用於捕獲可能發生異常的代碼塊。

            1. 建立一個Properties對象，用於讀取設定檔中的屬性。

            2. 使用 Main 類的類載入器擷取設定檔的輸入資料流。

            3. 使用載入的輸入資料流載入設定檔，將屬性載入到Properties對象中。

            4. 使用載入的屬性配置串連池。

            5. 動態載入 Proxool 資料庫驅動程式。

            6. 使用 Proxool 驅動程式建立資料庫連接。

            7. 建立一個Statement對象。

            8. 調用定義好的方法executeDDLStatements()，執行 DDL 語句，是建立表的操作。

            9. 調用定義好的方法executeDMLStatements()，執行 DML 語句，是插入、更新和刪除資料的操作。

            10. 調用定義好的方法executeQueryStatements()，執行查詢語句，擷取資料。

         2. 捕獲並列印可能發生的異常資訊。

   2. 定義了用於建立表、執行 DML 語句和查詢資料的方法。

   代碼如下：

   public class Main {
       private static final String DB_PROPERTIES_FILE = "/db.properties";
   
       public static void main(String[] args) {
           try {
               Properties properties = new Properties();
               InputStream is = Main.class.getResourceAsStream(DB_PROPERTIES_FILE);
               properties.load(is);
               PropertyConfigurator.configure(properties);
   
               Class.forName("org.logicalcobwebs.proxool.ProxoolDriver");
               try (Connection conn = DriverManager.getConnection("proxool.TEST");
                   Statement stmt = conn.createStatement()) {
                   executeDDLStatements(stmt);
                   executeDMLStatements(stmt);
                   executeQueryStatements(stmt);
               }
           } catch (Exception e) {
               e.printStackTrace();
           }
       }
   
       // 定義用於建立表的方法
       // 定義用於執行 DML 語句的方法
       // 定義用於查詢資料的方法
   }

3. 定義用於建立表的方法。

   定義一個私人靜態方法executeDDLStatements()，用於執行 DDL（資料定義語言 (Data Definition Language)）語句，包括建立表的語句。具體步驟如下：

   1. 定義一個私人靜態方法executeDDLStatements()，它接收一個Statement對象作為參數，並可能拋出Exception異常。

   2. 使用execute()方法執行 SQL 陳述式，建立一個名為test_proxool的表，該表有兩列c1和c2，分別為INT類型和VARCHAR(32)類型。

   代碼如下：

       private static void executeDDLStatements(Statement stmt) throws Exception {
           stmt.execute("CREATE TABLE test_proxool (c1 INT, c2 VARCHAR(32))");
       }

4. 定義用於執行 DML 語句的方法。

   定義一個私人靜態方法executeDMLStatements()，用於執行 DML（資料操作語言）語句，包括插入資料、刪除資料和更新資料的語句。具體步驟如下：

   1. 定義一個私人靜態方法executeDMLStatements()，它接收一個Statement對象作為參數，如果在執行過程中出現異常，方法將拋出Exception異常。

   2. 使用for迴圈，從 1 到 10 進行迭代。在迴圈中，使用execute()方法執行 SQL 插入語句，將變數i和相關的字串值插入到test_proxool表中。

   3. 執行 SQL 刪除語句，從test_proxool表中刪除c1列值小於等於 5 的行。

   4. 執行 SQL 更新語句，將test_proxool表中c1列值為 6 的行的c2列更新為test_update。

   代碼如下：

       private static void executeDMLStatements(Statement stmt) throws Exception {
           for (int i = 1; i <= 10; i++) {
               stmt.execute("INSERT INTO test_proxool VALUES (" + i + ",'test_insert" + i + "')");
           }
           stmt.execute("DELETE FROM test_proxool WHERE c1 <= 5");
           stmt.execute("UPDATE test_proxool SET c2 = 'test_update' WHERE c1 = 6");
       }

5. 定義用於查詢資料的方法。

   定義一個私人靜態方法executeQueryStatements()，用於執行SELECT查詢語句並處理結果。具體步驟如下：

   1. 定義一個私人靜態方法executeQueryStatements()，它接收一個Statement對象作為參數，如果在執行過程中出現異常，方法將拋出Exception異常。

   2. 使用executeQuery()方法執行SELECT查詢語句，並將結果儲存在ResultSet對象rs中。在這裡，查詢返回了test_proxool表中的所有資料。使用try-with-resources語句，確保在使用完ResultSet後自動關閉它。

   3. 使用while迴圈和next()方法迭代ResultSet對象rs中的每一行資料。在每次迭代中，rs.next()方法將指標移動到結果集的下一行。如果還有下一行資料可用，則該方法返回true，否則返回false。在while迴圈中，只要rs.next()返回true，就表示還有更多的行資料可用。迴圈體內的代碼將執行，並處理當前行的資料。當所有行的資料都被處理完畢後，rs.next()將返回false，迴圈結束。

   4. 通過getInt()和getString()方法擷取當前行中指定列名的值，並將它們列印到控制台。在這裡，列印了c1和c2列的值。getInt()方法用於擷取整數值，getString()方法用於擷取字串值。

   代碼如下：

       private static void executeQueryStatements(Statement stmt) throws Exception {
           try (ResultSet rs = stmt.executeQuery("SELECT * FROM test_proxool")) {
               while (rs.next()) {
                   System.out.println(rs.getInt("c1") + "   " + rs.getString("c2"));
               }
           }
       }

完整的代碼展示

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.oceanbase</groupId>
    <artifactId>proxool-mysql-client</artifactId>
    <version>1.0-SNAPSHOT</version>
    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <configuration>
                    <source>8</source>
                    <target>8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>

    <dependencies>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.47</version>
        </dependency>
        <dependency>
            <groupId>proxool</groupId>
            <artifactId>proxool-cglib</artifactId>
            <version>0.9.1</version>
        </dependency>
        <dependency>
            <groupId>proxool</groupId>
            <artifactId>proxool</artifactId>
            <version>0.9.1</version>
        </dependency>
        <dependency>
            <groupId>commons-logging</groupId>
            <artifactId>commons-logging</artifactId>
            <version>1.2</version>
        </dependency>
    </dependencies>
</project>

db.properties

#alias: the alias of the data source
jdbc-1.proxool.alias=TEST
#driver-class: driver name
jdbc-1.proxool.driver-class=com.mysql.jdbc.Driver
#driver-url: url connection string, username and password must be determined
jdbc-1.proxool.driver-url=jdbc:mysql://$host:$port/$database_name?useSSL=false
jdbc-1.user=$user_name
jdbc-1.password=$password
#The maximum number of database connections. The default is 15
jdbc-1.proxool.maximum-connection-count=8
#The minimum number of database connections, defaults to 5
jdbc-1.proxool.minimum-connection-count=5
#The number of available connections in the Connection pool. If the number of connections in the current Connection pool is less than this value, new connections will be established (assuming that the maximum number of available connections is not exceeded). For example, if we have three active connections and two available connections, and our prototype count is 4, the database Connection pool will try to establish another two connections. This is different from the minimum connection count Minimum connection count also counts active connections. Prototype count is the number of spare connections
jdbc-1.proxool.prototype-count=4
#verbose: detailed information settings. Parameter bool value
jdbc-1.proxool.verbose=true
#statistics: connection pool usage statistics. Parameter "10s, 1m, 1d"
jdbc-1.proxool.statistics=10s,1m,1d
#statistics-log-level:  log statistics tracking type. Parameter 'ERROR' or 'INFO'
jdbc-1.proxool.statistics-log-level=error

Main.java

package com.example;

import org.logicalcobwebs.proxool.configuration.PropertyConfigurator;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Properties;

public class Main {
    private static final String DB_PROPERTIES_FILE = "/db.properties";

    public static void main(String[] args) {
        try {
            Properties properties = new Properties();
            InputStream is = Main.class.getResourceAsStream(DB_PROPERTIES_FILE);
            properties.load(is);
            PropertyConfigurator.configure(properties);

            Class.forName("org.logicalcobwebs.proxool.ProxoolDriver");
            try (Connection conn = DriverManager.getConnection("proxool.TEST");
                Statement stmt = conn.createStatement()) {
                executeDDLStatements(stmt);
                executeDMLStatements(stmt);
                executeQueryStatements(stmt);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private static void executeDDLStatements(Statement stmt) throws Exception {
        stmt.execute("CREATE TABLE test_proxool (c1 INT, c2 VARCHAR(32))");
    }

    private static void executeDMLStatements(Statement stmt) throws Exception {
        for (int i = 1; i <= 10; i++) {
            stmt.execute("INSERT INTO test_proxool VALUES (" + i + ",'test_insert" + i + "')");
        }
        stmt.execute("DELETE FROM test_proxool WHERE c1 <= 5");
        stmt.execute("UPDATE test_proxool SET c2 = 'test_update' WHERE c1 = 6");
    }

    private static void executeQueryStatements(Statement stmt) throws Exception {
        try (ResultSet rs = stmt.executeQuery("SELECT * FROM test_proxool")) {
            while (rs.next()) {
                System.out.println(rs.getInt("c1") + "   " + rs.getString("c2"));
            }
        }
    }
}

相關文檔

• 更多 MySQL Connector/J 的資訊，請參見 Overview of MySQL Connector/J。

• 更多使用 Proxool 串連池的資訊，請參見 Introduction for Users。