PHP PDOの基本操作を学習するフロントエンド

×

目次

[1] PDOの作成 [2] PDOの使用 [3] トランザクション処理

前の言葉

PDO (php data object) 拡張クラス ライブラリは、PHP がデータベースにアクセスするための軽量で一貫したインターフェイスを定義し、どのようなデータベースが使用されても、一貫した関数を通じてクエリを実行してデータを取得できるようにします。これにより、データベースの操作が大幅に簡素化され、異なるデータベース間の差異を隠すことができます。PDO を使用すると、クロスデータベース プログラムの開発や異なるデータベース間の移植が簡単に実行できます。これは、データベース処理における PDO の主な用途になります。将来的には、mysql、postgresql、oracle、mssql、その他のデータベースをサポートできるようになります

PDOオブジェクトを作成する

PDO を使用してさまざまなデータベース管理システムと対話する場合、PDO オブジェクトのメンバー メソッドはさまざまなデータベースのアクセス インターフェイスを統合するため、PDO を使用してデータベースと対話する前に、まず PDO オブジェクトを作成する必要があります。コンストラクターメソッドを通じてオブジェクトを作成する際、データベースサーバーとの接続を確立し、データベースを選択する必要があります

PDOの構築方法のプロトタイプは以下の通りです

リーリー

構築メソッドでは、最初に必須のパラメータはデータ ソース名 (dsn) で、これは特定のデータベースと使用する必要があるドライバーを定義するために使用されます。 DSN の PDO 命名規則は、PDO ドライバーの名前の後にコロンが続き、その後にホスト名、ポート、データベース名などのオプションのドライバー データベース接続変数情報が続きます

構築メソッドの第二パラメータusernameと第三パラメータpasswordはそれぞれデータベースへの接続に使用するユーザー名とパスワードを指定します。最後のパラメーター driver_options には、接続に必要なすべての追加オプションを指定するための配列が必要で、追加の調整パラメーターを PDO または基礎となるドライバーに渡します

リーリー

PDO オブジェクトを作成するとき、データを形成するために必要なオプションをコンストラクターの 4 番目のパラメーター driver_opts に渡して、追加の調整パラメーターを PDO または基礎となるドライバーに渡すことができます。

リーリー

リーリー

PDO オブジェクトを使用する

PDO の動作属性を調整します

PDO オブジェクトには、PDO の動作を調整したり、基礎となるドライバーのステータスを取得したりするために使用されるプロパティが多数あります。 PDO オブジェクトの作成時にコンストラクターの最後のパラメーターとして属性オプションを渡さない場合は、PDO オブジェクトの作成後に、PDO オブジェクトの setAttribute() メソッドと getAttribute() メソッドを通じてこれらの属性の値を設定および取得することもできます。オブジェクトが作成されました

PDO::getAttribute()

PDO::getAttribute() はデータベース接続の属性を取得するために使用されます

リーリー

PDO::setAttribute()

属性の設定にはPDO::setAttribute()を使用します

リーリー

リーリー

エラー処理

PDO は合計 3 つの異なるエラー処理モードを提供し、さまざまなスタイルのプログラミングに対応できるだけでなく、エラー処理方法を調整および拡張することもできます

PDO:ERRORMODE_SILENT

これはデフォルトのモードで、エラーが発生してもアクションは実行されず、PDO はエラー コードを設定するだけです。開発者は、PDO オブジェクトの errorCode() メソッドと errorInfo() メソッドを使用してステートメントとデータベース オブジェクトをチェックできます。ステートメント オブジェクトの呼び出しによってエラーが発生した場合は、そのステートメント オブジェクトに対して errorCode() メソッドまたは errorInfo() メソッドを呼び出すことができます。データベース オブジェクトの呼び出しによってエラーが発生した場合は、そのデータベース オブジェクトに対して上記の 2 つのメソッドを呼び出すことができます

PDO:ERRMODE_WARNING

エラーコードの設定に加えて、PDO は PHP の従来の E_WARNING メッセージも発行します。これは、通常の PHP エラー ハンドラーを使用して捕捉できます。この設定は、アプリケーションのフローを誤って中断せずに、何が問題になったのかを確認したいだけの場合、デバッグやテストに役立ちます

リーリー

PDO:ERRMODE_EXCEPTION

