在处理具有层级关系的树形结构数据时，递归查询是常见的需求。PHP结合MySQL可以很好地实现这一功能。本文将详细讲解如何使用MySQL实现递归查询，以及在PHP中如何调用这些查询来处理树形结构数据。
1. MySQL中的递归查询
MySQL从5.7版本开始支持递归查询，使用递归查询可以简化树形结构的查询操作。
1.1 创建树形结构的数据表
首先，我们需要一个数据表来存储树形结构的数据。以下是一个简单的例子：
CREATE TABLE categories (
id INT AUTO_INCREMENT PRIMARY KEY,
parent_id INT,
name VARCHAR(255),
FOREIGN KEY (parent_id) REFERENCES categories(id)
);
在这个例子中，
categories
表包含三个字段：
id
、
parent_id
和
name
。
parent_id
字段用于表示层级关系，其中
NULL
表示顶级节点。
1.2 使用递归查询获取所有子节点
使用递归查询可以轻松地获取某个节点的所有子节点。以下是一个示例：
SELECT id, name
FROM categories
WHERE parent_id = ?
ORDER BY id;
这个查询通过
parent_id
来获取指定节点的所有子节点。在递归查询中，我们通常使用一个临时表来存储中间结果，以下是递归查询的完整SQL语句：
WITH RECURSIVE sub_categories AS (
SELECT id, name, parent_id
FROM categories
WHERE parent_id = ?
UNION ALL
SELECT c.id, c.name, c.parent_id
FROM categories c
INNER JOIN sub_categories sc ON c.parent_id = sc.id
)
SELECT id, name
FROM sub_categories
ORDER BY id;
在这个查询中，
WITH RECURSIVE
语句用于定义递归查询。首先，我们选择顶级节点的子节点，然后通过
UNION ALL
语句将它们与下一级节点的子节点合并，直到没有更多子节点为止。
2. PHP中的递归查询
在PHP中，我们可以使用PDO或mysqli扩展来执行递归查询，并处理查询结果。
2.1 使用PDO执行递归查询
以下是使用PDO执行递归查询的示例：
PDO::ERRMODE_EXCEPTION,
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
PDO::ATTR_EMULATE_PREPARES => false,
];
try {
$pdo = new PDO($dsn, $user, $pass, $options);
} catch (\PDOException $e) {
throw new \PDOException($e->getMessage(), (int)$e->getCode());
}
// 获取顶级节点
$parentId = 1; // 假设顶级节点ID为1
$stmt = $pdo->prepare(“SELECT id, name, parent_id FROM categories WHERE parent_id = ?”);
$stmt->execute([$parentId]);
$categories = $stmt->fetchAll();
// 递归查询子节点
function getSubCategories($pdo, $parentId) {
$stmt = $pdo->prepare(“SELECT id, name, parent_id FROM categories WHERE parent_id = ?”);
$stmt->execute([$parentId]);
$subCategories = $stmt->fetchAll();
foreach ($subCategories as $category) {
$category[‘subCategories’] = getSubCategories($pdo, $category[‘id’]);
}
return $subCategories;
}
// 获取所有子节点
$allCategories = getSubCategories($pdo, $parentId);
在这个示例中，我们首先创建一个PDO连接，并使用递归函数
getSubCategories
来获取所有子节点。递归函数通过查询子节点并递归调用自身来获取所有层级的数据。
2.2 使用mysqli执行递归查询
以下是使用mysqli扩展执行递归查询的示例：
connect_error) {
die(‘Connect Error (‘ . $mysqli->connect_errno . ‘) ‘ . $mysqli->connect_error);
}
// 获取顶级节点
$parentId = 1; // 假设顶级节点ID为1
$stmt = $mysqli->prepare(“SELECT id, name, parent_id FROM categories WHERE parent_id = ?”);
$stmt->bind_param(“i”, $parentId);
$stmt->execute();
$categories = $stmt->get_result()->fetch_all(MYSQLI_ASSOC);
// 递归查询子节点
function getSubCategories($mysqli, $parentId) {
$stmt = $mysqli->prepare(“SELECT id, name, parent_id FROM categories WHERE parent_id = ?”);
$stmt->bind_param(“i”, $parentId);
$stmt->execute();
$subCategories = $stmt->get_result()->fetch_all(MYSQLI_ASSOC);
foreach ($subCategories as $category) {
$category[‘subCategories’] = getSubCategories($mysqli, $category[‘id’]);
}
return $subCategories;
}
// 获取所有子节点
$allCategories = getSubCategories($mysqli, $parentId);
在这个示例中，我们使用mysqli扩展创建了一个数据库连接，并使用递归函数
getSubCategories
来获取所有子节点。
3. 总结
通过以上示例，我们可以看到在PHP中使用MySQL实现递归查询的方法。递归查询可以帮助我们轻松处理树形结构数据，并简化我们的代码。在实际应用中，我们可以根据具体需求调整递归查询的SQL语句和PHP代码。