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

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   = "postgres"
   	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/postgres?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/postgres",
    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=postgres
   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=postgres
         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=postgres
       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=c-<идентификатор_кластера>.rw.mdb.yandexcloud.net
           port=6432
           dbname=postgres
           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