php mysql PDO 查询操作的实例详解

叁歲伎倆 2022-04-22 09:32 168阅读 0赞

**php mysql PDO 查询操作的实例详解**

[?][Link 1]

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 </td> 
 <td> <code>&lt;?php </code> <code>$dbh</code> <code>= </code><code>new</code> <code>PDO(</code><code>'mysql:host=localhost;dbname=access_control'</code><code>, </code><code>'root'</code><code>, </code><code>''</code><code>);&nbsp; </code> <code>$dbh</code><code>-&gt;setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);&nbsp; </code> <code>$dbh</code><code>-&gt;</code><code>exec</code><code>(</code><code>'set names utf8'</code><code>);&nbsp; </code> <code>/*添加*/</code> <code>//$sql = "INSERT INTO `user` SET `login`=:login AND `password`=:password";&nbsp; </code> <code>$sql</code> <code>= </code><code>"INSERT INTO `user` (`login` ,`password`)VALUES (:login, :password)"</code><code>; </code><code>$stmt</code> <code>= </code><code>$dbh</code><code>-&gt;prepare(</code><code>$sql</code><code>); </code><code>$stmt</code><code>-&gt;execute(</code><code>array</code><code>(</code><code>':login'</code><code>=&gt;</code><code>'kevin2'</code><code>,</code><code>':password'</code><code>=&gt;</code><code>''</code><code>));&nbsp; </code> <code>echo</code> <code>$dbh</code><code>-&gt;lastinsertid();&nbsp; </code> <code>/*修改*/</code> <code>$sql</code> <code>= </code><code>"UPDATE `user` SET `password`=:password WHERE `user_id`=:userId"</code><code>;&nbsp; </code> <code>$stmt</code> <code>= </code><code>$dbh</code><code>-&gt;prepare(</code><code>$sql</code><code>);&nbsp; </code> <code>$stmt</code><code>-&gt;execute(</code><code>array</code><code>(</code><code>':userId'</code><code>=&gt;</code><code>'7'</code><code>, </code><code>':password'</code><code>=&gt;</code><code>'4607e782c4d86fd5364d7e4508bb10d9'</code><code>));&nbsp; </code> <code>echo</code> <code>$stmt</code><code>-&gt;rowCount();&nbsp; </code> <code>/*删除*/</code> <code>$sql</code> <code>= </code><code>"DELETE FROM `user` WHERE `login` LIKE 'kevin_'"</code><code>; </code><code>//kevin%&nbsp; </code> <code>$stmt</code> <code>= </code><code>$dbh</code><code>-&gt;prepare(</code><code>$sql</code><code>);&nbsp; </code> <code>$stmt</code><code>-&gt;execute();&nbsp; </code> <code>echo</code> <code>$stmt</code><code>-&gt;rowCount();&nbsp; </code> <code>/*查询*/</code> <code>$login</code> <code>= </code><code>'kevin%'</code><code>;&nbsp; </code> <code>$sql</code> <code>= </code><code>"SELECT * FROM `user` WHERE `login` LIKE :login"</code><code>;&nbsp; </code> <code>$stmt</code> <code>= </code><code>$dbh</code><code>-&gt;prepare(</code><code>$sql</code><code>);&nbsp; </code> <code>$stmt</code><code>-&gt;execute(</code><code>array</code><code>(</code><code>':login'</code><code>=&gt;</code><code>$login</code><code>));&nbsp; </code> <code>while</code><code>(</code><code>$row</code> <code>= </code><code>$stmt</code><code>-&gt;fetch(PDO::FETCH_ASSOC)){&nbsp;&nbsp;&nbsp; </code> <code>&nbsp;</code><code>print_r(</code><code>$row</code><code>);&nbsp; </code> <code>}&nbsp; </code> <code>print_r( </code><code>$stmt</code><code>-&gt;fetchAll(PDO::FETCH_ASSOC));&nbsp; </code> <code>?&gt; </code> </td> 
 </tr> 
 </tbody> 
</table>

**1 建立连接**

[?][Link 1]

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 </td> 
 <td> <code>&lt;?php </code> <code>$dbh</code><code>=newPDO(</code><code>'mysql:host=localhost;port=3306; dbname=test'</code><code>,</code><code>$user</code><code>,</code><code>$pass</code><code>,</code><code>array</code><code>( </code> <code>PDO::ATTR_PERSISTENT=&gt;true </code> <code>)); </code> <code>?&gt; </code> </td> 
 </tr> 
 </tbody> 
