数据库操作类mysql/mysqli/pdo
2023-09-14 08:59:47 时间
PDO,MySQL,MYSQLI的各自不同介绍,PDO,MYSQL,MYSQLI 性能哪个比较好
普通的mysql连接肯定是会被抛弃的 因为每次都要防止sql注入的问题 而且相对来说比较慢
首先， mysqli 连接是永久连接，而mysql是非永久连接 。什么意思呢？ mysql连接每当第二次使用的时候，都会重新打开一个新的进程，而mysqli则只使用同一个进程，这样可以很大程度的减轻服务器端压力。
mysqli是在普通mysql的基础上做的一次优化说实话很成功 预处理方式完全解决了sql注入的问题
但是唯一的不足点 就是只支持mysql数据库当然如果你要是不操作其他的数据库或者 当然这无疑是最好的选择
PDO则是最新出来的一种 连接方式 兼容大部分数据库 也解决了sql注入 但是也有缺点 它只支持php5.1以上的版本不过听说在未来的php6中 只支持这种连接.PDO统一所有数据库抽象层对象接口，mysqli只统一mysql的
简单说，PDO可以实现同样的代码对不同数据库的操作，例如你从mysql迁移到mssql，程序基本不需要改动
而mysqli简单理解未mysql的封装就好 在高负载的情况下.PDO开启长连接能够得到一个相对稳定的负载“值”。但是效率却不是最高的。 mysql最快。mysqli其次。只是mysql和mysqli在高并发、系统高负载的时候。其所承担的负载也是很可观的。PDO则不会。http://hudeyong926.iteye.com/blog/1824869
if (!$dbname) { $this- db = new mysqli(HOST, USER, PASS, DBNAME, PORT); } else { $this- db = new mysqli(HOST, USER, PASS, $dbname, $port); } $this- db- set_charset(CHARSET); if ($this- db- connect_error) { if ($this- throw) { throw new Exception($this- db- connect_error, $this- db- connect_errno); } } } /** * 查询字段 * @param string $field 要查询的字段 * @return Db */ public function field($field) { $this- _query[field] = "SELECT {$field}"; return $this; } /** * 查询的表名 * @param string $table 要查询的表名可以带别名，例如table as tab * @return Db */ public function table($table) { $this- _query[table] = "FROM {$table}"; return $this; } /** * 联合查询 * @param string $join 联合的表名可以带别名，必须加上关联的on语句 * @return Db */ public function join($join) { $this- _query[join][] = $join; return $this; } /** * 条件语句 * @param string $where sql条件语句不需加where关键字 * @return Db */ public function where($where) { $this- _query[where] = "WHERE {$where}"; return $this; } /** * 排序 * @param string $order * @return Db */ public function order($order) { if ($order != ) { $this- _query[order] = "ORDER BY {$order}"; } return $this; } /** * 获取条数 * @param string $limit 格式0,5 * @return Db */ public function limit($limit) { if ($limit != ) { $this- _query[limit] = "LIMIT {$limit}"; } return $this; } /** * 构造sql语句 * @return string 返回sql语句 */ private function buildsql() { $sql = $this- _query[field] . . $this- _query[table]; if (!empty($this- _query[join])) { foreach ($this- _query[join] as $join) { $sql .= " {$join}"; }; } if (isset($this- _query[del])) { $sql = $this- _query[del] . . $this- _query[table]; } if ($this- _query[where] != ) { $sql .= . $this- _query[where]; } if (isset($this- _query[order]) $this- _query[order] != ) { $sql .= . $this- _query[order]; } unset($this- _query); return $sql; } /** * 执行select查询 * @return bool|array 失败返回FALSE，成功返回二维数组 */ public function select() { $sql = $this- buildsql(); return $this- fetchAll($sql); } /** * 获取所有记录数 * * @return int 返回所有记录数 */ public function findNumRows() { $sql = $this- buildsql(); $res = $this- query($sql); return $res- num_rows; } /** * 删除一行记录 * @return boolean */ public function delRow() { $this- _query[del] = "DELETE"; $sql = $this- buildsql(); $res = $this- query($sql); if ($res === FALSE) { return FALSE; } return TRUE; } /** * 检查唯一性 * * @param string $table 表名 * @param string $where 查询条件 * @param string $keyid 自动id * @return boolean 存在返回FALSE,否则返回TRUE */ public function chkUnique($table, $where, $keyid = id) { $sql = "SELECT {$keyid} from {$table} WHERE {$where}"; $num = $this- getNumRows($sql); if ($num 0) { return FALSE; } return TRUE; } /** * 执行select查询 * @return bool|array 失败返回FALSE，成功返回一维数组 */ public function findRow() { $sql = $this- buildsql(); return $this- fetchRow($sql); } /** * 执行sql语句查询 * @param string $sql sql语句 * @return mixed 返回资源结果集或布尔值 */ public function query($sql) { $this- _sql = $sql; $res = $this- db- query($sql); if ($res === FALSE) { if ($this- throw) { throw new Exception("发生错误: 错误信息 {$this- getLastErr()} 相关sql语句 {$this- _sql}", $this- db- errno); } else { return FALSE; } } return $res; } /** * 设置是否抛出sql异常 * @param bool $bool */ public function setThrow($bool = FALSE) { $this- throw = $bool; } /** * 执行sql脚本从文件 * @param file $sqlfile sql脚本文件路径 * @return boolean */ public function buildSqlfile($sqlfile) { $file = file($sqlfile); if ($file === FALSE || empty($file)) { return FALSE; } foreach ($file as $key = $val) { if (preg_match(/^(-|#)/, $val) || trim($val) == ) { continue; } $new[] = $val; } $sqls = split(;, join(, $new)); foreach ($sqls as $sql) { $this- query($sql); } return TRUE; } /** * 获取一条数据 * @param string $sql sql语句 * @return array 一维数组 */ public function fetchRow($sql) { $res = $this- query($sql); $result = @$res- fetch_assoc(); return $result; } /** * 获取多条数据 * @param string $sql * @return array 二维数组 */ public function fetchAll($sql, $key = ) { $res = $this- query($sql); $result = array(); while ($row = $res- fetch_assoc()) { if ($key) { $result [$row[$key]] = $row; } else { $result [] = $row; } } return $result; } /** * 获取所有记录数 * * @param string $sql sql语句 * @return int 返回所有记录数 */ public function getNumRows($sql) { $res = $this- query($sql); return $res- num_rows; } /** * 返回最后查询自动生成的id */ public function getLastId() { return $this- db- insert_id; } /** * 返回最后查询出现的错误信息 */ public function getLastErr() { return $this- db- error; } /** * 获取最后一次执行的sql语句 * * @return string sql */ public function getLastSql() { return $this- _sql; } /** * 锁定表 * @param string $tabname 表名 * @param string $mode 模式 */ public function locktab($tabname, $mode = READ) { $this- query("LOCK TABLE {$tabname} {$mode}"); return $this; } /** * 解锁表 */ public function unlocktab() { $this- query("UNLOCK TABLES"); } /** * 执行锁定查询 */ public function execlockquery() { $sql = $this- buildsql(); } /** * 执行添加记录操作 * @param $data 要增加的数据，参数为数组。数组key为字段值，数组值为数据取值 格式:array(字段名 = * @param $table 数据表 * @return boolean */ public function add($data, $table, $replace = false) { if (!is_array($data) || $table == || count($data) == 0) { return false; } $fields = $values = array(); //遍历记录, 格式化字段名称与值 foreach($data as $key = $val) { $fields[] = "`{$table}`.`{$key}`"; $values[] = is_numeric($val) ? $val : "{$val}"; } $field = join(,, $fields); $value = join(,, $values); unset($fields, $values); $cmd = $replace ? REPLACE INTO : INSERT INTO; $sql = $cmd . ` . $table . `( . $field . ) VALUES ( . $value . ); $this- query($sql); return $this- getLastId(); } /** * 执行更新记录操作 * @param $table 数据表 * @param $data 要更新的数据内容，参数可以为数组也可以为字符串，建议数组。 * 为数组时数组key为字段值，数组值为数据取值 * 为字符串时[例：`name`=phpcms,`hits`=`hits`+1]。 * 为数组时[例: array(name= phpcms,password= 123456)] * 数组可使用array(name= +=1, base= -=1);程序会自动解析为`name` = `name` + 1, `base` = `base` - 1 * * @param $where 更新数据时的条件 * @return boolean */ public function update($table, $data, $where = ) { if ($table == or $where == ) { return false; } $where = WHERE . $where; $field = ; if (is_string($data) $data != ) { $field = $data; } elseif (is_array($data) count($data) 0) { $fields = array(); foreach ($data as $k = $v) { switch (substr($v, 0, 2)) { case +=: $v = substr($v, 2); if (is_numeric($v)) { $fields[] = "`{$k}`=`{$k}` + $v"; } else { continue; } break; case -=: $v = substr($v, 2); if (is_numeric($v)) { $fields[] = "`{$k}`=`{$k}` - $v"; } else { continue; } break; default: $fields[] = "`{$k}`= $v"; } } $field = implode(,, $fields); } else { return false; } $sql = UPDATE ` . $table . ` SET . $field . $where; return $this- query($sql); } /** * 执行删除记录操作 * @param $table 数据表 * @param $where 删除数据条件,不充许为空。 * 如果要清空表，使用empty方法 * @return boolean */ public function delete($table, $where = null) { if ($table == ) { return false; } $sql = DELETE FROM ` . $table . `; if ($where) { $sql .= " WHERE {$where}"; } return $this- query($sql); } /** * 自动提交 * @param BOOL $status 默认false关闭自动提交，设置为true时打开自动提交 */ public function autocommit($status = FALSE) { $this- db- autocommit($status); } /** * 提交事务 */ public function commit() { $this- db- commit(); } /** * 回滚事务 */ public function rollback() { $this- db- rollback(); } public function __destruct() { $this- db- close(); }
MySql生成.Net中Model类的存储过程 最近用Mysql,花时间写了一个过程用来生成EF的model类，有注释，挺方便，用EF类Entity自动生成的没有字段注释。 要用到的函数： DELIMITER $$ DROP FUNCTION IF EXISTS `fun_GetCSTypeF...
相关文章
- 面试过程中Mysql数据库常被问到的问题详解
- mysql group by分组查询后 查询个数详解数据库
- linux下MySql操作常用命令汇总和详解大全数据库
- MySQL精准解析：智能提取数据价值（mysql解析数据）
- 探索MySQL数据库索引的原理（mysql数据库索引原理）
- MySQL数据库：实现高效热备份（mysql数据库热备份）
- 数据库探索服务器MySQL数据库的奥秘（查看服务器mysql）
- 完成MySQL数据库卸载的正确步骤（mysql库卸载）
- MySQL的依赖关系：解析与实践（mysql的依赖关系）
- 一步步指导：yum升级MySQL至最新版本（yum升级mysql）
- 轻松配置Eclipse开发环境使用MySQL（eclipse配置mysql）
- MySQL保护：支持你的系统运行（mysql支持系统）
- MySQL视图的极致操作精髓（mysql视图操作）
- 在阿里云上轻松部署MySQL数据库（阿里云装mysql）
- MySQL备份指南：如何成功备份数据库（mysql如何备份）
- MySQL安装失败：解决常见错误（mysql安装错误）
- 高性能MySQL第3版：挖掘更快的数据库应用潜力（高性能mysql第3版）
- MySQL的int类型宽度影响你的数据库性能了解如何优化（mysql中int型宽度）
- 用CMD快速操作MySQL语句，提升效率（cmd操作mysql语句）
- MySQL日志之三错误日志二进制日志慢查询日志（mysql三个log）
- MySQL数据转换一行变多行（mysql一行转为多行）
- MySQL状态查询的使用技巧（mysql不同状态查询）
- MySQL数据库的三视图简介及用法（mysql三视图）
- 深入探索MySQL和ZF构建全面的数据库应用（mysql zf）