mysqli

<?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);
?>

<?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);
}