程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> 網頁編程 >> PHP編程 >> PHP綜合 >> PHP mysqli連接MySQL數據庫

PHP mysqli連接MySQL數據庫

編輯:PHP綜合

1. 開啟PHP的API支持

(1)首先修改您的php.ini的配置文件。
查找下面的語句:
;extension=php_mysqli.dll
將其修改為:
extension=php_mysqli.dll

(2)重新啟動Apache/IIS,即可。

(3)說明:PHP需要單獨的文件來支持這個擴展庫,一般在PHP目錄下的ext目錄裡能找到php_mysqli.dll文件(PHP <= 5.0.2 中是 libmysqli.dll),當然,在PHP的配置文件當中要有正確指向ext的信息(extension_dir)。假若您的PHP沒有這個文件,您可以去下載PHP5的源碼包。另外,這個API擴展,只能在PHP5以上版本使用。其它具體信息,請看下面。

2.PHP mysqli身份證

mysqli是“MySQL, Improved”的縮寫,該擴展僅適用於PHP 5。它能用於MySQL 4.1.1和更高版本。該擴展完全支持MySQL 5.1中采用的鑒定協議,也支持預處理語句和多語句API。此外,該擴展還提供了先進的、面向對象的編程接口。

3. mysqli預定義類

mysqli

表達了 PHP 和 MySQL 數據庫之間的連接。

構造函數

mysqli - 構造一個新的PHP mysqli對象

方法

autocommit - 打開或關閉自動提交的數據庫選項
change_user - 改變指定的數據庫連接的用戶
character_set_name - 返回數據庫連接的默認字符集
close - 關閉一個之前打開的連接
commit - 提交當前事務
connect - 打開一個到 MySQL 數據庫服務器的新連接
debug - 執行排錯操作
dump_debug_info - 取得排錯信息
get_client_info - 返回客戶端版本
get_host_info - 返回連接使用的類型
get_server_info - 返回 MySQL 服務器的版本
get_server_version - 返回 MySQL 服務器的版本
init - 初始化PHP mysqli對象
info - 取得最近執行的查詢的信息
kill - 要求服務器停止一個 mysql 線程
multi_query - 執行多個查詢
more_results - 從目前多查詢執行檢查是否存在更多的結果
next_result - 從目前多查詢執行讀取下一個結果
options - 設置選項
ping - 如果沒有連接,ping服務器連接或重新連接
prepare - 編寫 SQL 查詢
query - 執行查詢
real_connect - 嘗試打開到 MySQL 數據庫服務器的連接
escape_string - 在 SQL 語句中,考慮到當前連接的字符集使用字符串中的特殊字符進行轉義
rollback - 回滾當前事務
select_db - 選擇默認數據庫
set_charset - 設置默認的客戶端字符集
ssl_set - 設置 ssl 參數
stat - 獲取當前的系統狀態
stmt_init- 初始化與 mysqli_stmt_prepare 一起使用的語句
store_result - 轉讓從最後一個查詢的結果集
thread_safe - 返回線程安全是否給定或不
use_result - 從上一次查詢轉移無緩存的結果集

屬性

affected_rows - 獲取前一個 MySQL 操作中受影響的行數
client_info - 以字符串形式返回 MySQL 客戶端版本
client_version - 作為一個整數返回 MySQL 客戶端版本
errno - 返回的錯誤代碼為最新的函數調用
error - 返回最新的函數調用的錯誤字符串
field_count - 返回最新查詢的列的數
host_info - 返回一個字符串,表示使用的連接類型
info - 檢索有關最近執行的查詢的信息
insert_id - 返回最後一個查詢中使用的自動生成 id
protocol_version - 返回使用的 MySQL 協議版本
server_info - 返回一個字符串,表示服務器版本號
server_version - 作為一個整數返回服務器的版本號
sqlstate - 返回一個字符串,包含最後一個錯誤的 SQLSTATE 錯誤代碼
thread_id - 返回當前連接的線程 ID
warning_count - 返回前面的 SQL 語句的執行過程中生成的警告的數目

 4. 基本語法

<?php   
      
    /* Connect to a MySQL server  連接數據庫服務器 */   
    $link = mysqli_connect(   
                'localhost',  /* The host to connect to 連接MySQL地址 */   
                'user',      /* The user to connect as 連接MySQL用戶名 */   
                'password',  /* The password to use 連接MySQL密碼 */   
                'world');    /* The default database to query 連接數據庫名稱*/   
      
    if (!$link) {   
       printf("Can't connect to MySQL Server. Errorcode: %s ", mysqli_connect_error());   
       exit;   
    }   
      
    /* Send a query to the server 向服務器發送查詢請求*/   
    if ($result = mysqli_query($link, 'SELECT Name, Population FROM City ORDER BY Population DESC LIMIT 5')) {   
      
        print("Very large cities are: ");   
      
        /* Fetch the results of the query 返回查詢的結果 */   
        while( $row = mysqli_fetch_assoc($result) ){   
            printf("%s (%s) ", $row['Name'], $row['Population']);   
        }   
      
        /* Destroy the result set and free the memory used for it 結束查詢釋放內存 */   
        mysqli_free_result($result);   
    }   
      
    /* Close the connection 關閉連接*/   
    mysqli_close($link);   
    ?> 

 ————————————————————————————————————————————————————————————

