8

我一直在使用 mysql_query 并且现在开始使用 PDO。太棒了！

但是在我的旧脚本中，我构建了一个动态查询构建器，并且我很难通过使用 PDO 来移植它。

如果有人能给我一些指导，那就太好了！

这是它的理论。

  1. 我有一个数组
  2. 数据库字段和值（插入时）。
  3. 创建查询字符串以生成有效的 PDO 事务

这是我正在尝试做的一部分。

public $dbFields; // This is an array of the fields plus VALUES

public function select($where, $limit) {
    // This is what I **had** before
    $query = "SELECT ". implode(", ", $this->dbFields) ." FROM ". $this->table." WHERE ". $where ." ". $limit."";

    // Now i need to convert that to PDO
    $this->connection->beginTransaction();

    # START Query
    $select = $this->connection->prepare("SELECT {$this->fieldNames} FROM {$this->table}");

    // I need to BIND my params and values, but i'm not sure the best route to take when I have a WHERE clause that includes, "AND" / "OR" operators.

    # EXECUTE the query
    $select->execute();

    $this->connection->commit();
}

这是我以前的

$results = $db->select("userId = 111 OR userId = 222");

但我想我需要做的是使用更像

$results = $db->select(array("userId"=>111, "userId"=>222));

我知道这是一项艰巨的任务，我希望这对我正在尝试做的事情有意义，但是对于尝试构建这些查询的任何帮助将不胜感激。

4

2 回答 2

5

您的方法需要一个单独的$params参数select。我冒昧地为方法参数提供默认值。就像@userXxxx 笔记一样，您不需要交易只是为了做一个SELECT.

<?php

class db {

    public $connection; //PDO
    public $dbFields; // This is an array of the fields plus VALUES

    public function select($where = '1', $params = array(), $limit = '', $fetchStyle = PDO::FETCH_ASSOC) { //fetchArgs, etc
        $fields = implode(', ', $this->dbFields);

        //create query
        $query = "SELECT $fields FROM {$this->table} WHERE $where $limit";

        //prepare statement
        $stmt = $this->connection->query($query);

        $stmt->execute($params);

        return $stmt->fetchAll($fetchStyle);
    }

    //...
}


$where = 'userId IN(:userId1, :userId2)';
$params = array(':userId1' => 111, ':userId2' => 2222);
$db->select($where, $params);

笔记：

  • 如果你真的想要，你可以添加额外的方法参数来匹配PDOStatement::fetchAll的所有灵活性。
  • 我不确定您所说$dbFields的“字段加值”是什么意思。你可以解释吗？

[编辑]

您可能想查看PDOStatement::execute的文档/示例，因为这似乎是您困惑的根源——尤其是$input_parameters方法参数。

于 2012-08-28T03:14:11.540 回答
-2

那这个呢？

public function select($where, $limit) {
    $query = "SELECT ". implode(", ", $this->dbFields) ." FROM ". $this->table." WHERE ". $where ." ". $limit."";
    $this->connection->query($query);
}

//Use what you had before:
$results = $db->select("userId = 111 OR userId = 222");

不确定为什么要使用事务（用于全有或全无或捕获异常和回滚）或准备好的查询（用于发送多个查询）...

于 2012-08-28T02:51:51.933 回答