简单的MYsql操作类
1、连接服务器 2、各类sql动作 <?php class mysql { private $host; //服务器地址 private $name; //用户名称 private $pass; //密码 private $table; //连接数据库教程 private $jiema; //设置解码 private $ztime; //设置服务器的时区 //构造函数 function __construct($host, $name, $pass, $table, $jiema, $ztime) { $this->host = $host; $this->name = $name; $this->pass = $pass; $this->table = $table; $this->jiema = $jiema; $this->ztime = $ztime; $this->connect(); } //数据库连接和设置 function connect() { $link = @mysql_connect($this->host, $this->name, $this->pass) or die("连接服务器失败"); @mysql_select_db($this->table, $link) or die("连接数据失败"); @mysql_query("set names '$this->jiema'"); @date_default_timezone_set("$this->ztime"); } //执行操作 function query($sql) { if (!($query = @mysql_query($sql))) $this->show($sql); return $query; } //显示信息 function show($message = '', $sql = '') { if (!$sql) echo $message; else echo $message . '<br>' . $sql; } //取得数据集的某个值 function result($query, $row, $values) { return @mysql_result($query, $row, $values); } //取得数据集的某个值 function get_values($table, $row, $values) { $query = $this->query("select * from $table"); $returnvalues = mysql_result($query, $row, $values); return $returnvalues; } //取得数据集的行数 function num_rows($query) { return @mysql_num_rows($query); } //循环读取数据 function fetch($query) { return @mysql_fetch_array($query); } //最后一次插入纪录的id值 function insert_id() { return mysql_insert_id(); } //取得数据集中的一行 function fetch_row($query) { return mysql_fetch_row($query); } //插入一条数据 function fn_insert($table, $name, $value) { if ($this->query("insert into $table ($name) values ($value)")) { return true; } else { return false; } } //插入任意数据 function sql_insert($tbname, $postvalues) { foreach ($postvalues as $key => $value) { $postvalue.= "`" . $key . "`" . ","; $sqlvalue.= "'" . $value . "',"; } $sqlfield = mb_substr("$postvalue", 0, -1, 'gbk'); $sqlvalue = mb_substr("$sqlvalue", 0, -1, 'gbk'); if ($this->fn_insert("$tbname", "$sqlfield", "$sqlvalue")) { return true; } else { return false; } } //修改万能数据 function sql_update($table, $postvalues, $wwhere) { foreach ($postvalues as $key => $value) { $sqlfield.= $key . "=" . "'" . $value . "'" . ","; } $sqlfield = mb_substr("$sqlfield", 0, -1, 'gbk'); if ($this->fn_update("$table", "$sqlfield", "$wwhere")) { return true; } else { return false; } } //修改一条数据 function fn_update($table, $value, $wwhere) { if ($this->query("update $table set $value where $wwhere")) { return true; } else { return false; } } //删除一条数据 function sql_delete($table, $wwhere) { if ($this->query("delete from $table where $wwhere")) { return true; } else { return false; } } //关闭数据连接 function close() { return mysql_close(); } //开源代码phprm.com } $db = new mysql($location['host'], $location['hostname'], $location['hostpass'], $location['table'], $location['jiema']
文章链接:http://www.phprm.com/mxdx/fs5395.html
随便收藏,请保留本文地址!