Microsoft PowerPoint - PHPデータベース.ppt [互換モード]

Size: px

Start display at page:

Download "Microsoft PowerPoint - PHPデータベース.ppt [互換モード]"

さみらさどひら
5 years ago
Views:

1 PHP データベース基本基本的な概念とサンプルコード

2 データベース処理の基本知識を解説しますデータベース基本 # 2

3 データベース基礎知識データベースとは特定のテーマに沿ったデータを集めて管理し容易に検索抽出などの再利用をできるようにしたものデータベースの管理は DBMS( データベース管理システム ) が行う # 3

4 データベース基礎知識 RDBMS とはリレーショナルデータベース管理システム現在最も多く利用されている 1 件のデータを複数の項目 ( カラム / フィールド ) の集合として表現カラムレコードレコードの集合をテーブルとして保持テーブル # 4

5 データベースリレーションリレーションとはテーブル関連する値を通じて結合して表を作成 ( 重複 ) ID 部署 No 名前内線番号 1 11 佐藤田中山田 1113 部署 No 部門名ロケーション 11 システム部研究所 22 営業部営業所カラム 33 総務部本社 ID 名前部門名ロケーション 1 佐藤システム部研究所 2 田中営業部営業所 3 山田総務部本社 # 5

6 データベース基礎知識主な RDBMS MySQL PostgreSQL Oracle DB2 MSSQL その他 Access, Firebird, Cloudscape... # 6

7 データベース基礎知識データベースの役割大量のデータを多数のユーザのもとで一元管理を行うことが可能管理者 SQL 処理 Web サーバ DB サーバ Web アプリ一般ユーザ # 7

8 データベース SQL SQL とは SQL: Structured Query Language 世界標準規格のデータベース操作言語 RDBMS においてデータの操作や定義を行うためのデータベース言語 ( 問い合わせ言語 ) # 8

9 データベース SQL SQL の種類 DDL: Data Definition Language CREATE,ALTER,DROP,GRANT 文 DML: Data Manipulation Language INSERT,DELETE,UPDATE,SELECT 文 DCL: Data Control Language COMMIT,ROLLBACK 文 # 9

10 データベース SQL SQL の互換性原則的に ANSI / JIS に準拠最低限の互換性が保証されているが各 RDBMS によって独自拡張機能が数多くありその部分の互換性は確保されていない上記理由によりマイグレーション作業には注意が必要 # 10

11 ベンダー固有モジュールから PDO まで PHP のデータベース環境 # 11

12 PHP データベース機能 PHP からデータベースを利用するデータベースサーバに接続するには以下の 3 つの方法がありますビルトイン関数処理速度が速いベンダー固有モジュールデータベースごとに異なったコーディングが必要 PEAR DB PHP に標準バンドルされているライブラリデータベースの種類に依存しない設計ビルトイン関数を PHP によってラッピングしているので処理速度の問題がある PDO (PHP Data Objects ) PHP5.1 以降から標準バンドルライトウェイトでデータベースの種類に依存しない設計 Zend Framework にて使用 # 12

13 SQLITE3 を使用して手軽にデータベース処理を体感ベンダー固有モジュールによるデータベース処理 # 13

14 ベンダー固有モジュール対象となるデータベース毎に用意された関数データベース固有の機能が利用可能対象データベースに特化した処理が可能 # 14

15 ベンダー固有のモジュール CUBRID DB++ dbase filepro Firebird/InterBase FrontBase IBM DB2 IBM DB2 Cloudscape および Apache Derby Informix Ingres Ingres DBMS, EDBC および Enterprise Access Gateways MaxDB Mongo MongoDB msql Mssql Microsoft SQL Server MySQL MySQL ドライバおよびプラグイン OCI8 Oracle OCI8 Paradox Paradox ファイルアクセス PostgreSQL SQLite SQLite3 SQLSRV PHP 用 Microsoft SQL Server ドライバ Sybase tokyo_tyrant # 15

16 MySQL で検証 Mysql 最初の MySQL API Mysqli MySQL 改良版拡張モジュール Mysqlnd MySQL Native Driver mysqlnd_ms Mysqlnd レプリケーションおよびロードバランシング用プラグイン mysqlnd_qc Mysqlnd クエリ結果キャッシュプラグイン mysqlnd_uh Mysqlnd user handler plugin mysqlnd_mux Mysqlnd connection multiplexing plugin mysqlnd_memcache Mysqlnd Memcache プラグイン # 16

