PHP数据库操作类

1. /*==================================================================*/
2. /* 文件名:BaseLogic.class.php */
3. /* 概要: 数据处理公共类. */
5. class BaseLogic extends MyDB {
6. protected $tabName; //表的名称
7. protected $fieldList; //字段集合
8. protected $messList;
10. //==========================================
11. // 函数: add($postList)
12. // 功能: 添加
13. // 参数: $postList 提交的变量列表
14. // 返回: 刚插入的自增ID
15. //==========================================
16. function add($postList) {
17. $fieldList='';
18. $value='';
19. foreach ($postList as $k=>$v) {
20. if(in_array($k, $this->fieldList)){
21. $fieldList.=$k.",";
22. if (!get_magic_quotes_gpc())
23. $value .= "'".addslashes($v)."',";
24. else
25. $value .= "'".$v."',";
26. }
27. }
29. $fieldList=rtrim($fieldList, ",");
30. $value=rtrim($value, ",");
32. $sql = "INSERT INTO {$this->tabName} (".$fieldList.") VALUES(".$value.")";
33. echo $sql;
34. $result=$this->mysqli->query($sql);
35. if($result && $this->mysqli->affected_rows >0 )
36. return $this->mysqli->insert_id;
37. else
38. return false;
39. }
42. //==========================================
43. // 函数: mod($postList)
44. // 功能: 修改表数据
45. // 参数: $postList 提交的变量列表
46. //==========================================
47. function mod($postList) {
48. $id=$postList["id"];
49. unset($postList["id"]);
50. $value='';
51. foreach ($postList as $k=>$v) {
52. if(in_array($k, $this->fieldList)){
53. if (!get_magic_quotes_gpc())
54. $value .= $k." = '".addslashes($v)."',";
55. else
56. $value .= $k." = '".$v."',";
57. }
58. }
59. $value=rtrim($value, ",");
60. $sql = "UPDATE {$this->tabName} SET {$value} WHERE id={$id}";
61. return $this->mysqli->query($sql);
62. }
64. //==========================================
65. // 函数: del($id)
66. // 功能: 删除
67. // 参数: $id 编号或ID列表数组
68. // 返回: 0 失败 成功为删除的记录数
69. //==========================================
70. function del($id) {
71. if(is_array($id))
72. $tmp = "IN (" . join(",", $id) . ")";
73. else
74. $tmp = "= $id";
76. $sql = "DELETE FROM {$this->tabName} WHERE id " . $tmp ;
77. return $this->mysqli->query($sql);
79. }
82. function get($id) {
83. $sql = "SELECT * FROM {$this->tabName} WHERE id ={$id}";
85. $result=$this->mysqli->query($sql);
87. if($result && $result->num_rows ==1){
88. return $result->fetch_assoc();
89. }else{
90. return false;
91. }
93. }
94. function getMessList(){
95. $message="";
96. if(!empty($this->messList)){
97. foreach($this->messList as $value){
98. $message.=$value."
    ";
99. }
100. }
101. return $message;
102. }
103. }
104. ?>

复制代码