我对PDO的执行命令是有原因的吗？

Question

我刚刚开始通过YouTube上的视频了解php OOP，我正在关注构建网站应用程序。

正如那个人所解释的那样，我必须使用PDO连接到SQL数据库。我遵循了他所做的一切，但是我的PDO执行部分不起作用，我不知道这是什么问题。代码在下面。它不会带来任何错误，只是没有带回数据库中的任何数据。我在函数之间放了一些回声，以找出代码走的距离，这就是我发现它准备查询但从未执行的。请帮助我解决这个问题。谢谢。

class Database{
private function connect()
{
    $string = DBDRIVER . ":host =" .DBHOST.";dbname =".DBNAME;
    if ($conn = new PDO($string, DBUSER, DBPASS)) {
        return $conn;
    } else {
        die("Could not connect to database");
    }
}

上面的代码是与数据库的连接。据我所知，它正常工作。

下面的代码应该将数据库中的数据返回以使用view.php文件显示的数据库返回

public function query($query, $data = array(), $data_type = "object")
{

    $con = $this->connect();
    $stm = $con->prepare($query);
    print_r($stm);

    if ($stm) {
        $check = $stm->execute($data); //right here is where I concluded that the code stops
        print_r($check);//does not print anything
        if ($check) {
            if ($data_type == "object") {
                $data = $stm->fetchAll(PDO::FETCH_OBJ);
            } else {
                $data = $stm->fetchAll(PDO::FETCH_ASSOC);
            }

            if (is_array($data) && count($data) > 0) {
                return $data;
            }
        }
    }
    return false;
}

，这是控制器中编写的零件，将查询分配给数据库以执行。

function index(){

        $db = new Database();
        
        $data = $db->query("select * from users");
        if($data){echo $data;} //echos nothing because $data is empty
        $this -> view('home', ['rows' => $data]);
    }

Answer 1

我已经测试了您的代码，因此发生了错误，因为您在dbname和=之间有一个空间。 DBNAME之后的半隆（不需要）。

class Database{
private function connect()
{
    $string = DBDRIVER . ":host=" .DBHOST.";dbname=".DBNAME.";";
    if ($conn = new PDO($string, DBUSER, DBPASS)) {
        return $conn;
    } else {
        die("Could not connect to database");
    }
}

现在对我有用。

我很长一段时间以来使用此连接类，也许您想使用它。

class Connection{

    private const CONNECTION = [
        "Host" => "",
        "User" => "",
        "Password" => "",
        "Databasename" => ""
    ];

    /**
     * Includes the pdo connection.
     * @var \PDO|null
     */
    private \PDO|null $PDO = null;

    /**
     * Includes the already called instance.
     * @var Connection|null
     */
    private static self|null $Connection = null;

    /**
     * Creates the DB connection and sets it to the class.
     * @return void 
     * @throws Exception 
     */
    private function __construct()
    {
        $Connection_str = 'mysql:';
        $Connection_str .= 'host=' . self::CONNECTION["Host"] . ';';
        $Connection_str .= 'dbname=' . self::CONNECTION["Databasename"] . ';';
        $Connection_str .= 'charset=utf8mb4';
        $this->PDO = new \PDO($Connection_str, self::CONNECTION["User"], self::CONNECTION["Password"]);
        $this->PDO->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
        $this->PDO->setAttribute(\PDO::ATTR_EMULATE_PREPARES, false);
        $this->PDO->setAttribute(\PDO::ATTR_DEFAULT_FETCH_MODE, \PDO::FETCH_ASSOC);
    }

    /**
     * Returns the static DB connection instance.
     * @return Connection 
     * @throws Exception 
     */
    public static function get(): Connection
    {
        return !isset(self::$Connection) ? self::$Connection = new self : self::$Connection;
    }

    /**
     * Returns the PDO instance.
     * @return PDO 
     * @throws Exception 
     */
    public function getPDO(): \PDO
    {
        return $this->PDO;
    }
}

您可以使用以下代码使用连接类：

$SQLString = "select * from users";
$Data = [

];
$Query = Connection::get()->getPDO()->prepare($SQLString);
$Query->execute($Data);
$Data = $Query->fetchAll();