php的mysqli數據庫連接的兩種方法

Mysqli是php5之後才有的功能,沒有開啟擴展的朋友可以打開您的php.ini的配置文件。
查找下面的語句:;extension=php_mysqli.dll將其修改為:extension=php_mysqli.dll即可。
相對於mysql有很多新的特性和優勢
(1)支持本地綁定、准備(prepare)等語法
(2)執行sql語句的錯誤代碼
(3)同時執行多個sql
(4)另外提供了面向對象的調用接口的方法。
下面一一用php實例進行mysqli數據庫連接!
使用方法一:使用傳統的面向過程的方法
php代碼如下:

<?php
$connect = mysqli_connect('localhost','root','','volunteer') or die('Unale to connect');
$sql = "select * from vol_msg";
$result = mysqli_query($connect,$sql);
while($row = mysqli_fetch_row($result)){
    echo $row[0];
}
?>

使用方法二:使用面向對象的方法調用接口(推薦使用)
看php代碼如下:

<?php
//創建對象並打開連接,最後一個參數是選擇的數據庫名稱
$mysqli = new mysqli('localhost','root','','volunteer');
//檢查連接是否成功
if (mysqli_connect_errno()){
    //注意mysqli_connect_error()新特性
    die('Unable to connect!'). mysqli_connect_error();
}
$sql = "select * from vol_msg";
//執行sql語句,完全面向對象的
$result = $mysqli->query($sql);
while($row = $result->fetch_array()){
    echo $row[0];
}
?>

    以上兩個php實例運行的結果完全相同,可以清楚的看到使用mysqli類對象構建數據庫連接的優勢!
插入和修改記錄我就不用講了,只要更改一下sql語句就行。

 

——————————————————————————————————————————————————————————————

PHP以mysqli方式連接類完整代碼實例

本文所述的是一個在PHP中以mysqli方式連接數

據庫的一個數據庫類實例,該數據庫類是從一個PHP的CMS中整理出來的,可實現PHP連接數據庫類,MySQLi版,兼容PHP4,對於有針對性需要的朋友可根據此代碼進行優化和修改。