</table>

持久性链接PDO::ATTR\_PERSISTENT=>true

**2. 捕捉错误**

[?][Link 1]

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 </td> 
 <td> <code>&lt;?php </code> <code>try</code><code>{ </code> <code>$dbh</code><code>=newPDO(</code><code>'mysql:host=localhost;dbname=test'</code><code>,</code><code>$user</code><code>,</code><code>$pass</code><code>); </code> <code>&nbsp;</code>&nbsp; <code>$dbh</code><code>-&gt;setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION); </code> <code>&nbsp;</code>&nbsp; <code>$dbh</code><code>-&gt;</code><code>exec</code><code>(</code><code>"SET CHARACTER SET utf8"</code><code>); </code> <code>$dbh</code><code>=null; </code><code>//断开连接 </code> <code>}</code><code>catch</code><code>(PDOException</code><code>$e</code><code>){ </code> <code>print</code><code>"Error!:"</code><code>.</code><code>$e</code><code>-&gt;getMessage().</code><code>"&lt;br/&gt;"</code><code>; </code> <code>die</code><code>(); </code> <code>} </code> <code>?&gt; </code> </td> 
 </tr> 
 </tbody> 
</table>

**3. 事务的**

[?][Link 1]

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 </td> 
 <td> <code>&lt;?php </code> <code>try</code><code>{ </code> <code>$dbh</code><code>-&gt;setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION); </code> <code>&nbsp;</code>&nbsp; <code>$dbh</code><code>-&gt;beginTransaction();</code><code>//开启事务 </code> <code>$dbh</code><code>-&gt;</code><code>exec</code><code>(</code><code>"insertintostaff(id,first,last)values(23,'Joe','Bloggs')"</code><code>); </code> <code>$dbh</code><code>-&gt;</code><code>exec</code><code>("insertintosalarychange(id,amount,changedate) </code> <code>values(23,50000,NOW())"); </code> <code>$dbh</code><code>-&gt;commit();</code><code>//提交事务 </code> <code>&nbsp;</code>&nbsp; <code>}</code><code>catch</code><code>(Exception</code><code>$e</code><code>){ </code> <code>$dbh</code><code>-&gt;rollBack();</code><code>//错误回滚 </code> <code>echo</code><code>"Failed:"</code><code>.</code><code>$e</code><code>-&gt;getMessage(); </code> <code>} </code> <code>?&gt; </code> </td> 
 </tr> 
 </tbody> 
</table>

**4. 错误处理**

a. 静默模式(默认模式)

[?][Link 1]

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 </td> 
 <td> <code>$dbh</code><code>-&gt;setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_SILENT); </code><code>//不显示错误</code> <code>$dbh</code><code>-&gt;setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);</code><code>//显示警告错误，并继续执行</code> <code>$dbh</code><code>-&gt;setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);</code><code>//产生致命错误，PDOException</code> </td> 
 </tr> 
 </tbody> 
</table>

