PHP基于MySQLI函数封装的数据库连接工具类【定义与用法】

php  /  管理员 发布于 7年前   245

本文实例讲述了PHP基于MySQLI函数封装的数据库连接工具类。分享给大家供大家参考，具体如下：

mysql.class.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;  }}

使用方法

 '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, $field, $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, $data, $where);echo '受影响的记录数量为' . $rows . '条';/* 删除数据 */$table = 'mysqli';$where = 'id = 45';$rows = $mysql->delete($table, $where);echo '已删除' . $rows . '条数据';

更多关于PHP相关内容感兴趣的读者可查看本站专题：《php+mysqli数据库程序设计技巧总结》、《php面向对象程序设计入门教程》、《PHP数组(Array)操作技巧大全》、《PHP基本语法入门教程》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》

希望本文所述对大家PHP程序设计有所帮助。

您可能感兴趣的文章:

• PHP7使用ODBC连接SQL Server2008 R2数据库示例【基于thinkPHP5.1框架】
• mysqli扩展无法在PHP7下升级问题的解决
• php操作mysqli(示例代码)
• php使用mysqli向数据库添加数据的方法
• PHP入门教程之使用Mysqli操作数据库的方法(连接,查询,事务回滚等)
• PHP数据库操作之基于Mysqli的数据库操作类库
• php封装的mysqli类完整实例
• PHP mysql与mysqli事务使用说明 分享
• PHP以mysqli方式连接类完整代码实例
• php简单解析mysqli查询结果的方法(2种方法)
• PHP7.0连接DB操作实例分析【基于mysqli】