17 phpinfo 関数によるデータベースドライバの確認 PHP 環境の確認 # 17

18 PHP 環境の確認 1 # 18

19 PHP 環境の確認 2 # 19

20 シンプルで軽量なデータベース環境を用意します SQLITE3 のインストール # 20

インストール手順 1 SQLITE3 を入手 http://www.sqlite.

21 インストール手順 1 SQLITE3 を入手 Precompiled Binaries for Windows sqlite-shell-win32-x zip ( KiB) *2/15 現在適当に展開 ( 別途説明 ) # 21

22 インストール手順 2 SQLITE3 を実行 & データベースファイルの作成 C: SQLITE>sqlite3 test SQLite version :30:45 Enter ".help" for usage hints. 起動時にデータベースファイルを指定します存在しない場合には自動的に作成します # 22

23 インストール手順 3 C: SQLITE>sqlite3 test SQLite version :30:45 Enter ".help" for usage hints. sqlite> create table meibo (...> sno INTEGER,...> name text,...> memo text,...> dflag INTEGER,...> bdate text,...> idate text,...> udate text); 例題で使用するテーブル meibo を作成します # 23

24 データを挿入入力 sqlite> insert into meibo (sno,name,dflag) values (1,"Satou",0); sqlite> select * from meibo; 1 Satou 0 sqlite> insert into meibo (sno,name,dflag) values (2," 佐藤 ",0); sqlite> select * from meibo; 1 Satou 0 2 佐藤 0 # 24

25 例題ファイル処理内容参照挿入更新削除ファイル名 select.php insert.php update.php delete.php # 25

26 select.php <?php try { $db = new SQLite3('c: sqlite test'); $results = $db->query('select * FROM meibo'); while ($row = $results->fetcharray()) { print $row['sno'].' ' ; print $row['name'].' ' ; print $row['memo'].' ' ; } $db->close(); } catch (Exception $e) { print 'DB への接続でエラーが発生しました '; print $e->gettraceasstring(); }?> # 26

27 insert.php <?php try { $db = new SQLite3('c: sqlite test'); $stmt = $db->prepare('insert INTO meibo (sno,name) VALUES (:id,:name)'); $stmt->bindvalue(':id', $sno_max+1, SQLITE3_INTEGER); $stmt->bindvalue(':name', ' 吉田 ', SQLITE3_TEXT); $result = $stmt->execute(); $db->close(); } catch (Exception $e) { print 'DBへの接続でエラーが発生しました '; print $e->gettraceasstring(); }?> # 27

28 update.php <?php try { $db = new SQLite3('c: sqlite test'); $stmt = $db->prepare('update meibo set memo = :memo where name like :name'); $stmt->bindvalue(':memo', ' メモを更新 ', SQLITE3_TEXT); $stmt->bindvalue(':name', ' 吉田 ', SQLITE3_TEXT); $result = $stmt->execute(); $db->close(); } catch (Exception $e) { print 'DBへの接続でエラーが発生しました '; print $e->gettraceasstring(); }?> # 28

29 delete.php <?php try { $db = new SQLite3('c: sqlite test'); $stmt = $db->prepare('delete from meibo where name like :name'); $stmt->bindvalue(':name', ' 吉田 ', SQLITE3_TEXT); $result = $stmt->execute(); $db->close(); } catch (Exception $e) { print 'DBへの接続でエラーが発生しました '; print $e->gettraceasstring(); }?> # 29

30 SQLITE3 を使用してベンダー固有モジュールとの比較 PDO によるデータベース処理 # 30

31 抽象化レイヤー DBA データベース (dbm 形式 ) 抽象化レイヤ dbx ODBC ODBC (Unified) PDO PHP Data Objects # 31

32 PDO の目的 PDO (PHP Data Objects ) PDO は様々な RDBMS を統一的に扱うことが可能です ( 隠蔽化 : カプセル化 ) 言い換えると一度 PDO の使い方を覚えてしまえば対応している RDBMS であれば全て同じコーディングで済みますオブジェクト指向と例外処理に対応しています # 32

