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

sudo apt update && sudo apt install -y python3 python3-pip && \
pip3 install psycopg2-binary

import psycopg2

conn = psycopg2.connect("""
    host=<FQDN одного или нескольких хостов PostgreSQL>
    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()

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

python3 connect.py

sudo apt update && sudo apt install -y php php-pgsql

<?php
  $conn = pg_connect("
      host=<FQDN одного или нескольких хостов PostgreSQL>
      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);
?>

<?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);
?>

php connect.php

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

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

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

sudo apt update && sudo apt install -y nodejs npm && \
npm install pg

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

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

node app.js

sudo apt update && sudo apt install -y golang git && \
go get github.com/jackc/pgx && go mod init example

package main

import (
  "io/ioutil"
  "crypto/tls"
  "crypto/x509"
  "fmt"
  "github.com/jackc/pgx"
)

const (
  host     = "<FQDN одного или нескольких хостов PostgreSQL>"
  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.")
  }

  config := pgx.ConnConfig {
    Host: host,
    Port: port,
    User: user,
    Password: password,
    Database: dbname,
    TargetSessionAttrs: "read-write",
    TLSConfig: &tls.Config {
      RootCAs: rootCertPool,
      InsecureSkipVerify: true,
    },
  }

  conn, err := pgx.Connect(config)
  if err != nil {
    panic(err)
  }

  defer conn.Close()

  var version string

  err = conn.QueryRow("SELECT version()").Scan(&version)
  if err != nil {
    panic(err)
  }

  fmt.Println(version)
}

package main

import (
  "fmt"
  "github.com/jackc/pgx"
)

const (
  host     = "<FQDN одного или нескольких хостов PostgreSQL>"
  port     = 6432
  user     = "<имя пользователя>"
  password = "<пароль пользователя>"
  dbname   = "<имя БД>"
)

func main() {

  config := pgx.ConnConfig {
    Host: host,
    Port: port,
    User: user,
    Password: password,
    Database: dbname,
    TargetSessionAttrs: "read-write",
  }

  conn, err := pgx.Connect(config)
  if err != nil {
    panic(err)
  }

  defer conn.Close()

  var version string

  err = conn.QueryRow("SELECT version()").Scan(&version)
  if err != nil {
    panic(err)
  }

  fmt.Println(version)
}

go run connect.go

sudo apt update && sudo apt install -y ruby ruby-pg

require "pg"

conn = PG.connect("
        host=<FQDN одного или нескольких хостов PostgreSQL>
        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()

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

ruby connect.rb

sudo apt update && sudo apt install -y unixodbc odbc-postgresql

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

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

isql -v postgresql