PDO mysql データベース操作 class_PHP チュートリアル
- WBOYオリジナル
- 2016-07-13 17:05:40914ブラウズ
pdoのmysqlチュートリアルデータベースチュートリアル操作クラス
* dbconfig クラスは、サーバー アドレス、ポート、データベース インスタンス名、ユーザー名、ユーザー パスワード、文字セットなどを含むデータベース アクセス情報の構成を担当します。
* dbtemplate クラスは、主に以下の操作を含むデータベースへのアクセス操作を収集します:
1. queryrows: 複数行のレコードを返します
2. queryrow: 単一のレコードを返します
3. queryforint: 単一フィールドをクエリして整数を返します
4. queryforfloat: 単一フィールドをクエリし、浮動小数点数 (float) を返します
5. queryfordouble: 単一フィールドをクエリして、浮動小数点数 (double) を返します
6. queryforobject: 単一フィールドをクエリし、オブジェクトを返します。実際のタイプはデータベースによって決定されます
。
7. update: update ステートメントを実行します
*/
クラス dbconfig {
プライベート静的$dbms = "mysql";
プライベート静的 $host = '127.0.0.1';
プライベート静的 $port = '3306';
プライベート静的 $username = '';
プライベート静的 $password = '';
プライベート静的 $dbname = '';
プライベート静的 $charset = 'utf-8';
プライベート静的 $dsn;/**
/**
*
* @return PDO DSN 設定に戻ります
*/
パブリック静的関数 getdsn() {
If (!isset(self::$dsn)) {
self::$dsn = self::$dbms . self::$host .
If (strlen(self::$charset) > 0) {
self::$dsn = self::$dsn . self::$charset;
}
}
return self::$dsn;
}
* * mysqlデータベースサーバーホストをセットアップします
/**
* @param $host ホストのIPアドレス
*/
パブリック静的関数 sethost($host) {
If (isset($host) && strlen($host) > 0)
self::$host = トリム($host);
}
* *mysqlデータベースサーバーのポートを設定します
/**
* @param $port ポート
*/
パブリック静的関数 setport($port) {
If (isset($port) && strlen($port) > 0)
self::$port = トリム($port);
}
* * mysqlデータベースサーバーのログインユーザー名を設定します
/**
* @param $ユーザー名
*/
パブリック静的関数 setusername($username) {
If (isset($username) && strlen($username) > 0)
self::$username = $username;
}
※mysqlデータベースサーバーのログインパスワードを設定します
/**
* @param $パスワード
*/
パブリック静的関数 setpassword($password) {
If (isset($password) && strlen($password) > 0)
self::$password = $password;
}
* *mysqlデータベースサーバーのデータベースインスタンス名を設定します
* @param $dbname データベースインスタンス名
*/
パブリック静的関数 setdbname($dbname) {
If (isset($dbname) && strlen($dbname) > 0)
self::$dbname = $dbname;
}/**
*データベースエンコーディングを設定します
* @param $charset
*/
パブリック静的関数 setcharset($charset) {
if (isset($charset) && strlen($charset) > 0)
self::$charset = $charset;
}}
/**
※データベース操作ツールクラス
*
* @著者 zhjiun@gmail.com
*/
クラス dbtemplate {/**
*複数行のレコードを返す
* @param $sql
* @param $parameters
* @return レコードデータ
*/
パブリック関数 queryrows($sql, $parameters = null) {
return $this->exequery($sql, $parameters);
}/**
*単一のレコードに戻ります
* @param $sql
* @param $parameters
* @return
*/
パブリック関数 queryrow($sql, $parameters = null) {
$rs = $this->exequery($sql, $parameters);
if (count($rs) > 0) {
$rs[0] を返します;
} その他 {
null を返す;
}
}/**
* 単一フィールドをクエリして整数を返します
* @param $sql
* @param $parameters
* @return
*/
パブリック関数 queryforint($sql, $parameters = null) {
$rs = $this->exequery($sql, $parameters);
if (count($rs) > 0) {
return intval($rs[0][0]);
} その他 {
null を返す;
}
}/**
* 単一フィールドをクエリして浮動小数点数 (float) を返します
* @param $sql
* @param $parameters
* @return
*/
パブリック関数 queryforfloat($sql, $parameters = null) {
$rs = $this->exequery($sql, $parameters);
if (count($rs) > 0) {
return floatval($rs[0][0]);
} その他 {
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]);
} その他 {
null を返す;
}
}/**
* 単一フィールドをクエリしてオブジェクトを返します。実際の型はデータベースによって決定されます
。 * @param $sql
* @param $parameters
* @return
*/
パブリック関数 queryforobject($sql, $parameters = null) {
$rs = $this->exequery($sql, $parameters);
if (count($rs) > 0) {
$rs[0][0] を返します;
} その他 {
null を返す;
}
}/**
* 更新ステートメントを実行します。insert/upadate/delete
* @param $sql
* @param $parameters
* @return 影響を受ける行数
*/
public function update($sql, $parameters = null) {
return $this->exeupdate($sql, $parameters);
}プライベート関数 getconnection() {
$conn = 新しい pdo(dbconfig::getdsn(), dbconfig::getusername(), dbconfig::getpassword());
$conn->setattribute(pdo::attr_case, pdo::case_upper);
$conn を返します;
}プライベート関数 exequery($sql, $parameters = null) {
$conn = $this->getconnection();
$stmt = $conn->prepare($sql);
$stmt->execute($parameters);
$rs = $stmt->fetchall();
$stmt = null;
$conn = null;
$rs を返します;
}プライベート関数 exeupdate($sql, $parameters = null) {
$conn = $this->getconnection();
$stmt = $conn->prepare($sql);
$stmt->execute($parameters);
$affectedrows = $stmt->rowcount();
$stmt = null;
$conn = null;
$影響を受けた行を返します;
}
}
/*
pdo は php 教程 5 から始まり、php6 で pdo の使用が認められています。以前のバージョンの無秩序なデータ アクセス方式とは異なり、pdo はデータ アクセス方式であり、プログラム バンドに非常に優れた利便性を備えています。 pdo、模拟了java世界spring框架中のjdbctemplate操作类
*/