エラー コードの設定に加えて、PDO は PDOException をスローし、そのプロパティを設定してエラー コードとエラー情報を反映します。この設定は、スクリプト内のエラーが発生している箇所にズームインし、コードの問題の可能性がある領域を迅速に特定できるため、デバッグにも役立ちます。例外パターンのもう 1 つの便利な側面は、従来の PHP スタイルの警告よりも明確に独自のエラー処理を構築できることです。各データベース呼び出しの戻り値をサイレントかつ明示的にチェックするのではなく、例外パターンのコードとネストされたコードが少なくなります

リーリー

执行SQL语句

　　在使用PDO执行查询数据之前，先提供一组相关的数据。创建PDO对象并通过mysql驱动连接mysql数据库服务器，创建一个以'testdb'命名的数据库，并在该数据库中创建一个联系人信息表contactInfo

<span style="color: #000000;">CREATE TABLE contactInfo(
    uid MEDIUMINT(</span>8) UNSIGNED NOT <span style="color: #0000ff;">NULL</span> AUTO_INCREMENT,<span style="color: #000000;">
    name VARCHAR(</span>50) NOT <span style="color: #0000ff;">NULL</span>,<span style="color: #000000;">
    departmentID CHAR(</span>3) NOT <span style="color: #0000ff;">NULL</span>,<span style="color: #000000;">
    address VARCHAR(</span>80) NOT <span style="color: #0000ff;">NULL</span>,<span style="color: #000000;">
    phone VARCHAR(</span>20),<span style="color: #000000;">
    email VARCHAR(</span>20),<span style="color: #000000;">
    PRIMARY </span><span style="color: #008080;">KEY</span><span style="color: #000000;">(uid)
);</span>

　　数据表contactInfo建立之后，向表中插入多行记录

INSERT INTO contactInfo(name,departmentID,address,phone,email) VALUES ('张三','D01','朝阳','15011111234','zs@aaa.com'),('李四','D02','朝阳','15011112345','ls@aaa.com'),('王五','D02','海淀','15011113456','ww@aaa.com'),('赵四','D01','海淀','15011114567','zx@aaa.com');

PDO::exec()

　　PDO::exec()函数执行一条SQL语句，并返回受影响的行数

int PDO::<span style="color: #008080;">exec</span> ( <span style="color: #0000ff;">string</span> <span style="color: #800080;">$statement</span> )

　　当执行INSERT、UPDATE、DELETET等没有结果集的查询时，使用PDO对象中的exec()方法去执行。该方法成功执行后，将返回受影响的行数

<?<span style="color: #000000;">php
</span><span style="color: #0000ff;">try</span><span style="color: #000000;"> {
    </span><span style="color: #008000;">//</span><span style="color: #008000;">创建对象</span>
    <span style="color: #800080;">$dbh</span> = <span style="color: #0000ff;">new</span> PDO("mysql:host=localhost;dbname=testdb", "root", "zhiaihebe0123"<span style="color: #000000;">);
}</span><span style="color: #0000ff;">catch</span>(PDOException <span style="color: #800080;">$e</span><span style="color: #000000;">) {
    </span><span style="color: #0000ff;">echo</span> "数据库连接失败：".<span style="color: #800080;">$e</span>-><span style="color: #000000;">getMessage();
    </span><span style="color: #0000ff;">exit</span><span style="color: #000000;">;
}

</span><span style="color: #800080;">$query</span> = "UPDATE contactInfo SET phone='12345678900' WHERE name='张三'"<span style="color: #000000;">;
</span><span style="color: #800080;">$affected</span> = <span style="color: #800080;">$dbh</span>-><span style="color: #008080;">exec</span>(<span style="color: #800080;">$query</span><span style="color: #000000;">);
</span><span style="color: #0000ff;">if</span>(<span style="color: #800080;">$affected</span><span style="color: #000000;">){
    </span><span style="color: #008000;">//</span><span style="color: #008000;">数据表contactInfo中受影响的行数为:1</span>
    <span style="color: #0000ff;">echo</span> '数据表contactInfo中受影响的行数为:' .<span style="color: #800080;">$affected</span><span style="color: #000000;">;
}</span><span style="color: #0000ff;">else</span><span style="color: #000000;">{
    </span><span style="color: #008080;">print_r</span>(<span style="color: #800080;">$dbh</span>-><span style="color: #000000;">errorInfo());
}
</span><span style="color: #800080;">$query</span> = "UPDATE contactInfo SET phone='123456789' WHERE (uid%2 = 0)"<span style="color: #000000;">;
</span><span style="color: #800080;">$affected</span> = <span style="color: #800080;">$dbh</span>-><span style="color: #008080;">exec</span>(<span style="color: #800080;">$query</span><span style="color: #000000;">);
</span><span style="color: #0000ff;">if</span>(<span style="color: #800080;">$affected</span><span style="color: #000000;">){
    </span><span style="color: #008000;">//</span><span style="color: #008000;">数据表contactInfo中受影响的行数为:2</span>
    <span style="color: #0000ff;">echo</span> '数据表contactInfo中受影响的行数为:' .<span style="color: #800080;">$affected</span><span style="color: #000000;">;
}</span><span style="color: #0000ff;">else</span><span style="color: #000000;">{
    </span><span style="color: #008080;">print_r</span>(<span style="color: #800080;">$dbh</span>-><span style="color: #000000;">errorInfo());
}
</span>?>

