php连接mysql集群

<?php
// 主服务器配置
$master_host = 'master_host';
$master_user = 'master_user';
$master_pass = 'master_pass';
$master_db = 'master_db';

// 从服务器配置
$slave_hosts = [
    ['host' => 'slave_host1', 'user' => 'slave_user1', 'pass' => 'slave_pass1'],
    ['host' => 'slave_host2', 'user' => 'slave_user2', 'pass' => 'slave_pass2']
];

// 连接主服务器
$master_conn = mysqli_connect($master_host, $master_user, $master_pass, $master_db);

if (!$master_conn) {
    die('主服务器连接失败: ' . mysqli_connect_error());
}

// 连接从服务器
$slave_conns = [];
foreach ($slave_hosts as $slave) {
    $conn = mysqli_connect($slave['host'], $slave['user'], $slave['pass'], $master_db);
    if ($conn) {
        $slave_conns[] = $conn;
    } else {
        echo '从服务器连接失败: ' . mysqli_connect_error() . "\n";
    }
}

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

if ($result) {
    while ($row = mysqli_fetch_assoc($result)) {
        echo "主服务器结果: " . $row['column_name'] . "\n";
    }
    mysqli_free_result($result);
}

foreach ($slave_conns as $conn) {
    $result = mysqli_query($conn, $query);
    if ($result) {
        while ($row = mysqli_fetch_assoc($result)) {
            echo "从服务器结果: " . $row['column_name'] . "\n";
        }
        mysqli_free_result($result);
    }
}

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