PolarDB:データベースへの接続

まず、MySQL JDBC ドライバーの依存関係を pom.xml ファイルに追加する必要があります。以下はコード例です：

<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-X インスタンスのエンドポイント、ポート、データベース名
      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-X インスタンスのエンドポイント
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-X インスタンスのエンドポイント
    dbPort := "3306"         // デフォルトのポートは 3306
    dbUser := "<USER>"       // データベースアカウント
    dbPass := "<PASSWORD>"   // データベースパスワード
    dbName := "<DATABASE>"   // ターゲットデータベース名
    // DSN (データソース名) を構築
    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()
    // サーバーに PING を送信して接続をテスト
    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)
    // SQL クエリを実行
    rows, err := db.Query("SELECT * FROM `<YOUR_TABLE_NAME>`") // クエリするテーブル
    if err != nil {
        log.Fatalf("クエリの実行に失敗しました: %v", err)
    }
    defer rows.Close()
    // クエリ結果を処理
    for rows.Next() {
        var id int
        var name string
        if err := rows.Scan(&id, &name); err != nil {
            log.Fatalf("行のスキャンに失敗しました: %v", err)
        }
        fmt.Printf("ID: %d, Name: %s\n", id, name)
    }
    // 行の反復処理中のエラーをチェック
    if err := rows.Err(); err != nil {
        log.Fatalf("反復処理中のエラー: %v", err)
    }
}