PHP快速入门13-MySQL数据库与Redis操作

news2024/11/27 7:34:10

文章目录

前言
一、PHP连接MySQL
- 1.1 建立数据库链接
- 1.2 插入数据
- 1.3 更新数据
- 1.4 删除数据
- 1.5 查询数据并输出结果
- 1.6 查询数据并返回结果
- 1.7 获取查询结果的行数
- 1.8 获取查询结果的列数
- 1.9 获取查询结果的字段名
- 1.10 获取查询结果的字段类型
- 1.11 获取上一次操作影响的行数
- 1.12 开启事务
- 1.13 设置字符集
- 1.14 预处理语句
- 1.15 关闭数据库连接
二、PHP链接操作Redis
- 2.1 安装Redis
- 2.2 操作redis的30个例子
总结

前言

本文已收录于PHP全栈系列专栏：PHP快速入门与实战

在这里插入图片描述

一、PHP连接MySQL

PHP链接MySQL可以使用mysqli或PDO两种方式，其中mysqli是面向过程的，而PDO是面向对象的。以下是使用mysqli链接MySQL的示例代码：

1.1 建立数据库链接

$conn = mysqli_connect("localhost", "username", "password", "database");
if (!$conn) {
    die("连接失败: " . mysqli_connect_error());
}

1.2 插入数据

$sql = "INSERT INTO users (name, age, email) VALUES ('John', 25, 'john@example.com')";
if (mysqli_query($conn, $sql)) {
    echo "新记录插入成功";
} else {
    echo "Error：" . $sql . "<br>" . mysqli_error($conn);
}

1.3 更新数据

$sql = "UPDATE users SET name='Jane' WHERE id=1";
if (mysqli_query($conn, $sql)) {
    echo "记录更新成功";
} else {
    echo "Error：" . $sql . "<br>" . mysqli_error($conn);
}

1.4 删除数据

$sql = "DELETE FROM users WHERE id=1";
if (mysqli_query($conn, $sql)) {
    echo "记录删除成功";
} else {
    echo "Error：" . $sql . "<br>" . mysqli_error($conn);
}

1.5 查询数据并输出结果

$sql = "SELECT * FROM users";
$result = mysqli_query($conn, $sql);

if (mysqli_num_rows($result) > 0) {
    while($row = mysqli_fetch_assoc($result)) {
        echo "Name: " . $row["name"]. " - Age: " . $row["age"]. " - Email: " . $row["email"]. "<br>";
    }
} else {
    echo "没有记录";
}

1.6 查询数据并返回结果

$sql = "SELECT * FROM users WHERE age > 18";
$result = mysqli_query($conn, $sql);

if (mysqli_num_rows($result) > 0) {
    while($row = mysqli_fetch_assoc($result)) {
        print_r($row); // 输出结果数组
    }
} else {
    echo "没有记录";
}

1.7 获取查询结果的行数

$sql = "SELECT * FROM users";
$result = mysqli_query($conn, $sql);

echo "共有 ". mysqli_num_rows($result) . " 条记录";

1.8 获取查询结果的列数

$sql = "SELECT * FROM users";
$result = mysqli_query($conn, $sql);

$num_columns = mysqli_field_count($conn);
echo "共有 ".$num_columns." 列";

1.9 获取查询结果的字段名

$sql = "SELECT * FROM users";
$result = mysqli_query($conn, $sql);
$fields = mysqli_fetch_fields($result);

foreach ($fields as $field) {
    echo $field->name."<br>";
}

1.10 获取查询结果的字段类型

$sql = "SELECT * FROM users";
$result = mysqli_query($conn, $sql);
$fields = mysqli_fetch_fields($result);

foreach ($fields as $field) {
    echo $field->type."<br>";
}

1.11 获取上一次操作影响的行数

$sql = "DELETE FROM users WHERE age < 18";
mysqli_query($conn, $sql);
echo "删除了 ". mysqli_affected_rows($conn) . " 条记录";

1.12 开启事务

mysqli_autocommit($conn, false);
mysqli_begin_transaction($conn);

// 执行一系列操作

if (成功) {
    mysqli_commit($conn);
} else {
    mysqli_rollback($conn);
}

1.13 设置字符集

mysqli_set_charset($conn, "utf8");

1.14 预处理语句

$stmt = mysqli_prepare($conn, "INSERT INTO users (name, age, email) VALUES (?, ?, ?)");
mysqli_stmt_bind_param($stmt, "sis", $name, $age, $email);

$name = "John";
$age = 25;
$email = "john@example.com";
mysqli_stmt_execute($stmt);

1.15 关闭数据库连接

mysqli_close($conn);

二、PHP链接操作Redis

2.1 安装Redis

PHP链接redis:

首先需要安装redis扩展，可以使用pecl命令进行安装：pecl install redis
在php.ini文件中添加extension=redis.so
使用以下代码链接redis数据库：

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

其中’127.0.0.1’是redis主机地址，6379是redis端口号。

2.2 操作redis的30个例子

设置key和value: $redis->set('key', 'value');
获取key的值: $redis->get('key');
判断key是否存在: $redis->exists('key');
删除key: $redis->del('key');
设置key过期时间: $redis->expire('key', 60);
获取key过期时间: $redis->ttl('key');
自增: $redis->incr('key');
自减: $redis->decr('key');
加入列表: $redis->lPush('key', 'value1', 'value2', ...);
弹出列表中的一个元素: $redis->lPop('key');
获取列表长度: $redis->lLen('key');
获取列表中指定范围内的元素: $redis->lRange('key', $start, $end);
在列表中删除指定元素: $redis->lRem('key', 'value');
对集合进行添加操作: $redis->sAdd('key', 'value1', 'value2', ...);
获取集合的元素个数: $redis->sCard('key');
判断元素是否在集合中: $redis->sIsMember('key', 'value');
从集合中删除一个元素: $redis->sRem('key', 'value');
向有序集合中添加元素: $redis->zAdd('key', $score, 'value');
获取有序集合中元素的数量: $redis->zCard('key');
获取有序集合中指定范围内的元素: $redis->zRange('key', $start, $end);
从有序集合中删除指定元素: $redis->zRem('key', 'value');
获取hash表中所有的键值对: $redis->hGetAll('key');
设置hash表中某个字段的值: $redis->hSet('key', 'field', 'value');
获取hash表中某个字段的值: $redis->hGet('key', 'field');
判断hash表中某个字段是否存在: $redis->hExists('key', 'field');
删除hash表中某个字段: $redis->hDel('key', 'field');
发布消息: $redis->publish('channel', 'message');
订阅消息: $redis->subscribe(array('channel'), function($redis, $channel, $message) {echo $message;});
监听某个key的变化: $redis->subscribe(array('__keyspace@0__:key'), function($redis, $channel, $message) {echo $channel, ':', $message;});
设置某个key的值，当值为指定值时才更新: $redis->watch('key'); $redis->multi(); $redis->set('key', 'new_value'); $redis->exec();