当前位置：Gxlcms > PHP教程 > 基于php和mysql的简单的dao类

基于php和mysql的简单的dao类

时间：2021-07-01 10:21:17 帮助过：13人阅读

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

人气教程排行

本站所有资源全部来源于网络，若本站发布的内容侵害到您的隐私或者利益，请联系我们删除！