mysqli

mysql.php

<?php
require('common_function.php');

$db_host='127.0.0.1';
$db_database='easytrade1';
$db_username='root';
$db_password='admin';
$conn=mysqli_connect($db_host,$db_username,$db_password);//鏈接到數據庫
if($conn == false){die("could not connect to the database:</br>".mysqli_error($conn));}//診斷鏈接錯誤

mysqli_query($conn, "set names 'utf8'");//編碼轉化

if(!mysqli_select_db($conn, $db_database)){ //選擇數據庫
    die("could not to the database</br>".mysqli_error($conn));
}

//查詢
$query = 'SELECT * FROM table WHERE id = 1';
$select = get_one($query);

//插入
$data = array(
    'id' => 2,
    'content' => 2,
    'date' => time()
);
$insert = insert('table', $data);

//更新
$data = array(
    'content' => 3,
    'date' => time()
);
$update = update('table', $data, 'id=2');

//刪除
$delete = delete('table', 'id=2');

mysqli_close($conn);
?>

 

commo_function.php

<?php
/*
 * 根據條件查詢數據表，並返回所查到的全部記錄
 * @param string $sql 查詢語句
 * @return array $data 所查到的全部記錄
 */
function get_all($sql){
    global $conn;
    $res=mysqli_query($conn, $sql);
    $data=array();
    if($res && mysqli_num_rows($res)){
        while($arr=mysqli_fetch_assoc($res)){
            $data[]=$arr;
        }
    }
    return $data;
}
    
/*
 * 根據條件查詢數據表，並返回所查到的一條記錄
 * @param string $sql 查詢語句
 * @return array $data 所查到的一條記錄
 */
function get_one($sql){
    global $conn;
    $result=mysqli_query($conn, $sql);
    $data=array();
    if($result && mysqli_num_rows($result)>0){
        $data=mysqli_fetch_assoc($result);
    }    
    return $data;
}
/*
 * 向數據表插入記錄，並返回剛插入的記錄的id
 * @param string $table 數據表名
 * @param array $fields 要插入的數據（寫成array形式，每一個key都必須是數據表的字段）
 * @return int 新記錄的id
 */
function insert($table,$fields){
    global $conn;
    $k = '`' . implode('`,`', array_keys($fields)) . '`';
    $v = "'" . implode("','", $fields) . "'";
    $sql = "INSERT INTO `$table` ({$k}) VALUES ({$v})";
    mysqli_query($conn, $sql);
    return mysqli_insert_id($conn);
}

/**
 * 向數據表更新一些記錄，並返回所影響的記錄行數
 * @param string $table 數據表名
 * @param array $fields 要更新的數據（寫成array形式，每一個key都必須是數據表的字段）
 * @param string $where 查詢條件
 * @return int 所影響的記錄行數
 */
function update($table, $fields, $where = 0){
    global $conn;
    $str='';
    foreach($fields as $k=>$v){
        $str .= "$k='$v',";    
    }
    $str = rtrim($str, ',');
    $sql = "UPDATE $table SET $str  WHERE $where";
    mysqli_query($conn, $sql);
    return mysqli_affected_rows($conn);
}

/**
 * 向數據表刪除一些記錄，並返回所影響的記錄行數
 * @param string $table 數據表的名稱
 * @param string $where 查詢條件
 * @return int 所影響的記錄行數
 */
function delete($table, $where = 0){
    global $conn;
    $sql = "DELETE FROM $table WHERE $where";
    mysqli_query($conn, $sql);
    return mysqli_affected_rows($conn);
}