PDO::lastInsertId()

　　PDO::lastInsertId()函数用于返回最后插入行的ID或序列值

<span style="color: #0000ff;">string</span> PDO::lastInsertId ([ <span style="color: #0000ff;">string</span> <span style="color: #800080;">$name</span> = <span style="color: #0000ff;">NULL</span> ] )

<?<span style="color: #000000;">php
</span><span style="color: #0000ff;">try</span><span style="color: #000000;"> {
    </span><span style="color: #008000;">//</span><span style="color: #008000;">创建对象</span>
    <span style="color: #800080;">$dbh</span> = <span style="color: #0000ff;">new</span> PDO("mysql:host=localhost;dbname=testdb", "root", "zhiaihebe0123"<span style="color: #000000;">);
}</span><span style="color: #0000ff;">catch</span>(PDOException <span style="color: #800080;">$e</span><span style="color: #000000;">) {
    </span><span style="color: #0000ff;">echo</span> "数据库连接失败：".<span style="color: #800080;">$e</span>-><span style="color: #000000;">getMessage();
    </span><span style="color: #0000ff;">exit</span><span style="color: #000000;">;
}

</span><span style="color: #0000ff;">try</span><span style="color: #000000;">{
    </span><span style="color: #800080;">$query</span> = "INSERT INTO contactInfo(name,departmentID,phone,email) VALUES ('诸葛','D03','120120120','zg@aaa.com')"<span style="color: #000000;">;
    </span><span style="color: #800080;">$affected</span> = <span style="color: #800080;">$dbh</span>-><span style="color: #008080;">exec</span>(<span style="color: #800080;">$query</span><span style="color: #000000;">);    
    </span><span style="color: #0000ff;">echo</span> <span style="color: #800080;">$affected</span>."<br>";<span style="color: #008000;">//</span><span style="color: #008000;">1</span>
    <span style="color: #0000ff;">echo</span> <span style="color: #800080;">$dbh</span>->lastInsertId();<span style="color: #008000;">//</span><span style="color: #008000;">5</span>
}<span style="color: #0000ff;">catch</span>(PDOException <span style="color: #800080;">$e</span><span style="color: #000000;">){
    </span><span style="color: #0000ff;">echo</span> "错误：" .<span style="color: #800080;">$e</span>-><span style="color: #000000;">getMessage();
}
</span>?>

PDO::query()

　　当执行返回结果集的SELECT查询时，或者所影响的行数无关紧要时，应当使用PDO对象中的query()方法。如果该方法成功执行指定的查询，则返回一个PDOStatement对象。如果使用了query()方法，并想了解获取的数据行总数，可以使用PDOStatement对象中的rowCount()方法获取

PDOStatement::rowCount()

　　PDOStatement::rowCount()函数返回受上一个 SQL 语句影响的行数

int PDOStatement::rowCount ( void )

