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 クラスタのエンドポイント、ポート、およびデータベース名。
      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 (データソース名) を構築します
    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)

    // SQL クエリを実行します。
    rows, err := db.Query("SELECT * FROM '<YOUR_TABLE_NAME>'") // クエリされるデータテーブルの名前。
    if err != nil {
        log.Fatalf("クエリの発行に失敗しました: %v", err)
    }
    defer rows.Close()