|
马上注册,结交更多好友,享用更多功能,让你轻松玩转社区。
您需要 登录 才可以下载或查看,没有帐号?立即注册
x
看到好的帖子最好up一下,以使得更多的人得到分享。mysql|数据|数据库 本人写着玩的,代码没有测试,不外感觉思绪不错,假如可以加上局部异常处置的功效,应当对照帅了,撑持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);
}
}
?>
刚开始觉得自己对这些多少有些基础,很简单,但是看了老师那么熟练的进行网页布局的时候,突然之间发现,其实,我的基础并没有自己想像的那么好,自己设计的页面其实并不好看,就连表格的边框为1像素都不会弄。 |
|