[?][Link 1]

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 </td> 
 <td> <code>&lt;?php </code> <code>try</code><code>{&nbsp;&nbsp; </code> <code>&nbsp;</code><code>$dbh</code> <code>= </code><code>new</code> <code>PDO(</code><code>$dsn</code><code>, </code><code>$user</code><code>, </code><code>$password</code><code>);&nbsp;&nbsp; </code> <code>&nbsp;</code><code>$sql</code> <code>= </code><code>'Select * from city where CountryCode =:country'</code><code>;&nbsp;&nbsp; </code> <code>&nbsp;</code><code>$dbh</code><code>-&gt;setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);&nbsp;&nbsp; </code> <code>&nbsp;</code><code>$stmt</code> <code>= </code><code>$dbh</code><code>-&gt;prepare(</code><code>$sql</code><code>);&nbsp;&nbsp; </code> <code>&nbsp;</code><code>$stmt</code><code>-&gt;bindParam(</code><code>':country'</code><code>, </code><code>$country</code><code>, PDO::PARAM_STR);&nbsp;&nbsp; </code> <code>&nbsp;</code><code>$stmt</code><code>-&gt;execute();&nbsp;&nbsp; </code> <code>&nbsp;</code><code>while</code> <code>(</code><code>$row</code> <code>= </code><code>$stmt</code><code>-&gt;fetch(PDO::FETCH_ASSOC)) {&nbsp;&nbsp;&nbsp; </code> <code>&nbsp;</code><code>print</code> <code>$row</code><code>[</code><code>'Name'</code><code>] . </code><code>"/t"</code><code>;&nbsp;&nbsp; </code> <code>&nbsp;</code><code>}&nbsp; </code> <code>}&nbsp; </code><code>// if there is a problem we can handle it here&nbsp; </code> <code>catch</code> <code>(PDOException </code><code>$e</code><code>) {&nbsp;&nbsp; </code> <code>&nbsp;</code><code>echo</code> <code>'PDO Exception Caught. '</code><code>;&nbsp;&nbsp; </code> <code>&nbsp;</code><code>echo</code> <code>'Error with the database: &lt;br /&gt;'</code><code>;&nbsp;&nbsp; </code> <code>&nbsp;</code><code>echo</code> <code>'SQL Query: '</code><code>, </code><code>$sql</code><code>;&nbsp;&nbsp; </code> <code>&nbsp;</code><code>echo</code> <code>'Error: '</code> <code>. </code><code>$e</code><code>-&gt;getMessage();&nbsp; </code> <code>}&nbsp; </code> <code>?&gt; </code> </td> 
 </tr> 
 </tbody> 
</table>

**1. 使用 query()**

[?][Link 1]

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 </td> 
 <td> <code>&lt;?php </code> <code>$dbh</code><code>-&gt;query(</code><code>$sql</code><code>); 当</code><code>$sql</code> <code>中变量可以用</code><code>$dbh</code><code>-&gt;quote(</code><code>$params</code><code>); </code><code>//转义字符串的数据 </code> <code>&nbsp;</code>&nbsp; <code>$sql</code> <code>= </code><code>'Select * from city where CountryCode ='</code><code>.</code><code>$dbh</code><code>-&gt;quote(</code><code>$country</code><code>);&nbsp; </code> <code>foreach</code> <code>(</code><code>$dbh</code><code>-&gt;query(</code><code>$sql</code><code>) </code><code>as</code> <code>$row</code><code>)&nbsp; {&nbsp;&nbsp; </code> <code>&nbsp;</code><code>print</code> <code>$row</code><code>[</code><code>'Name'</code><code>] . </code><code>"/t"</code><code>;&nbsp;&nbsp; </code> <code>&nbsp;</code><code>print</code> <code>$row</code><code>[</code><code>'CountryCode'</code><code>] . </code><code>"/t"</code><code>;&nbsp;&nbsp; </code> <code>&nbsp;</code><code>print</code> <code>$row</code><code>[</code><code>'Population'</code><code>] . </code><code>"/n"</code><code>;&nbsp; </code> <code>}&nbsp; </code> <code>?&gt; </code> </td> 
 </tr> 
 </tbody> 
</table>

**2. 使用 prepare, bindParam和 execute \[建议用,同时可以用添加、修改、删除\]**

[?][Link 1]

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 </td> 
 <td> <code>&lt;?php </code> <code>$dbh</code><code>-&gt;prepare(</code><code>$sql</code><code>); 产生了个PDOStatement对象 </code> <code>&nbsp;</code>&nbsp; <code>PDOStatement-&gt;bindParam() </code> <code>&nbsp;</code>&nbsp; <code>PDOStatement-&gt;execute();</code><code>//可以在这里放绑定的相应变量 </code> <code>?&gt; </code> </td> 
 </tr> 
 </tbody> 
</table>

**3. 事物**

