PolarDB：串連資料庫

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

<dependency>
  <groupId>org.postgresql</groupId>
  <artifactId>postgresql</artifactId>
  <version>42.2.18</version>
</dependency>

串連叢集。請將參數<HOST>、<PORT>、<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 PolarDBConnection {
    public static void main(String[] args) {
        // 資料庫URL, 使用者名稱, 密碼
        String url = "jdbc:postgresql://<HOST>:<PORT>/<DATABASE>";
        String user = "<USER>";
        String password = "<PASSWORD>";

        try {
            // 載入JDBC驅動
            Class.forName("org.postgresql.Driver");
            
            // 建立串連
            Connection conn = DriverManager.getConnection(url, user, password);
            
            // 建立Statement對象
            Statement stmt = conn.createStatement();
            
            // 執行SQL查詢
            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 e) {
            e.printStackTrace();
        }
    }
}

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

pip3 install psycopg2-binary

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

import psycopg2

try:
    # 串連參數
    conn = psycopg2.connect(
        host="<HOST>",  # 資料庫主機地址
        database="<DATABASE>",  # 資料庫名稱
        user="<USER>",  # 使用者名稱
        password="<PASSWORD>",  # 密碼
        port="<PORT>"  # 連接埠
    )

    # 建立遊標對象
    cursor = conn.cursor()

    # 執行查詢
    cursor.execute("SELECT * FROM <YOUR_TABLE_NAME>")

    # 擷取所有結果
    records = cursor.fetchall()
    for record in records:
        print(record)
        
except Exception as e:
    print("錯誤:", e)
finally:
    # 關閉串連
    if 'cursor' in locals():
        cursor.close()
    if 'conn' in locals():
        conn.close()

首先，您需要安裝lib/pq驅動。您可以通過以下命令進行安裝：

go get -u github.com/lib/pq

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

package main

import (
    "database/sql"
    "fmt"
    "log"

    _ "github.com/lib/pq" // 初始化驅動
)

func main() {
    // 連接字串格式
    connStr := "user=<USER> password=<PASSWORD> dbname=<DATABASE> host=<HOST> port=<PORT> sslmode=disable"

    // 開啟資料庫連接
    db, err := sql.Open("postgres", connStr)
    if err != nil {
        log.Fatal(err)
    }
    defer db.Close() // 程式退出前關閉串連

    // 測試連接是否成功
    err = db.Ping()
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("Connected to PostgreSQL!")

    // 執行查詢樣本
    rows, err := db.Query("SELECT * FROM <YOUR_TABLE_NAME>")
    if err != nil {
        log.Fatal(err)
    }
    defer rows.Close()
}