<?php 
// ==================================================================================================
// Filename: /db/db_mysqli.php
// Note : 連接數據庫類,MySQLi版
// ==================================================================================================
// [類庫sql]
class db_mysqli {
    var $query_count = 0;
    var $host;
    var $user;
    var $pass;
    var $data;
    var $conn;
    var $result;
    var $prefix = "qinggan_"; 
    // 返回結果集類型,默認是數字+字符
    var $rs_type = MYSQLI_ASSOC;
    var $query_times = 0; #[查詢時間]
    var $conn_times = 0; #[連接數據庫時間]
    var $unbuffered = false; 
    // 定義查詢列表
    var $querylist;
    var $debug = false; 
    // [構造函數]
    function __construct($config = array()) {
        $this -> host = $config['host'] ? $config['host'] : 'localhost';
        $this -> port = $config['port'] ? $config['port'] : '3306';
        $this -> user = $config['user'] ? $config['user'] : 'root';
        $this -> pass = $config['pass'] ? $config['pass'] : '';
        $this -> data = $config['data'] ? $config['data'] : '';
        $this -> debug = $config["debug"] ? $config["debug"] : false;
        $this -> prefix = $config['prefix'] ? $config['prefix'] : 'qinggan_';
        if ($this -> data) {
            $ifconnect = $this -> connect($this -> data);
            if (!$ifconnect) {
                $this -> conn = false;
                return false;
            } 
        } 
        return true;
    } 
    // [兼容PHP4]
    function db_mysqli($config = array()) {
        return $this -> __construct($config);
    } 
    // [連接數據庫]
    function connect($database = "") {
        $start_time = $this -> time_used();
        if (!$this -> port) $this -> port = "3306";
        $this -> conn = @mysqli_connect($this -> host, $this -> user, $this -> pass, "", $this -> port) or false;
        if (!$this -> conn) {
            return false;
        } 
        $version = $this -> get_version();
        if ($version > "4.1") {
            mysqli_query($this -> conn, "SET NAMES 'utf8'");
            if ($version > "5.0.1") {
                mysqli_query($this -> conn, "SET sql_mode=''");
            } 
        } 
        $end_time = $this -> time_used();
        $this -> conn_times += round($end_time - $start_time, 5); #[連接數據庫的時間]
        $ifok = $this -> select_db($database);
        return $ifok ? true : false;
    } 
    function select_db($data = "") {
        $database = $data ? $data : $this -> data;
        if (!$database) {
            return false;
        } 
        $this -> data = $database;
        $start_time = $this -> time_used();
        $ifok = mysqli_select_db($this -> conn, $database);
        if (!$ifok) {
            return false;
        } 
        $end_time = $this -> time_used();
        $this -> conn_times += round($end_time - $start_time, 5); #[連接數據庫的時間]
        return true;
    } 
    // [關閉數據庫連接,當您使用持續連接時該功能失效]
    function close() {
        if (is_resource($this -> conn)) {
            return mysqli_close($this -> conn);
        } else {
            return true;
        } 
    } 
    function __destruct() {
        return $this -> close();
    } 
    function set($name, $value) {
        if ($name == "rs_type") {
            $value = strtolower($value) == "num" ? MYSQLI_NUM : MYSQLI_ASSOC;
        } 
        $this -> $name = $value;
    } 
    function query($sql) {
        if (!is_resource($this -> conn)) {
            $this -> connect();
        } else {
            if (!mysql_ping($this -> conn)) {
                $this -> close();
                $this -> connect();
            } 
        } 
        if ($this -> debug) {
            $sqlkey = md5($sql);
            if ($this -> querylist) {
                $qlist = array_keys($this -> querylist);
                if (in_array($sqlkey, $qlist)) {
                    $count = $this -> querylist[$sqlkey]["count"] + 1;
                    $this -> querylist[$sqlkey] = array("sql" => $sql, "count" => $count);
                } else {
                    $this -> querylist[$sqlkey] = array("sql" => $sql, "count" => 1);
                } 
            } else {
                $this -> querylist[$sqlkey] = array("sql" => $sql, "count" => 1);
            } 
        } 
        $start_time = $this -> time_used();
        $func = $this -> unbuffered && function_exists("mysqli_multi_query") ? "mysqli_multi_query" : "mysqli_query";
        $this -> result = @$func($this -> conn, $sql);
        $this -> query_count++;
        $end_time = $this -> time_used();
        $this -> query_times += round($end_time - $start_time, 5); #[查詢時間]
        if (!$this -> result) {
            return false;
        } 
        return $this -> result;
    } 
    function get_all($sql = "", $primary = "") {
        $result = $sql ? $this -> query($sql) : $this -> result;
        if (!$result) {
            return false;
        } 
        $start_time = $this -> time_used();
        $rs = array();
        $is_rs = false;
        while ($rows = mysqli_fetch_array($result, $this -> rs_type)) {
            if ($primary && $rows[$primary]) {
                $rs[$rows[$primary]] = $rows;
            } else {
                $rs[] = $rows;
            } 
            $is_rs = true;
        } 
        $end_time = $this -> time_used();
        $this -> query_times += round($end_time - $start_time, 5); #[查詢時間]
        return ($is_rs ? $rs : false);
    } 
    function get_one($sql = "") {
        $start_time = $this -> time_used();
        $result = $sql ? $this -> query($sql) : $this -> result;
        if (!$result) {
            return false;
        } 
        $rows = mysqli_fetch_array($result, $this -> rs_type);
        $end_time = $this -> time_used();
        $this -> query_times += round($end_time - $start_time, 5); #[查詢時間]
        return $rows;
    } 
    function insert_id($sql = "") {
        if ($sql) {
            $rs = $this -> get_one($sql);
            return $rs;
        } else {
            return mysqli_insert_id($this -> conn);
        } 
    } 
    function insert($sql) {
        $this -> result = $this -> query($sql);
        $id = $this -> insert_id();
        return $id;
    } 
    function all_array($table, $condition = "", $orderby = "") {
        if (!$table) {
            return false;
        } 
        $table = $this -> prefix . $table;
        $sql = "SELECT * FROM " . $table;
        if ($condition && is_array($condition) && count($condition) > 0) {
            $sql_fields = array();
            foreach($condition AS $key => $value) {
                $sql_fields[] = "`" . $key . "`='" . $value . "' ";
            } 
            $sql .= " WHERE " . implode(" AND ", $sql_fields);
        } 
        if ($orderby) {
            $sql .= " ORDER BY " . $orderby;
        } 
        $rslist = $this -> get_all($sql);
        return $rslist;
    } 
    function one_array($table, $condition = "") {
        if (!$table) {
            return false;
        } 
        $table = $this -> prefix . $table;
        $sql = "SELECT * FROM " . $table;
        if ($condition && is_array($condition) && count($condition) > 0) {
            $sql_fields = array();
            foreach($condition AS $key => $value) {
                $sql_fields[] = "`" . $key . "`='" . $value . "' ";
            } 
            $sql .= " WHERE " . implode(" AND ", $sql_fields);
        } 
        $rslist = $this -> get_one($sql);
        return $rslist;
    } 
    // 將數組寫入數據中
    function insert_array($data, $table, $insert_type = "insert") {
        if (!$table || !is_array($data) || !$data) {
            return false;
        } 
        $table = $this -> prefix . $table; //自動增加表前綴
        if ($insert_type == "insert") {
            $sql = "INSERT INTO " . $table;
        } else {
            $sql = "REPLACE INTO " . $table;
        } 
        $sql_fields = array();
        $sql_val = array();
        foreach($data AS $key => $value) {
            $sql_fields[] = "`" . $key . "`";
            $sql_val[] = "'" . $value . "'";
        } 
        $sql .= "(" . (implode(",", $sql_fields)) . ") VALUES(" . (implode(",", $sql_val)) . ")";
        return $this -> insert($sql);
    } 
    // 更新數據
    function update_array($data, $table, $condition) {
        if (!$data || !$table || !$condition || !is_array($data) || !is_array($condition)) {
            return false;
        } 
        $table = $this -> prefix . $table; //自動增加表前綴
        $sql = "UPDATE " . $table . " SET ";
        $sql_fields = array();
        foreach($data AS $key => $value) {
            $sql_fields[] = "`" . $key . "`='" . $value . "'";
        } 
        $sql .= implode(",", $sql_fields);
        $sql_fields = array();
        foreach($condition AS $key => $value) {
            $sql_fields[] = "`" . $key . "`='" . $value . "' ";
        } 
        $sql .= " WHERE " . implode(" AND ", $sql_fields);
        return $this -> query($sql);
    } 
    function count($sql = "") {
        if ($sql) {
            $this -> rs_type = MYSQLI_NUM;
            $this -> query($sql);
            $rs = $this -> get_one();
            $this -> rs_type = MYSQLI_ASSOC;
            return $rs[0];
        } else {
            return mysqli_num_rows($this -> result);
        } 
    } 
    function num_fields($sql = "") {
        if ($sql) {
            $this -> query($sql);
        } 
        return mysqli_num_fields($this -> result);
    } 
    function list_fields($table) {
        $rs = $this -> get_all("SHOW COLUMNS FROM " . $table);
        if (!$rs) {
            return false;
        } 
        foreach($rs AS $key => $value) {
            $rslist[] = $value["Field"];
        } 
        return $rslist;
    } 
    // [顯示表名]
    function list_tables() {
        $rs = $this -> get_all("SHOW TABLES");
        return $rs;
    } 
    function table_name($table_list, $i) {
        return $table_list[$i];
    } 
    function escape_string($char) {
        if (!$char) {
            return false;
        } 
        return mysqli_escape_string($this -> conn, $char);
    } 
    function get_version() {
        return mysqli_get_server_info($this -> conn);
    } 
    function time_used() {
        $time = explode(" ", microtime());
        $used_time = $time[0] + $time[1];
        return $used_time;
    } 
    // Mysql的查詢時間
    function conn_times() {
        return $this -> conn_times + $this -> query_times;
    } 
    // MySQL查詢資料
    function conn_count() {
        return $this -> query_count;
    } 
    // 高效SQL生成查詢,僅適合單表查詢
    function phpok_one($tbl, $condition = "", $fields = "*") {
        $sql = "SELECT " . $fields . " FROM " . $this -> db -> prefix . $tbl;
        if ($condition) {
            $sql .= " WHERE " . $condition;
        } 
        return $this -> get_one($sql);
    } 
    function debug() {
        if (!$this -> querylist || !is_array($this -> querylist) || count($this -> querylist) < 1) {
            return false;
        } 
        $html = '<table cellpadding="0" cellspacing="0" width="100%" bgcolor="#CECECE"><tr><td>';
        $html .= '<table cellpadding="1" cellspacing="1" width="100%">';
        $html .= '<tr><th bgcolor="#EFEFEF" height="30px">SQL</th><th bgcolor="#EFEFEF" width="80px">查詢</th></tr>';
        foreach($this -> querylist AS $key => $value) {
            $html .= '<tr><td bgcolor="#FFFFFF"><div >' . $value['sql'] . '</div></td>';
            $html .= '<td align="center" bgcolor="#FFFFFF"><div >' . $value["count"] . '</div></td></tr>';
        } 
        $html .= "</table>";
        $html .= "</td></tr></table>";
        return $html;
    } 
    function conn_status() {
        if (!$this -> conn) return false;
        return true;
    } 
} 

?>
  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved