Микросервисы: подключение к базам данных из приложений на Python, Go и JavaScript

Для работы с MySQL существует официальный драйвер MySQL Connector.

1) Для начала установим драйвер при помощи менеджера пакетов pip:

    

      

    
    pip install mysql-connector-python
  

2) Далее инициализируем новое соединение к серверу MySQL. Импортируем библиотеку mysql.connector и отдельно класс Error который в случае проблем с подключением будет выводить конкретную ошибку.

Создаем функцию с именем create_connection в которую передадим значения адреса БД (host), имени пользователя (user) и пароля пользователя (password). Чтобы произвести соединение создадим класс create_connection в который передадим имена переменных в которых хранятся данные для подключения к баз данных:

    

      

    
    import mysql.connector
from mysql.connector import Error

def create_connection(host_name, user_name, user_password):
    connection = None
    try:
        connection = mysql.connector.connect(
            host="194.87.190.137",
            user="gen_user",
            password="m-EE6Wm}z@wCKe"
        )
        print("Successfully connected to MySQL Server!")
    except Error as e:
        print(f"The error '{e}' occurred")
    return connection

def execute_query(connection, query):
    cursor = connection.cursor()
    try:
        cursor.execute(query)
        connection.commit()
        print("Query executed successfully")
    except Error as e:
        print(f"The error '{e}' occurred")

connection = create_connection("194.87.190.137", "gen_user", "m-EE6Wm}z@wCKe")
  

3) Запускаем скрипт. При успешном соединение с MySQL будет выведено сообщение «Successfully connected to MySQL Server!».

При наличие ошибок будет выведен код и описание ошибки.

4) Создадим новую таблицу. Подключаемся к базе данных используя класс connection.database в котором указываем имя базы данных. БД должна уже быть предварительно создана.

Для создания таблицы инициализируем переменную create_table_query в которой указываем SQL запрос CREATE TABLE. Для вставки данных инициализируем другую переменную insert_data_query в которой будет указан SQL запрос INSERT INTO. Для выполнения каждого запроса используется класс execute_query который принимает строку с соединением к БД и имя переменной с SQL запросом: 

    

      

    
    connection.database = 'test_db'

create_table_query = """
CREATE TABLE IF NOT EXISTS users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(100) NOT NULL,
    age INT NOT NULL
)
"""
execute_query(connection, create_table_query)

insert_data_query = """
INSERT INTO users (name, age) VALUES 
('Alice', 30),
('Bob', 25)
"""
execute_query(connection, insert_data_query)

if connection.is_connected():
    connection.close()
    print("Connection closed")

  

5) Запускаем скрипт:

Как можно увидеть данные были успешно созданы.

Для работы с СУБД MySQL в Go используется драйвер go-sql-driver/mysql.

1) Создаем новый каталог, в котором будут храниться файлы проекта, и переходим в него: 

    

      

    
    mkdirmysql-connect && cd mysql-connect
  

2) Создаем файл go.mod, в котором будут храниться зависимости:

    

      

    
    go mod init golang-connect-mysql
  

3) Скачиваем драйвер mysql при помощи команды go get:

    

      

    
    go get -u github.com/go-sql-driver/mysql
  

4) Создаем новый файл с именем main.go Данные для подключения к СУБД указаны в переменной dsn:

    

      

    
    package main

import (
    "database/sql"
    "fmt"
    "log"

    _ "github.com/go-sql-driver/mysql"
)

func main() {
    dsn := "root:password@tcp(localhost:3306)/testdb"

    db, err := sql.Open("mysql", dsn)
    if err != nil {
        log.Fatal(err)
    }
    defer db.Close()

    if err := db.Ping(); err != nil {
        log.Fatal(err)
    }

    fmt.Println("Successfully connected to the database!")

    query := "INSERT INTO users (name, age) VALUES (?, ?)"

    result, err := db.Exec(query, "Alex", 25)
    if err != nil {
        log.Fatal(err)
    }

    lastInsertID, err := result.LastInsertId()
    if err != nil {
        log.Fatal(err)
    }

    fmt.Printf("Inserted data with ID: %d\n", lastInsertID)
}
  

Для работы с MySQL используется драйвер mysql2. 

1) Создаем директорию в которой будем хранить файлы проекта:

    

      

    
    mkdir js-mysql-connect && cd js-mysql-connect
  

2) Инициализируем проект:

    

      

    
    npm init -y
  

3) Устанавливаем библиотеку mysql2:

    

      

    
    npm install mysql2
  

4) Для подключения к СУБД MySQL используем следующий код:

    

      

    
    const mysql = require('mysql2');

const connection_to_mysql = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'PasswordForRoot74463',
  database: db1,
});

connection_to_mysql.connect((err) => {
  if (err) {
    console.error('Error connecting to MySQL:', err.message);
    return;
  }
  console.log('Successfully connected to MySQL Server!');

    connection_to_mysql.end((endErr) => {
      if (endErr) {
        console.error('Error closing the connection_to_mysql:', endErr.message);
      } else {
        console.log('Connection closed.');
      }
    });
  });