php实例 调用redis 读取mysql员工信息数据集到redis 命名为$rs 和 遍历显示保存到 redis的记录集$rs 清空$rs
以下是一个使用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 著作权归作者所有。请勿转载和采集!