ホームページ php教程 php手册 封装了一个PDO的类,希望CSDN的大牛们指导一下不足之处

封装了一个PDO的类,希望CSDN的大牛们指导一下不足之处

Jun 06, 2016 pm 07:43 PM
pdo 一度 大牛 ガイド

封装了一个PDO的类,希望CSDN的大牛们指点一下不足之处 封装了一个PDO的类,希望CSDN的大牛们指点一下不足之处。 大师们,comeon! ?php /** *PDO封装类,目的是为了使用起来更简单方便 *modifyDate:2014-07-01 */ classPDOX{ private$pdo=null; public$statem

封装了一个PDO的类,希望CSDN的大牛们指点一下不足之处
封装了一个PDO的类,希望CSDN的大牛们指点一下不足之处。

大师们,come on !

<?php<br />
/**<br />
 * PDO封装类,目的是为了使用起来更简单方便<br />
 * modify Date: 2014-07-01<br />
 */<br />
class PDOX {<br />
	private $pdo 	   = null;<br />
	<br />
	public  $statement = null;<br />
	<br />
	public  $options = array(<br />
		PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES ",<br />
	);<br />
	<br />
	public function __construct($dsn, $user = '', $pass = '', $persistent = false, $charset = "utf8"){<br />
		$this->options[PDO::MYSQL_ATTR_INIT_COMMAND] .= $charset;<br />
		if($persistent){<br />
			$this->options[PDO::ATTR_PERSISTENT] = true;<br />
		}<br />
		$this->pdo = new PDO($dsn, $user, $pass, $this->options);<br />
	}<br />
	/**<br />
	全局属性设置,包括:列名格式和错误提示类型    可以使用数字也能直接使用参数<br />
	*/<br />
	public function setAttr($param, $val = ''){<br />
		if(is_array($param)){<br />
			foreach($param as $key => $val){<br />
				$this->pdo->setAttribute($key, $val);<br />
			}<br />
		}else{<br />
			if($val != '' ){<br />
				$this->pdo->setAttribute($param, $val);<br />
			}else{<br />
				return false;<br />
			}<br />
		}<br />
	}<br />
	/**<br />
	生成一个编译好的sql语句模版 你可以使用 ? :name 的形式<br />
	返回一个statement对象<br />
	*/<br />
	public function prepare($sql){<br />
		if(empty($sql)){<br />
			return false;<br />
		}<br />
		$this->statement = $this->pdo->prepare($sql);<br />
		return $this->statement;<br />
	}<br />
	/**<br />
	执行Sql语句,一般用于 增、删、更新或者设置  返回影响的行数<br />
	*/<br />
	public function exec($sql){<br />
		if(empty($sql)){<br />
			return false;<br />
		}<br />
		try{<br />
			return $this->pdo->exec($sql);<br />
		}catch(Exception $e){<br />
			return $e->getMessage();<br />
		}<br />
	}<br />
	/**<br />
	执行有返回值的查询,返回PDOStatement  可以通过链式操作,可以通过这个类封装的操作获取数据<br />
	*/<br />
	public function query($sql){<br />
		if(empty($sql)){<br />
			return false;<br />
		}<br />
		$this->statement = $this->pdo->query($sql);<br />
		return $this->statement;<br />
	}<br />
	/**<br />
	开启事务<br />
	*/<br />
	public function beginTransaction(){<br />
		return $this->pdo->beginTransaction();<br />
	}<br />
	/**<br />
	提交事务<br />
	*/<br />
	public function commit(){<br />
		return $this->pdo->commit();<br />
	}<br />
	/**<br />
	事务回滚<br />
	*/<br />
	public function rollBack(){<br />
		return $this->pdo->rollBack();<br />
	}<br />
	<br />
	public function lastInertId(){<br />
		return $this->pdo->lastInsertId();<br />
	}<br />
	<br />
	<br />
	//**   PDOStatement 类操作封装    **//<br />
	<br />
	/**<br />
	让模版执行SQL语句,1、执行编译好的 2、在执行时编译<br />
	*/<br />
	public function execute($param = ""){<br />
		if(is_array($param)){<br />
			try{<br />
				return $this->statement->execute($param);<br />
			}catch (Exception $e){<br />
				//return $this->errorInfo();<br />
				return $e->getMessage();<br />
			}<br />
		}else{<br />
			try{<br />
				return $this->statement->execute();<br />
			}catch(Exception $e){<br />
				/* 返回的错误信息格式<br />
				[0] => 42S22<br />
    			[1] => 1054<br />
    			[2] => Unknown column 'col' in 'field list'<br />
    			return $this->errorInfo();<br />
    			*/<br />
				return $e->getMessage();<br />
			}<br />
		}<br />
	}<br />
	<br />
	/**<br />
	参数1说明:<br />
	PDO::FETCH_BOTH		也是默认的,两者都有(索引,关联)<br />
	PDO::FETCH_ASSOC	关联数组<br />
	PDO::FETCH_NUM		索引<br />
	PDO::FETCH_OBJ			对象<br />
	PDO::FETCH_LAZY		对象 会附带queryString查询SQL语句<br />
	PDO::FETCH_BOUND	如果设置了bindColumn,则使用该参数<br />
	*/<br />
	public function fetch($fetch_type = PDO::FETCH_ASSOC){<br />
		if(is_object($this->statement)){<br />
			return $this->statement->fetch($fetch_type);<br />
		}<br />
		return false;<br />
	}<br />
	/**<br />
	参数1说明:<br />
	PDO::FETCH_BOTH		也是默认的,两者都有(索引,关联)<br />
	PDO::FETCH_ASSOC	关联数组<br />
	PDO::FETCH_NUM		索引<br />
	PDO::FETCH_OBJ		对象<br />
	PDO::FETCH_COLUMN	指定列 参数2可以指定要获取的列<br />
	PDO::FETCH_CLASS	指定自己定义的类<br />
	PDO::FETCH_FUNC		自定义类 处理返回的数据<br />
	PDO_FETCH_BOUND	如果你需要设置bindColumn,则使用该参数<br />
	参数2说明:<br />
	给定要处理这个结果的类或函数<br />
	*/<br />
	public function fetchAll($fetch_type = PDO::FETCH_ASSOC, $handle = ''){<br />
		if(empty($handle)){<br />
			return $this->statement->fetchAll($fetch_type);<br />
		}<br />
		return $this->statement->fetchAll($fetch_type, $handle);<br />
	}<br />
	/**<br />
	以对象形式返回 结果 跟fetch(PDO::FETCH_OBJ)一样<br />
	*/<br />
	public function fetchObject($class_name){<br />
		if(empty($clss_name)){<br />
			return $this->statement->fetchObject();<br />
		}<br />
		return $this->statement->fetchObject($class_name);<br />
	}<br />
	<br />
	public function fetchColumn($intColumn = 0){<br />
		return $this->statement->fetchColumn($intColumn);<br />
	}<br />
	<br />
	/**<br />
	public function bindColumn($array=array(),$type=EXTR_OVERWRITE){<br />
		if(count($array)>0){<br />
			extract($array,$type);<br />
		}<br />
		//$this->statement->bindColumn()<br />
	}<br />
	*/<br />
	<br />
	/**<br />
	以引用的方式绑定变量到占位符(可以只执行一次prepare,执行多次bindParam达到重复使用的效果)<br />
	*/<br />
	public function bindParam($parameter, $variable, $data_type = 'STR', $length = 0){<br />
		switch ($data_type){<br />
			case  'STR':<br />
				$data_type = PDO::PARAM_STR;<br />
				break;<br />
			case 'INT':<br />
				$data_type = PDO::PARAM_INT;<br />
				break;<br />
			default :<br />
				$data_type = '';<br />
		【本文来自鸿网互联 (http://www.68idc.cn)】		break;<br />
		}<br />
		return $this->statement->bindParam($parameter, $variable, $data_type, $length);<br />
	}<br />
	<br />
	/**<br />
	返回statement记录集的行数<br />
	*/<br />
	public function rowCount(){<br />
		return $this->statement->rowCount();<br />
	}<br />
	public function count(){<br />
		return $this->statement->rowCount();<br />
	}<br />
	public function columnCount(){<br />
		$this->statement->execute();<br />
		return $this->statement->columnCount();<br />
	}<br />
	public function getColumnMeta($intColumn){<br />
		return $this->statement->getColumnMeta($intColumn);<br />
	}<br />
	<br />
	<br />
	/**<br />
	关闭<br />
	*/<br />
	public function close(){<br />
		return $this->statement->closeCursor();<br />
	}<br />
	<br />
	public function closeCursor(){<br />
		return $this->statement->closeCursor();<br />
	}<br />
	/**<br />
	返回错误信息也包括错误号<br />
	*/<br />
	private function errorInfo(){<br />
		return $this->statement->errorInfo();<br />
	}<br />
	/**<br />
	返回错误号<br />
	*/<br />
	private function errorCode(){<br />
		return $this->statement->errorCode();<br />
	}<br />
	<br />
	<br />
	<br />
	//简化操作<br />
	public function insert($table, $data){<br />
		if(!is_array($data)){<br />
			return false;<br />
		}<br />
		$cols = array();<br />
		$vals = array();<br />
		foreach($data as $key => $val){<br />
			$cols[] = $key;<br />
			$vals[] = "'" . $val . "'";<br />
		}<br />
		$sql  = "INSERT INTO {$table} (";<br />
		$sql .= implode(",", $cols) . ") VALUES (";		<br />
		$sql .= implode(",", $vals) . ")";<br />
		return $this->exec($sql);<br />
	}<br />
	public function insertBind($table, $arrayData){<br />
		if(!is_array($arrayData)){<br />
			return false;<br />
		}<br />
		$vals = array_keys($arrayData);<br />
		$cols = array();<br />
		/*<br />
		$arrayobject  = new  ArrayObject( $arrayData );<br />
		$iterator  	  =  $arrayobject->getIterator();<br />
		while($iterator->valid()) {<br />
			$vals[] =  ':' . $iterator->key() . '';<br />
			$iterator->next();<br />
		}<br />
		*/<br />
		$c	  = implode('', $vals);<br />
		$cols = array_filter(explode(':', $c));<br />
<br />
		$sql  = "INSERT INTO {$table} (";<br />
		$sql .= implode(",", $cols) . ") VALUES (";		<br />
		$sql .= implode(",", $vals) . ")";<br />
		<br />
		$this->statement = $this->pdo->prepare($sql);<br />
		$this->statement->execute($arrayData);<br />
		return  $this->statement->rowCount();<br />
	}<br />
	<br />
	public function update($table, $data, $where){<br />
		if(!is_array($data)){<br />
			return false;<br />
		}<br />
		$set = array();<br />
		foreach($data as $key => $val){<br />
			$set[] = $key . "='" . $val  . "'";<br />
		}<br />
		$sql = "UPDATE {$table} SET ";<br />
		$sql .= implode(",", $set);<br />
		$sql .= " WHERE " . $where;<br />
		return $this->exec($sql);<br />
	}<br />
	public function updateBind($sql, $arrayWhere){<br />
		if(empty($sql) || !is_array($arrayWhere)){<br />
			return false;<br />
		}<br />
		$this->statement = $this->pdo->prepare($sql);<br />
		$this->statement->execute($arrayWhere);<br />
		return $this->statement->rowCount();<br />
	}<br />
<br />
	<br />
	public function delete($table, $where){<br />
		if(empty($table) || empty($where)){<br />
			return false;<br />
		} <br />
		$sql = "DELETE FROM {$table} WHERE " . $where;<br />
		return $this->exec($sql);<br />
	}<br />
	public function deleteBind($sql, $arrayWhere){<br />
		if(empty($sql) || !is_array($arrayWhere)){<br />
			return false;<br />
		}<br />
		$this->statement = $this->pdo->prepare($sql);<br />
		$this->statement->execute($arrayWhere);<br />
		return $this->statement->rowCount();<br />
	}<br />
}<br />
?>
ログイン後にコピー




毕竟在一个项目当中,不可能到处的写PDO自身的一些东西。也不要说PDO已经封装好了,无须再次封装之类的废话。
------解决思路----------------------
几点建议:
1、如果我
$db = new PDOX;
$a = $db->query($sql1);
$b = $db->query($sql2);
print_r($a->fetchall());
print_r($b->fetchall());
可以吗?显然是不可以的,因为
$this->statement = $this->pdo->query($sql);
前一次的查询结果被后一次的覆盖了
2、事务(Transaction)操作宜封装成整体,只传入一组 sql 而隐藏相关操作
3、没考虑使用存储过程
4、PDOX 可直接继承于 PDO 而无需抄写 PDO 已有方法


このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。

ホットAIツール

Undresser.AI Undress

Undresser.AI Undress

リアルなヌード写真を作成する AI 搭載アプリ

AI Clothes Remover

AI Clothes Remover

写真から衣服を削除するオンライン AI ツール。

Undress AI Tool

Undress AI Tool

脱衣画像を無料で

Clothoff.io

Clothoff.io

AI衣類リムーバー

Video Face Swap

Video Face Swap

完全無料の AI 顔交換ツールを使用して、あらゆるビデオの顔を簡単に交換できます。

ホットツール

メモ帳++7.3.1

メモ帳++7.3.1

使いやすく無料のコードエディター

SublimeText3 中国語版

SublimeText3 中国語版

中国語版、とても使いやすい

ゼンドスタジオ 13.0.1

ゼンドスタジオ 13.0.1

強力な PHP 統合開発環境

ドリームウィーバー CS6

ドリームウィーバー CS6

ビジュアル Web 開発ツール

SublimeText3 Mac版

SublimeText3 Mac版

神レベルのコード編集ソフト(SublimeText3)

PHP 致命的エラーの解決策: 未定義メソッド PDO::prepare() の呼び出し PHP 致命的エラーの解決策: 未定義メソッド PDO::prepare() の呼び出し Jun 22, 2023 pm 06:40 PM

PHP は、長い間使用されている人気のある Web 開発言語です。 PHP に統合された PDO (PHP Data Object) クラスは、Web アプリケーションの開発中にデータベースと対話する一般的な方法です。ただし、一部の PHP 開発者がよく遭遇する問題は、PDO クラスを使用してデータベースと対話するときに、次のようなエラーが表示されることです。

PHP の PDO_PGSQL 拡張機能を使用するにはどうすればよいですか? PHP の PDO_PGSQL 拡張機能を使用するにはどうすればよいですか? Jun 02, 2023 pm 06:10 PM

PHP は人気のあるプログラミング言語として、Web 開発の分野で広く使用されています。その中でも、PHP の PDO_PGSQL 拡張機能は一般的に使用されている PHP 拡張機能で、PostgreSQL データベースとの対話型インターフェイスを提供し、PHP と PostgreSQL 間のデータ送信と対話を実現できます。この記事では、PHPのPDO_PGSQL拡張機能の使い方を詳しく紹介します。 1. PDO_PGSQL 拡張機能とは何ですか? PDO_PGSQL は PHP の拡張ライブラリです。

PHP と PDO: 一括挿入と更新を実行する方法 PHP と PDO: 一括挿入と更新を実行する方法 Jul 28, 2023 pm 07:41 PM

PHP と PDO: バッチ挿入およびバッチ更新を実行する方法 はじめに: PHP を使用してデータベース関連アプリケーションを作成する場合、データをバッチ挿入および更新する必要がある状況によく遭遇します。従来のアプローチでは、ループを使用して複数のデータベース操作を実行しますが、この方法は非効率的です。 PHP の PDO (PHPDataObject) は、バッチ挿入および更新操作を実行するためのより効率的な方法を提供します。この記事では、PDO を使用してバッチ挿入および更新操作を実装する方法を紹介します。 1. PDO の概要: PDO は PH です

PHP と PDO: ページング クエリを実行してデータを表示する方法 PHP と PDO: ページング クエリを実行してデータを表示する方法 Jul 29, 2023 pm 04:10 PM

PHP と PDO: ページ内のデータをクエリして表示する方法 Web アプリケーションを開発する場合、ページ内のデータをクエリして表示することは非常に一般的な要件です。ページングにより、一度に一定量のデータを表示できるため、ページの読み込み速度とユーザー エクスペリエンスが向上します。 PHP では、PHP データ オブジェクト (PDO) ライブラリを使用して、ページング クエリとデータの表示の機能を簡単に実現できます。この記事では、PHP で PDO を使用してページごとにデータをクエリおよび表示する方法と、対応するコード例を紹介します。 1. データベースとデータテーブルを作成する

PHP PDO と mysqli: 比較対照 PHP PDO と mysqli: 比較対照 Feb 19, 2024 pm 12:24 PM

PDOPDO は、PHP に統合インターフェイスを提供するオブジェクト指向のデータベース アクセス抽象化レイヤーであり、同じコードを使用して異なるデータベース (Mysql、postgresql、oracle など) と対話できるようにします。 PDO は、基礎となるデータベース接続の複雑さを隠し、データベース操作を簡素化します。長所と短所 長所: 統一されたインターフェイス、複数のデータベースのサポート、データベース操作の簡素化、開発の困難さの軽減、プリペアドステートメントの提供、セキュリティの向上、トランザクション処理のサポート 短所: パフォーマンスはネイティブ拡張よりわずかに低い場合があり、外部ライブラリに依存し、オーバーヘッドが増加する可能性があります。デモ コードでは PDO を使用します。 mysql データベースに接続します: $db=newPDO("mysql:host=localhost;dbnam

PHP と PDO: データベースで全文検索を実行する方法 PHP と PDO: データベースで全文検索を実行する方法 Jul 30, 2023 pm 04:33 PM

PHP と PDO: データベースで全文検索を実行する方法 最新の Web アプリケーションでは、データベースは非常に重要なコンポーネントです。全文検索は、大量のデータから特定の情報を検索する必要がある場合に非常に便利な機能です。 PHP および PDO (PHPDataObjects) は、データベース内で全文検索を実行するためのシンプルかつ強力な方法を提供します。この記事では、PHP と PDO を使用して全文検索を実装する方法を紹介し、そのプロセスを示すサンプル コードをいくつか紹介します。初め

PHP と PDO: データベース内の JSON データを処理する方法 PHP と PDO: データベース内の JSON データを処理する方法 Jul 29, 2023 pm 05:17 PM

PHP と PDO: データベースで JSON データを処理する方法 現代の Web 開発では、大量のデータを処理して保存することが非常に重要なタスクです。モバイル アプリケーションとクラウド コンピューティングの人気に伴い、JSON (JavaScript Object Notation) 形式でデータベースに保存されるデータがますます増えています。一般的に使用されるサーバー側言語として、PHP の PDO (PHPDataObject) 拡張機能は、データベースを処理および操作するための便利な方法を提供します。本

PHP および PDO: データベースのバックアップおよび復元操作を実行する方法 PHP および PDO: データベースのバックアップおよび復元操作を実行する方法 Jul 29, 2023 pm 06:54 PM

PHP と PDO: データベースのバックアップと復元操作を実行する方法 Web アプリケーションを開発する場合、データベースのバックアップと復元は非常に重要なタスクです。人気のあるサーバー側スクリプト言語として、PHP は豊富なライブラリと拡張機能を提供しており、その中の PDO (PHP Data Objects) は強力なデータベース アクセス抽象化レイヤーです。この記事では、PHP と PDO を使用してデータベースのバックアップと復元の操作を実行する方法を紹介します。ステップ 1: データベースに接続する 実際の操作の前に、データベースへの接続を確立する必要があります。 PDOペアを使用する

See all articles