以下是一个使用PHP调用Redis读取MySQL员工信息数据集,并将其保存到Redis中的示例:

<?php
// 连接MySQL数据库
$mysqlHost = 'localhost';
$mysqlUsername = 'root';
$mysqlPassword = 'password';
$mysqlDatabase = 'employees';

$mysqli = new mysqli($mysqlHost, $mysqlUsername, $mysqlPassword, $mysqlDatabase);

if ($mysqli->connect_errno) {
    echo "Failed to connect to MySQL: " . $mysqli->connect_error;
    exit();
}

// 连接Redis数据库
$redisHost = '127.0.0.1';
$redisPort = 6379;

$redis = new Redis();
$redis->connect($redisHost, $redisPort);

// 读取MySQL员工信息数据集
$query = "SELECT * FROM employees";
$result = $mysqli->query($query);

// 清空$rs
$redis->del('rs');

// 遍历显示并保存到Redis的记录集$rs
while ($row = $result->fetch_assoc()) {
    $redis->rpush('rs', json_encode($row));
    echo "Employee ID: " . $row['emp_id'] . ", Name: " . $row['emp_name'] . "<br>";
}

// 关闭MySQL数据库连接
$mysqli->close();

// 读取Redis的记录集$rs并显示
$rs = $redis->lrange('rs', 0, -1);
foreach ($rs as $row) {
    $employee = json_decode($row, true);
    echo "Employee ID: " . $employee['emp_id'] . ", Name: " . $employee['emp_name'] . "<br>";
}

// 清空$rs
$redis->del('rs');

// 关闭Redis数据库连接
$redis->close();
?>

在上述示例中,我们首先连接到MySQL数据库并执行查询,然后将查询结果遍历保存到Redis的记录集$rs中。接着,我们从Redis中读取记录集$rs并进行显示。最后,我们清空记录集$rs并关闭数据库连接

标签: 科技


原文地址: https://cveoy.top/t/topic/hXKB 著作权归作者所有。请勿转载和采集!