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

mkdir ~/.mysql; curl -o ~/.mysql/root.crt https://storage.yandexcloud.net/cloud-certs/CA.pem

mysqlsh --host=<FQDN хоста MySQL> `
        --port=3306 `
        --ssl-ca=<абсолютный путь к файлу сертификата> `
        --ssl-mode=VERIFY_IDENTITY `
        --user=<имя пользователя> `
        --password `
        --database=<имя БД> `
        --sql

mysqlsh --host=<FQDN хоста MySQL> `
        --port=3306 `
        --ssl-mode=DISABLED `
        --user=<имя пользователя> `
        --password `
        --database=<имя БД>

sudo apt update && sudo apt install -y python3 python3-pip libmysqlclient-dev && \
pip3 install mysqlclient

import MySQLdb

conn = MySQLdb.connect(
      host="<FQDN хоста MySQL>",
      port=3306,
      db="<имя БД>",
      user="<имя пользователя>",
      passwd="<пароль пользователя>",
      ssl={'ca': '~/.mysql/root.crt'})

cur = conn.cursor()
cur.execute('SELECT version()')

print(cur.fetchone()[0])

conn.close()

import MySQLdb

conn = MySQLdb.connect(
      host="<FQDN хоста MySQL>",
      port=3306,
      db="<имя БД>",
      user="<имя пользователя>",
      passwd="<пароль пользователя>")

cur = conn.cursor()
cur.execute('SELECT version()')

print(cur.fetchone()[0])

conn.close()

python3 connect.py

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

 <?php
    $conn = mysqli_init();

    $conn->options(MYSQLI_OPT_SSL_VERIFY_SERVER_CERT, true);
    $conn->ssl_set(NULL, NULL, '/home/<домашняя директория>/.mysql/root.crt', NULL, NULL);
    $conn->real_connect('<FQDN хоста-мастера MySQL>', '<имя пользователя>', '<пароль пользователя>', '<имя БД>', 3306, NULL, MYSQLI_CLIENT_SSL);

    $q = $conn->query('SELECT version()');
    $result = $q->fetch_row();
    echo($result[0]);

    $q->close();
    $conn->close();
?>

 <?php
    $conn = mysqli_init();

    $conn->options(MYSQLI_OPT_SSL_VERIFY_SERVER_CERT, false);
    $conn->real_connect('<FQDN хоста MySQL>', '<имя пользователя>', '<пароль пользователя>', '<имя БД>', 3306, NULL, NULL);

    $q = $conn->query('SELECT version()');
    $result = $q->fetch_row();
    echo($result[0]);

    $q->close();
    $conn->close();
?>

php connect.php

package com.example;

import java.sql.*;

