Примеры кода для подключения к кластеру PostgreSQL

1. Создайте проект на основе шаблона для сервиса.

2. Измените конфигурационный файл configs/config_vars.yaml. В качестве значения переменной dbconnection укажите строку подключения к кластеру PostgreSQL:

   postgres://<имя_пользователя>:<пароль_пользователя>@c-<идентификатор_кластера>.rw.mdb.yandexcloud.net:6432/<имя_БД>?ssl=true&sslmode=verify-full
   

3. Соберите проект и запустите сервис:

   make build-debug && \
   ./build_debug/pg_service_template -c configs/static_config.yaml --config_vars configs/config_vars.yaml
   

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

   connect.go

   package main
   
   import (
       "context"
       "crypto/tls"
       "crypto/x509"
       "fmt"
       "io/ioutil"
       "os"
   
       "github.com/jackc/pgx/v4"
   )
   
   const (
     host     = "c-<идентификатор_кластера>.rw.mdb.yandexcloud.net"
     port     = 6432
     user     = "<имя_пользователя>"
     password = "<пароль_пользователя>"
     dbname   = "<имя_БД>"
     ca       = "/home/<домашняя_директория>/.postgresql/root.crt"
   )
   
   func main() {
   
       rootCertPool := x509.NewCertPool()
       pem, err := ioutil.ReadFile(ca)
       if err != nil {
           panic(err)
       }
   
       if ok := rootCertPool.AppendCertsFromPEM(pem); !ok {
           panic("Failed to append PEM.")
       }
   
       connstring := fmt.Sprintf(
           "host=%s port=%d dbname=%s user=%s password=%s sslmode=verify-full 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)
       }
   
       connConfig.TLSConfig = &tls.Config{
           RootCAs:            rootCertPool,
           ServerName: "c-<идентификатор_кластера>.rw.mdb.yandexcloud.net",
       }
   
       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)
   }
   

   При этом способе подключения в коде необходимо указывать полный путь к сертификату root.crt для PostgreSQL в переменной ca.

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://c-<идентификатор_кластера>.rw.mdb.yandexcloud.net:6432/<имя_БД>?targetServerType=master&ssl=true&sslmode=verify-full";
       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
   

app.js

"use strict";
const fs = require("fs");
const pg = require("pg");

const config = {
    connectionString:
        "postgres://<имя_пользователя>:<пароль_пользователя>@c-<идентификатор_кластера>.rw.mdb.yandexcloud.net:6432/<имя_БД>",
    ssl: {
        rejectUnauthorized: true,
        ca: fs
            .readFileSync("/home/<домашняя_директория>/.postgresql/root.crt")
            .toString(),
    },
};

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();
});

При этом способе подключения в коде необходимо указывать полный путь к сертификату root.crt для PostgreSQL в переменной ca.

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

   /etc/odbc.ini

   [postgresql]
   Driver=PostgreSQL Unicode
   Servername=c-<идентификатор_кластера>.rw.mdb.yandexcloud.net
   Username=<имя_пользователя>
   Password=<пароль_пользователя>
   Database=<имя_БД>
   Port=6432
   Pqopt=target_session_attrs=read-write
   Sslmode=verify-full
   

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

   isql -v postgresql
   

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

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

   connect.php

   <?php
     $conn = pg_connect("
         host=c-<идентификатор_кластера>.rw.mdb.yandexcloud.net
         port=6432
         sslmode=verify-full
         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. Пример кода:

   connect.py

   import psycopg2
   
   conn = psycopg2.connect("""
       host=c-<идентификатор_кластера>.rw.mdb.yandexcloud.net
       port=6432
       sslmode=verify-full
       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.r

   library(DBI)
   
   conn <- dbConnect(RPostgres::Postgres(),
       dbname="<имя_БД>",
       host="c-<идентификатор_кластера>.rw.mdb.yandexcloud.net",
       port=6432,
       sslmode="verify-full",
       user="<имя_пользователя>",
       password="<пароль_пользователя>"
   )
   
   res <- dbSendQuery(conn, "SELECT VERSION();")
   dbFetch(res)
   dbClearResult(res)
   
   dbDisconnect(conn)
   

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

   R connect.r
   

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

   connect.rb

   require "pg"
   
   conn = PG.connect("
           host=c-<идентификатор_кластера>.rw.mdb.yandexcloud.net
           port=6432
           dbname=<имя_БД>
           user=<имя_пользователя>
           password=<пароль_пользователя>
           target_session_attrs=read-write
           sslmode=verify-full
   ")
   
   q = conn.exec("SELECT version()")
   puts q.getvalue 0, 0
   
   conn.close()
   

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

   ruby connect.rb