将DevExtreme过滤器转换为MySQL WHERE子句的PHP教程

{
  "from": "get_data",
  "skip": 0,
  "take": 50,
  "requireTotalCount": true,
  "filter": [["SizeCd","=","UNIT"],"or",["SizeCd","=","JOGO"]]
}

$filterArray = [
    ["SizeCd","=","UNIT"],
    "or",
    ["SizeCd","=","JOGO"],
    "or",
    ["SizeCd","=","PACOTE"]
];

/**
 * 将过滤数组转换为带有占位符的SQL WHERE子句。
 *
 * @param string $tableName 目标表名。
 * @param array $filterArray DevExtreme风格的过滤数组。
 * @return string 包含占位符的SQL查询字符串。
 */
function arrayToQuery(string $tableName, array $filterArray) : string
{
    // 确保表名被反引号包围，以处理特殊字符或保留字
    $select = "SELECT * FROM `{$tableName}` WHERE ";

    foreach($filterArray as $item) {
        if(is_array($item)) {
            // 条件数组：[字段, 运算符, 值]
            // 字段名用反引号包围，值用问号占位符
            $select .= "`{$item[0]}` {$item[1]} ?";
        } else {
            // 逻辑运算符："or", "and"
            $select .= " {$item} ";
        }
    }

    return $select;
}

/**
 * 从过滤数组中提取所有条件的值。
 *
 * @param array $filterArray DevExtreme风格的过滤数组。
 * @return array 包含所有参数值的数组。
 */
function arrayToParams(array $filterArray) : array
{
    $params = [];
    foreach($filterArray as $item) {
        if(is_array($item)) {
            // 提取条件数组中的第三个元素（即值）
            $params[] = $item[2];
        }
    }
    return $params;
}

// 示例数据
$filterArray = [
    ["SizeCd","=","UNIT"],
    "or",
    ["SizeCd","=","JOGO"],
    "or",
    ["SizeCd","=","PACOTE"]
];

// 假设您已建立PDO连接
// $dsn = 'mysql:host=localhost;dbname=your_database';
// $username = 'your_username';
// $password = 'your_password';
// try {
//     $conn = new PDO($dsn, $username, $password);
//     $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
// } catch (PDOException $e) {
//     die("数据库连接失败: " . $e->getMessage());
// }
// 替换为您的实际PDO连接对象
$conn = null; // 占位符，请替换为您的实际PDO连接

$tableName = "your_table_name"; // 替换为您的实际表名

// 生成SQL查询字符串和参数数组
$sql = arrayToQuery($tableName, $filterArray);
$params = arrayToParams($filterArray);

echo "生成的SQL查询: " . $sql . "\n";
echo "绑定的参数: " . print_r($params, true) . "\n";

// 实际执行查询
if ($conn) {
    try {
        $stmt = $conn->prepare($sql);
        $stmt->execute($params);
        $results = $stmt->fetchAll(PDO::FETCH_ASSOC);
        echo "查询结果:\n";
        print_r($results);
    } catch (PDOException $e) {
        echo "查询执行失败: " . $e->getMessage();
    }
} else {
    echo "请提供有效的PDO连接对象。\n";
}

生成的SQL查询: SELECT * FROM `your_table_name` WHERE `SizeCd` = ? or `SizeCd` = ? or `SizeCd` = ?
绑定的参数: Array
(
    [0] => UNIT
    [1] => JOGO
    [2] => PACOTE
)

/**
 * 将过滤数组转换为MySQLi风格的SQL WHERE子句，并对值进行转义。
 *
 * @param mysqli $mysqli MySQLi连接对象。
 * @param string $tableName 目标表名。
 * @param array $filterArray DevExtreme风格的过滤数组。
 * @return string 完整的SQL查询字符串。
 */
function arrayToQueryMysqli($mysqli, string $tableName, array $filterArray) : string
{
    // 确保表名被反引号包围
    $select = "SELECT * FROM `{$tableName}` WHERE ";
    foreach($filterArray as $item) {
        if(is_array($item)) {
            // 条件数组：[字段, 运算符, 值]
            // 字段名用反引号包围，值通过 real_escape_string 转义后用单引号包围
            $escapedValue = $mysqli->real_escape_string($item[2]);
            $select .= "`{$item[0]}` {$item[1]} '{$escapedValue}'";
        } else {
            // 逻辑运算符
            $select .= " {$item} ";
        }
    }
    return $select;
}

// 示例数据
$filterArray = [
    ["SizeCd","=","UNIT"],
    "or",
    ["SizeCd","=","JOGO"],
    "or",
    ["SizeCd","=","PACOTE"]
];

// 替换为您的实际MySQLi连接设置
// $mysqli = new mysqli("localhost", "your_username", "your_password", "your_database");
// if ($mysqli->connect_errno) {
//     die("MySQLi 连接失败: " . $mysqli->connect_error);
// }
$mysqli = null; // 占位符，请替换为您的实际MySQLi连接

$tableName = "tablename"; // 替换为您的实际表名

// 生成SQL查询字符串
if ($mysqli) {
    $query = arrayToQueryMysqli($mysqli, $tableName, $filterArray);
    echo "生成的SQL查询: " . $query . "\n";

    // 执行查询
    $result = $mysqli->query($query);

    if ($result) {
        echo "查询成功，获取到 " . $result->num_rows . " 条记录。\n";
        // 示例：打印第一行数据
        // if ($row = $result->fetch_assoc()) {
        //     print_r($row);
        // }
        $result->free(); // 释放结果集
    } else {
        echo "查询失败: " . $mysqli->error . "\n";
    }
    $mysqli->close(); // 关闭连接
} else {
    echo "请提供有效的MySQLi连接对象。\n";
}

生成的SQL查询: SELECT * FROM `tablename` WHERE `SizeCd` = 'UNIT' or `SizeCd` = 'JOGO' or `SizeCd` = 'PACOTE'