33 PDO ドライバ CUBRID 関数 (PDO_CUBRID) Microsoft SQL Server および Sybase 関数 (PDO_DBLIB) Firebird 関数 (PDO_FIREBIRD) IBM 関数 (PDO_IBM) Informix 関数 (PDO_INFORMIX) MySQL 関数 (PDO_MYSQL) Microsoft SQL Server 関数 (PDO_SQLSRV) Oracle 関数 (PDO_OCI) ODBC および DB2 関数 (PDO_ODBC) PostgreSQL 関数 (PDO_PGSQL) SQLite 関数 (PDO_SQLITE) 4D 関数 (PDO_4D) # 33

34 データベース PDO PDO のクラス PDO RDBMS への接続を保持するクラス PDOStatement SQL の実行結果セットとして返される PDOException PDOStatement が投げる例外のクラス # 34

35 データベース PDO PDO の使い方 PHPスクリプトでデータベースに接続するにはまずデータソース (DSN) を確認する必要があります DSN (Database Source Name) データベース接続の際に必要なデータを文字列であらわしますユーザ名パスワード 'mysql:host=localhost;dbname=test','user','pass' DB の種類 DB ホスト名使用する DB 名 # 35

36 データベース PDO PDO の使い方 MySQL への接続 DSN を引数として PDO クラスのインスタンスを生成することで MySQL に接続することができます $dbh = new PDO('mysql:host=localhost;dbname=test','user','pass'); PDO の切断スクリプト終了と同時に自動的に切断するが明示的に切断したい場合は以下のようにする $dbh = null; # 36

37 データベース PDO PDO の使い方 PHP スクリプトで接続する際には例外処理を使用します PDO に接続してみましょう try { $dbh = new PDO('mysql:host=localhost;dbname=test','user','pass'); } $dbh = null; } catch (PDOException $e) { print " エラー!: ". $e->getmessage(). " "; die(); } # 37

