Shared Database with Automatic Replication

{
  "version": 8,
  "name": "myshareddb",
  "description": "Application with shared replicated database",
  "owner": "YOUR_ZELID_HERE",
  "instances": 3,
  "staticip": false,
  "enterprise": "",
  "compose": [
    {
      "name": "mysql",
      "description": "MySQL database engine",
      "repotag": "mysql:8.0",
      "ports": [3306],
      "containerPorts": [3306],
      "domains": [""],
      "environmentParameters": [
        "MYSQL_ROOT_PASSWORD=myRootPassword123",
        "MYSQL_DATABASE=myapp"
      ],
      "commands": [],
      "containerData": "s:/var/lib/mysql",
      "cpu": 1.0,
      "ram": 2000,
      "hdd": 10,
      "tiered": false
    },
    {
      "name": "operator",
      "description": "Flux Shared DB operator",
      "repotag": "runonflux/shared-db:latest",
      "ports": [3307, 8080],
      "containerPorts": [3307, 8080],
      "domains": [""],
      "environmentParameters": [
        "DB_COMPONENT_NAME=fluxmysql_myshareddb",
        "DB_APPNAME=myshareddb",
        "CLIENT_APPNAME=myapp",
        "DB_INIT_PASS=myRootPassword123",
        "INIT_DB_NAME=myapp",
        "DB_USER=root",
        "DB_PORT=3307",
        "API_PORT=8080"
      ],
      "commands": [],
      "containerData": "s:/app/dumps",
      "cpu": 1.0,
      "ram": 2000,
      "hdd": 10,
      "tiered": false
    },
    {
      "name": "app",
      "description": "Application using shared database",
      "repotag": "yourusername/yourapp:latest",
      "ports": [3000],
      "containerPorts": [3000],
      "domains": [""],
      "environmentParameters": [
        "DB_HOST=fluxoperator_myshareddb",
        "DB_PORT=3307",
        "DB_NAME=myapp",
        "DB_USER=root",
        "DB_PASSWORD=myRootPassword123"
      ],
      "commands": [],
      "containerData": "/appdata",
      "cpu": 2.0,
      "ram": 4000,
      "hdd": 20,
      "tiered": false
    }
  ]
}

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

// Connect to Flux Shared DB operator, NOT directly to MySQL
const pool = mysql.createPool({
  host: process.env.DB_HOST,        // fluxoperator_myshareddb
  port: process.env.DB_PORT || 3307, // Operator proxy port
  database: process.env.DB_NAME,
  user: process.env.DB_USER,
  password: process.env.DB_PASSWORD,
  waitForConnections: true,
  connectionLimit: 10,
  queueLimit: 0
});

// Test connection
async function testConnection() {
  try {
    const connection = await pool.getConnection();
    console.log('✓ Connected to Flux Shared DB');

    // This query will be routed to local replica (fast!)
    const [rows] = await connection.query('SELECT 1 + 1 AS result');
    console.log('✓ Query test successful:', rows);

    connection.release();
  } catch (error) {
    console.error('✗ Database connection failed:', error);
  }
}

// Write operation (routed to master, then replicated)
async function createUser(name, email) {
  const [result] = await pool.execute(
    'INSERT INTO users (name, email) VALUES (?, ?)',
    [name, email]
  );
  return result.insertId;
}

// Read operation (routed to local replica)
async function getUsers() {
  const [rows] = await pool.query('SELECT * FROM users');
  return rows;
}

module.exports = { testConnection, createUser, getUsers };

# Get cluster information
curl https://myshareddb-operator-abc123.app.runonflux.io:8080/cluster

# Response shows master node and all replicas
{
  "master": "192.168.1.10:3307",
  "replicas": [
    "192.168.1.11:3307",
    "192.168.1.12:3307"
  ],
  "status": "healthy"
}