PHP/MySQL 隔离类中的数据库访问——如何以 OOP 方式处理多行结果集

Question

类中的PHP/MySQL隔离数据库访问——如何处理多行选择

这是一个编码问题。 我隔离了一个类中的所有数据库访问函数

<?php
class DB {
    var $conn;         
    function DBClass () {
                @$this-> conn = mysqli_connect (DB_SERVER, DB_USER, DB_PASS, DB_NAME);
    }
    function validateUser ($aUserid, $aPassword) {
                …  validation code – sql injection code etc..
                $sql = "Select userid, name, level From users where userid = '$aUserid' and password = '$aPassword'";
                $result = mysqli_query ( $this->conn, $sql );
                if (!$result || (mysqli_num_rows ($result) < 1)) {
                            return false;
                }
                $dbarray = mysqli_fetch_assoc ($result); // get a row
                return $dbarray;
    }

    function getProduct ($aProductid) {

                return $dbarray;
    }

    function getProductList () {  
                // <----------- this would be the problem function
    }
}

$DB = new DBClass();
?>

我的调用例程：

<?php
        $dbarray = $DB->validateUser ($_POST['userid'], $_POST['password']); 
?>

没问题，它工作正常。我遇到了超过一行的结果集的问题。现在我必须回到每一行的类对象。如果我在调用例程中包含 MySQL 代码没问题，但我想将它隔离在我的类中，我不知道如何编写它。

有什么想法吗？有什么例子吗？

Answer 1

如果你使用 PHP 5.3.0 和 mysqlnd，你可以使用新函数mysqli_fetch_all()。这将返回一个关联数组的数组。

如果您使用的是早期版本的 PHP，您可以切换到使用 PDO，并使用函数PDOStatement::fetchAll()。

您在评论中询问一个非常大的结果集怎么样。确实，无限的结果集可能会导致数组超出 PHP 内存限制，这会导致致命错误并停止脚本。但这真的是个问题吗？你有多少产品？您可以使用LIMIT 来确保查询不是无限的。

---

关于重返课堂的另一部分问题，我建议开设 Iterator 课堂：

class DB implements IteratorAggregate
{
  protected $_data = array();

  public function getProductList() {
    // fetch all results from SQL query, stuff them into $this->_data
    return $this->getIterator();
  }

  public function getIterator() {
    return new ArrayIterator($this->_data);
  }
}

现在您可以在foreach 循环中使用该类：

$db = new DB();
foreach ($db->getProductList() as $product) {
  // do something with each product
}

IteratorAggregate 接口意味着您甚至可以这样做：

$db = new DB();
$db->getProductList();
// ...other steps...
foreach ($db as $product) {
  // do something with each product
}

当然，使用此方法一次只能存储一个结果集。如果您同时将 DB 类用于任何其他查询，这会使事情变得复杂。出于这个原因，大多数人不会尝试编写单个类来封装所有数据库操作。他们为需要使用的每种类型的Domain Model 编写单独的类，与数据库连接分离。

Answer 2

您可以将结果保存在数组中并返回：

function getProductList () {
   $sql = "SELECT ...";
   $result = mysqli_query ( $this->conn, $sql );

   $myProducts = array();

   while ($row = mysqli_fetch_assoc($result))
      $myProducts[] = $row; // or array_push($myProducts, $row)
   }

   return $myProducts
}

因此，您将拥有一个数组数组，其中的每个元素将包含一行结果。

Answer 3

您的登录页面中有一个 SQL 注入。

如果有人输入密码会发生什么： xxx' 或 'yyy' 'x