本文实例讲述了PHP基于MysqLI函数封装的数据库连接工具类。分享给大家供大家参考，具体如下：
rush:PHP;">
MysqLi = new MysqLi($host,$username,$password,$database,$port);
}
/**
* 数据查询
* @param $table 数据表
* @param null $field 字段
* @param null $where 条件
* @return mixed 查询结果数目
*/
public function select($table,$field = null,$where = null)
{
$sql = "SELECT * FROM {$table}";
if (!empty($field)) {
$field = '`' . implode('`,`',$field) . '`';
$sql = str_replace('*',$field,$sql);
}
if (!empty($where)) {
$sql = $sql . ' WHERE ' . $where;
}
$this->result = $this->MysqLi->query($sql);
return $this->result->num_rows;
}
/**
* @return mixed 获取全部结果
*/
public function fetchAll()
{
return $this->result->fetch_all(MysqLI_ASSOC);
}
/**
* 插入数据
* @param $table 数据表
* @param $data 数据数组
* @return mixed 插入ID
*/
public function insert($table,$data)
{
foreach ($data as $key => $value) {
$data[$key] = $this->MysqLi->real_escape_string($value);
}
$keys = '`' . implode('`,array_keys($data)) . '`';
$values = '\'' . implode("','",array_values($data)) . '\'';
$sql = "INSERT INTO {$table}( {$keys} )VALUES( {$values} )";
$this->MysqLi->query($sql);
return $this->MysqLi->insert_id;
}
/**
* 更新数据
* @param $table 数据表
* @param $data 数据数组
* @param $where 过滤条件
* @return mixed 受影响记录
*/
public function update($table,$data,$where)
{
foreach ($data as $key => $value) {
$data[$key] = $this->MysqLi->real_escape_string($value);
}
$sets = array();
foreach ($data as $key => $value) {
$kstr = '`' . $key . '`';
$vstr = '\'' . $value . '\'';
array_push($sets,$kstr . '=' . $vstr);
}
$kav = implode(',',$sets);
$sql = "UPDATE {$table} SET {$kav} WHERE {$where}";
$this->MysqLi->query($sql);
return $this->MysqLi->affected_rows;
}
/**
* 删除数据
* @param $table 数据表
* @param $where 过滤条件
* @return mixed 受影响记录
*/
public function delete($table,$where)
{
$sql = "DELETE FROM {$table} WHERE {$where}";
$this->MysqLi->query($sql);
return $this->MysqLi->affected_rows;
}
}
使用方法
rush:PHP;">
'MysqL','host' => 'localhost','username' => 'woider','password' => '3243','database' => 'PHP','port' => '3306'
);
/* 连接数据库 */
$MysqL = new MysqL();
$MysqL->connect($config);
/* 查询数据 */
//1、查询所有数据
$table = 'MysqLi';//数据表
$num = $MysqL->select($table);
echo '共查询到' . $num . '条数据';
print_r($MysqL->fetchAll());
//2、查询部分数据
$field = array('username','password'); //过滤字段
$where = 'id % 2 =0'; //过滤条件
$MysqL->select($table,$where);
print_r($MysqL->fetchAll());
/* 插入数据 */
$table = 'MysqLi';//数据表
$data = array( //数据数组
'username' => 'admin','password' => sha1('admin')
);
$id = $MysqL->insert($table,$data);
echo '插入记录的ID为' . $id;
/* 修改数据 */
$table = 'MysqLi';//数据表
$data = array(
'password' => sha1('nimda')
);
$where = 'id = 44';
$rows = $MysqL->update($table,$where);
echo '受影响的记录数量为' . $rows . '条';
/* 删除数据 */
$table = 'MysqLi';
$where = 'id = 45';
$rows = $MysqL->delete($table,$where);
echo '已删除' . $rows . '条数据';
更多关于PHP相关内容感兴趣的读者可查看本站专题：《》、《》、《》、《》、《》、《》及《PHP常见数据库操作技巧汇总》
希望本文所述对大家PHP程序设计有所帮助。
