ホームページ >php教程 >php手册 >シンプル、高速、興味深い MySQL データベース操作クラス: SimpleDB

シンプル、高速、興味深い MySQL データベース操作クラス: SimpleDB

WBOY
WBOYオリジナル
2016-06-21 09:06:551139ブラウズ

mysql|数据|数据库

自己写着玩的,代码没有测试,不过觉得思路不错,如果能够加上部分异常处理的功能,应该比较帅了,支持PHP4/PHP5,恩,虽然没有ADOdb或者PEAR::DB强,不错一般应用应该不错,恩。

喜欢的就自己拿去用吧,自己随便改,呵呵,也欢迎提意见。(注释遵循PHPDoc的标准,便于生成手册)

 注意:代码未经测试,出现问题可要自己负责哇,呵呵。

 

 

 

 

//==========================================
// 文件: SimpleDB.class.php
// 程序: MySQL数据库操作类
// 作者: heiyeluren // 时间: 2006-09-20
//==========================================

class SimpleDB
{
/**
* 接続識別子
* @var resource
*/
var $dbLink;
/**
* データベースクエリステートメント
* @var string
*/
var $dbSql;
/**
* クエリ結果
* @var リソース
*/
var $dbResult;
/ **
* クエリレコードセット
* @var array
*/
var $dbRecord;
/**
* データベース文字セット
* @var string
*/
var $dbCharset = 'GBK';
/**
* データベース結果セットの抽出方法
* @var int
*/
var $fetchMode = MYSQL_ASSOC;
/**
* ログ保存パス
* @var 文字列
*/
var $logPath = '/tmp/mysql_log';

/**
* 失敗した SQL クエリの SQL ログを記録するかどうか、デフォルトは false です
* @var bool
*/
var $isLog = false;
/**
* SQL クエリエラーが発生したときにエラーを表示してスクリプトの実行を終了するかどうか、デフォルトは true です
*
* @var bool
*/
var $isError = true;


//--------------------------
// 内部インターフェース
//--------------- ---------------
/**
*コンストラクター
*
* @param string $ db_host connect into Host
* @param string $ db_user connectユーザー
* @param string $ db_passwd database password ? 接続、デフォルトは
* @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 実行のすべての結果セット (2 次元配列) を取得します
*
* @param string $sql クエリを実行する必要がある SQL ステートメント
* @return クエリ結果の 2 次元配列を正常に返します。失敗した場合は 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;
}

/**
*単一の行レコード(1次元配列)を取得します
*
* @param string $ sql実行する必要があるsqlステートメント
* @return*/
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;
}

/**
* データの列 (一次元配列) を取得します
1 次元配列を返します抽出された結果レコードの場合、失敗した場合は 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;
    }

/**
*さまざまな条件を指定するレコードを取得します。レコードの条件付きステートメントを除く、デフォルトを除く制限を除く、デフォルトは空です。 getRow を呼び出すか getAll を呼び出すか、デフォルトは false、つまり getAll を呼び出します)
false
*/
function getRecord($table, $field='*', $where='', $order='', $limit='', $single=false){
$ sql = "SELECT $field FROM $table";
$sql .= トリム($where)!='' ? " WHERE $where " : $where;
$sql .= トリム($order)!='' ? " $order で注文" : $order;
$sql .= トリム($limit)!='' ? " LIMIT $limit" : $limit;
if ($single){
return $this->getRow($sql);
}
return $this->getAll($sql);
}

/* *
* さまざまな条件を指すレコードを取得します (getRecored と同様)
*
* @param string $table テーブル名 (アクセスするデータテーブル)
* @param string $field フィールド (取得するフィールド)
* @param 文字列$where 条件 (レコードを取得するための条件文、WHERE を除く、デフォルトは空) * @param array $order_arr 配列のソート (形式は array('id'=>true) と似ており、ID 順にソートされます、array('id'=>false)、IDで逆順にソートされます)
* @param array $limit_arr データを抽出するための制限配列()
* @returnunknown
*/
function getSpecifyRecord($table, $field='*', $where='', $order_arr=array(), $limit_arr=array()){
$sql = "SELECT $field FROM $table";
$sql .= トリム($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($ 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 offset
Param String $ where 条件 (レコード取得の条件文) 、where を除く、デフォルトは空です)
* @Param String $ Order Sort (どのフィールドがソートされるか、order by を除く、デフォルトは空です)
@Return は、含まれている記録された 2 次元配列を含めるように正常に戻り、失敗した場合は false
を返します*/
function getLimitRecord($table, $start_pos, $offset, $field='*', $where='', $oder=''){
$sql = "SELECT $field FROM $table";
$sql .= トリム($where)!='' ? " WHERE $where " : $where;
$sql .= トリム($order)!='' ? " $order で注文" : $order;
        $sql .= "LIMIT $start_pos,$offset";
return $this->getAll($sql);
}

/**
* ソートされたレコードを取得します
*
* @param string $table テーブル名
* @param string $order_field ソートする必要があるフィールド (id など)
* @param string $order_method ソート方法 (1 は order、 2 は逆順、デフォルトは 1)
* @param string $field 抽出するフィールド (デフォルトは *、すべてのフィールド)
* @param string $where 条件 (WHERE を除く、デフォルトのレコードを取得するための条件文)は空です)
* @ Param String $ Limit Limited Records (抽出する必要があるレコードの数、Limit を除く、デフォルトは空)
* @Return は記録されたレコードの 2 次元配列を正常に返しましたが、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 .= トリム($where)!='' ? " WHERE $where " : $where;
$sql .= " ORDER BY $order_field " 。 ( $order_method==1 ? "ASC" : "DESC");
$sql .= トリム($limit)!='' ? " LIMIT $limit" : $limit;
return $this->getAll($sql);
}

/**
*ページングクエリ(クエリの記録の数を制限)*/
function limitQuery($sql, $start_pos, $offset){
$ start_pos = intval($start_pos);
$offset = intval($offset);
$sql = $sql 。 " LIMIT $start_pos,$offset ";
return $this->getAll($sql);
}


//---------- -----
// 無数据返操作
//--------------------------
/**
*/
関数execute($ sql){
if(!$ this-> query($ sql)){
false; <= 0){
return false;
}
return true;
}

/**作 * 自動実行操作 (Insert/Update 操作の場合)
*
* @param String $ Table テーブル名
@param Array $ Field_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=''){
もし($table=='' || !is_array($field_array) || empty($field_array)){
return false; $ sql = rtrim ($ sql, ',');
if ($ mode == 2 && $ where! = '') {
$ sql = "どこ $ どこ";
//---------------
// その他のデータ関連の操作
//--- -------- ---------------
– – − −評判-‑ ‑ ‑ ‑ ‑ – – − − −評判@@ l_insert_id($ this-&gt; dblink){!$ this-&gt; dbresult)





声明:
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。