源码网商城,靠谱的源码在线交易网站 我的订单 购物车 帮助

源码网商城

基于php和mysql的简单的dao类实现crud操作功能

  • 时间:2021-07-05 02:36 编辑: 来源: 阅读:
  • 扫一扫,手机访问
摘要:基于php和mysql的简单的dao类实现crud操作功能
[u]复制代码[/u] 代码如下:
<?php     //require_once('FirePHPCore/FirePHP.class.php');     //$firephp = FirePHP::getInstance(true); // debugger in firefox     class SimpleDao {         private $_table = null;         private static $_con = null;         public function SimpleDao() {             if ($this->_con == null) {                 $this->_con = @mysql_connect("localhost", "root", "123456");                 if ($this->_con == FALSE) {                     echo("connect to db server failed.");                     $this->_con = null;                     return;                 }                 //$firephp->log("new DAO object");                 @mysql_select_db("swan", $this->_con);             }         }         public function table($tablename) {             $this->_table = $tablename;             return $this;         }         public function query($sql) {             $result = @mysql_query($sql);             $ret = [];             if ($result) {                 while ($row = mysql_fetch_array($result)) {                     $ret[] = $row;                 }             }             return $ret;         }         public function get($where = null) {             $sql = "select * from ".$this->_table;             $sql = $sql.$this->_getWhereString($where);             //echo "[get]".$sql."<br>";             return $this->query($sql);         }         public function insert($params) {             if ($params == null || !is_array($params)) {                 return -1;             }             $keys = $this->_getParamKeyString($params);             $vals = $this->_getParamValString($params);             $sql = "insert into ".$this->_table."(".$keys.") values(".$vals.")";             //echo "[insert]".$sql."<br>";             $result = @mysql_query($sql);             if (! $result) {                 return -1;             }             return @mysql_insert_id();         }         public function update($params, $where = null) {             if ($params == null || !is_array($params)) {                 return -1;             }             $upvals = $this->_getUpdateString($params);             $wheres = $this->_getWhereString($where);             $sql = "update ".$this->_table." set ".$upvals." ".$wheres;             //echo "[update]".$sql."<br>";             $result = @mysql_query($sql);             if (! $result) {                 return -1;             }             return @mysql_affected_rows();         }         public function delete($where) {             $wheres = $this->_getWhereString($where);             $sql = "delete from ".$this->_table.$wheres;             //echo "[delete]".$sql."<br>";             $result = @mysql_query($sql);             if (! $result) {                 return -1;             }             return @mysql_affected_rows();         }         protected function _getParamKeyString($params) {             $keys = array_keys($params);             return implode(",", $keys);         }         protected function _getParamValString($params) {             $vals = array_values($params);             return "'".implode("','", $vals)."'";         }         private function _getUpdateString($params) {             //echo "_getUpdateString";             $sql = "";             if (is_array($params)) {                 $sql = $this->_getKeyValString($params, ",");             }             return $sql;         }         private function _getWhereString($params) {             //echo "_getWhereString";             $sql = "";             if (is_array($params)) {                 $sql = " where ";                 $where = $this->_getKeyValString($params, " and ");                 $sql = $sql.$where;             }             return $sql;         }         private function _getKeyValString($params, $split) {             $str = "";             if (is_array($params)) {                 $paramArr = array();                 foreach($params as $key=>$val) {                     $valstr = $val;                     if (is_string($val)) {                         $valstr = "'".$val."'";                     }                     $paramArr[] = $key."=".$valstr;                 }                 $str = $str.implode($split, $paramArr);             }             return $str;         }         public function release() {             @mysql_close();         }     }     function T($table) {         return (new SimpleDao())->table($table);     } ?>
  • 全部评论(0)
联系客服
客服电话:
400-000-3129
微信版

扫一扫进微信版
返回顶部