PolarDB：串連資料庫

首先，您需要在pom.xml檔案中添加MySQL JDBC驅動的依賴，程式碼範例：

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

串連叢集。請將參數<HOST>、連接埠號碼、<USER>、<PASSWORD>、<DATABASE>、<YOUR_TABLE_NAME>及<YOUR_TABLE_COLUMN_NAME>進行替換。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class DatabaseConnection {
   public DatabaseConnection() {
   }

   public static void main(String[] args) {
      // PolarDB叢集串連地址、連接埠、需要串連的資料庫名
      String url = "jdbc:mysql://<HOST>:3306/<DATABASE>?useSSL=false&serverTimezone=UTC";
      // 資料庫帳號
      String user = "<USER>";
      // 資料庫帳號的密碼
      String password = "<PASSWORD>";

      try {
         Class.forName("com.mysql.cj.jdbc.Driver");
         Connection conn = DriverManager.getConnection(url, user, password);
         Statement stmt = conn.createStatement();
         // 需要檢索的資料表名
         ResultSet rs = stmt.executeQuery("SELECT * FROM `<YOUR_TABLE_NAME>`");

         while(rs.next()) {
            // 需要檢索的資料表的列名
            System.out.println(rs.getString("<YOUR_TABLE_COLUMN_NAME>"));
         }

         rs.close();
         stmt.close();
         conn.close();
      } catch (Exception var7) {
         var7.printStackTrace();
      }

   }
}

首先，您需要安裝PyMySQL庫。如果您還沒有安裝，可以通過以下命令進行安裝：

pip3 install PyMySQL

串連叢集。請將參數<HOST>、連接埠號碼、<USER>、<PASSWORD>、<DATABASE>及<YOUR_TABLE_NAME>進行替換。

import pymysql

# 資料庫連接參數
host = '<HOST>'  # PolarDB叢集串連地址
port = 3306  # 預設連接埠3306
user = '<USER>'  # 資料庫帳號
password = '<PASSWORD>'  # 資料庫帳號的密碼
database = '<DATABASE>'  # 需要串連的資料庫名

try:
    # 建立資料庫連接
    connection = pymysql.connect(
        host=host,
        port=port,
        user=user,
        passwd=password,
        db=database
    )

    # 擷取操作遊標
    with connection.cursor() as cursor:
        # 執行 SQL 查詢
        sql = "SELECT * FROM `<YOUR_TABLE_NAME>`"  # 需要檢索的資料表名
        cursor.execute(sql)

        # 擷取查詢結果
        results = cursor.fetchall()
        for row in results:
            print(row)

finally:
    # 關閉資料庫連接
    if 'connection' in locals() and connection.open:
        connection.close()

首先，您需要安裝go-sql-driver/mysql驅動。您可以通過以下命令進行安裝：

go get -u github.com/go-sql-driver/mysql

串連叢集。請將參數<HOST>、連接埠號碼、<USER>、<PASSWORD>、<DATABASE>及<YOUR_TABLE_NAME>進行替換。

package main

import (
    "database/sql"
    "fmt"
    "log"
    _ "github.com/go-sql-driver/mysql"
)

func main() {
    // 資料庫連接參數
    dbHost := "<HOST>"       // PolarDB叢集串連地址
    dbPort := "3306"         // 預設連接埠3306
    dbUser := "<USER>"       // 資料庫帳號
    dbPass := "<PASSWORD>"   // 資料庫帳號的密碼
    dbName := "<DATABASE>"   // 需要串連的資料庫名

    // 構建 DSN (Data Source Name)
    dsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=True&loc=Local", dbUser, dbPass, dbHost, dbPort, dbName)

    // 開啟資料庫連接
    db, err := sql.Open("mysql", dsn)
    if err != nil {
        log.Fatalf("Failed to connect to database: %v", err)
    }
    defer db.Close()

    // 測試連接
    err = db.Ping()
    if err != nil {
        log.Fatalf("Failed to ping database: %v", err)
    }

    // 建立一個操作遊標
    var result string
    err = db.QueryRow("SELECT VERSION()").Scan(&result)
    if err != nil {
        log.Fatalf("Failed to execute query: %v", err)
    }

    // 輸出資料庫版本
    fmt.Printf("Connected to database, version: %s\n", result)

    // 執行 SQL 查詢
    rows, err := db.Query("SELECT * FROM `<YOUR_TABLE_NAME>`") // 需要檢索的資料表名
    if err != nil {
        log.Fatalf("Failed to execute query: %v", err)
    }
    defer rows.Close()

    // 處理查詢結果
    for rows.Next() {
        var id int
        var name string
        if err := rows.Scan(&id, &name); err != nil {
            log.Fatalf("Failed to scan row: %v", err)
        }
        fmt.Printf("ID: %d, Name: %s\n", id, name)
    }

    // 檢查是否有錯誤
    if err := rows.Err(); err != nil {
        log.Fatalf("Error during iteration: %v", err)
    }
}