Подключение к базе данных в кластере PostgreSQL

Настройте все группы безопасности кластера так, чтобы они разрешали входящий трафик с любых IP-адресов на порт 6432. Для этого создайте следующее правило для входящего трафика:

• протокол: TCP;
• диапазон портов: 6432;
• тип источника: CIDR;
• источник: 0.0.0.0/0.

1. Создайте источник данных:
   1. Выберите в меню File → New → Data Source → PostgreSQL.
   2. Укажите параметры подключения на вкладке General:

      • User, Password — имя и пароль пользователя БД;

      • URL — строка подключения:

        jdbc:postgresql://<хост 1 PostgreSQL:6432>,...,<хост N PostgreSQL:6432>/<имя БД>
        

        Также в строке подключения можно использовать особые FQDN:

        jdbc:postgresql://<особый FQDN:6432>/<имя БД>
        

      • Нажмите ссылку Download, чтобы загрузить драйвер соединения.

   3. На вкладке SSH/SSL:
      1. Включите настройку Use SSL.
      2. В поле CA file укажите путь к файлу SSL-сертификата для подключения.
2. Нажмите ссылку Test Connection для проверки подключения. При успешном подключении будет выведен статус подключения, информация о СУБД и драйвере.
3. Нажмите кнопку OK, чтобы сохранить источник данных.

1. Подключитесь к базе данных:

   psql "host=<FQDN одного или нескольких хостов PostgreSQL> \
       port=6432 \
       sslmode=disable \
       dbname=<имя БД> \
       user=<имя пользователя> \
       target_session_attrs=read-write"
   

   После выполнения команды введите пароль пользователя для завершения процедуры подключения.

2. Для проверки успешности подключения выполните запрос:

   SELECT version();
   

Пример настроек в файле appsettings.json:

...
"ConnectionStrings": {
	"Default": "Server=<FQDN одного или нескольких хостов PostgreSQL>;Database=<имя БД>;Port=6432;User Id=<имя пользователя>;Password=<пароль пользователя>;Ssl Mode=Require; Trust Server Certificate=true;"
},
...

1. Пример кода:

   connect.go

   package main
   
   import (
     "context"
     "fmt"
     "os"
   
     "github.com/jackc/pgx/v4"
   )
   
   const (
     host     = "<FQDN одного или нескольких хостов PostgreSQL>"
     port     = 6432
     user     = "<имя пользователя>"
     password = "<пароль пользователя>"
     dbname   = "<имя БД>"
   )
   
   func main() {
   
     connstring := fmt.Sprintf(
       "host=%s port=%d dbname=%s user=%s password=%s target_session_attrs=read-write",
       host, port, dbname, user, password)
   
     connConfig, err := pgx.ParseConfig(connstring)
     if err != nil {
       fmt.Fprintf(os.Stderr, "Unable to parse config: %v\n", err)
       os.Exit(1)
     }
   
     conn, err := pgx.ConnectConfig(context.Background(), connConfig)
     if err != nil {
       fmt.Fprintf(os.Stderr, "Unable to connect to database: %v\n", err)
       os.Exit(1)
     }
   
     defer conn.Close(context.Background())
   
     var version string
   
     err = conn.QueryRow(context.Background(), "select version()").Scan(&version)
     if err != nil {
       fmt.Fprintf(os.Stderr, "QueryRow failed: %v\n", err)
       os.Exit(1)
     }
   
     fmt.Println(version)  
   }  
   

2. Подключение:

   go run connect.go
   

1. Пример кода:

   src/java/com/example/App.java

   package com.example;
   
   import java.sql.*;
   
   public class App {
     public static void main(String[] args) {
       String DB_URL     = "jdbc:postgresql://<хост 1 PostgreSQL:6432,...,хост N PostgreSQL:6432>/<имя БД>&  targetServerType=master&ssl=true&  sslmode=disable";
       String DB_USER    = "<имя пользователя>";
       String DB_PASS    = "<пароль пользователя>";
   
       try {
         Class.forName("org.postgresql.Driver");
   
         Connection conn = DriverManager.getConnection(DB_URL, DB_USER, DB_PASS);
         ResultSet q = conn.createStatement().executeQuery("SELECT version()");
         if(q.next()) {System.out.println(q.getString(1));}
   
         conn.close();
       }
       catch(Exception ex) {ex.printStackTrace();}
     }
   }
   

2. Сборка и подключение:

   mvn clean package && \
   java -jar target/app-0.1.0-jar-with-dependencies.jar
   

1. Пример кода:

   app.js

   "use strict"
   const pg = require('pg');
   
   const config = {
     connectionString: 'postgres://<имя пользователя>:<пароль пользователя>@c-<идентификатор кластера>.rw.mdb. yandexcloud.net:6432/<имя БД>',
   }
   
   const conn = new pg.Client(config)
   
   conn.connect(err => {if (err) throw err})
   conn.query('SELECT version()', (err, q) => {
     if (err) throw err
     console.log(q.rows[0])
     conn.end()
   })
   

   Идентификатор кластера можно получить со списком кластеров.

2. Подключение:

   node app.js
   

1. Пример кода:

   /etc/odbc.ini

   [postgresql]
   Driver=PostgreSQL Unicode
   Servername=<хост 1 PostgreSQL>,...,<хост N PostgreSQL>
   Username=<имя пользователя>
   Password=<пароль пользователя>
   Database=<имя БД>
   Port=6432
   Pqopt=target_session_attrs=read-write
   

2. Подключение:

   isql -v postgresql
   

   После подключения к СУБД выполните команду SELECT version();.

1. Пример кода:

   connect.php

   <?php
     $conn = pg_connect("
         host=<FQDN одного или нескольких хостов PostgreSQL>
         port=6432
         sslmode=disable
         dbname=<имя БД>
         user=<имя пользователя>
         password=<пароль пользователя>
         target_session_attrs=read-write
     ");
   
     $q = pg_query($conn, "SELECT version()");
     $result = pg_fetch_row($q);
     echo($result[0]);
   
     pg_close($conn);
   ?>
   

2. Подключение:

   php connect.php
   

1. Установите переменные окружения для подключения:

   $Env:PGSSLMODE="disable"; $Env:PGTARGETSESSIONATTRS="read-write"
   

2. Подключитесь к базе данных:

   & 'C:\Program Files\PostgreSQL\<версия>\bin\psql.exe' `
         -h <FQDN одного или нескольких хостов PostgreSQL> `
         -p 6432 `
         -U <имя пользователя> `
         <имя БД>
   

   После выполнения команды введите пароль пользователя для завершения процедуры подключения.

3. Для проверки успешности подключения выполните запрос:

   SELECT version();
   

1. Пример кода:

   connect.py

   import psycopg2
   
   conn = psycopg2.connect("""
       host=<FQDN одного или нескольких хостов PostgreSQL>
       port=6432
       sslmode=disable
       dbname=<имя БД>
       user=<имя пользователя>
       password=<пароль пользователя>
       target_session_attrs=read-write
   """)
   
   q = conn.cursor()
   q.execute('SELECT version()')
   
   print(q.fetchone())
   
   conn.close()
   

2. Подключение:

   python3 connect.py
   

1. Пример кода:

   connect.rb

   require "pg"
   
   conn = PG.connect("
           host=<FQDN одного или нескольких хостов PostgreSQL>
           port=6432
           dbname=<имя БД>
           user=<имя пользователя>
           password=<пароль пользователя>
           target_session_attrs=read-write
           sslmode=disable
   ")
   
   q = conn.exec("SELECT version()")
   puts q.getvalue 0, 0
   
   conn.close()
   

2. Подключение:

   ruby connect.rb