简体中文（ZH-CN）English（EN）繁体中文（ZH-TW）
Home
Article
Q&A
Course
Topic
Download
Game
Dictionary

Home  >  Article  >  Backend Development  >  基于php和mysql的简单的dao类

基于php和mysql的简单的dao类

WBOY
WBOYOriginal
2016-07-23 08:55:00810browse
SimpleDao.class
  1. //require_once('FirePHPCore/FirePHP.class.php');
  2. //$firephp = FirePHP::getInstance(true); // debugger in firefox
  3. class SimpleDao {
  4. private $_table = null;
  5. private static $_con = null;
  7. public function SimpleDao() {
  8. if ($this->_con == null) {
  9. $this->_con = @mysql_connect("localhost", "root", "123456");
  10. if ($this->_con == FALSE) {
  11. echo("connect to db server failed.");
  12. $this->_con = null;
  13. return;
  14. }
  15. //$firephp->log("new DAO object");
  16. @mysql_select_db("swan", $this->_con);
  17. }
  18. }
  20. public function table($tablename) {
  21. $this->_table = $tablename;
  22. return $this;
  23. }
  25. public function query($sql) {
  26. $result = @mysql_query($sql);
  27. $ret = [];
  28. if ($result) {
  29. while ($row = mysql_fetch_array($result)) {
  30. $ret[] = $row;
  31. }
  32. }
  33. return $ret;
  34. }
  36. public function get($where = null) {
  37. $sql = "select * from ".$this->_table;
  38. //$sql = $sql.$this->_getWhereString($where);
  39. //echo "[get]".$sql."
    ";
  40. return $this->query($sql);
  41. }
  43. public function insert($params) {
  44. if ($params == null || !is_array($params)) {
  45. return -1;
  46. }
  47. $keys = $this->_getParamKeyString($params);
  48. $vals = $this->_getParamValString($params);
  49. $sql = "insert into ".$this->_table."(".$keys.") values(".$vals.")";
  50. //echo "[insert]".$sql."
    ";
  51. $result = @mysql_query($sql);
  52. if (! $result) {
  53. return -1;
  54. }
  55. return @mysql_insert_id();
  56. }
  58. public function update($params, $where = null) {
  59. if ($params == null || !is_array($params)) {
  60. return -1;
  61. }
  62. $upvals = $this->_getUpdateString($params);
  63. $wheres = $this->_getWhereString($where);
  64. $sql = "update ".$this->_table." set ".$upvals." ".$wheres;
  65. //echo "[update]".$sql."
    ";
  66. $result = @mysql_query($sql);
  67. if (! $result) {
  68. return -1;
  69. }
  70. return @mysql_affected_rows();
  71. }
  73. public function delete($where) {
  74. $wheres = $this->_getWhereString($where);
  75. $sql = "delete from ".$this->_table.$wheres;
  76. //echo "[delete]".$sql."
    ";
  77. $result = @mysql_query($sql);
  78. if (! $result) {
  79. return -1;
  80. }
  81. return @mysql_affected_rows();
  82. }
  84. protected function _getParamKeyString($params) {
  85. $keys = array_keys($params);
  86. return implode(",", $keys);
  87. }
  89. protected function _getParamValString($params) {
  90. $vals = array_values($params);
  91. return "'".implode("','", $vals)."'";
  92. }
  94. private function _getUpdateString($params) {
  95. //echo "_getUpdateString";
  96. $sql = "";
  97. if (is_array($params)) {
  98. $sql = $this->_getKeyValString($params, ",");
  99. }
  100. return $sql;
  101. }
  103. private function _getWhereString($params) {
  104. //echo "_getWhereString";
  105. $sql = "";
  106. if (is_array($params)) {
  107. $sql = " where ";
  108. $where = $this->_getKeyValString($params, " and ");
  109. $sql = $sql.$where;
  110. }
  111. return $sql;
  112. }
  114. private function _getKeyValString($params, $split) {
  115. $str = "";
  116. if (is_array($params)) {
  117. $paramArr = array();
  118. foreach($params as $key=>$val) {
  119. $valstr = $val;
  120. if (is_string($val)) {
  121. $valstr = "'".$val."'";
  122. }
  123. $paramArr[] = $key."=".$valstr;
  124. }
  125. $str = $str.implode($split, $paramArr);
  126. }
  127. return $str;
  128. }
  130. public function release() {
  131. @mysql_close();
  132. }
  133. }
  135. function T($table) {
  136. return (new SimpleDao())->table($table);
  137. }
  138. ?>
复制代码
使用SimpleDao的代码段
  1. include "test/simpledao.php";
  2. $dao = T("sw_post");
  3. $result = $dao->get();//get all posts
  4. $dao->release();
  5. echo json_encode($result);
  6. ?>
  8. include "test/simpledao.php";
  9. $dao = T("sw_post");
  10. // update title where id=1
  11. $cnt = $dao->update(array("title"=>"Hello REST2"), array("id"=>1));
  12. $dao->release();
  13. echo json_encode(array("count"=>$cnt));
  14. ?>
  16. include "test/simpledao.php";
  17. $dao = T("sw_tag");
  18. // insert new record
  19. $cnt = $dao->insert(array("postid"=>4, "name"=>"测试TAG"));
  20. $dao->release();
  21. echo json_encode(array("count"=>$cnt));
  22. ?>
  24. include "test/simpledao.php";
  25. $dao = T("sw_tag");
  26. // delete from table where name='测试TAG'
  27. $cnt = $dao->delete(array("name"=>"测试TAG"));
  28. $dao->release();
  29. echo json_encode(array("count"=>$cnt));
  30. ?>
复制代码
php, mysql, dao


Statement：
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn
Previous article：PHP实现linux命令tail Next article：PHP 汉字转拼音源码（GB2312类库，大约支持6000个汉字左右）

Related articles

See more