38 try { データベース PDO PDO の使い方先程作成したテーブル test にデータを挿入するスクリプトを作ります $dbh = new PDO('mysql:dbname=test;host=localhost', 'user','pass'); // エラー時に例外を投げる設定 $dbh ->setattribute(pdo::attr_errmode, PDO::ERRMODE_EXCEPTION); $sql = 'INSERT INTO test VALUES(2, "tanaka")'; $stmt = $dbh->query($sql); $dbh = null; } catch (PDOException $e) { print " エラー!: ". $e->getmessage(). " "; die(); } # 38

39 データベース PDO PDO の使い方 SELECT 文を発行して test テーブルに登録されている全てのデータを取得します try { $dbh = new PDO('mysql:dbname=test;host=localhost', 'user','pass'); $dbh ->setattribute(pdo::attr_errmode, PDO::ERRMODE_EXCEPTION); // foreach 文を使って一行ずつ取得 foreach ($dbh->query('select * from test') as $row) { } var_dump($row); $dbh = null; } catch (PDOException $e) { } print " エラー!: ". $e->getmessage(). " "; die(); # 39

40 例題ファイル処理内容参照挿入更新削除ファイル名 select2.php insert2.php update2.php delete2.php # 40

41 select2.php <?php try { $db = new PDO('sqlite:c: sqlite test'); $sql ='SELECT * FROM meibo'; $results = $db->query($sql); foreach ($results as $row) { print $row['sno'].' ' ; print $row['name'].' ' ; print $row['memo'].' ' ; } $db=null; } catch (Exception $e) { print 'DB への接続でエラーが発生しました '; print $db->errorinfo(); }?> # 41

$ame,memo) values (?,?,?)"); $arg = array($sno_max + 1, " 田中 "," メモ帳 "); $sql->execute($arg); $db=null; } catch (Exception $e) { print$

42 insert2.php <?php try { $db = new PDO('sqlite:c: sqlite test'); $sql = $db->prepare("insert into meibo (sno,name,memo) values (?,?,?)"); $arg = array($sno_max + 1, " 田中 "," メモ帳 "); $sql->execute($arg); $db=null; } catch (Exception $e) { print 'DBへの接続でエラーが発生しました '; print $db->errorinfo(); }?> # 42

43 update2.php <?php try { $db = new PDO('sqlite:c: sqlite test'); $sql = $db->prepare("update meibo set memo=? where name like?"); $arg = array(" 手の甲にメモ "," 田中 "); $sql->execute($arg); $db=null; } catch (Exception $e) { print 'DBへの接続でエラーが発生しました '; print $db->errorinfo(); }?> # 43

44 delete2.php <?php try { $db = new PDO('sqlite:c: sqlite test'); $sql = $db->prepare("delete from meibo where name like?"); $arg = array(" 田中 "); $sql->execute($arg); $db=null; } catch (Exception $e) { print 'DBへの接続でエラーが発生しました '; print $db->errorinfo(); }?> # 44

45 IBMi と PHP の連係

46 DB2/400 への接続 : 概要 PHP から DB2/400 を操作可能 db2 関数 # 46

47 DB2/400 への接続 : 命令 ( 関数 ) 接続と切断 db2_connect db2_close db2_pconnect db2_pclose SQL 実行 db2_exec db2_fetch_array db2_fetch_assoc db2_fetch_both プリペア db2_prepare db2_bind_param db2_execute トランザクション db2_commit db2_rollback # 47

48 DB2/400 への接続 : コードサンプル <?php $db_con = db2_connect('', '', ''); if(!$db_con){ echo 'DB2 に接続できません :', db2_conn_errormsg(); exit; } $query = ' SELECT * FROM ZPHPTEST.ZLOGF ORDER BY CTIME '; $result = db2_exec($db_con, $query); if(!$result){ echo 'SQL が実行できませんでした :', db2_stmt_errormsg(); db2_close($db_con); exit; } echo '<table border=1>', '<tr><th>ctime</th></tr>'; while($row = db2_fetch_array($result)) { echo '<tr>', '<td>', $row[0], '</td>', '</tr>'; } echo '</table>'; db2_close($db_con);?> # 48

49 DB2/400 への接続 : 参考情報 Konekto 技術情報ページ Old%2FZend%20Server%2FIBMi%2Fd b2func Ustream(PHP 勉強会 2011 年度 ) :TEAM-HALh # 49

50 IBM i との連携 : 概要 PHP から IBM i に接続プログラムの実行システム資源の参照 CL RPG スプールジョブログシステム値オブジェクト一覧 XML Toolkit db2 関数 RPG # 50

51 IBM i との連携 : 命令 ( メソッド ) Toolkit オブジェクト getinstanceメソッドェクトの作成 Disconnectメソッド接続とオブジ切断とオブジェクトの削除メソッドの種類 CLCommand メソッド PGMCall メソッドパラメーター設定メソッド AddParameterChar AddParameterPackDec, AddParameterZoned AddParameterFloat AddParameterReal AddParameterBin AddParameterInt32, AddParameterUInt32 AddParameterInt64, AddParameterUint64 AddDataStruct UpdateParameterValue itoolkit サービスクラススプールファイル GetSPLList GetSPLF ジョブログ JobList createjoblistarray JobLog システム値 SystemValuesList GetSystemValue オブジェクト一覧 getobjectlist # 51

52 IBM i との連携 : コードサンプル </pre> <?php include_once 'authorization.php'; include_once '../API/ToolkitService.php'; try { $obj = ToolkitService::getInstance($db, $user, $pass); } catch (Exception $e) { echo $e->getmessage(), " n"; exit(); } $obj->settoolkitserviceparams(array('internalkey'=>"/tmp/$user", 'debug'=>false, 'plug' => "iplug32k")); $cmd = "addlible ZENDSVR"; $obj->clcommand($cmd); echo "<pre>"; $Rows = $obj->clinteractivecommand("dsplibl"); /*$Rows = $obj->clinteractivecommand("wrksysval OUTPUT(*PRINT)");*/ if(!$rows ) echo $obj->getlasterror(); else var_dump($rows); echo "</pre>";?> # 52

PHP 分科会 '11/11 OpenSource 協議会 System i 2011/11/25

PHP 分科会 '11/11 OpenSource 協議会 System i 2011/11/25 最も簡単な例最低限下記の処理が必要です db2_(p)connect で DB2 に接続します指定されたユーザーで QSYSWRK サブシステムの QSQSRVR ジョブが作成されます db2_exec で SQL を実行しますデータを取得します # 6 DB2 に接続 db2_(p)connect('