[?][Link 1]

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 </td> 
 <td> <code>&lt;?php&nbsp; </code> <code>&nbsp;</code><code>try</code> <code>{&nbsp; </code> <code>&nbsp;</code><code>$dbh</code> <code>= </code><code>new</code> <code>PDO(</code><code>'mysql:host=localhost;dbname=test'</code><code>, </code><code>'root'</code><code>, </code><code>''</code><code>);&nbsp; </code> <code>&nbsp;</code><code>$dbh</code><code>-&gt;query(</code><code>'set names utf8;'</code><code>);&nbsp; </code> <code>&nbsp;</code><code>$dbh</code><code>-&gt;setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);&nbsp; </code> <code>&nbsp;</code><code>$dbh</code><code>-&gt;beginTransaction();&nbsp; </code> <code>&nbsp;</code><code>$dbh</code><code>-&gt;</code><code>exec</code><code>(</code><code>"Insert INTO `test`.`table` (`name` ,`age`)VALUES ('mick', 22);"</code><code>);&nbsp; </code> <code>&nbsp;</code><code>$dbh</code><code>-&gt;</code><code>exec</code><code>(</code><code>"Insert INTO `test`.`table` (`name` ,`age`)VALUES ('lily', 29);"</code><code>);&nbsp; </code> <code>&nbsp;</code><code>$dbh</code><code>-&gt;</code><code>exec</code><code>(</code><code>"Insert INTO `test`.`table` (`name` ,`age`)VALUES ('susan', 21);"</code><code>);&nbsp; </code> <code>&nbsp;</code><code>$dbh</code><code>-&gt;commit();&nbsp; </code> <code>&nbsp;</code><code>} </code><code>catch</code> <code>(Exception </code><code>$e</code><code>) {&nbsp; </code> <code>&nbsp;</code><code>$dbh</code><code>-&gt;rollBack();&nbsp; </code> <code>&nbsp;</code><code>echo</code> <code>"Failed: "</code> <code>. </code><code>$e</code><code>-&gt;getMessage();&nbsp; </code> <code>&nbsp;</code><code>}&nbsp; </code> <code>?&gt;&nbsp; </code> </td> 
 </tr> 
 </tbody> 
</table>

**PDO常用方法：**

PDO::query()主要用于有记录结果返回的操作（PDOStatement），特别是select操作。  
PDO::exec()主要是针对没有结果集合返回的操作。如insert,update等操作。返回影响行数。  
PDO::lastInsertId()返回上次插入操作最后一条ID，但要注意：如果用insert into tb(col1,col2) values(v1,v2),(v11,v22)..的方式一次插入多条记录，lastinsertid()返回的只是第一条(v1,v2)插入时的ID,而不是最后一条记录插入的记录ID。  
PDOStatement::fetch()是用来获取一条记录。配合while来遍历。  
PDOStatement::fetchAll()是获取所有记录集到一个中。  
PDOStatement::fetchcolumn(\[int column\_indexnum\])用于直接访问列，参数column\_indexnum是该列在行中的从0开始索引值，但是，这个方法一次只能取得同一行的一列，只要执行一次，就跳到下一行。因此，用于直接访问某一列时较好用，但要遍历多列就用不上。  
PDOStatement::rowcount()适用于当用query("select ...")方法时，获取记录的条数。也可以用于预处理中。$stmt->rowcount();  
PDOStatement::columncount()适用于当用query("select ...")方法时，获取记录的列数。

**注解：**

1、选fetch还是fetchall？

小记录集时，用fetchall效率高，减少从数据库检索次数，但对于大结果集，用fetchall则给系统带来很大负担。数据库要向WEB前端传输量太大反而效率低。

2、fetch()或fetchall()有几个参数：

[?][Link 1]

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 </td> 
 <td> <code>mixed pdostatement::fetch([int fetch_style [,int cursor_orientation [,int cursor_offset]]])</code> <code>array</code> <code>pdostatement::fetchAll(int fetch_style)</code> </td> 
 </tr> 
 </tbody> 
</table>

fetch\_style参数:

■$row=$rs->fetchAll(PDO::FETCH\_BOTH); FETCH\_BOTH是默认的，可省，返回关联和索引。  
■$row=$rs->fetchAll(PDO::FETCH\_ASSOC); FETCH\_ASSOC参数决定返回的只有关联数组。  
■$row=$rs->fetchAll(PDO::FETCH\_NUM); 返回索引数组  
■$row=$rs->fetchAll(PDO::FETCH\_OBJ); 如果fetch()则返回对象，如果是fetchall(),返回由对象组成的二维数组

如有疑问请留言或者到本站社区交流讨论，感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

参考文献：

[https://www.jb51.net/article/124388.htm][https_www.jb51.net_article_124388.htm]

[Link 1]: https://www.jb51.net/article/124388.htm#
[https_www.jb51.net_article_124388.htm]: https://www.jb51.net/article/124388.htm