簡単なPHPデータベース操作コード（追加、削除、変更、確認）_PHPチュートリアル-PHPチュートリアル-php.cn

簡単なPHPデータベース操作コード（追加、削除、変更、確認）_PHPチュートリアル

WBOY

リリース： 2016-07-21 15:12:37

オリジナル

667 人が閲覧しました

データベース操作の基本プロセスは次のとおりです:

1.データベースサーバーに接続します

2.データベースを選択します

3. SQL文を実行します

4. 結果セットを処理する

5. 運行情報を印刷する

使用される関連関数は

•resource mysql_connect ( [string サーバー [, string ユーザー名 [, string パスワード [, bool new_link [, int client_flags]]]]] ) データベースサーバーに接続します
• resource mysql_pconnect ( [string サーバー [, string ユーザー名 [, stringパスワード [ , int client_flags]]]] ) データベースサーバーに接続します、長い接続です
•int mysql_affected_rows ( [resource link_identifier] ) link_identifier に関連付けられた最新の INSERT、UPDATE、または DELETE クエリによって影響を受けるレコード行の数を取得します。
•bool mysql_close ([resource link_identifier]) 成功した場合は TRUE を返し、失敗した場合は FALSE を返します。
•int mysql_errno ( [resource link_identifier] ) は、前の MySQL 関数のエラー番号を返します。エラーがない場合は 0 (ゼロ) を返します。
•string mysql_error ( [resource link_identifier] ) は、前の MySQL 関数のエラーテキストを返します。エラーがない場合は '' (空の文字列) を返します。接続リソース番号が指定されていない場合は、最後に正常に開かれた接続が MySQL サーバーからエラー情報を抽出するために使用されます。
•array mysql_fetch_array ( resource result [, int result_type] ) 結果セットからフェッチされた行に基づいて配列を返します。行がもうない場合は FALSE を返します。
•bool mysql_free_result (リソース結果) 結果識別子 result に関連付けられたすべてのメモリを解放します。
•int mysql_num_fields (リソース結果) は、結果セット内のフィールドの数を返します。
•int mysql_num_rows (リソース結果) は、結果セット内の行数を返します。このコマンドは SELECT ステートメントに対してのみ有効です。 INSERT、UPDATE、または DELETE クエリによって影響を受ける行の数を取得するには、mysql_affected_rows() を使用します。
•resource mysql_query ( string query [, resource link_identifier] ) 指定された接続識別子に関連付けられたサーバー内の現在アクティブなデータベースにクエリを送信します。 link_identifier が指定されていない場合は、最後に開かれた接続が使用されます。開いている接続がない場合、この関数はパラメータなしで mysql_connect() 関数を呼び出し、接続を確立して使用しようとします。クエリ結果はキャッシュされます
コードは次のとおりです:

コードをコピーしますコードは次のとおりです:

class mysql {

 private $db_host; //データベース ホスト
 private $db_pwd; //データベース ログイン パスワード 
 private $db_name //データベース名 
 /データベースの文字エンコーディング 
 private $db_pconn; //長い接続識別ビット
 private $debug; //デバッグが有効です
 private $conn; //private $sql = "" //実行される SQL ステートメント 

 $db_host、$db_user、$db_pwd、$db_name、$db_chaeset = 'utf8'、$db_pconn = false、$debug = false) {
 $db_ name;
 $this-> ;db_charset = $db_chaeset;
使用する 使用するuse using use using using db_charset Connect();
 } L パブリック関数 () {
 IF ($ this-& gt; db_pconn) {
 $ this- & gt; conn = @Mysql_pconnect ($ this- & gt; db_host, $ GT; 

} u Public Function Queery n); } Else {}} 
 if ($ this-& gt; result == false) {
 $ this-& gt; msg = "SQL がエラーを実行しました。エラー番号:"。 ;

 public function select($tableName, $columnName = "*", $where = "") {
 $sql = "SELECT " . $columnName 。 " から " 。 $tableName;
 $sql .= $where ? " どこ " 。 $where : null;
 $this->query($sql);
 }

 public function findAll($tableName) {
 $sql = "SELECT * FROM $tableName";
 $this->query($ sql);
 }

 public function insert($tableName, $column = array()) {
 $columnName = "";
 $columnValue = "";
 foreach ($column as $key => $value) {
 $columnName .= $key . ",";
 $columnValue .= "'" 。 $value 。 "',";
 }
 $columnName = substr($columnName, 0, strlen($columnName) - 1);
 $columnValue = substr($columnValue, 0, strlen($columnValue) - 1);
 $s QL = "INSERT INTO $tableName($columnName) VALUES($columnValue)";
 $this->query($sql);
 if($this->result){
 $this->msg = "データ挿入は成功しました。新しい挿入の ID は次のとおりです。 mysql_insert_id($this->conn);
 }
 }

 public function update($tableName, $column = array(), $where = "") {
 $updateValue = "";
 foreach ($column as $key => $value) {
 $updateValue .= $key . 「=」。 $value 。 "',";
 }
 $updateValue = substr($updateValue, 0, strlen($updateValue) - 1);
 $sql = "UPDATE $tableName SET $updateValue";
 $sql .= $where ? " WHERE $where" : null;
 $this->query($sql);
 if($this->result){
 $this->msg = "データ更新成功。影響を受ける行数：" 。 mysql_affected_rows($this->conn);
 }
 }

 public function delete($tableName, $where = ""){
 $sql = "DELETE FROM $tableName";
 $sql .= $where ? " WHERE $where" : null;
 $this->query($sql);
 if($this->result){
 $this->msg = "データ删除成功。影響响行数：" . mysql_affected_rows($this->conn);
 }
 }

 public function fetchArray($result_type = MYSQL_BOTH){
 $resultArray = array();
 $i = 0;
 while( $result = mysql_fetch_array($this->result, $result_type)){
 $resultArray[$i] = $result;
 $i++;
 }
 $resultArray;
 }

 // public function fetchObject() {
 // return mysql_fetch_object($this->result);
 // }

 public function printMessage(){
 return $this->msg;
 }

 public function freeResult(){ 
 @mysql_free_result( $this->result);
 }

 public function __destruct() {
 if(!empty($this->result)){
 $this->freeResult();
 }
 mysql_close($this ->conn);
 }
 }

调用代码如下

复制代码代码如下:

require_once 'mysql_V1.class.php';
 require_once 'commonFun.php';
 $db = new mysql('localhost', 'root', '', " test");

 //select 查
 $db->select("user", "*", "username = 'system'");
 $result = $db->fetchArray(MYSQL_ASSOC);
 print_r($result);
 dump($db->printMessage());

 //insert 增
 //$userInfo = array('username'=>'system', 'password' => md5 ("システム"));
 //$db->insert("user", $userInfo);
 //dump($db->printMessage());

 //update 修正
 //$ userInfo = array('password' => md5("123456"));
 //$db->update("user", $userInfo, "id = 2");
 //dump($db- >printMessage());

 //delete 删
 //$db->delete("user", "id = 1");
 //dump($db->printMessage());
 
 //findAll 查询全部
 $db->findAll("user");
 $result = $db->fetchArray();
 dump($result);