Ниже приведен класс подключения к базе данных, который я разработал до сих пор, но я собираюсь улучшить его, расширив сам класс PDO,
<?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;
}
}
Вот как я создаю экземпляр класс,
# 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,
Предупреждение: PDO :: __ construct () ожидает параметр 4 должен быть массивом, заданной строкой в C: \ wamp \ www \ xx \ class_database.php в строке xx
Неустранимая ошибка: вызов функции-члена setAttribute () для не-объекта в C: \ wamp \ www \ xx \ class_database.php на line xx
Я провел небольшое исследование в Интернете, я нашел эту базовую структуру расширения pdo, но я ее не понимаю ...
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);
}
}
Для чего нужна переменная $ ds
n? Как передать мою переменную $ hostname
в расширенный класс pdo?
Еще вопросы: Как сделать метод отображения ошибки в расширенном классе pdo? Как закрыть соединение в расширенном классе pdo?
Так сложно перейти с mysqli на pdo!
Спасибо.