php+mysql源生连接数据库和增删改查数据

新建一个init.php文件，执行链接数据库。内容如下

header("Content-type: text/html; charset=utf-8");

$con = @mysqli_connect('127.0.0.1', 'root', 'mycjl', 'mycjl') or die('mysql connection failed');

mysqli_query($con, 'set names utf8');

require_once "db.fun.php";

?>

新建一个db.fun.php，写好增删改查方法：

/*手写CMS数据库函数库*/

/**

* 获取所有的记录

* $con 数据库的连接后的资源

* $table 要获取的数据表名

*/

function getAll($con, $table){

$sql = "SELECT * FROM `$table`";

$query = mysqli_query($con, $sql);

$data = array();

while($row = mysqli_fetch_assoc($query)){

$data[] = $row;

}

return $data;

}

function getIdAll($con, $table,$whereid){

$sql = "SELECT * FROM `$table` WHERE $whereid";

$query = mysqli_query($con, $sql);

$data = array();

while($row = mysqli_fetch_assoc($query)){

$data[] = $row;

}

return $data;

}

/**

* 查找指定的一条记录

* $con 连接数据库的资源(句柄)

* $table 要查找的数据表名

* $criteria 条件数组

*/

function getOne($con, $table, $criteria){

$criteriaStr = '';//初始化为空字符串

foreach($criteria as $key=>$value){

$criteriaStr .= "`$key` = '$value' AND ";

}

$criteriaStr = substr($criteriaStr, 0, -5);

$sql = "SELECT * FROM `$table` WHERE $criteriaStr";

$query = mysqli_query($con, $sql);

return mysqli_fetch_assoc($query);

}

/**

* 查找指定ID的记录

* $con 连接数据库的资源(句柄)

* $table 要查找的数据表名

* $id 序号

*/

function getById($con, $table, $id){

return getOne($con, $table, array('id'=>$id));

}

/**

* 添加数据库一条记录

* $con 连接数据库的资源(句柄)

* $table 要添加的数据表名

* $data 要添加的数据数组

*/

function add($con, $table, $data){

$keyStr = '';//初始化

$valueStr = '';

foreach($data as $key=>$value){

$keyStr .= "`$key`, ";//=>$keyStr = $keyStr."`$key`, ";

$valueStr .= "'$value', ";

}

$keyStr = substr($keyStr, 0, -2);

$valueStr = substr($valueStr, 0, -2);

$sql = "INSERT INTO `$table` ($keyStr) VALUE ($valueStr)";

mysqli_query($con, $sql);

return mysqli_insert_id($con);

}

/**

* 删除指定的记录

* $con 连接数据库的资源(句柄)

* $table 要删除的数据表名

* $criteria 条件数组

*/

function delete($con, $table, $criteria){//array('id'=>2, 'name'='dd')

$criteriaStr = '';//初始化为空字符串

foreach($criteria as $key=>$value){

$criteriaStr .= "`$key` = '$value' AND ";

}

$criteriaStr = substr($criteriaStr, 0, -5);

$sql = "DELETE FROM `$table` WHERE $criteriaStr";

return mysqli_query($con, $sql);

}

/**

* 删除指定ID的记录

* $con 连接数据库的资源(句柄)

* $table 要删除的数据表名

* $id 序号

*/

function delById($con, $table, $id){

return delete($con, $table, array('id'=>$id));

}

/**

* 修改一条记录

* $con 连接数据库的资源(句柄)

* $table 要修改的数据表名

* $criteria 条件数组

*/

function update($con, $table, $data){

$valueStr = '';

foreach($data as $key=>$value){

if($key == 'id'){

$criteriaStr = "`$key` = '$value'";

}else{

$valueStr .= "`$key` = '$value', ";

}

}

$valueStr = substr($valueStr, 0, -2);

$sql = "UPDATE `$table` SET $valueStr WHERE $criteriaStr";

return mysqli_query($con, $sql);

}

?>