自己写的MySQL数据库操作类

自己写的MySQL数据库操作类自己练练手，写一个一个功能比较简单的MySQL数据库操作类 array( /数据库配置 DB_HOST=, /服务器地址 DB_NAME = tmp, / 数据库名 DB_USER = root, / 用户名 DB_PWD = , / 密码 DB_ENCODE=utf8,/编码 DB_PREFIX = dmtx_ / 数据库表前缀 ); */class M private $link; /数据库连接 private $table; /表名 private $prefix; /表前缀 private $db_config; /数据库配置 /* * 参数:表名 数据库配置数组 或 数据库配置文件路径 * param $table * param string $db_config_arr_path */ function _construct($table, $db_config_arr_path = config.php) if (is_array($db_config_arr_path) $this-db_config = $db_config_arr_path; else $this-db_config = require($db_config_arr_path); $this-conn(); $this-table = $this-prefix . $table; /* * 连接数据库 */ private function conn() $db_config = $this-db_config; $host = $db_configDB_CONFIGDB_HOST; $user = $db_configDB_CONFIGDB_USER; $pwd = $db_configDB_CONFIGDB_PWD; $db_name = $db_configDB_CONFIGDB_NAME; $db_encode = $db_configDB_CONFIGDB_ENCODE; $this-prefix = $db_configDB_CONFIGDB_PREFIX; $this-link = mysql_connect($host, $user, $pwd) or die(数据库服务器连接错误: . mysql_error(); mysql_select_db($db_name) or die(数据库连接错误: . mysql_error(); mysql_query(set names $db_encode); /* * 数据查询 * 参数:sql条件 查询字段 使用的sql函数名 * param string $where * param string $field * param string $fun * return array * 返回值:结果集 或 结果(出错返回空字符串) */ public function select($where = 1, $field = *, $fun = ) $rarr = array(); if (empty($fun) $sqlStr = select $field from $this-table where $where; $rt = mysql_query($sqlStr, $this-link); while ($rt & $arr = mysql_fetch_assoc($rt) array_push($rarr, $arr); else $sqlStr = select $fun($field) as rt from $this-table where $where; $rt = mysql_query($sqlStr, $this-link); if ($rt) $arr = mysql_fetch_assoc($rt); $rarr = $arrrt; else $rarr = ; return $rarr; /* * 数据更新 * 参数:sql条件 要更新的数据(字符串 或 关联数组) * param $where * param $data * return bool * 返回值:语句执行成功或失败,执行成功并不意味着对数据库做出了影响 */ public function update($where, $data) $ddata = ; if (is_array($data) while (list($k, $v) = each($data) if (empty($ddata) $ddata = $k=$v; else $ddata .= ,$k=$v; else $ddata = $data; $sqlStr = update $this-table set $ddata where $where; return mysql_query($sqlStr); /* * 数据添加 * 参数:数据(数组 或 关联数组 或 字符串) * param $data * return int * 返回值:插入的数据的ID 或者 0 */ public function insert($data) $field = ; $idata = ; if (is_array($data) & array_keys($data) != range(0, count($data) - 1) /关联数组 while (list($k, $v) = each($data) if (empty($field) $field = $k; $idata = $v; else $field .= ,$k; $idata .= ,$v; $sqlStr = insert into $this-table($field) values ($idata); else /非关联数组 或字符串 if (is_array($data) while (list($k, $v) = each($data) if (empty($idata) $idata = $v; else $idata .= ,$v; else /为字符串 $idata = $data; $lStr = insert into $this-table values ($idata); if(mysql_query($sqlStr,$this-link) return mysql_insert_id($this-link); return 0; /* * 数据删除 * 参数:sql条件 * param $where * return bool */ public function delete($where) $sqlStr = delete from $this-table where $where; return mysql_query($sqlStr); /* * 关闭MySQL连接 * return bool */ public function close() return mysql_close($this-link); /$hj = new M(user);/echo $hj-insert(NULL,,cde);/$arr = $hj-select();/print_r($arr);/echo $hj-update(id3,array(email=bnc.cc);insert(array(NULL,1,xxx);echo $hj-insert(array(email=12,password=cccc);echo $hj-insert(NULL,123,cde);/查/查看所有数据$arr = $hj-select();print_r($arr);/查看id大于3且id小于6 的id 和email 字段 的所有数据$arr = $hj-select(id3 an