PHP数据库表操作的封装类及用法实例详解
更新时间：2016年07月12日 09:13:56 作者：dotcoo
这篇文章主要介绍了PHP数据库表操作的封装类及用法,结合实例形式详细分析了php数据库表操作的封装类定义与具体使用方法,需要的朋友可以参考下
脚本之家 / 编程助手：解决程序员“几乎”所有问题！
脚本之家官方知识库 → 点击立即使用
本文实例讲述了PHP数据库表操作的封装类及用法。分享给大家供大家参考，具体如下：
数据库表结构：
1 2 3 4 5 6 7 8 9 10 11 12 13 14 | CREATE TABLE `test_user` (`id` int(11) NOT NULL AUTO_INCREMENT,`username` varchar(45) NOT NULL,`password` varchar(45) NOT NULL,`nickname` varchar(45) NOT NULL,`r` tinyint(4) NOT NULL,PRIMARY KEY (`id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;CREATE TABLE `test_blog` ( `id` int(11) NOT NULL AUTO_INCREMENT, `user_id` int(11) NOT NULL, `title` varchar(45) NOT NULL, PRIMARY KEY (`id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8; |
设置字符编码：
引入Table类：
设置数据库参数：
1 2 3 4 5 | Table::$__host = '127.0.0.1:3306';Table::$__user = 'root';Table::$__pass = '123456';Table::$__name = 'test';Table::$__charset = 'utf8'; |
创建实体对象：
Table类有三个参数: $table, $pk, $pdo=null
$table: 表名称.
$pk: 主键名称. 不支持联合主键
$pdo: 独立的PDO对象. 一般不需要传
Notice: Table类是表操作的封装,不是Model层的基类,所以不支持表前缀,表前缀应该在Model层实现
插入数据：
1 2 3 4 5 6 7 8 | $user = array( 'username' => "admin1", 'password' => "admin1", 'nickname' => "管理员1", 'r' => mt_rand(0, 5),);echo $userTable->insert($user)->rowCount(), "\n";echo $userTable->lastInsertId(), "\n"; |
批量插入数据：
1 2 3 4 5 | $fields = array('username','password','nickname','r');for ($i=2; $i<=100; $i++) { $rows[] = array("admin$i", "admin$i", "管理员$i", mt_rand(0, 5));}$userTable->batchInsert($fields, $rows); |
查询所有数据：
select方法返回一个PDOStatement对象, fetchAll返回多行, fetch返回单行
field自定义：
where查询：
where and条件：
1 2 | var_dump($userTable->where('id > ?', 6)->where('id in (?)', array(5,7,9)) ->select()->fetchAll()); |
where or条件：
group分组 having过滤：
1 2 | var_dump($userTable->group('r')->having('c between ? and ?', 10, 20) ->select('*, r, count(*) as c')->fetchAll()); |
order排序：
limit 行数：
跳过30行 返回10行
查询单行：
根据主键查询数据：
update更新数据：
1 2 | $user = array( 'username' => 'admin4-1', 'nickname' => '管理员4-1', );echo $userTable->where('id = ?', 4)->update($user)->rowCount(), "\n"; |
replace替换数据：
使用了MySQL的REPLACE语句
1 2 3 4 5 6 7 8 | $user = array( 'id' => 4, 'username' => 'admin4', 'password' => 'admin4', 'nickname' => '管理员4', 'r' => mt_rand(0, 5),);echo $userTable->replace($user)->rowCount(), "\n"; |
删除数据：
分页查询
第2页, 每页10行数据：
分页查询的总行数：
1 2 3 | $userTable->where('r=?', 3)->order('id desc')->page(2, 10) ->select()->fetchAll();echo $userTable->count(), "\n"; |
复杂查询：
1 2 3 | var_dump($userTable->where('id > ?', 1)->where('id < ?', 100) ->group('r')->having('c between ? and ?', 1, 100)->having('c > ?', 1) ->order('c desc')->page(2, 3)->select('*, count(*) as c')->fetchAll()); |
自增：
1 2 3 4 5 6 7 | $id = 2;// 加一var_dump($userTable->where('id = ?', $id)->plus('r')->find($id));// 减一var_dump($userTable->where('id = ?', $id)->plus('r', -1)->find($id));// 多列var_dump($userTable->where('id = ?', $id)->plus('r', 1, 'r', -1)->find($id)); |
自增,并获得自增后的值：
1 2 3 4 5 | $id = 2;// 加一echo $userTable->where('id = ?', $id)->incr('r'), "\n";// 减一echo $userTable->where('id = ?', $id)->incr('r', -1), "\n"; |
save 保存修改：
判断数据中是否存在主键字段,如果存在主键字段就update数据,反之insert数据
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 | // 修改$user = array( 'id' => 3, 'nickname' => '管理员3-3',);echo $userTable->save($user)->rowCount(), "\n";var_dump($userTable->find(3));// 添加$user = array( 'username' => 'admin11', 'password' => 'admin11', 'nickname' => '管理员11', 'r' => mt_rand(0, 5),);echo $userTable->save($user)->rowCount(), "\n";$id = $userTable->lastInsertId();var_dump($userTable->find($id)); |
生成外表测试数据：
1 2 3 4 5 6 7 8 9 10 11 12 | $users = $userTable->select('id')->fetchAll();$id = 0;foreach ($users as $user) { for ($i=0; $i<10; $i++) { $id++; $blog = array( 'user_id' => $user['id'], 'title' => "blog$id", ); $blogTable->insert($blog); }} |
Table类不支持JOIN查询
需要的朋友可以手写sql语句,使用query方法来执行.或者自己修改Table类来支持JOIN
获取外表数据：
1 2 3 4 5 6 7 8 9 10 11 12 | $blogs = $blogTable->where('id in (?)', array(1,12,23,34,56,67,78,89,90,101)) ->select()->fetchAll();// 获取外表数据 key为外表id value为外表行数据var_dump($userTable->foreignKey($blogs, 'user_id') ->fetchAll(PDO::FETCH_UNIQUE));var_dump($userTable->foreignKey($blogs, 'user_id', '*,id') ->fetchAll(PDO::FETCH_UNIQUE));var_dump($userTable->foreignKey($blogs, 'user_id', 'id,username,nickanem,id') ->fetchAll(PDO::FETCH_UNIQUE));// 获取外表数据 返回键值对数组 key为id value为usernamevar_dump($userTable->foreignKey($blogs, 'user_id', 'id,username') ->fetchAll(PDO::FETCH_KEY_PAIR)); |
PDOStatement::fetchAll 示例：
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 | // 获取映射数据var_dump($userTable->select('*, id')->fetchAll(PDO::FETCH_UNIQUE));// 获取数组var_dump($userTable->select('nickname')->fetchAll(PDO::FETCH_COLUMN));// 获取键值对var_dump($userTable->select('id, nickname')->fetchAll(PDO::FETCH_KEY_PAIR));// 获取数据分组var_dump($userTable->select('r, id, nickname')->fetchAll(PDO::FETCH_GROUP));// 获取数据分组var_dump($userTable->select('r, id')->fetchAll(PDO::FETCH_GROUP|PDO::FETCH_COLUMN));// 获取数据分组var_dump($userTable->select('r, nickname')->fetchAll(PDO::FETCH_GROUP|PDO::FETCH_KEY_PAIR));// 获取对象 指定获取方式，将结果集中的每一行作为一个属性名对应列名的对象返回。var_dump($userTable->select()->fetchAll(PDO::FETCH_OBJ));// 获取对象 指定获取方式，返回一个所请求类的新实例，映射列到类中对应的属性名。// Note: 如果所请求的类中不存在该属性，则调用 __set() 魔术方法var_dump($userTable->select()->fetchAll(PDO::FETCH_CLASS));// 获取对象 指定获取方式，更新一个请求类的现有实例，映射列到类中对应的属性名。var_dump($userTable->select()->fetchAll(PDO::FETCH_INTO));// 获取自定义行var_dump($userTable->select()->fetchAll(PDO::FETCH_FUNC, function($id, $username, $password, $r){ return array('id'=>$id, 'name'=>"$username - $password - $r");}));// 获取单一值var_dump($userTable->select()->fetchAll(PDO::FETCH_FUNC, function($id, $username, $password, $r){ return "$id - $username - $password - $r";})); |
Table类源代码：
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 | <?php/** * @author dotcoo zhao <dotcoo at 163 dot com> *//** * 模型*/class Table { /** * @var PDO */ public static $__pdo = null; // 默认PDO对象 public static $__host = '127.0.0.1'; // 默认主机 public static $__user = 'root'; // 默认账户 public static $__pass = '123456'; // 默认密码 public static $__name = 'test'; // 默认数据库名称 public static $__charset = 'utf8'; // 默认字符集 /** * @var PDO */ public $_pdo = null; // PDO对象 public $_table = null; // 表名 public $_pk = 'id'; // paramry public $_where = array(); // where public $_where_params = array(); // where params public $_count_where = array(); // count where public $_count_where_params = array(); // count where params public $_group = ''; // group public $_having = array(); // having public $_having_params = array(); // having params public $_order = null; // order public $_limit = null; // limit public $_offset = null; // offset public $_for_update = ''; // read lock public $_lock_in_share_model = ''; // write lock /** * Table Construct * @param string $table_name * @param string $pk * @param string $prefix * @param PDO $pdo */ function __construct($table=null, $pk=null, PDO $pdo=null) { $this->_table = isset($table) ? $table : $this->_table; $this->_pk = isset($pk) ? $pk : $this->_pk; $this->_pdo = $pdo; } /** * @return PDO */ public function getPDO() { if (isset($this->_pdo)) { return $this->_pdo; } if (isset(self::$__pdo)) { return self::$__pdo; } $dsn = sprintf("mysql:host=%s;dbname=%s;charset=%s;", self::$__host, self::$__name, self::$__charset); $options = array( PDO::ATTR_PERSISTENT => true, PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC ); return self::$__pdo = new PDO($dsn, self::$__user, self::$__pass, $options); } /** * 执行语句 * @param string $sql * @return PDOStatement */ public function query($sql) { $params = func_get_args(); array_shift($params); return $this->queryParams($sql, $params); } /** * 执行语句 * @param string $sql * @return PDOStatement */ public function queryParams($sql, array $params) { $sqls = explode('?', $sql); $sql_new = array_shift($sqls); $params_new = array(); foreach ($sqls as $i => $sql_item) { if (is_array($params[$i])) { $sql_new .= str_repeat('?,', count($params[$i])-1).'?'.$sql_item; $params_new = array_merge($params_new, $params[$i]); } else { $sql_new .= '?'.$sql_item; $params_new[] = $params[$i]; } } $stmt = $this->getPDO()->prepare($sql_new); foreach ($params_new as $i => $param) { switch (gettype($param)) { case 'integer': $stmt->bindValue($i+1, $param, PDO::PARAM_INT); break; case 'NULL': $stmt->bindValue($i+1, $param, PDO::PARAM_NULL); break; default : $stmt->bindValue($i+1, $param); } }// echo $sql_new, "\n"; var_dump($params_new); // exit(); $stmt->executeResult = $stmt->execute(); $this->reset(); return $stmt; } /** * 查询数据 * @param string $field * @return PDOStatement */ public function select($columns='*') { $params = array_merge($this->_where_params, $this->_having_params); $sql = "SELECT $columns FROM `{$this->_table}`"; $sql .= empty($this->_where) ? '' : ' WHERE '. implode(' AND ', $this->_where); $sql .= empty($this->_group) ? '' : ' GROUP BY '. $this->_group; $sql .= empty($this->_having) ? '' : ' HAVING '. implode(' AND ', $this->_having); $sql .= empty($this->_order) ? '' : ' ORDER BY '. $this->_order; if (isset($this->_limit)) { $sql .= ' LIMIT ?'; $params[] = $this->_limit; if (isset($this->_offset)) { $sql .= ' OFFSET ?'; $params[] = $this->_offset; } } $sql .= $this->_for_update; $sql .= $this->_lock_in_share_model; $this->_count_where = $this->_where; $this->_count_where_params = $this->_where_params; return $this->queryParams($sql, $params); } /** * 添加数据 * @param array $data * @return PDOStatement */ public function insert(array $data) { $sql = "INSERT `{$this->_table}` SET"; $params = array(); foreach ($data as $col=>$val) { $sql .= " `$col` = ?,"; $params[] = $val; } $sql{strlen($sql)-1} = ' '; return $this->queryParams($sql, $params); } /** * 批量插入数据 * @param array $names * @param array $rows * @param number $batch * @return Table */ public function batchInsert(array $fields, array $rows, $batch=1000) { $i = 0; $sql = "INSERT `{$this->_table}` (`".implode('`, `', $fields)."`) VALUES "; foreach ($rows as $row) { $i++; $sql .= "('".implode("','", array_map('addslashes', $row))."'),"; if ($i >= $batch) { $sql{strlen($sql)-1} = ' '; $this->query($sql); $i = 0; $sql = "INSERT `{$this->_table}` (`".implode('`, `', $fields)."`) VALUES "; } } if ($i > 0) { $sql{strlen($sql)-1} = ' '; $this->query($sql); } return $this; } /** * 更新数据 * @param array $data * @return PDOStatement */ public function update(array $data) { $sql = "UPDATE `{$this->_table}` SET"; $params = array(); foreach ($data as $col=>$val) { $sql .= " `$col` = ?,"; $params[] = $val; } $sql{strlen($sql)-1} = ' '; $sql .= empty($this->_where) ? '' : 'WHERE '. implode(' AND ', $this->_where); $params = array_merge($params, $this->_where_params); return $this->queryParams($sql, $params); } /** * 替换数据 * @param array $data * @return PDOStatement */ public function replace(array $data) { $sql = "REPLACE `{$this->_table}` SET"; $params = array(); foreach ($data as $col=>$val) { $sql .= " `$col` = ?,"; $params[] = $val; } $sql{strlen($sql)-1} = ' '; $sql .= empty($this->_where) ? '' : 'WHERE '. implode(' AND ', $this->_where); $params = array_merge($params, $this->_where_params); return $this->queryParams($sql, $params); } /** * 删除数据 * @return PDOStatement */ public function delete() { $sql = "DELETE FROM `{$this->_table}`"; $sql .= empty($this->_where) ? '' : ' WHERE '. implode(' AND ', $this->_where); return $this->queryParams($sql, $this->_where_params); } /** * 重置所有 * @return Table */ public function reset() { $this->_where = array(); $this->_where_params = array(); $this->_group = null; $this->_having = array(); $this->_having_params = array(); $this->_order = null; $this->_limit = null; $this->_offset = null; $this->_for_update = ''; $this->_lock_in_share_model = ''; return $this; } /** * where查询条件 * @param string $format * @return Table */ public function where($format) { $args = func_get_args(); array_shift($args); $this->_where[] = $format; $this->_where_params = array_merge($this->_where_params, $args); return $this; } /** * group分组 * @param string $columns * @return Table */ public function group($columns) { $this->_group = $columns; return $this; } /** * having过滤条件 * @param string $format * @return Table */ public function having($format) { $args = func_get_args(); array_shift($args); $this->_having[] = $format; $this->_having_params = array_merge($this->_having_params, $args); return $this; } /** * order排序 * @param string $columns * @return Table */ public function order($order) { $this->_order = $order; return $this; } /** * limit数据偏移 * @param number $offset * @param number $limit * @return Table */ public function limitOffset($limit, $offset=null) { $this->_limit = $limit; $this->_offset = $offset; return $this; } /** * 独占锁，不可读不可写 * @return Table */ public function forUpdate() { $this->forUpdate = ' FOR UPDATE'; return $this; } /** * 共享锁，可读不可写 * @return Table */ public function lockInShareMode() { $this->_lock_in_share_model = ' LOCK IN SHARE MODE'; return $this; } /** * 事务开始 * @return bool */ public function begin() { return $this->getPDO()->beginTransaction(); } /** * 事务提交 * @return bool */ public function commit() { return $this->getPDO()->commit(); } /** * 事务回滚 * @return bool */ public function rollBack() { return $this->getPDO()->rollBack(); } /** * page分页 * @param number $page * @param number $pagesize * @return Table */ public function page($page, $pagesize = 15) { $this->_limit = $pagesize; $this->_offset = ($page - 1) * $pagesize; return $this; } /** * 获取自增ID * @return int */ public function lastInsertId() { return $this->getPDO()->lastInsertId(); } /** * 获取符合条件的行数 * @return int */ public function count() { $sql = "SELECT count(*) FROM `{$this->_table}`"; $sql .= empty($this->_count_where) ? '' : ' WHERE '. implode(' AND ', $this->_count_where); return $this->queryParams($sql, $this->_count_where_params)->fetchColumn(); } /** * 将选中行的指定字段加一 * @param string $col * @param number $val * @return Table */ public function plus($col, $val = 1) { $sets = array("`$col` = `$col` + $val"); $args = array_slice(func_get_args(), 2); while (count($args) > 1) { $col = array_shift($args); $val = array_shift($args); $sets[] = "`$col` = `$col` + $val"; } $sql = "UPDATE `{$this->_table}` SET ".implode(', ', $sets); $sql .= empty($this->_where) ? '' : ' WHERE '. implode(' AND ', $this->_where); $params = array_merge(array($val), $this->_where_params); $this->queryParams($sql, $params); return $this; } /** * 将选中行的指定字段加一 * @param string $col * @param number $val * @return int */ public function incr($col, $val = 1) { $sql = "UPDATE `{$this->_table}` SET `$col` = last_insert_id(`$col` + ?)"; $sql .= empty($this->_where) ? '' : ' WHERE '. implode(' AND ', $this->_where); $params = array_merge(array($val), $this->_where_params); $this->queryParams($sql, $params); return $this->getPDO()->lastInsertId(); } /** * 根据主键查找行 * @param number $id * @return array */ public function find($id) { return $this->where("`{$this->_pk}` = ?", $id)->select()->fetch(); } /** * 保存数据,自动判断是新增还是更新 * @param array $data * @return PDOStatement */ public function save(array $data) { if (array_key_exists($this->_pk, $data)) { $pk_val = $data[$this->_pk]; unset($data[$this->_pk]); return $this->where("`{$this->_pk}` = ?", $pk_val)->update($data); } else { return $this->insert($data); } } /** * 获取外键数据 * @param array $rows * @param string $fkey * @param string $field * @param string $key * @return PDOStatement */ public function foreignKey(array $rows, $fkey, $field='*') { $ids = array(); foreach($rows as $row) { $ids[] = $row[$fkey]; }// $ids = array_column($rows, $fkey); if (empty($ids)) { return new PDOStatement(); } return $this->where("`{$this->_pk}` in (?)", $ids)->select($field); }} |
github地址：
https://github.com/dotcoo/php/blob/master/Table/Table.php
更多关于PHP相关内容感兴趣的读者可查看本站专题：《PHP+MongoDB数据库操作技巧大全》、《PHP基于pdo操作数据库技巧总结》、《php面向对象程序设计入门教程》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》
希望本文所述对大家PHP程序设计有所帮助。
微信公众号搜索 “ 脚本之家 ” ，选择关注
程序猿的那些事、送书等活动等着你
相关文章
这篇文章主要介绍了PHP实现的各种进制相互转换功能小工具,涉及php常见的二进制、八进制、十六进制等相互转换操作实现技巧,需要的朋友可以参考下2018-03-03
下面小编就为大家带来一篇基于php编程规范(详解)。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-08-08
php函数之子字符串替换 str_replace
php函数str_replace: 返回一个字符串或者数组。该字符串或数组是将 subject 中全部的 search 都被 replace 替换之后的结果。2011-03-03
整理的非常详细，推荐给大家，留着以后方便查询使用2013-07-07
PHP中cookies使用指南...2007-03-03
这篇文章主要介绍了PHP重载的相关知识，帮助大家更好的理解和复习php，感兴趣的朋友可以了解下2020-09-09
php获取服务器信息的一段代码，包括获取mysql数据库版本信息、GD库信息、php上传相关信息等。有需要的朋友，可以参考下2013-02-02
在本篇文章里小编给大家整理了关于Laravel向公共模板赋值方法以及相关知识点总结，有兴趣的朋友们学习下。2019-06-06
Laravel框架中队列和工作(Queues、Jobs)操作实例详解
这篇文章主要介绍了Laravel框架中队列和工作(Queues、Jobs)操作实例详解,需要的朋友可以参考下2020-04-04
这篇文章主要介绍了PHP实现二叉树的深度优先与广度优先遍历方法,涉及php针对二叉树进行遍历的相关技巧,具有一定参考借鉴价值,需要的朋友可以参考下2015-09-09
最新评论