简单快速有趣的MySQL数据库操作类SimpleDB.docx
- 文档编号:17956474
- 上传时间:2023-08-05
- 格式:DOCX
- 页数:14
- 大小:18.51KB
简单快速有趣的MySQL数据库操作类SimpleDB.docx
《简单快速有趣的MySQL数据库操作类SimpleDB.docx》由会员分享,可在线阅读,更多相关《简单快速有趣的MySQL数据库操作类SimpleDB.docx(14页珍藏版)》请在冰点文库上搜索。
简单快速有趣的MySQL数据库操作类SimpleDB
//==========================================
//文件:
SimpleDB.class.php
//程序:
MySQL数据库操作类
//作者:
heiyeluren<
//时间:
2006-09-20
//==========================================
classSimpleDB
{
/**
*连接标识
*@varresource
*/
var$dbLink;
/**
*数据库查询语句
*@varstring
*/
var$dbSql;
/**
*查询结果
*@varresource
*/
var$dbResult;
/**
*查询记录集
*@vararray
*/
var$dbRecord;
/**
*数据库字符集
*@varstring
*/
var$dbCharset='GBK';
/**
*数据库结果集提取方式
*@varint
*/
var$fetchMode=MYSQL_ASSOC;
/**
*日志保存路径
*@varstring
*/
var$logPath='/tmp/mysql_log';
/**
*是否记录SQL查询失败的SQL日志,缺省是false
*@varbool
*/
var$isLog=false;
/**
*是否在SQL查询出错的时候显示错误并且终止脚本执行,缺省是true
*
*@varbool
*/
var$isError=true;
//--------------------------
//内部接口
//--------------------------
/**
*构造函数
*
*@paramstring$db_host连接主机
*@paramstring$db_user连接用户
*@paramstring$db_passwd数据库密码
*@paramstring$db_name数据库
*@parambool$is_pconnect是否长连接,默认是否
*@returnSimpleDB
*/
functionSimpleDB($db_host,$db_user,$db_passwd,$db_name,$is_pconnect=false){
$this->connect($db_host,$db_user,$db_passwd,$db_name,$is_pconnect);
}
/**
*连接数据库
*
*@paramstring$db_host 数据库主机地址,例如:
localhost,或者localhost:
3306
*@paramstring$db_user连接数据库的用户
*@paramstring$db_passwd用户密码
*@paramstring$db_name数据库名字
*@paramboo$is_pconnect是否使用长连接
*@returnresource返回连接资源标识符
*/
functionconnect($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("SELECTVERSION()");
if($this->dbCharset!
=''&&preg_match("/^(5.|4.1)/",$mysql_version)){
$this->query("SETNAMES'$this->dbCharset'",$this->dbLink);
}
return$this->dbLink;
}
/**
*关闭数据库连接
*
*@returnbool是否成功关闭连接
*/
functiondisconnect(){
$ret=@mysql_close($this->dbLink);
$this->dbLink=null;
return$ret;
}
/**
*设置查询结果返回数据类型
*
*@paramint$modeType设置查询结果返回设置,1为关联索引和数字所有都有,2为使用关联索引,3为使用数字索引
*/
functionsetFetchMode($modeType){
switch($modeType){
case1:
//数字索引和关联索引都有
$this->fetchMode=MYSQL_BOTH;
break;
case2:
//使用关联索引
$this->fetchMode=MYSQL_ASSOC;
break;
case3:
//使用数字索引
$this->fetchMode=MYSQL_NUM;
break;
default:
//缺省使用关联索引
$this->fetchMode=MYSQL_ASSOC;
}
}
/**
*设置数据库客户端提取结果集的字符编码
*
*@paramstring$charset编码的字符串,比如UTF8,GBK之类的,缺省是GBK
*/
functionsetCharset($charset){
if($charset!
=''){
$this->dbCharset=$charset;
}
}
/**
*设置日志存储路径
*
*@paramstring$log_path日志路径,该必须是可写的
*/
functionsetLogPath($log_path){
if($log_path!
=''){
$this->logPath=$log_path;
}
}
/**
*写SQL执行日志
*
*@paramstring$sql查询的SQL语句
*@paramstring$file当前执行查询的文件
*/
functionwriteLog($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-dH:
i:
s")."]-".$file.":
".$sql."";
error_log($log_msg,3,$log_file);
}
/**
*显示上依次SQL执行错误的错误信息
*/
functionshowError(){
$errMessage="MySQLqueryerror".mysql_errno($this->dbLink).":
".mysql_error($this->dbLink);
die($errMessage);
}
/**
*返回MySQL的版本信息
*
*@returnstringMysql的版本
*/
functiongetVersion(){
return$this->getOne("SELECTVERSION()");
}
/**
*查询操作的底层接口
*
*@paramstring$sql要执行查询的SQL语句
*@returnbool执行成功返回true,失败返回false
*/
functionquery($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();
}
returnfalse;
}
returntrue;
}
//--------------------------
//数据获取接口
//--------------------------
/**
*获取SQL执行的全部结果集(二维数组)
*
*@paramstring$sql需要执行查询的SQL语句
*@return成功返回查询结果的二维数组,失败返回false
*/
functiongetAll($sql){
if(!
$this->query($sql)){
returnfalse;
}
$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)){
returnfalse;
}
return$this->dbRecord;
}
/**
*获取单行记录(一维数组)
*
*@paramstring$sql需要执行查询的SQL语句
*@return成功返回结果记录的一维数组,失败返回false
*/
functiongetRow($sql){
if(!
$this->query($sql)){
returnfalse;
}
$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)){
returnfalse;
}
return$this->dbRecord;
}
/**
*获取一列数据(一维数组)
*
*@paramstring$sql需要获取的字符串
*@paramstring$field需要获取的列,如果不指定,默认是第一列
*@return成功返回提取的结果记录的一维数组,失败返回false
*/
functiongetCol($sql,$field=''){
if(!
$this->query($sql)){
returnfalse;
}
$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)){
returnfalse;
}
return$this->dbRecord;
}
/**
*获取一个数据(当条数组)
*
*@paramstring$sql需要执行查询的SQL
*@return成功返回获取的一个数据,失败返回false
*/
functiongetOne($sql,$field=''){
if(!
$this->query($sql)){
returnfalse;
}
$this->dbRecord=array();
$row=@mysql_fetch_array($this->dbResult,$this->fetchMode);
@mysql_free_result($this->dbResult);
if(!
is_array($row)||empty($row)){
returnfalse;
}
if(trim($field)!
=''){
$this->dbRecord=$row[$field];
}else{
$this->dbRecord=current($row);
}
return$this->dbRecord;
}
/**
*获取指定各种条件的记录
*
*@paramstring$table表名(访问的数据表)
*@paramstring$field字段(要获取的字段)
*@paramstring$where条件(获取记录的条件语句,不包括WHERE,默认为空)
*@paramstring$order排序(按照什么字段排序,不包括ORDERBY,默认为空)
*@paramstring$limit限制记录(需要提取多少记录,不包括LIMIT,默认为空)
*@parambool$single是否只是取单条记录(是调用getRow还是getAll,默认是false,即调用getAll)
*@return成功返回记录结果集的数组,失败返回false
*/
functiongetRecord($table,$field='*',$where='',$order='',$limit='',$single=false){
$sql="SELECT$fieldFROM$table";
$sql.=trim($where)!
=''?
"WHERE$where":
$where;
$sql.=trim($order)!
=''?
"ORDERBY$order":
$order;
$sql.=trim($limit)!
=''?
"LIMIT$limit":
$limit;
if($single){
return$this->getRow($sql);
}
return$this->getAll($sql);
}
/**
*获取指点各种条件的记录(跟getRecored类似)
*
*@paramstring$table表名(访问的数据表)
*@paramstring$field字段(要获取的字段)
*@paramstring$where条件(获取记录的条件语句,不包括WHERE,默认为空)
*@paramarray$order_arr排序数组(格式类似于:
array('id'=>true),那么就是按照ID为顺序排序,array('id'=>false),就是按照ID逆序排序)
*@paramarray$limit_arr提取数据的限制数组()
*@returnunknown
*/
functiongetSpecifyRecord($table,$field='*',$where='',$order_arr=array(),$limit_arr=array()){
$sql="SELECT$fieldFROM$table";
$sql.=trim($where)!
=''?
"WHERE$where":
$where;
if(is_array($order_arr)&&!
empty($order_arr)){
$arr_key=key($order_arr);
$sql.="ORDERBY$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);
}
/**
*获取指定条数的记录
*
*@paramstring$table表名
*@paramint$start_pos开始记录
*@paramint$offset偏移量
*@paramstring$field字段名
*@paramstring$where条件(获取记录
- 配套讲稿:
如PPT文件的首页显示word图标,表示该PPT已包含配套word讲稿。双击word图标可打开word文档。
- 特殊限制:
部分文档作品中含有的国旗、国徽等图片,仅作为作品整体效果示例展示,禁止商用。设计者仅对作品中独创性部分享有著作权。
- 关 键 词:
- 简单 快速 有趣 MySQL 数据库 操作 SimpleDB