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) {
        // クラスターエンドポイント、ポート、データベース名
        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>'         # クラスターエンドポイント
port = 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 = "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 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>"     // クラスターエンドポイント
    dbPort := "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("データベースへの接続に失敗しました: %v", err)
    }
    defer db.Close()

    // 接続の検証
    err = db.Ping()
    if err != nil {
        log.Fatalf("データベースへの PING に失敗しました: %v", err)
    }

    // データベースのバージョンを出力
    var result string
    err = db.QueryRow("SELECT VERSION()").Scan(&result)
    if err != nil {
        log.Fatalf("クエリの実行に失敗しました: %v", err)
    }
    fmt.Printf("データベースに接続しました。バージョン: %s\n", result)

    // クエリの実行
    rows, err := db.Query("SELECT * FROM '<YOUR_TABLE_NAME>'")
    if err != nil {
        log.Fatalf("クエリの実行に失敗しました: %v", err)
    }
    defer rows.Close()
}