php 连接mysql集群

<?php
// 主节点配置
$master_host = 'master_host';
$master_user = 'master_user';
$master_password = 'master_password';
$master_db = 'master_db';

// 从节点配置
$slave_hosts = [
    'slave_host1',
    'slave_host2',
    'slave_host3'
];
$slave_user = 'slave_user';
$slave_password = 'slave_password';
$slave_db = 'slave_db';

// 连接主节点
$master_conn = mysqli_connect($master_host, $master_user, $master_password, $master_db);

if (!$master_conn) {
    die('连接主节点失败: ' . mysqli_connect_error());
}

// 连接从节点
$slave_conns = [];
foreach ($slave_hosts as $slave_host) {
    $conn = mysqli_connect($slave_host, $slave_user, $slave_password, $slave_db);
    if ($conn) {
        $slave_conns[] = $conn;
    } else {
        echo '连接从节点失败: ' . mysqli_connect_error() . "\n";
    }
}

// 示例查询
$sql = "SELECT * FROM example_table";
$result = mysqli_query($master_conn, $sql);

if ($result) {
    while ($row = mysqli_fetch_assoc($result)) {
        echo "ID: " . $row['id'] . " - Name: " . $row['name'] . "\n";
    }
    mysqli_free_result($result);
} else {
    echo '查询失败: ' . mysqli_error($master_conn);
}

// 关闭连接
mysqli_close($master_conn);
foreach ($slave_conns as $conn) {
    mysqli_close($conn);
}
?>