Aiven for MySQL

const mysql = require('mysql2/promise');
const fs = require('fs');

async function main() {
  const connection = await mysql.createConnection({
    host: 'mysql-service.aivencloud.com',
    port: 12345,
    user: 'avnadmin',
    password: 'your-password',
    database: 'defaultdb',
    ssl: {
      ca: fs.readFileSync('./ca.pem')
    }
  });

  // Insert data
  await connection.execute(
    'INSERT INTO users (email, name) VALUES (?, ?)',
    ['[email protected]', 'John Doe']
  );

  // Query data
  const [rows] = await connection.execute(
    'SELECT * FROM users WHERE email = ?',
    ['[email protected]']
  );
  
  console.log(rows);
  await connection.end();
}

main().catch(console.error);

import java.sql.*;

public class MySQLExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://mysql-service.aivencloud.com:12345/defaultdb" +
                    "?sslMode=VERIFY_CA" +
                    "&trustCertificateKeyStoreUrl=file:./ca.pem";
        String user = "avnadmin";
        String password = "your-password";

        try (Connection conn = DriverManager.getConnection(url, user, password)) {
            // Create table
            Statement stmt = conn.createStatement();
            stmt.execute(
                "CREATE TABLE IF NOT EXISTS products (" +
                "id INT AUTO_INCREMENT PRIMARY KEY," +
                "name VARCHAR(255)," +
                "price DECIMAL(10,2))" 
            );

            // Insert data
            PreparedStatement pstmt = conn.prepareStatement(
                "INSERT INTO products (name, price) VALUES (?, ?)"
            );
            pstmt.setString(1, "Widget");
            pstmt.setBigDecimal(2, new BigDecimal("19.99"));
            pstmt.executeUpdate();

            // Query data
            ResultSet rs = stmt.executeQuery("SELECT * FROM products");
            while (rs.next()) {
                System.out.println(rs.getString("name") + ": $" + rs.getBigDecimal("price"));
            }

        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

<?php
$host = 'mysql-service.aivencloud.com';
$port = 12345;
$dbname = 'defaultdb';
$user = 'avnadmin';
$password = 'your-password';

// Create connection
$mysqli = new mysqli($host, $user, $password, $dbname, $port);

// Configure SSL
$mysqli->ssl_set(NULL, NULL, './ca.pem', NULL, NULL);

if ($mysqli->connect_error) {
    die('Connection failed: ' . $mysqli->connect_error);
}

// Insert data
$stmt = $mysqli->prepare("INSERT INTO users (email, name) VALUES (?, ?)");
$stmt->bind_param("ss", $email, $name);
$email = '[email protected]';
$name = 'John Doe';
$stmt->execute();

// Query data
$result = $mysqli->query("SELECT * FROM users");
while ($row = $result->fetch_assoc()) {
    echo $row['name'] . ' - ' . $row['email'] . "\n";
}

$mysqli->close();
?>

package main

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

func main() {
    dsn := "avnadmin:password@tcp(mysql-service.aivencloud.com:12345)/defaultdb?tls=true"
    db, err := sql.Open("mysql", dsn)
    if err != nil {
        log.Fatal(err)
    }
    defer db.Close()

    // Insert data
    _, err = db.Exec(
        "INSERT INTO users (email, name) VALUES (?, ?)",
        "[email protected]", "John Doe",
    )
    if err != nil {
        log.Fatal(err)
    }

    // Query data
    rows, err := db.Query("SELECT id, email, name FROM users")
    if err != nil {
        log.Fatal(err)
    }
    defer rows.Close()

    for rows.Next() {
        var id int
        var email, name string
        if err := rows.Scan(&id, &email, &name); err != nil {
            log.Fatal(err)
        }
        fmt.Printf("%d: %s (%s)\n", id, name, email)
    }
}

avn service create my-mysql-replica \
  --service-type mysql \
  --cloud aws-eu-west-1 \
  --plan business-4 \
  --replica-of my-mysql-primary

avn service update my-mysql \
  --restore-backup backup-id