Data Management (DMS)、pgAdmin、psql、またはプログラミング言語を使用して、PolarDB for PostgreSQL、 のクラスターに接続します。
前提条件
接続する前に、以下を確認してください。
これでクラスターに接続できます。
クラスターへの接続
接続方法を選択してください。
DMS を使用した接続
Data Management (DMS) は、データベース管理、セキュリティ監査、パフォーマンス最適化を提供します。DMS で PolarDB クラスターを直接管理できます。
-
PolarDB コンソールにログインします。クラスター一覧で、クラスター ID をクリックして[基本情報] ページを開きます。右上隅で、[データベースにログイン] をクリックします。

-
ダイアログボックスにデータベースアカウントとパスワードを入力し、[ログイン] をクリックします。

-
ログイン後、左側のナビゲーションペインでを選択して、 クラスターを管理します。

クライアントを使用した接続
この手順では、pgAdmin 4 v9.0 を使用して PolarDB クラスターに接続します。
-
pgAdmin 4 クライアントを ダウンロードしてインストールします。
-
pgAdmin 4 クライアントを開き、[サーバー] を右クリックし、 を選択します。

-
[一般] タブで接続名を設定し、[接続] タブで接続パラメーターを設定してから、[保存] をクリックします。


パラメーター
説明
[ホスト名/アドレス]
PolarDB クラスターの エンドポイントとポート。
-
ECS インスタンスから PolarDB クラスターにアクセスし、かつその ECS インスタンスが PolarDB クラスターと同じ VPC 内にある場合は、[プライベート] エンドポイントとポートを指定します。
-
オンプレミス環境から PolarDB クラスターにアクセスするには、[パブリック] エンドポイントとポートを指定します。
-
デフォルトのポート番号は 5432 です。
[ポート]
[ユーザー名]
PolarDB クラスターの データベースアカウントとパスワード。
[パスワード]
-
-
接続に成功すると、次のページが表示されます。
説明postgresはデフォルトのシステムデータベースです。このデータベースに対する操作は行わないでください。
psql を使用した接続
PostgreSQL Downloads から psql をダウンロードして、PolarDB クラスターに接続します。PolarDB-Tools psql を使用して PolarDB クラスターに接続することもできます。
-
接続方法は Windows と Linux で同じです。
-
公式の psql ドキュメントで詳細な使用方法を確認できます。
構文
psql -h <host> -p <port> -U <username> -d <dbname>
|
パラメーター |
説明 |
|
|
PolarDB クラスターの クラスターエンドポイントとポート。
|
|
|
|
|
|
PolarDB クラスターの データベースアカウント。 |
|
|
例
psql -h pc-xxx.rwlb.rds.aliyuncs.com -p 5432 -U testusername -d postgres
プログラミング言語による接続
PolarDB for PostgreSQL、 のクラスターへの接続は、通常の PostgreSQL データベースへの接続と同様です。エンドポイント、ポート、アカウント、パスワードを更新するだけです。
Java
Maven ベースの Java プロジェクトで PostgreSQL JDBC ドライバーを使用して、PolarDB for PostgreSQL、 のクラスターに接続します。
-
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 { // PostgreSQL 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(); } } }
Python
Python 3 で psycopg2 ライブラリを使用して、PolarDB for PostgreSQL、 のクラスターに接続します。
-
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("Error:", e) finally: # 接続を閉じます if 'cursor' in locals(): cursor.close() if 'conn' in locals(): conn.close()
Go
Go 1.23.0 で database/sql パッケージと lib/pq ドライバーを使用して、PolarDB for PostgreSQL、 のクラスターに接続します。
-
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" // PostgreSQLドライバーを初期化します ) 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() }






