PHPはPDOのmysqlデータベース操作クラスを実現する
7932 ワード
この例では、PHP実装PDOのmysqlデータベース操作クラスについて説明します.皆さんの参考にしてください.具体的な分析は以下の通りである.
dbconfigクラスは、サーバアドレス、ポート、データベースインスタンス名、ユーザー名、ユーザーパスワード、文字セットなど、データベースアクセス情報の構成を担当する.
dbtemplateクラスには、データベースへのアクセス操作が集合しています.主に次の操作があります.
1.queryrows:複数行レコードを返す
2.queryrow:単一レコードに戻る
3.queryforint:単一フィールドを問合せ、整数を返す
4.queryforfloat:単一フィールドをクエリーし、浮動小数点数(float)を返します.
5.queryfordouble:単一フィールドをクエリーし、浮動小数点数(double)を返します.
6.queryforobject:クエリー・フィールド、オブジェクトを返します.実際のタイプはデータベースによって決まります.
7.update:更新文を実行します.insert/upadate/delete
具体的なコードは以下の通りです.
pdoはphp 5から始まる、php 6ではpdoがデフォルトで使用され、以前のバージョンで混乱していたデータベースの操作方式とは異なり、pdoはデータベースへのアクセス方式を統一し、プログラミングに極めて便利性をもたらし、本ツールクラスはpdoに基づいてjava世界springフレームワークのjdbctemplate操作クラスをシミュレートする.
ここで述べたことが皆さんのPHPプログラム設計に役立つことを願っています.
dbconfigクラスは、サーバアドレス、ポート、データベースインスタンス名、ユーザー名、ユーザーパスワード、文字セットなど、データベースアクセス情報の構成を担当する.
dbtemplateクラスには、データベースへのアクセス操作が集合しています.主に次の操作があります.
1.queryrows:複数行レコードを返す
2.queryrow:単一レコードに戻る
3.queryforint:単一フィールドを問合せ、整数を返す
4.queryforfloat:単一フィールドをクエリーし、浮動小数点数(float)を返します.
5.queryfordouble:単一フィールドをクエリーし、浮動小数点数(double)を返します.
6.queryforobject:クエリー・フィールド、オブジェクトを返します.実際のタイプはデータベースによって決まります.
7.update:更新文を実行します.insert/upadate/delete
具体的なコードは以下の通りです.
class dbconfig {
private static $dbms = "mysql";
private static $host = '127.0.0.1';
private static $port = '3306';
private static $username = '';
private static $password = '';
private static $dbname = '';
private static $charset = 'utf-8';
private static $dsn;
/**
*
* @return pdo dsn
*/
public static function getdsn() {
if (!isset(self::$dsn)) {
self::$dsn = self::$dbms . ':host=' . self::$host . ';port=' .
self::$port . ';dbname=' . self::$dbname;
if (strlen(self::$charset) > 0) {
self::$dsn = self::$dsn . ';charset=' . self::$charset;
}
}
return self::$dsn;
}
/**
* mysql
* @param $host ip
*/
public static function sethost($host) {
if (isset($host) && strlen($host) > 0)
self::$host = trim($host);
}
/**
* mysql
* @param $port
*/
public static function setport($port) {
if (isset($port) && strlen($port) > 0)
self::$port = trim($port);
}
/**
* mysql
* @param $username
*/
public static function setusername($username) {
if (isset($username) && strlen($username) > 0)
self::$username = $username;
}
/**
* mysql
* @param $password
*/
public static function setpassword($password) {
if (isset($password) && strlen($password) > 0)
self::$password = $password;
}
/**
* mysql
* @param $dbname
*/
public static function setdbname($dbname) {
if (isset($dbname) && strlen($dbname) > 0)
self::$dbname = $dbname;
}
/**
*
* @param $charset
*/
public static function setcharset($charset) {
if (isset($charset) && strlen($charset) > 0)
self::$charset = $charset;
}
}
/**
*
*
* @author [email protected]
*/
class dbtemplate {
/**
*
* @param $sql
* @param $parameters
* @return
*/
public function queryrows($sql, $parameters = null) {
return $this->exequery($sql, $parameters);
}
/**
*
* @param $sql
* @param $parameters
* @return
*/
public function queryrow($sql, $parameters = null) {
$rs = $this->exequery($sql, $parameters);
if (count($rs) > 0) {
return $rs[0];
} else {
return null;
}
}
/**
* ，
* @param $sql
* @param $parameters
* @return
*/
public function queryforint($sql, $parameters = null) {
$rs = $this->exequery($sql, $parameters);
if (count($rs) > 0) {
return intval($rs[0][0]);
} else {
return null;
}
}
/**
* ， (float)
* @param $sql
* @param $parameters
* @return
*/
public function queryforfloat($sql, $parameters = null) {
$rs = $this->exequery($sql, $parameters);
if (count($rs) > 0) {
return floatval($rs[0][0]);
} else {
return null;
}
}
/**
* ， (double)
* @param $sql
* @param $parameters
* @return
*/
public function queryfordouble($sql, $parameters = null) {
$rs = $this->exequery($sql, $parameters);
if (count($rs) > 0) {
return doubleval($rs[0][0]);
} else {
return null;
}
}
/**
* ， ，
* @param $sql
* @param $parameters
* @return
*/
public function queryforobject($sql, $parameters = null) {
$rs = $this->exequery($sql, $parameters);
if (count($rs) > 0) {
return $rs[0][0];
} else {
return null;
}
}
/**
* .insert / upadate / delete
* @param $sql
* @param $parameters
* @return
*/
public function update($sql, $parameters = null) {
return $this->exeupdate($sql, $parameters);
}
private function getconnection() {
$conn = new pdo(dbconfig::getdsn(), dbconfig::getusername(), dbconfig::getpassword());
$conn->setattribute(pdo::attr_case, pdo::case_upper);
return $conn;
}
private function exequery($sql, $parameters = null) {
$conn = $this->getconnection();
$stmt = $conn->prepare($sql);
$stmt->execute($parameters);
$rs = $stmt->fetchall();
$stmt = null;
$conn = null;
return $rs;
}
private function exeupdate($sql, $parameters = null) {
$conn = $this->getconnection();
$stmt = $conn->prepare($sql);
$stmt->execute($parameters);
$affectedrows = $stmt->rowcount();
$stmt = null;
$conn = null;
return $affectedrows;
}
}
pdoはphp 5から始まる、php 6ではpdoがデフォルトで使用され、以前のバージョンで混乱していたデータベースの操作方式とは異なり、pdoはデータベースへのアクセス方式を統一し、プログラミングに極めて便利性をもたらし、本ツールクラスはpdoに基づいてjava世界springフレームワークのjdbctemplate操作クラスをシミュレートする.
ここで述べたことが皆さんのPHPプログラム設計に役立つことを願っています.