一个非常实用的php数据库pdo操作类(curd操作类)
来源:SegmentFault
时间:2023-01-25 15:14:46 407浏览 收藏
IT行业相对于一般传统行业,发展更新速度更快,一旦停止了学习,很快就会被行业所淘汰。所以我们需要踏踏实实的不断学习,精进自己的技术,尤其是初学者。今天golang学习网给大家整理了《一个非常实用的php数据库pdo操作类(curd操作类)》,聊聊MySQL、数据库、PHP、pdo、class,我们一起来看看吧!
操作类文件
db.class.php
pdo = new PDO("mysql:host=".$config['db_host'].";port=".$config['db_port'].";dbname=".$config['db_name'],$config['db_user'], $config['db_pass']); }catch(PDOException $e){ // 数据库无法链接,如果您是第一次使用,请先配置数据库! exit($e->getMessage()); } $this->prefix = $config['db_prefix']; $this->pdo->exec("SET NAMES UTF8"); } // 配置表信息 public function set_table($table=null,$primary='id'){ if($table==null){ exit('Not found Table');} $this->primary = $primary; $this->table = $this->prefix.$table; return $this; } // 获取数据 public function getData($sql) { if(!$result = $this->query($sql))return array(); if(!$this->Statement->rowCount())return array(); $rows = array(); while($rows[] = $this->Statement->fetch(PDO::FETCH_ASSOC)){} $this->Statement=null; array_pop($rows); return $rows; } // 查询数据条数 public function getCount($conditions){ $where = ''; if(is_array($conditions)){ $join = array(); foreach( $conditions as $key => $value ){ $value = '\''.$value.'\''; $join[] = "{$key} = {$value}"; } $where = "WHERE ".join(" AND ",$join); }else{ if(null != $conditions)$where = "WHERE ".$conditions; } $sql = "SELECT count(*) as Frcount FROM {$this->table} {$where}"; $result = $this->getData($sql); return $result[0]['Frcount']; } // 获取单一字段内容 public function getField($where=null,$fields=null){ if( $record = $this->findAll($where, null, $fields, 1) ){ $res = array_pop($record); return $res[$fields]; }else{ return FALSE; } } // 递增数据 public function goInc($conditions,$field,$vp=1){ $where = ""; if(is_array($conditions)){ $join = array(); foreach( $conditions as $key => $value ){ $value = '\''.$value.'\''; $join[] = "{$key} = {$value}"; } $where = "WHERE ".join(" AND ",$join); }else{ if(null != $conditions)$where = "WHERE ".$conditions; } $values = "{$field} = {$field} + {$vp}"; $sql = "UPDATE {$this->table} SET {$values} {$where}"; return $this->pdo->exec($sql); } // 递减 public function goDec($conditions,$field,$vp=1){ return $this->goInc($conditions,$field,-$vp); } // 修改数据 public function update($conditions,$row) { $where = ""; $row = $this->__prepera_format($row); if(empty($row)){ return FALSE; } if(is_array($conditions)){ $join = array(); foreach( $conditions as $key => $condition ){ $condition = '\''.$condition.'\''; $join[] = "{$key} = {$condition}"; } $where = "WHERE ".join(" AND ",$join); }else{ if(null != $conditions){ $where = "WHERE ".$conditions; } } foreach($row as $key => $value){ $value = '\''.$value.'\''; $vals[] = "{$key} = {$value}"; } $values = join(", ",$vals); $sql = "UPDATE {$this->table} SET {$values} {$where}"; //echo $sql.'
'; $res = $this->pdo->exec($sql); if($res){ return $res; }else{ var_dump($this->pdo->errorInfo()); } } // 查询所有 public function findAll($conditions=null,$order=null,$fields=null,$limit=null) { $where = ''; if(is_array($conditions)){ $join = array(); foreach( $conditions as $key => $value ){ $value = '\''.$value.'\''; $join[] = "{$key} = {$value}"; } $where = "WHERE ".join(" AND ",$join); }else{ if(null != $conditions)$where = "WHERE ".$conditions; } if(is_array($order)){ $where .= ' ORDER BY '; $where .= implode(',', $order); }else{ if($order!=null)$where .= " ORDER BY ".$order; } if(!empty($limit))$where .= " LIMIT {$limit}"; $fields = empty($fields) ? "*" : $fields; $sql = "SELECT {$fields} FROM {$this->table} {$where}"; return $this->getData($sql); } // 查询一条 public function find($where=null,$order=null,$fields=null,$limit=1) { if( $record = $this->findAll($where, $order, $fields, 1) ){ return array_pop($record); }else{ return FALSE; } } // 执行SQL语句并检查是否错误 public function query($sql){ $this->filter[] = $sql; $this->Statement = $this->pdo->query($sql); if ($this->Statement) { return $this; }else{ $msg = $this->pdo->errorInfo(); if($msg[2]) exit('数据库错误:' . $msg[2] . end($this->filter)); } } // 执行SQL语句函数 public function findSql($sql) { return $this->getData($sql); } // 根据条件 (conditions) 删除 public function delete($conditions) { $where = ""; if(is_array($conditions)){ $join = array(); foreach( $conditions as $key => $condition ){ $condition = '\''.$condition.'\''; $join[] = "{$key} = {$condition}"; } $where = "WHERE ( ".join(" AND ",$join). ")"; }else{ if(null != $conditions)$where = "WHERE ( ".$conditions. ")"; } $sql = "DELETE FROM {$this->table} {$where}"; return $this->pdo->exec($sql); } // 新增数据 public function add($row) { if(!is_array($row)){ return FALSE; } $row = $this->__prepera_format($row); if(empty($row)){ return FALSE; } foreach($row as $key => $value){ $cols[] = $key; $vals[] = '\''.$value.'\''; } $col = join(',', $cols); $val = join(',', $vals); $sql = "INSERT INTO {$this->table} ({$col}) VALUES ({$val})"; if( FALSE != $this->pdo->exec($sql) ){ if( $newinserid = $this->pdo->lastInsertId() ){ return $newinserid; }else{ $a=$this->find($row, "{$this->primary} DESC",$this->primary); return array_pop($a); } } return FALSE; } private function __prepera_format($rows) { $stmt = $this->pdo->prepare('DESC '.$this->table); $stmt->execute(); $columns = $stmt->fetchAll(PDO::FETCH_COLUMN); $newcol = array(); foreach( $columns as $col ){ $newcol[$col] = null; } return array_intersect_key($rows,$newcol); } }
实例化类
'localhost', // 数据库地址 'db_port' => 3306, // 默认mysql数据库端口 'db_name' => 'test', // 数据库名字 'db_user' => 'root', // 数据库用户名 'db_pass' => 'root', // 数据库密码 'db_prefix' => '', // 表前缀 ]; // 实例化类 $db = new DB_API($config); // 表名 $article = $db->set_table('article'); // 新增数据 $newdata = ['title'=>'this is a title']; $r = $article->add($newdata); if($r){ echo '新增成功!'; }else{ echo '操作失败!'; } // 查询数据 $where = ['id'=>3]; $find = $article->find($where); //查询一条数据 $find = $article->findAll($where); // 查询多条数据 print_r($find); // 更新数据 $where = ['title'=>'hello world666']; $update = $article->update(['id'=>1],$where); if($update ){ echo '更新成功!'; // 查询并打印 $newdata = $article->find('id=1'); print_r($newdata); }else{ echo '更新失败!'; } // 删除数据 $where = ['id'=>1]; $del = $article->delete($where); if($del){ echo '删除成功!'; }else{ echo '删除失败!'; } // 获取符合条件的记录数 $where = ['author'=>'TANKING']; $count = $article->getCount($where); echo $count; // 执行原生SQL语句 $sql = 'select * from article where id=3'; $lists = $article->findSql($sql); print_r($lists); // 根据条件查询出对应的字段的值 $where = ['id'=>1]; $res = $article->getField($where,'title'); if ($res) { echo $res; }else{ echo "没有数据"; } // 高级查询 // $conditions查询条件 // $order排序方法 // $fields指定字段 // $limit查询条数 $res = $article->findAll($conditions=null,$order='id asc',$fields=null,$limit=null); if ($res) { print_r($res); }else{ print_r("没有数据"); }
Author:TANKING
以上就是《一个非常实用的php数据库pdo操作类(curd操作类)》的详细内容,更多关于mysql的资料请关注golang学习网公众号!
声明:本文转载于:SegmentFault 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
-
499 收藏
-
244 收藏
-
235 收藏
-
157 收藏
-
101 收藏
最新阅读
更多>
-
230 收藏
-
321 收藏
-
260 收藏
-
229 收藏
-
478 收藏
-
427 收藏
课程推荐
更多>
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 立即学习 542次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 立即学习 507次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 立即学习 497次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 立即学习 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 立即学习 484次学习