自己写着玩的，代码没有测试，不过觉得思路不错，如果能够加上部分异常处理的功能，应该比较帅了，支持php4/php5，恩，虽然没有adodb或者pear::db强，不错一般应用应该不错，恩。
喜欢的就自己拿去用吧，自己随便改，呵呵，也欢迎提意见。（注释遵循phpdoc的标准，便于生成手册）
注意：代码未经测试，出现问题可要自己负责哇，呵呵。
<?
//==========================================
// 文件: simpledb.class.php
// 程序: mysql数据库操作类
// 作者: heiyeluren <http://blog.csdn.net/heiyeshuwu
// 时间: 2006-09-20
//==========================================
class simpledb
{
/**
* 连接标识
* @var resource
*/
var $dblink;
/**
* 数据库查询语句
* @var string
*/
var $dbsql;
/**
* 查询结果
* @var resource
*/
var $dbresult;
/**
* 查询记录集
* @var array
*/
var $dbrecord;
/**
* 数据库字符集
* @var string
*/
var $dbcharset = 'gbk';
/**
* 数据库结果集提取方式
* @var int
*/
var $fetchmode = mysql_assoc;
/**
* 日志保存路径
* @var string
*/
var $logpath = '/tmp/mysql_log';
/**
* 是否记录sql查询失败的sql日志,缺省是false
* @var bool
*/
var $islog = false;
/**
* 是否在sql查询出错的时候显示错误并且终止脚本执行,缺省是true
*
* @var bool
*/
var $iserror = true;
//--------------------------
// 内部接口
//--------------------------
/**
* 构造函数
*
* @param string $db_host 连接主机
* @param string $db_user 连接用户
* @param string $db_passwd 数据库密码
* @param string $db_name 数据库
* @param bool $is_pconnect 是否长连接,默认是否
* @return simpledb
*/
function simpledb($db_host, $db_user, $db_passwd, $db_name, $is_pconnect=false){
$this->connect($db_host, $db_user, $db_passwd, $db_name, $is_pconnect);
}
/**
* 连接数据库
*
* @param string $db_host 数据库主机地址,例如:localhost,或者 localhost:3306
* @param string $db_user 连接数据库的用户
* @param string $db_passwd 用户密码
* @param string $db_name 数据库名字
* @param boo $is_pconnect 是否使用长连接
* @return resource 返回连接资源标识符
*/
function connect($db_host, $db_user, $db_passwd, $db_name, $is_pconnect){
if ($is_pconnect){
return $this->dblink = @mysql_pconnect($db_host, $db_user, $db_passwd);
}
$this->dblink = @mysql_connect($db_host, $db_user, $db_passwd);
@mysql_select_db($db_name, $this->dblink);
$mysql_version = $this->getone("select version()");
if ($this->dbcharset!='' && preg_match("/^(5.|4.1)/", $mysql_version)){
$this->query("set names '$this->dbcharset'", $this->dblink);
}
return $this->dblink;
}
/**
* 关闭数据库连接
*
* @return bool 是否成功关闭连接
*/
function disconnect(){
$ret = @mysql_close($this->dblink);
$this->dblink = null;
return $ret;
}
/**
* 设置查询结果返回数据类型
*
* @param int $modetype 设置查询结果返回设置,1为关联索引和数字所有都有,2为使用关联索引,3为使用数字索引
*/
function setfetchmode($modetype){
switch ($modetype){
case 1: //数字索引和关联索引都有
$this->fetchmode = mysql_both;
break;
case 2: //使用关联索引
$this->fetchmode = mysql_assoc;
break;
case 3: //使用数字索引
$this->fetchmode = mysql_num;
break;
default://缺省使用关联索引
$this->fetchmode = mysql_assoc;
}
}
/**
* 设置数据库客户端提取结果集的字符编码
*
* @param string $charset 编码的字符串,比如 utf8,gbk之类的,缺省是gbk
*/
function setcharset($charset){
if ($charset != ''){
$this->dbcharset = $charset;
}
}
/**
* 设置日志存储路径
*
* @param string $log_path 日志路径,该必须是可写的
*/
function setlogpath($log_path){
if ($log_path != ''){
$this->logpath = $log_path;
}
}
/**
* 写sql执行日志
*
* @param string $sql 查询的sql语句
* @param string $file 当前执行查询的文件
*/
function writelog($sql, $file){
if (!file_exists($this->logpath)){
@mkdir($this->logpath);
}
$log_file = $this->logpath ."/mysql_".date("y-m-d").".log";
$log_msg = "[".date("y-m-d h:i:s")."] - ".$file.": ".$sql." ";
error_log($log_msg, 3, $log_file);
}
/**
* 显示上依次sql执行错误的错误信息
*/
function showerror(){
$errmessage = "mysql query error ". mysql_errno($this->dblink) .": ". mysql_error($this->dblink);
die($errmessage);
}
/**
* 返回mysql的版本信息
*
* @return string mysql的版本
*/
function getversion(){
return $this->getone("select version()");
}
/**
* 查询操作的底层接口
*
* @param string $sql 要执行查询的sql语句
* @return bool 执行成功返回true,失败返回false
*/
function query($sql){
$this->dbsql = $sql;
$this->dbresult = null;
$this->dbresult = @mysql_query($sql, $this->dblink);
if ($this->dbresult === false){
if ($this->islog){
$this->writelog($sql, __file__);
}
if ($this->iserror){
$this->showerror();
}
return false;
}
return true;
}
//--------------------------
// 数据获取接口
//--------------------------
/**
* 获取sql执行的全部结果集(二维数组)
*
* @param string $sql 需要执行查询的sql语句
* @return 成功返回查询结果的二维数组,失败返回false
*/
function getall($sql){
if (!$this->query($sql)){
return false;
}
$this->dbrecord = array();
while ($row = @mysql_fetch_array($this->dbresult, $this->fetchmode)) {
$this->dbrecord[] = $row;
}
@mysql_free_result($this->dbresult);
if (!is_array($this->dbrecord) || empty($this->dbrecord)){
return false;
}
return $this->dbrecord;
}
/**
* 获取单行记录(一维数组)
*
* @param string $sql 需要执行查询的sql语句
* @return 成功返回结果记录的一维数组,失败返回false
*/
function getrow($sql){
if (!$this->query($sql)){
return false;
}
$this->dbrecord = array();
$this->dbrecord = @mysql_fetch_array($this->dbresult, $this->fetchmode);
@mysql_free_result($this->dbresult);
if (!is_array($this->dbrecord) || empty($this->dbrecord)){
return false;
}
return $this->dbrecord;
}
/**
* 获取一列数据(一维数组)
*
* @param string $sql 需要获取的字符串
* @param string $field 需要获取的列,如果不指定,默认是第一列
* @return 成功返回提取的结果记录的一维数组,失败返回false
*/
function getcol($sql, $field=''){
if (!$this->query($sql)){
return false;
}
$this->dbrecord = array();
while($row = @mysql_fetch_array($this->dbresult, $this->fetchmode)){
if (trim($field) == ''){
$this->dbrecord[] = current($row);
} else {
$this->dbrecord[] = $row[$field];
}
}
@mysql_free_result($this->dbresult);
if (!is_array($this->dbrecord) || empty($this->dbrecord)){
return false;
}
return $this->dbrecord;
}
/**
* 获取一个数据(当条数组)
*
* @param string $sql 需要执行查询的sql
* @return 成功返回获取的一个数据,失败返回false
*/
function getone($sql, $field=''){
if (!$this->query($sql)){
return false;
}
$this->dbrecord = array();
$row = @mysql_fetch_array($this->dbresult, $this->fetchmode);
@mysql_free_result($this->dbresult);
if (!is_array($row) || empty($row)){
return false;
}
if (trim($field) != ''){
$this->dbrecord = $row[$field];
}else{
$this->dbrecord = current($row);
}
return $this->dbrecord;
}
/**
* 获取指定各种条件的记录
*
* @param string $table 表名(访问的数据表)
* @param string $field 字段(要获取的字段)
* @param string $where 条件(获取记录的条件语句,不包括where,默认为空)
* @param string $order 排序(按照什么字段排序,不包括order by,默认为空)
* @param string $limit 限制记录(需要提取多少记录,不包括limit,默认为空)
* @param bool $single 是否只是取单条记录(是调用getrow还是getall,默认是false,即调用getall)
* @return 成功返回记录结果集的数组,失败返回false
*/
function getrecord($table, $field='*', $where='', $order='', $limit='', $single=false){
$sql = "select $field from $table";
$sql .= trim($where)!='' ? " where $where " : $where;
$sql .= trim($order)!='' ? " order by $order" : $order;
$sql .= trim($limit)!='' ? " limit $limit" : $limit;
if ($single){
return $this->getrow($sql);
}
return $this->getall($sql);
}
/**
* 获取指点各种条件的记录(跟getrecored类似)
*
* @param string $table 表名(访问的数据表)
* @param string $field 字段(要获取的字段)
* @param string $where 条件(获取记录的条件语句,不包括where,默认为空)
* @param array $order_arr 排序数组(格式类似于: array('id'=>true), 那么就是按照id为顺序排序, array('id'=>false), 就是按照id逆序排序)
* @param array $limit_arr 提取数据的限制数组()
* @return unknown
*/
function getspecifyrecord($table, $field='*', $where='', $order_arr=array(), $limit_arr=array()){
$sql = "select $field from $table";
$sql .= trim($where)!='' ? " where $where " : $where;
if (is_array($order_arr) && !empty($order_arr)){
$arr_key = key($order_arr);
$sql .= " order by $arr_key " . ($order_arr[$arr_key] ? "asc" : "desc");
}
if (is_array($limit_arr) && !empty($limit_arr)){
$start_post = intval(array_shift($limit_arr));
$offset = intval(array_shift($limit_arr));
$sql .= " limit $start_post,$offset";
}
return $this->getall($sql);
}
/**
* 获取指定条数的记录
*
* @param string $table 表名
* @param int $start_pos 开始记录
* @param int $offset 偏移量
* @param string $field 字段名
* @param string $where 条件(获取记录的条件语句,不包括where,默认为空)
* @param string $order 排序(按照什么字段排序,不包括order by,默认为空)
* @return 成功返回包含记录的二维数组,失败返回false
*/
function getlimitrecord($table, $start_pos, $offset, $field='*', $where='', $oder=''){
$sql = "select $field from $table";
$sql .= trim($where)!='' ? " where $where " : $where;
$sql .= trim($order)!='' ? " order by $order" : $order;
$sql .= "limit $start_pos,$offset";
return $this->getall($sql);
}
/**
* 获取排序记录
*
* @param string $table 表名
* @param string $order_field 需要排序的字段(比如id)
* @param string $order_method 排序的方式(1为顺序, 2为逆序, 默认是1)
* @param string $field 需要提取的字段(默认是*,就是所有字段)
* @param string $where 条件(获取记录的条件语句,不包括where,默认为空)
* @param string $limit 限制记录(需要提取多少记录,不包括limit,默认为空)
* @return 成功返回记录的二维数组,失败返回false
*/
function getorderrecord($table, $order_field, $order_method=1, $field='*', $where='', $limit=''){
//$order_method的值为1则为顺序, $order_method值为2则2则是逆序排列
$sql = "select $field from $table";
$sql .= trim($where)!='' ? " where $where " : $where;
$sql .= " order by $order_field " . ( $order_method==1 ? "asc" : "desc");
$sql .= trim($limit)!='' ? " limit $limit" : $limit;
return $this->getall($sql);
}
/**
* 分页查询(限制查询的记录条数)
*
* @param string $sql 需要查询的sql语句
* @param int $start_pos 开始记录的条数
* @param int $offset 每次的偏移量,需要获取多少条
* @return 成功返回获取结果记录的二维数组,失败返回false
*/
function limitquery($sql, $start_pos, $offset){
$start_pos = intval($start_pos);
$offset = intval($offset);
$sql = $sql . " limit $start_pos,$offset ";
return $this->getall($sql);
}
//--------------------------
// 无数据返回操作
//--------------------------
/**
* 执行执行非select查询操作
*
* @param string $sql 查询sql语句
* @return bool 成功执行返回true, 失败返回false
*/
function execute($sql){
if (!$this->query($sql)){
return false;
}
$count = @mysql_affected_rows($this->dblink);
if ($count <= 0){
return false;
}
return true;
}
/**
* 自动执行操作(针对insert/update操作)
*
* @param string $table 表名
* @param array $field_array 字段数组(数组中的键相当于字段名,数组值相当于值, 类似 array( 'id' => 100, 'user' => 'heiyeluren')
* @param int $mode 执行操作的模式 (是插入还是更新操作, 1是插入操作insert, 2是更新操作update)
* @param string $where 如果是更新操作,可以添加where的条件
* @return bool 执行成功返回true, 失败返回false
*/
function autoexecute($table, $field_array, $mode, $where=''){
if ($table=='' || !is_array($field_array) || empty($field_array)){
return false;
}
//$mode为1是插入操作(insert), $mode为2是更新操作
if ($mode == 1){
$sql = "insert into $table set ";
}else{
$sql = "update $table set ";
}
foreach ($field_array as $key => $value){
$sql .= "$key='$value',";
}
$sql = rtrim($sql, ',');
if ($mode==2 && $where!=''){
$sql .= "where $where";
}
return $this->execute($sql);
}
//--------------------------
// 其他数据相关操作
//--------------------------
/**
* 获取最后一次查询的sql语句
*
* @return string 返回最后一次查询的sql语句
*/
function getlastsql(){
return $this->dbsql;
}
/**
* 获取上次插入操作的的id
*
* @return int 如果没有连接或者查询失败,返回0, 成功返回id
*/
function getlastid(){
if (!$this->dblink){
return 0;
}
if (($last_id = mysql_insert_id($this->dblink)) > 0){
return $last_id;
}
return $this->getone("select last_insert_id()");
}
/**
* 获取记录集里面的记录条数 (用于select操作)
*
* @return int 如果上一次无结果集或者记录结果集为空,返回0, 否则返回结果集数量
*/
function getnumrows(){
if (!$this->dbresult){
return 0;
}
return mysql_num_rows($this->dbresult);
}
/**
* 获取受到影响的记录数量 (用于update/delete/insert操作)
*
* @return int 如果没有连接或者影响记录为空, 否则返回影响的行数量
*/
function getaffectedrows(){
if (!$this->dblink){
return 0;
}
return mysql_affected_rows($this->dblink);
}
}
?>
新闻热点
疑难解答
