PHP实现DevExtreme过滤条件到MySQL WHERE子句的转换

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

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

/**
 * 将DevExtreme风格的过滤数组转换为带占位符的SQL WHERE子句。
 *
 * @param string $tableName 表名。
 * @param array $filterArray 过滤条件数组。
 * @return string 生成的SQL查询字符串。
 */
function arrayToQuery(string $tableName, array $filterArray) : string 
{
    $select = "SELECT * FROM `{$tableName}` WHERE ";

    foreach($filterArray as $item) {
        if(is_array($item)) {
            // 处理形如 ["SizeCd","=","UNIT"] 的条件
            // 字段名用反引号括起来，防止与SQL关键字冲突
            $select .= "`{$item[0]}` {$item[1]} ?"; 
        } else {
            // 处理形如 "or" 的逻辑运算符
            $select .= " {$item} ";
        }
    }

    return $select;
}

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

// 假设的过滤数组
$filterArray = [["SizeCd","=","UNIT"],"or",["SizeCd","=","JOGO"],"or",["SizeCd","=","PACOTE"]];

// 示例输出
var_dump(
    arrayToQuery("your_table_name", $filterArray),
    arrayToParams($filterArray)
);

/*
输出结果:
string(66) "SELECT * FROM `your_table_name` WHERE `SizeCd` = ? or `SizeCd` = ? or `SizeCd` = ?"
array(3) {
  [0]=>
  string(4) "UNIT"
  [1]=>
  string(4) "JOGO"
  [2]=>
  string(6) "PACOTE"
}
*/

// 实际PDO数据库操作
try {
    // 假设 $conn 是一个已建立的PDO连接对象
    $dsn = 'mysql:host=localhost;dbname=testdb;charset=utf8';
    $username = 'root';
    $password = 'password';
    $conn = new PDO($dsn, $username, $password);
    $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

    $tableName = "your_table_name"; // 替换为你的表名
    $sql = arrayToQuery($tableName, $filterArray);
    $params = arrayToParams($filterArray);

    $stmt = $conn->prepare($sql);
    $stmt->execute($params);

    $results = $stmt->fetchAll(PDO::FETCH_ASSOC);
    print_r($results);

} catch (PDOException $e) {
    echo "数据库错误: " . $e->getMessage();
}

/**
 * 将DevExtreme风格的过滤数组转换为MySQLi风格的SQL WHERE子句。
 * 注意：此方法直接将值嵌入SQL，需使用mysqli_real_escape_string进行转义以防SQL注入。
 * 
 * @param mysqli $mysqli MySQLi连接对象。
 * @param string $table 表名。
 * @param array $filterArray 过滤条件数组。
 * @return string 生成的SQL查询字符串。
 */
function arrayToQueryMysqli($mysqli, string $table, array $filterArray) : string 
{
    $select = "SELECT * FROM `{$table}` WHERE ";
    foreach($filterArray as $item) {
        if(is_array($item)) {
            // 对值进行转义并用单引号括起来
            $escapedValue = $mysqli->real_escape_string($item[2]);
            $select .= "`{$item[0]}` {$item[1]} '" . $escapedValue . "'";
        } else {
            $select .= " {$item} ";
        }
    }
    return $select;
}

// MySQLi使用示例
// 假设 $mysqli 是一个已建立的MySQLi连接对象
$mysqli = new mysqli("localhost", "root", "password", "testdb");

if ($mysqli->connect_error) {
    die("连接失败: " . $mysqli->connect_error);
}

$filterArray = [["SizeCd","=","UNIT"],"or",["SizeCd","=","JOGO"],"or",["SizeCd","=","PACOTE"]];
$tableName = "your_table_name"; // 替换为你的表名

$query = arrayToQueryMysqli($mysqli, $tableName, $filterArray);
echo "生成的SQL: " . $query . "\n";

$result = $mysqli->query($query);

if ($result) {
    while ($row = $result->fetch_assoc()) {
        print_r($row);
    }
    $result->free();
} else {
    echo "查询失败: " . $mysqli->error;
}

$mysqli->close();