最近，我在使用 php 编写一个视频观看网站，发现一个很常见的需求是把用户的观看历史记录保存到数据库中，并且随时同步更新。基于此需求，我尝试了多种实现方式，最终选择了将观看记录同步到 mysql 数据库中的方案。本文将分享一下我是如何使用 php 实现观看记录同步到 mysql 的。
首先，我在 MySQL 数据库中创建了一个名为 watch_history 的表，该表包含以下字段：id、user_id、video_id 和 created_at。其中，id 为主键，user_id 指用户的 ID，video_id 指观看的视频 ID，created_at 指记录的创建时间。
接下来，在 PHP 代码中，我创建了一个名为 WatchHistory 的类，该类包括以下方法：
- add($userId, $videoId)：新增一条用户的观看记录
- getList($userId)：获取指定用户的观看记录列表
- clean($userId)：清除指定用户的所有观看记录
在 add 方法中，我使用 INSERT INTO 语句向 watch_history 表中添加一条记录。示例代码如下：
public function add($userId, $videoId) {
$created_at = date('Y-m-d H:i:s');
$sql = "INSERT INTO watch_history (user_id, video_id, created_at) VALUE ('$userId', '$videoId', '$created_at')";
// 执行 MySQL 插入操作
// ...
}在 getList 方法中，我使用 SELECT 语句从 watch_history 表中获取指定用户的所有观看记录。示例代码如下：
立即学习“PHP免费学习笔记（深入）”；
public function getList($userId) {
$sql = "SELECT * FROM watch_history WHERE user_id = '$userId' ORDER BY created_at DESC";
// 执行 MySQL 查询操作
// ...
}在 clean 方法中，我使用 DELETE 语句从 watch_history 表中删除指定用户的所有观看记录。示例代码如下：
public function clean($userId) {
$sql = "DELETE FROM watch_history WHERE user_id = '$userId'";
// 执行 MySQL 删除操作
// ...
}最后，为了避免频繁连接和关闭数据库连接，我使用了一个名为 Database 的单例类来管理 MySQL 数据库的连接。示例代码如下：
class Database {
private static $_instance;
private $_pdo;
private function __construct() {
// 连接 MySQL 数据库
// ...
}
public static function getInstance() {
if (!self::$_instance) {
self::$_instance = new self();
}
return self::$_instance;
}
public function query($sql, $params = null) {
$stmt = $this->_pdo->prepare($sql);
$stmt->execute($params);
return $stmt;
}
}至此，我成功实现了将观看记录同步到 MySQL 数据库的功能。虽然这只是一个简单的例子，但相信该方案在实际开发中也是可行的。希望我的经验能对各位 PHP 开发者有所帮助。
