PHP封装了一个DB数据库 mysql 的类

6. // 配置数据库
8. define('DB_HOST', '127.0.0.1'); //服务器地址
10. define('DB_USER', 'root'); //用户名
12. define('DB_PASS', ''); //密码
14. define('DB_DATABASENAME', 'fenxiao'); //数据库
22. class Dbmysql
24. {
28. /*
30. *变量
32. **/
34. private $tablename=""; //表名
36. private $fieldname="*";
38. private $conn;
40. private $where;
42. private $sql;
46. function __construct($tablename)
48. {
50. //生成一个连接
52. $this->conn = mysql_connect(DB_HOST, DB_USER, DB_PASS) or die("connect failed" . mysql_error());
54. //选择数据库
56. mysql_select_db(DB_DATABASENAME, $this->conn);
58. //设置编码格式
60. mysql_query("SET NAMES utf8");
62. //var_dump($conn);
64. $this->tablename=$tablename;
66. }
70. //设置sql语句
72. private function setsql($sql)
74. {
76. $this->sql=$sql;
78. }
82. //设置条件语句
84. public function where($where)
86. {
88. $this->where=" where ".$where;
92. return $this;
94. }
98. //按指定字段
100. public function field($keyword)
102. {
104. $this->fieldname=$keyword;
106. return $this;
108. }
110. //设置连接查询表
112. public function table($table1,$table2,$field,$bool)
114. {
116. $this->tablename="$table1 LEFT JOIN $table2 ON $table1.$field$bool$table2.$field";
118. //print_r($this->tablename);
120. return $this;
122. }
126. //设置多表查询
128. public function addtable($table1,$table2,$field,$bool)
130. {
132. $this->tablename.=" LEFT JOIN $table2 ON $table1.$field$bool$table2.$field";
134. //print_r($this->tablename);
136. return $this;
138. }
142. //设置连接查询表
144. ##SELECT * FROM 【wx_order LEFT JOIN wx_shopcar ON wx_shopcar.oid=wx_order.oid and wx_order.uid=wx_shopcar.uid LEFT JOIN wx_goods ON wx_shopcar.gid=wx_goods.gid】 WHERE wx_order.oid=1 and wx_order.uid=3
146. public function settable($sql)
148. {
150. $this->tablename=$sql;
152. //print_r($this->tablename);
154. return $this;
156. }
160. //查询所有数据库 以数组形式输出
162. public function select()
164. {
166. /**
168. * 查询数据库中所有的数据
170. **/
172. $arr=array();
174. //执行sql语句
176. $result = mysql_query("select ".$this->fieldname." from ".$this->tablename.$this->where, $this->conn);
180. while ($row = mysql_fetch_assoc($result)) {
184. array_push($arr, $row);
186. }
190. return $arr;
192. }
196. //搜索指定字段数据
198. public function find()
200. {
202. //执行sql语句
204. $result = mysql_query("select ".$this->fieldname." from ".$this->tablename.$this->where, $this->conn);
206. $result = mysql_fetch_assoc($result);
208. return $result;
210. }
214. //增加数据到数据库
216. public function add($data)
218. {
220. $keysql='';
222. $valuesql='';
224. foreach ($data as $key => $value) {
226. $keysql.=",`$key`";
228. $valuesql.=",'$value'";
230. }
232. $keysql=substr($keysql, 1);
234. $valuesql=substr($valuesql, 1);
236. $result=mysql_query("insert into `".$this->tablename."` ($keysql) VALUES($valuesql)");
238. $id=mysql_insert_id();
240. //print_r("insert into `".$this->tablename."` ($keysql) VALUES($valuesql)");
242. return $id;
244. }
248. //修改数据库的内容
250. public function save($data)
252. {
254. $keysql='';
256. $valuesql='';
258. foreach ($data as $key => $value) {
260. $keysql.=",`$key`='$value'";
262. }
264. $keysql=substr($keysql, 1);
266. //print_r($keysql);
268. //echo "
     ";
270. $result=mysql_query("UPDATE `".$this->tablename."` SET ".$keysql.$this->where);
272. //print_r("UPDATE `".$this->tablename."` SET ".$keysql.$this->where);
274. return $result;
276. }
280. ##删除数据
282. public function delete()
284. {
286. $result=mysql_query("DELETE FROM $this->tablename $this->where");
288. //print_r("DELETE FROM $this->tablename $this->where");
290. return $result;
292. }
296. }
300. /**
302. * mysql_fetch_row: 返回单列的各字段 [0]=>"111"
304. * mysql_fetch_field: 取得字段信息。[0]=> ['name']=> object
306. * mysql_fetch_array 返回数组资料。 [0]=>"asasds" ['name']=>
308. */
310. ?>

复制代码

装了, PHP, mysql