基于php和mysql的简单的dao类

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