<?<span style="color: #000000;">php
</span><span style="color: #0000ff;">try</span><span style="color: #000000;"> {
    </span><span style="color: #008000;">//</span><span style="color: #008000;">创建对象</span>
    <span style="color: #800080;">$dbh</span> = <span style="color: #0000ff;">new</span> PDO("mysql:host=localhost;dbname=testdb", "root", "zhiaihebe0123"<span style="color: #000000;">);
}</span><span style="color: #0000ff;">catch</span>(PDOException <span style="color: #800080;">$e</span><span style="color: #000000;">) {
    </span><span style="color: #0000ff;">echo</span> "数据库连接失败：".<span style="color: #800080;">$e</span>-><span style="color: #000000;">getMessage();
    </span><span style="color: #0000ff;">exit</span><span style="color: #000000;">;
}
</span><span style="color: #800080;">$query</span> = "SELECT name,phone,email FROM contactInfo WHERE departmentId='D01'"<span style="color: #000000;">;
</span><span style="color: #0000ff;">try</span><span style="color: #000000;">{
    </span><span style="color: #800080;">$pdostatement</span> = <span style="color: #800080;">$dbh</span>->query(<span style="color: #800080;">$query</span><span style="color: #000000;">);    
    </span><span style="color: #0000ff;">echo</span> "一共从表中获取到".<span style="color: #800080;">$pdostatement</span>->rowCount()."条记录:<br>"<span style="color: #000000;">;
    </span><span style="color: #0000ff;">foreach</span>(<span style="color: #800080;">$pdostatement</span> <span style="color: #0000ff;">as</span> <span style="color: #800080;">$row</span><span style="color: #000000;">){
        </span><span style="color: #0000ff;">echo</span> <span style="color: #800080;">$row</span>['name'] ."\t"<span style="color: #000000;">;
        </span><span style="color: #0000ff;">echo</span> <span style="color: #800080;">$row</span>['phone'] ."\t"<span style="color: #000000;">;
        </span><span style="color: #0000ff;">echo</span> <span style="color: #800080;">$row</span>['email'] ."<br>"<span style="color: #000000;">;
    }
}</span><span style="color: #0000ff;">catch</span> (PDOException <span style="color: #800080;">$e</span><span style="color: #000000;">){
    </span><span style="color: #0000ff;">echo</span> <span style="color: #800080;">$e</span>-><span style="color: #000000;">getMessage();
}
</span>?>

 

事务处理

　　事务是确保数据库一致的机制，是一个或一系列的查询，作为一个单元的一组有序的数据库操作。如果组中的所有SQL语句都操作成功，则认为事务成功，事务则被提交，其修改将作用于所有其他数据库进程。即使在事务的组中只有一个环节操作失败，事务也不成功，则整个事务将被回滚，该事务中所有操作都被取消。事务功能是企业级数据库的一个重要部分，因为很多业务过程都包括多个步骤。如果任何一个步骤失败，则所有步骤都不应发生。事务处理有4个特征：原子性(Atomicity)、一致性(Consistency)、独立性(Isolation)和持久性(Durability)，即ACID。对于在一个事务中执行的任何工作，即使它是分阶段进行的，也一定可以保证该工作会安全地应用于数据库，并且在工作被提交时，不会受到其他连接的影响

　　MySQL目前只有InnoDB和BDB两个数据库表类型才支持事务，两个表类型具有相同的特性，InnoDB表类型具有比BDB还丰富的特性，速度更快，因此建议使用InnoDB表类型。创建InnoDB类型的表实际上与创建任何其他类型表的过程没有区别，如果数据库没有设置为默认的表类型，只要在创建时显式指定要将表创建为InnoDB类型

　　要实现事务处理，首先要使用InnoDB引擎

ALTER TABLE contactInfo engine=innodb;

　　在默认的情况下，MySQL是以自动提交(autocommit)模式运行的，这就意味着所执行的每一个语句都将立即写入数据库中。但如果使用事务安全的表格类型，是不希望有自动 提交的行为的，所以要在当前的会话中关闭自动提交

SET AUTOCOMMIT = 0;<span style="color: #008000;">//</span><span style="color: #008000;">在当前的会话中关闭自动提交</span>

　　如果提交被打开了，必须开启一个事务；如果自动提交是关闭的，则不需要使用这条命令，因为输入一个SQL命令时，一个事务将自动启动

START TRANSACTION;<span style="color: #008000;">//</span><span style="color: #008000;">开启一个事务</span>

　　在完成了一组事务的语句输入后，需要提交一个事务，该事务才能在其他会话中被其他用户所见

COMMIT;<span style="color: #008000;">//</span><span style="color: #008000;">提交一个事务给数据库</span>

　　如果改变注意，可以回滚到以前的状态

ROOLBACK;<span style="color: #008000;">//</span><span style="color: #008000;">事务被回滚，所有操作都被取消</span>

　　事务处理完成后，再次开启自动提交

SET AUTOCOMMIT = 1;

　　下面在PHP中进行事务处理操作，对张三和李四进行部门交换来轮岗培养

