問題描述

以下是我目前推出的數據庫連接類，但我將通過擴展 PDO 類本身來改進它，

Below is the db connection class I came out with so far, but I am going to improve it by extending the PDO class itself,

<?php
class database
{
    protected $connection = null;

    #make a connection
    public function __construct($hostname,$dbname,$username,$password)
    {
        try 
        {
            # MySQL with PDO_MYSQL  
            $this->connection = new PDO("mysql:host=$hostname;dbname=$dbname", $username, $password);
            $this->connection->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); 
        }
        catch (PDOException $e) 
        {
            $this->connection = null;
            die($e->getMessage());
        }
    }

    #get the number of rows in a result
    public function num_rows($query)
    {
        # create a prepared statement
        $stmt = $this->connection->prepare($query);

        if($stmt) 
        {
            # execute query 
            $stmt->execute();

            return $stmt->rowCount();
        } 
        else
        {
            return self::get_error();
        }
    }

    #display error
    public function get_error() 
    {
        $this->connection->errorInfo();
    }

    # closes the database connection when object is destroyed.
    public function __destruct()
    {
        $this->connection = null;
    }
}
?>

擴展類，

class database extends PDO
{

    #make a connection
    public function __construct($hostname,$dbname,$username,$password)
    {
        parent::__construct($hostname,$dbname,$username,$password);

        try 
        { 
            $this->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); 
        }
        catch (PDOException $e) 
        {
            die($e->getMessage());
        }
    }

    #get the number of rows in a result
    public function num_rows($query)
    {
        # create a prepared statement
        $stmt = parent::prepare($query);

        if($stmt) 
        {
            # execute query 
            $stmt->execute();

            return $stmt->rowCount();
        } 
        else
        {
            return self::get_error();
        }
    }

    #display error
    public function get_error() 
    {
        $this->connection->errorInfo();
    }

    # closes the database connection when object is destroyed.
    public function __destruct()
    {
        $this->connection = null;
    }
}

這就是我實例化類的方式，

This is how I instantiate the class,

# the host used to access DB
define('DB_HOST', 'localhost');

# the username used to access DB
define('DB_USER', 'root');

# the password for the username
define('DB_PASS', 'xxx');

# the name of your databse 
define('DB_NAME', 'db_2011'); 

include 'class_database.php';

$connection = new database(DB_HOST,DB_NAME,DB_USER,DB_PASS);
$sql = "
    SELECT *
    FROM root_contacts_cfm
    ORDER BY cnt_id DESC
    ";

$connection->num_rows($sql);

但是當我調用這個擴展的 pdo 類時出現錯誤，

But I have errors when I call this extended pdo class,

警告:PDO::__construct() 需要參數 4 為數組，給出字符串在 C:wampwwwxxclass_database.php在線 xx

Warning: PDO::__construct() expects parameter 4 to be array, string given in C:wampwwwxxclass_database.php on line xx

致命錯誤:調用成員函數setAttribute() 在非對象上C:wampwwwxxclass_database.php 上第 xx 行

Fatal error: Call to a member function setAttribute() on a non-object in C:wampwwwxxclass_database.php on line xx

我在網上做了一些研究，我找到了擴展pdo的這個基本結構，但我不明白......

I have done some research online, I found this basic structure of extending pdo but I dont understand it...

class myPDO extends PDO
{
   public function __construct($dsn, 
                               $username=null, 
                               $password=null, 
                               $driver_options=null)
   {
      parent::__construct($dsn, $username, $password, $driver_options);
   }

   public function query($query)
   {
      $result = parent::query($query);
      // do other stuff you want to do here, then...
      return($result);
   }
}

$dsn 變量有什么用?如何將我的 $hostname 變量傳遞給擴展的 pdo 類?

What is $dsn variable for? How can I pass my $hostname variable into extended pdo class?

另一個問題:如何在擴展的 pdo 類中創建一個顯示錯誤的方法?如何關閉擴展 pdo 類中的連接?

Another questions: How can I make a method for displaying error in the extended pdo class? How can I close the connection in the extended pdo class?

從mysqli遷移到pdo太難了！

It is so difficult to move from mysqli to pdo!

謝謝.

推薦答案

$dsn 是數據源名稱.它為您處理您的主機名.你像這樣使用它:

$dsn is data source name. It handles your hostname for you. You use it like this:

$dsn = 'mysql:dbname=YOUR_DB_NAME;host=YOUR_HOSTNAME'

隨著行 $this->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); 你已經設置了在發生錯誤時引發的異常(我喜歡)，所以在你的擴展類，您可以處理異常處理程序中的錯誤.如果您的擴展 PDO 類中有一個名為 getAssoc 的方法，那么它看起來像這樣:

With the line $this->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); You have set exceptions to be raised when errors occur (which I like), so in your extended class you can handle errors in exception handlers. If you had a method called getAssoc in your extended PDO class then it would look like this:

/// Get an associative array of results for the sql.
public function getAssoc($sql, $params=array())
{
   try
   {
      $stmt = $this->prepare($sql);
      $params = is_array($params) ? $params : array($params);
      $stmt->execute($params);

      return $stmt->fetchAll(PDO::FETCH_ASSOC);
   }
   catch (Exception $e)
   {
      // Echo the error or Re-throw it to catch it higher up where you have more
      // information on where it occurred in your program.
      // e.g echo 'Error: ' . $e->getMessage(); 

      throw new Exception(
            __METHOD__ . 'Exception Raised for sql: ' . var_export($sql, true) .
            ' Params: ' . var_export($params, true) .
            ' Error_Info: ' . var_export($this->errorInfo(), true),
            0,
            $e);
   }
}

這篇關于擴展 PDO 類的文章就介紹到這了，希望我們推薦的答案對大家有所幫助，也希望大家多多支持html5模板網！