我正在从事一个使用工作单元设计模式的项目。它包括Storage,EntityCollection,..... 代码工作单元包括PDO Adapter代码文件。但是适配器对于运行查询来说并不完整。我从某个地方找到了这些文件。 我无法构建我想要的查询。每次我编写代码时，我都会遇到许多与查询相关的问题。那么你能帮我让它更灵活吗...例如我想像这样运行: $db->select()->where('id>:id')->andWhere('')->orWHere ()->orderBy()->groupBy()->having()->fetch()/fetchOne();或类似的。

<?php

namespace D\Adapter;

class PdoAdapter implements \D\DB\DatabaseInterface {

    protected $config = array();
    protected $database;
    protected $connection;
    protected $statement;
    protected $fetchMode = \PDO::FETCH_ASSOC;

    public function __construct($dsn, $username = null, $password = null, array $driverOptions = array()) {
        $this->config = compact("dsn", "username", "password", "driverOptions");
        $this->database = $driverOptions['db_name'];
    }

    public function getStatement() {
        if ($this->statement === null) {
            throw new \PDOException(
            "There is no PDOStatement object for use.");
        }
        return $this->statement;
    }

    public function connect() {
        // if there is a PDO object already, return early
        if ($this->connection) {
            return;
        }

        try {
            $this->connection = new \PDO(
                    $this->config["dsn"], $this->config["username"], $this->config["password"], $this->config["driverOptions"]);
            $this->connection->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
            $this->connection->setAttribute(
                    \PDO::ATTR_EMULATE_PREPARES, false);
        } catch (\PDOException $e) {
            throw new \RunTimeException($e->getMessage());
        }
    }

    public function disconnect() {
        $this->connection = null;
    }

    public function prepare($sql, array $options = array()) {
        $this->connect();

        try {
            $this->statement = $this->connection->prepare($sql, $options);

            return $this;
        } catch (\PDOException $e) {
            throw new \RunTimeException($e->getMessage());
        }
    }

    public function execute(array $parameters = array()) {

        try {
            $this->getStatement()->execute($parameters);
            return $this;
        } catch (\PDOException $e) {
            throw new \RunTimeException($e->getMessage());
        }
    }

    public function countAffectedRows() {
        try {
            return $this->getStatement()->rowCount();
        } catch (\PDOException $e) {
            throw new \RunTimeException($e->getMessage());
        }
    }

    /**
     * countAffectedRows iin Alias
     */
    public function count() {
        try {
            return $this->getStatement()->rowCount();
        } catch (\PDOException $e) {
            throw new \RunTimeException($e->getMessage());
        }
    }

    public function getLastInsertId($name = null) {
        $this->connect();
        return $this->connection->lastInsertId($name);
    }

    public function fetch($fetchStyle = null, $cursorOrientation = null, $cursorOffset = null) {
        if ($fetchStyle === null) {
            $fetchStyle = $this->fetchMode;
        }

        try {
            return $this->getStatement()->fetch($fetchStyle, $cursorOrientation, $cursorOffset);
        } catch (\PDOException $e) {
            throw new \RunTimeException($e->getMessage());
        }
    }

    public function fetchAll($fetchStyle = null, $column = 0) {
        if ($fetchStyle === null) {
            $fetchStyle = $this->fetchMode;
        }

        try {
            return $fetchStyle === \PDO::FETCH_COLUMN ? $this->getStatement()->fetchAll($fetchStyle, $column) : $this->getStatement()->fetchAll($fetchStyle);
        } catch (\PDOException $e) {
            throw new \RunTimeException($e->getMessage());
        }
    }

    public function select($table, $bind = array(), $where = "", $options = array()) {
        if (count($bind) > 0) {
            foreach ($bind as $col => $value) {
                unset($bind[$col]);
                $bind[":" . $col] = $value;
            }
        }
        if (isset($options['fields'])) {
            $fields = $options['fields'];
        } else {
            $fields = '*';
        }
        $sql = "SELECT " . $fields . " FROM " . $table . " ";

        if (strlen($where) > 2) {
            $sql .= "WHERE " . $where;
        }

//        set_flash($sql);
        $this->prepare($sql)
                ->execute($bind);

        return $this;
    }

    public function query($sql, array $bind = array()) {
        if (is_array($bind)) {
            foreach ($bind as $col => $value) {
                unset($bind[$col]);
                $bind[":" . $col] = $value;
            }
        }

        $this->prepare($sql)
                ->execute($bind);
        return $this;
    }

    public function insert($table, array $bind) {
        $cols = implode(", ", array_keys($bind));
        $values = implode(", :", array_keys($bind));
        foreach ($bind as $col => $value) {
            unset($bind[$col]);
            $bind[":" . $col] = $value;
        }

        $sql = "INSERT INTO " . $table
                . " (" . $cols . ")  VALUES (:" . $values . ")";
        return (int) $this->prepare($sql)
                        ->execute($bind)
                        ->getLastInsertId();
    }

    public function update($table, array $bind, $where = "") {
        $set = array();
        foreach ($bind as $col => $value) {
            unset($bind[$col]);
            $bind[":" . $col] = $value;
            $set[] = $col . " = :" . $col;
        }

        $sql = "UPDATE " . $table . " SET " . implode(", ", $set)
                . (($where) ? " WHERE " . $where : " ");
        return $this->prepare($sql)
                        ->execute($bind)
                        ->countAffectedRows();
    }

    public function delete($table, $where = "") {
        $sql = "DELETE FROM " . $table . (($where) ? " WHERE " . $where : " ");
        return $this->prepare($sql)
                        ->execute()
                        ->countAffectedRows();
    }

    public function fetchAllTables() {
        $sql = "SHOW TABLES FROM " . $this->database;
        $this->prepare($sql)
                ->execute();

        return $this;
    }

    public function fetchAllFields($table) {
        $sql = "SHOW FIELDS FROM " . $table;
        $this->prepare($sql)
                ->execute();

        return $this;
    }

}

---完整代码在这里--- https://github.com/batmunkhcom/mbm/tree/master/src/D

最佳答案

首先，UnitOfWork 模式关注的是跟踪您在业务事务期间所做的一切可能影响数据库的事情。事务完成后，它会计算出因您的工作而需要完成的所有更改数据库的操作。你的类(class)还有其他问题。

它看起来像一个 godclass(反模式)。它有不止一项职责:Connection、PeparedStatement、Execution 和其他助手。它很难扩展和维护。尝试在 SOLID 中将所有职责分配给不同的类方式与相应的设计模式。

您在代码中面临的想法已经由其他框架完成。再次实现非常辛苦。例如你可以尝试 Doctrine ORM/DBAL Framework .

关于php - 我在我的项目中使用 PHP 的工作单元设计模式，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/21203806/