<?<span style="color: #000000;">php
</span><span style="color: #0000ff;">try</span><span style="color: #000000;"> {
    </span><span style="color: #008000;">//</span><span style="color: #008000;">创建对象</span>
    <span style="color: #800080;">$dbh</span> = <span style="color: #0000ff;">new</span> PDO("mysql:host=localhost;dbname=testdb", "root", "zhiaihebe0123"<span style="color: #000000;">);
    </span><span style="color: #008000;">//</span><span style="color: #008000;">设置错误使用异常的模式</span>
    <span style="color: #800080;">$dbh</span> -> setAttribute(PDO::ATTR_ERRMODE, PDO::<span style="color: #000000;">ERRMODE_EXCEPTION);
    </span><span style="color: #008000;">//</span><span style="color: #008000;">关闭自动提交</span>
    <span style="color: #800080;">$dbh</span>-> setAttribute(PDO::ATTR_AUTOCOMMIT, 0<span style="color: #000000;">);
}</span><span style="color: #0000ff;">catch</span>(PDOException <span style="color: #800080;">$e</span><span style="color: #000000;">) {
    </span><span style="color: #0000ff;">echo</span> "数据库连接失败：".<span style="color: #800080;">$e</span>-><span style="color: #000000;">getMessage();
    </span><span style="color: #0000ff;">exit</span><span style="color: #000000;">;
}
</span><span style="color: #0000ff;">try</span><span style="color: #000000;"> {
    </span><span style="color: #008000;">//</span><span style="color: #008000;">开启一个事务</span>
    <span style="color: #800080;">$dbh</span> -><span style="color: #000000;"> beginTransaction();
    </span><span style="color: #800080;">$affected_rows</span> = <span style="color: #800080;">$dbh</span>-><span style="color: #008080;">exec</span>("UPDATE contactInfo set departmentID = 'D02' where uid=1"<span style="color: #000000;">);
    </span><span style="color: #0000ff;">if</span>(<span style="color: #800080;">$affected_rows</span> > 0<span style="color: #000000;">) {
        </span><span style="color: #0000ff;">echo</span> "张三转岗成功!<br>"<span style="color: #000000;">;
    } </span><span style="color: #0000ff;">else</span><span style="color: #000000;"> {
        </span><span style="color: #0000ff;">throw</span> <span style="color: #0000ff;">new</span> PDOException("张三转岗失败！<br>"<span style="color: #000000;">);
    }
    </span><span style="color: #800080;">$affected_rows</span> = <span style="color: #800080;">$dbh</span>-> <span style="color: #008080;">exec</span>("UPDATE contactInfo set departmentID = 'D01' where uid=2"<span style="color: #000000;">);
    </span><span style="color: #0000ff;">if</span>(<span style="color: #800080;">$affected_rows</span><span style="color: #000000;">) {
        </span><span style="color: #0000ff;">echo</span> "李四转岗成功!<br>"<span style="color: #000000;">;
    }</span><span style="color: #0000ff;">else</span><span style="color: #000000;"> {
        </span><span style="color: #0000ff;">throw</span> <span style="color: #0000ff;">new</span> PDOException("李四转岗失败！<br>"<span style="color: #000000;">);
    }
    </span><span style="color: #0000ff;">echo</span> "轮岗成功!<br>"<span style="color: #000000;">;
    </span><span style="color: #008000;">//</span><span style="color: #008000;">提交以上的操作</span>
    <span style="color: #800080;">$dbh</span>-><span style="color: #000000;">commit();    
}</span><span style="color: #0000ff;">catch</span>(PDOException <span style="color: #800080;">$e</span><span style="color: #000000;">) {
    </span><span style="color: #0000ff;">echo</span> "错误：".<span style="color: #800080;">$e</span>-><span style="color: #000000;">getMessage();
    </span><span style="color: #0000ff;">echo</span> "转岗失败!<br>"<span style="color: #000000;">;
    </span><span style="color: #008000;">//</span><span style="color: #008000;">撤销所有操作</span>
    <span style="color: #800080;">$dbh</span> -><span style="color: #000000;"> rollback();
}
</span><span style="color: #008000;">//</span><span style="color: #008000;">运行完成以后， 最后开启自动提交</span>
<span style="color: #800080;">$dbh</span>-> setAttribute(PDO::ATTR_AUTOCOMMIT, 1<span style="color: #000000;">);
</span>?>