PHPデータベース操作コード(追加、削除、変更、確認)_PHPチュートリアル

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

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

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

3. SQL文を実行します

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

5. 運行情報を印刷する

使用される関連関数は

•resource mysql_connect ([stringserver[,stringusername[,stringpassword[,boolnew_link[,intclient_flags]]]]]) データベースサーバーに接続します
•resource mysql_pconnect ([stringserver[,stringusername[,stringpassword[,intclient_flags]]]]) データベースサーバーに接続、長い接続
•int mysql_affected_rows ([resource link_identifier]) link_identifier に関連付けられた最新の INSERT、UPDATE、または DELETE クエリによって影響を受けるレコード行の数を取得します。
• bool mysql_close ( [resource link_identifier] ) 成功した場合は TRUE を返し、失敗した場合は FALSE を返します。
•int mysql_errno ([リソースリンク識別子]) は、前の 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 が指定されていない場合、php は最後に開かれた接続を使用します。開いている接続がない場合、この関数はパラメータなしで mysql_connect() 関数を呼び出し、接続を確立して使用しようとします。クエリ結果はキャッシュされます
コードは次のとおりです: ソース php チュートリアル センター

コードは次のとおりです:

クラスmysql{

private $db_host //データベースホスト
; private $db_user //データベースのログイン名
private $db_pwd; //データベースのログインパスワード
private $db_name //データベース名
private $db_charset; //データベースの文字エンコーディング
private $db_pconn; //長い接続フラグ
private $debug; //デバッグが有効になります
private $conn; //データベース接続識別子
private $msg = "" //データベース操作情報

;

// private $sql = "" //実行されるSQL文

;

パブリック関数 __construct($db_host, $db_user, $db_pwd, $db_name, $db_chaeset = 'utf8', $db_pconn = false, $debug = false) {
$this->db_host = $db_host;
$this->db_user = $db_user;
$this->db_pwd = $db_pwd;
$this->db_name = $db_name;
$this->db_charset = $db_chaeset;
$this->db_pconn = $db_pconn;
$this->結果 = '';
$this->debug = $debug;
$this->initConnect();
}

パブリック関数 initConnect() {
if ($this->db_pconn) {
$this->conn = @mysql_pconnect($this->db_host, $this->db_user, $this->db_pwd);
} その他 {
$this->conn = @mysql_connect($this->db_host, $this->db_user, $this->db_pwd);
}
if ($this->conn) {
$this->query("SET NAMES " . $this->db_charset);
} その他 {
$this->msg = "データベース接続エラー、エラー番号:" . mysql_errno() . mysql_error();
}
$this->selectDb($this->db_name);
}

パブリック関数 selectDb($dbname) {
if ($dbname == "") {
$this->db_name = $dbname;
}
if (!mysql_select_db($this->db_name, $this->conn)) {
$this->msg = "データベースが利用できません";
}
}

パブリック関数クエリ($sql, $debug = false) {
if (!$debug) {
$this->result = @mysql_query($sql, $this->conn);
} その他 {

}
if ($this->result == false) {
$this->msg = "SQL 実行エラー、エラー番号:" . mysql_errno() . mysql_error();
}
// var_dump($this->result);
}

パブリック関数 select($tableName, $columnName = "*", $where = "") {
$sql = "SELECT" 。 $columnName 。 " から " 。 $テーブル名;
$sql .= $where ? " どこ " 。 $where : null;
$this->クエリ($sql);
}

パブリック関数 findAll($tableName) {
$sql = "SELECT * FROM $tableName";
$this->クエリ($sql);
}

パブリック関数 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);
$sql = "$tableName($columnName) VALUES($columnValue) に挿入";
$this->クエリ($sql);
if($this->result){
$this->msg = "データの挿入が成功しました。新しい挿入の ID は次のとおりです。" . mysql_insert_id($this->conn);
}
}

パブリック関数 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->クエリ($sql);
if($this->result){
$this->msg = "データ更新成功。影響を受けた実行数：" . mysql_affected_rows($this->conn);
}
}

パブリック関数 delete($tableName, $where = ""){
$sql = "$tableName から削除";
$sql .= $where ? " WHERE $where" : null;
$this->クエリ($sql);
if($this->result){
$this->msg = "データ削除成功。影響を受ける行数：" . mysql_affected_rows($this->conn);
}
}

パブリック関数 fetchArray($result_type = MYSQL_BOTH){
$resultArray = array();
$i = 0;
while($result = mysql_fetch_array($this->result, $result_type)){
$resultArray[$i] = $result;
$i++;
}
$resultArray を返す;
}

// パブリック関数 fetchObject(){
// mysql_fetch_object($this->result);
を返します // }

パブリック関数 printMessage(){
$this->msg; を返す
}

パブリック関数 freeResult(){
@mysql_free_result($this->result);
}

パブリック関数 __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");

//查
を選択 $db->select("ユーザー", "*", "ユーザー名 = 'システム'");
$result = $db->fetchArray(MYSQL_ASSOC);
print_r($result);
dump($db->printMessage());

//增
を挿入 //$userInfo = array('username'=>'system', 'password' => md5("system"));
//$db->insert("user", $userInfo);
//dump($db->printMessage());

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

//削除删
//$db->delete("user", "id = 1");
//dump($db->printMessage());

//findAll 查询全部
$db->findAll("ユーザー");
$result = $db->fetchArray();

ダンプ($result);

 

http://www.bkjia.com/PHPjc/477577.htmlwww.bkjia.comtru​​ehttp://www.bkjia.com/PHPjc/477577.html技術記事データベース操作の基本的な流れは次のとおりです: 1、接続データベース库サービス 2、選択データベース库 3、実行 SQL 句 4、処理結果集 5、打印操作情報 その中で使用される関連関数の数は次のとおりです...