mysqli的连接,查询,插入,删除,修改

<?php
/**
 * mysqli方法库
 */
// 连接数据库
$db = @mysqli_connect('127.0.0.1', 'root', 'root', 'test');
// 连接出错抛出异常
if (!$db) {
    exit('数据库连接错误' . mysqli_connect_error());
}
// 组装插入语句
//获取时间戳
$add_time = time();
//$sql = "INSERT INTO `director` (`name`,`phone`,`country`,`add_time`) VALUES ('小智','19938543543','城都','{$add_time}');";
//$sql = "UPDATE `director` SET phone='1884444455' where tid=2;";
//$sql = "DELETE FROM `director` WHERE tid=6;";
//$sql = "INSERT INTO `user` (`name`,`phone`,`country`,`birthday`,`weight`,`height`,`add_time`) VALUES ('小智','19938543543','城都','1970-2-21','88','165','{$add_time}');";
$sql = "SELECT * FROM `user` where uid=2;";

$ret = select($db, $sql);

var_dump($ret);

// 关闭数据库
mysqli_close($db);


// 连接方法
function connect($db)
{
    $db = @mysqli_connect($db['host'], $db['user'], $db['pass'], $db['dbname'], 3306);
    // 连接出错抛出异常
    if (!$db) {
        exit('数据库连接错误' . mysqli_connect_error());
    }
}

// 统计数量
function count_number($db, $table, $where)
{
    $sql = "SELECT COUNT(*) AS count_number FROM ".$table." where ".$where;
    $return = mysqli_query($db, $sql);
    $return = mysqli_fetch_assoc($return);
    return $return;
}

// 查询单个数据
function find_one($db, $table, $where)
{
    $sql = "SELECT * FROM ".$table." where ".$where;
    $sql .= 'LIMIT 1';
    $return = mysqli_query($db, $sql);
    $return = mysqli_fetch_assoc($return);
    return $return;
}

// 查询单条数据
function find($db, $table, $where, $order)
{
    $sql = "SELECT * FROM ".$table." where ".$where;
    if ($order) {
        $sql .= 'ORDER BY' . $order;
    }
    $sql .= 'LIMIT 1';
    $return = mysqli_query($db, $sql);
    $return = mysqli_fetch_assoc($return);
    return $return;
}

// 插入方法
function insert($db, $sql)
{
    // 执行插入
    $return = mysqli_query($db, $sql);
    if ($return) {
        $return = mysqli_insert_id($db);
    }
    return $return;
}

// 修改方法
function save($db, $sql)
{
    $return = mysqli_query($db, $sql);
    return $return;
}

// 删除方法
function delete($db, $sql)
{
    $return = mysqli_query($db, $sql);
    return $return;
}

// 查询方法
function select($db, $table, $where, $order, $limit)
{
    $sql = "SELECT * FROM ".$table." where ".$where;
    if ($order) {
        $sql .= 'ORDER BY' . $order;
    }
    if ($limit) {
        $sql .= 'LIMIT' . $limit;
    }
    $return = mysqli_query($db, $sql);
    if ($return) {
        while ($row = mysqli_fetch_assoc($return)) {
            $rows[] = $row;
        }
        // 释放内存
        mysqli_free_result($return);
    }
    return $rows;
}