public class App {
  public static void main(String[] args) {
    String DB_URL     = "jdbc:mysql://<FQDN хоста MySQL>:3306/<имя БД>?useSSL=true";
    String DB_USER    = "<имя пользователя>";
    String DB_PASS    = "<пароль пользователя>";

    System.setProperty("javax.net.ssl.trustStore", "/home/<домашняя директория>/.mysql/YATrustStore");
    System.setProperty("javax.net.ssl.trustStorePassword", "<пароль хранилища сертификатов>");

    try {
      Class.forName("com.mysql.cj.jdbc.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:mysql://<FQDN хоста MySQL>:3306/<имя БД>?useSSL=false";
    String DB_USER    = "<имя пользователя>";
    String DB_PASS    = "<пароль пользователя>";

    try {
      Class.forName("com.mysql.cj.jdbc.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 mysql2

"use strict"
const fs = require('fs');
const mysql = require('mysql2');

const config = {
  host     : '<FQDN хоста MySQL>',
  port     : 3306,
  user     : '<имя пользователя>',
  password : '<пароль пользователя>',
  database : '<имя БД>',
  ssl: {
    rejectUnauthorized: true,
    ca: fs.readFileSync('/home/<домашняя директория>/.mysql/root.crt').toString(),
  },
}

const conn = mysql.createConnection(config)
conn.connect(err => {if (err) throw err})
  conn.query('SELECT version()', (err, result, fields) => {
    if (err) throw err
    console.log(result[0])
    conn.end()
  })

"use strict"
const mysql = require('mysql2');

const config = {
  host     : '<FQDN хоста MySQL>',
  port     : 3306,
  user     : '<имя пользователя>',
  password : '<пароль пользователя>',
  database : '<имя БД>',
}

const conn = mysql.createConnection(config)
conn.connect(err => {if (err) throw err})
  conn.query('SELECT version()', (err, result, fields) => {
    if (err) throw err
    console.log(result[0])
    conn.end()
  })

node app.js

sudo apt update && sudo apt install -y golang git && \
go get github.com/go-sql-driver/mysql

package main

import (
  "io/ioutil"
  "crypto/tls"
  "crypto/x509"
  "database/sql"
  "fmt"
  "github.com/go-sql-driver/mysql"
)

const (
  host     = "<FQDN хоста MySQL>"
  port     = 3306
  user     = "<имя пользователя>"
  password = "<пароль пользователя>"
  dbname   = "<имя БД>"
)

func main() {
  rootCertPool := x509.NewCertPool()
  pem, err := ioutil.ReadFile("/home/<домашняя директория>/.mysql/root.crt")
  if err != nil {
    panic(err)
  }
  if ok := rootCertPool.AppendCertsFromPEM(pem); !ok {
    panic("Failed to append PEM.")
  }

  mysql.RegisterTLSConfig("custom", &tls.Config{
    RootCAs: rootCertPool,
  })

  mysqlInfo := fmt.Sprintf("%s:%s@tcp(%s:%d)/%s?tls=custom",
    user, password, host, port, dbname)
  conn, err := sql.Open("mysql", mysqlInfo)
  if err != nil {
    panic(err)
  }

  defer conn.Close()

  q, err := conn.Query("SELECT version()")
  if err != nil {
    panic(err)
  }

  var result string

  for q.Next() {
   q.Scan(&result)
   fmt.Println(result)
  }
}

package main

import (
  "database/sql"
  "fmt"
  _ "github.com/go-sql-driver/mysql"
)

const (
  host     = "<FQDN хоста MySQL>"
  port     = 3306
  user     = "<имя пользователя>"
  password = "<пароль пользователя>"
  dbname   = "<имя БД>"
)

func main() {
  mysqlInfo := fmt.Sprintf("%s:%s@tcp(%s:%d)/%s",
    user, password, host, port, dbname)
  conn, err := sql.Open("mysql", mysqlInfo)
  if err != nil {
    panic(err)
  }

  defer conn.Close()

  q, err := conn.Query("SELECT version()")
  if err != nil {
    panic(err)
  }

  var result string

  for q.Next() {
   q.Scan(&result)
   fmt.Println(result)
  }
}

go run connect.go

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

require "mysql2"

conn = Mysql2::Client.new(
        :host => "<FQDN хоста MySQL>",
        :port => 3306,
        :database => "<имя БД>",
        :username => "<имя пользователя>",
        :password => "<пароль пользователя>",
        :ssl_mode => "verify_identity",
        :sslca => "~/.mysql/root.crt")

q = conn.query("SELECT version()")

q.each do |result|
  puts result["version()"]
end

conn.close()

require "mysql2"

conn = Mysql2::Client.new(
        :host => "<FQDN хоста MySQL>",
        :port => 3306,
        :database => "<имя БД>",
        :username => "<имя пользователя>",
        :password => "<пароль пользователя>")

q = conn.query("SELECT version()")

q.each do |result|
  puts result["version()"]
end

conn.close()

ruby connect.rb

sudo apt update && sudo apt install -y unixodbc && \
wget https://dev.mysql.com/get/Downloads/Connector-ODBC/8.0/mysql-connector-odbc_8.0.21-1ubuntu20.04_amd64.deb && \
sudo dpkg -i mysql-connector-odbc_8.0.21-1ubuntu20.04_amd64.deb

[mysql]
Driver=MySQL ODBC 8.0 Unicode Driver
SERVER=<FQDN хоста MySQL>
UID=<имя пользователя>
PWD=<пароль пользователя>
DATABASE=<имя БД>
PORT=3306
SSLCA=/home/<домашняя директория>/.mysql/root.crt
SSLVERIFY=1

[mysql]
Driver=MySQL ODBC 8.0 Unicode Driver
SERVER=<FQDN хоста MySQL>
UID=<имя пользователя>
PWD=<пароль пользователя>
DATABASE=<имя БД>
PORT=3306

isql -v mysql