搜尋
首頁php教程php手册转一个SQL Ralay数据库连接池的PHP操作类

数据|数据库|数据库连接

原文说明:目前此类只支持Sybase,稍加扩展就可以同时支持其它多种数据库,功能还不完善,但是基本上够用
,另外,还没有写说明文档,先放上来,有需要的朋友可以拿去看看,需要SQL Relay支持哦。
【操作类代码】

 

// pdbconn.inc.php

    /**
     * 全局常量定义
     *
     */
    define("SYBASE", 0);
    define("ORACLE", 1);
    define("SUCCESS", 1);
    define("FAILED", -1);

    define("DEBUG", 1);
    
    /**
     * 数据库连接类
     * 开始于:2006年1月10日
     * 作者  :秋衫客 (cntoby@gmail.com)
     *
     * 功能描述:数据库查询及连接池维护
     * 暂时不支持ORACLE
     */
    class dbconn {
        var $_conn;    // 当前连接ID
        var $_cur;    //
        var $_dbhost = "localhost";    // 数据库服务器名
        var $_dbport = 9000;    // 数据库端口号
        var $_dbuser = "dev";    // 登录数据库的用户名
        var $_dbpass = "dev";    // 登录数据库的密码
        var $_dbsock = "null"; // 数据库连接的Unix套接字
        var $_dbflag = SYBASE;    // 数据库类型
        var $_dbflagS = "sybase";    // SQLRelay中数据库类型标志
        var $_dbrtrt = 0;    // 连接失败后间接多长时间重试
        var $_dbtries = 1;    // 重试次数
        var $_debug = false;    // 是否为DEBUG模式
        var $_cursql = "";    // 当前存在的SQL文
        var $_lastrt = true;    // 最后一次执行的结果,成功与否boolean
        var $_queryrs = null;    // 查询过程中的结果
        var $rs = null;    // 最后一次执行结果
        var $recordcount = 0;    // 当次返回记录总数
        var $absolute = 0;    // 当前页码
        var $pagesize = 0;    // 每页显示记录数
        var $pagecount = 1;    // 本次查询总页数
        var $total = 0;    // 总记录数
        
        /**
         * 构造函数,在本函数内初始化连接及连接池
         * 构造函数的参数说明:
         *     不用任何参数可使用默认参数连接数据库
         *     当使用参数时,可以使用1到5个参数,顺序为
         *     dbhost    数据库服务器名
         *     dbuser    登录数据库用户名
         *     dbpass    登录数据库密码
         *     dbsock    数据库连接的Unix套接字
         *     dbport    数据库端口号
         *     dbflag    数据库类型,可选类型为SYBASE或ORACLE
         *
         * @return dbconn
         */
        function dbconn() {
            $argc = func_num_args();
            $argv = func_get_args();
            $this->_dbhost = (!empty($argv[0]))?$argv[0]:$this->_dbhost;
            $this->_dbuser = (!empty($argv[1]))?$argv[1]:$this->_dbuser;
            $this->_dbpass = (!empty($argv[2]))?$argv[2]:$this->_dbpass;
            $this->_dbsock = (!empty($argv[3]))?$argv[3]:$this->_dbsock;
            $this->_dbport = (!empty($argv[4]))?$argv[4]:$this->_dbport;
            $this->_dbflag = (!empty($argv[5]))?$argv[5]:$this->_dbflag;
            $this->_dbrtrt = (!empty($argv[6]))?$argv[6]:$this->_dbrtrt;
            $this->_dbtries = (!empty($argv[7]))?$argv[7]:$this->_dbtries;
            $this->_debug = defined("DEBUG");
            
            switch ($this->_dbflag) {
                case SYBASE:
                    $this->_conn = @sqlrcon_alloc($this->_dbhost, $this->_dbport, $this->_dbsock, $this->_dbuser, $this->_dbpass, $this->_dbrtrt, $this->_dbtries);
                    $this->_cur = @sqlrcur_alloc($this->_conn);
                    if(@sqlrcon_identify($this->_conn)!="sybase"||@sqlrcon_ping($this->_conn)!=1) {
                        return FAILED;
                    }
                    break;
                case ORACLE:
                    $this->_conn = @sqlrcon_alloc($this->_dbhost, $this->_dbport, $this->_dbsock, $this->_dbuser, $this->_dbpass, $this->_dbrtrt, $this->_dbtries);
                    $this->_cur = @sqlrcur_alloc($this->_conn);
                    if(substring(@sqlrcon_identify($this->_conn), 0, 6)!="oracle"||@sqlrcon_ping($this->_conn)!=1) {
                        return FAILED;
                    }
                    break;
                default:
                    return FAILED;
                    break;
            }
        }
        
        /**
         * 设置用于查询的SQL文
         *
         * @param string $sql
         */
        function setsql($sql = "") {
            $this->_cursql = $sql;
            return SUCCESS;
        }
        
        /**
         * 重置到初始状态
         *
         * @return bool
         */
        function rset() {
            $this->rs = null;
            $this->pagecount = 1;
            $this->recordcount = 0;
            $this->_queryrs = null;
            $this->_lastrt = true;
            
            return SUCCESS;
        }
        
        /**
         * 执行查询,返回查询是否成功,参数可以为一条SQL文,或者一个SQL文数组
         *
         * @param string $sql
         * @return bool
         */
        function doexec($sql = "") {
            $tran = false;
            $isa = false;
            $this->rset();
            if(""==$sql||empty($sql)) {
                $sql = $this->_cursql;
            }
            if(!is_array($sql)) {
                if(!eregi("^select", trim($sql))) {
                    $tran = true;
                }
            }else {
                $isa = true;
                for($i = 0; $i                     if (!eregi("^select", trim($sql[$i]))) {
                        $tran = true;
                        break;
                    }
                }
            }
            if ($tran) {
                $tmp = @sqlrcur_sendQuery($this->_cur, "Begin Transaction");
                if($tmp!=1) {
                    $this->_lastrt = false;
                    return FAILED;
                }
            }
            if(!$isa) {
                $tmp = @sqlrcur_sendQuery($this->_cur, $sql);
            }else {
                for ($i = 0; $i                     $tmp = @sqlrcur_sendQuery($this->_cur, $sql[$i]);
                    if($tmp!=1) break;
                }
            }
            $this->setsql();
            if($tmp==1) {
                if($tran) @sqlrcur_sendQuery($this->_cur, "Commit Transaction");
                $this->_lastrt = true;
            }else {
                if($tran) @sqlrcur_sendQuery($this->_cur, "Rollback Transaction");
                $this->_lastrt = false;
                return FAILED;
            }
            return SUCCESS;
        }
        
        /**
         * 记录查询,只返回一条记录
         *
         * @return bool
         */
        function doquery_row() {
            $this->rset();
            if((""==trim($this->_cursql))||empty($this->_cursql)) {
                return false;
            }
            if(SYBASE==$this->_dbflag) {
                @sqlrcur_sendQuery($this->_cur, "set rowcount 1");
                $tmp = @sqlrcur_sendQuery($this->_cur, $this->_cursql);
                if($tmp==1) {
                    $this->recordcount = @sqlrcur_rowCount($this->_cur);
                    $this->total = $this->recordcount;
                    if ($this->recordcount>0) {
                        $this->rs = @sqlrcur_getRow($this->_cur, 0);
                    }
                }else {
                    $this->recordcount = -1;
                    $this->total = $this->recordcount;
                    @sqlrcur_sendQuery($this->_cur, "set rowcount 0");
                    return FAILED;
                }
                @sqlrcur_sendQuery($this->_cur, "set rowcount 0");
            }elseif(ORACLE==$this->_dbflag) {
                // 暂时不支持ORACLE
                $sfmt = @ociparse($this->_conn, $this->_cursql);
                $ret = @ociexecute($sfmt, OCI_DEFAULT);
                if($ret) {
                    $this->recordcount = @oci_num_rows($sfmt);
                    $this->total = $this->recordcount;
                    if($this->recordcount>0) {
                        @ocifetchinto($sfmt, &$this->rs);
                    }
                }else {
                    $this->recordcount = -1;
                    $this->total = $this->recordcount;
                    return FAILED;
                }
            }
            $this->setsql();
            return SUCCESS;
        }
        
        /**
         * 记录查询,返回多条记录,可通过设置$rowcount来控制返回记录的最大数
         *
         * @param int $rowcount
         * @return bool
         */
        function doquery_rows($rowcount = 0) {
            if(!eregi("[0-9]+", $rowcount)) {
                $rowcount = 0;
            }
            $this->rset();
            if((""==trim($this->_cursql))||empty($this->_cursql)) {
                return FAILED;
            }
            if(SYBASE==$this->_dbflag) {
                @sqlrcur_sendQuery($this->_cur, "set rowcount " .strval($rowcount));
                $tmp = @sqlrcur_sendQuery($this->_cur, $this->_cursql);
                if($tmp==1) {
                    $this->recordcount = @sqlrcur_rowCount($this->_cur);
                    $this->total = $this->recordcount;
                    if($this->recordcount > 0) {
                        if(0>=$this->pagesize||null==$this->pagesize) {
                            $this->pagecount = 1;
                            $startidx = 0;
                            $endidx = $this->recordcount - 1;
                        }else {
                            if($this->absoluteabsolute=1;
                            $this->pagecount = ceil($this->recordcount/$this->pagesize);
                            if($this->absolute>$this->pagecount) $this->absolute = $this->pagecount;
                            $startidx = $this->pagesize * ($this->absolute-1);
                            $endidx = $this->pagesize * $this->absolute -1;
                        }
                        $rcidx = 0;
                        // 以下保存结果到$this->rc
                        for($i = $startidx; $i total; $i++) {
                            if($rowcount!=0&&$rowcount==$i) break;
                            $this->rs[$rcidx++] = @sqlrcur_getRow($this->_cur, $i);
                        }
                        $this->recordcount = $rcidx;
                    }
                }else {
                    $this->recordcount = -1;
                    $this->total = $this->recordcount;
                    @sqlrcur_sendQuery($this->_cur, "set rowcount 0");
                    return FAILED;
                }
                @sqlrcur_sendQuery($this->_cur, "set rowcount 0");
            }elseif(ORACLE==$this->_dbflag) {
                // 暂时不支持ORACLE
                // Oracle 处理部分
                $sfmt = @ociparse($this->_conn, $this->_cursql);
                $ret = @ociexecute($sfmt, OCI_DEFAULT);
                if($ret) {
                    $this->recordcount = @oci_num_rows($sfmt);
                    $this->total = $this->recordcount;
                    if($this->recordcount > 0) {
                        if($this->pagesizepagesize) {
                            $this->pagecount = 1;
                            $startidx = 0;
                            $endidx = $this->recordcount - 1;
                        }else {
                            if($this->absolute absolute = 1;
                            $this->pagecount = ceil($this->recordcount/$this->pagesize);
                            if($this->absolute>$this->pagecount) $this->absolute = $this->pagecount;
                            $startidx = $this->pagesize * ($this->absolute - 1);
                            $endidx = $this->pagesize * $this->absolute - 1;
                            // aaaaaaaaaaaaaa
                        }
                    }
                }else {
                    $this->recordcount = -1;
                    $this->total = $this->recordcount;
                    return FAILED;
                }
                return FAILED;
            }
            $this->setsql();
            return SUCCESS;
        }
        
        /**
         * 关闭数据连接
         *
         * @return bool
         */
        function dbclose() {
            @sqlrcon_free($this->_conn);
            @sqlrcur_free($this->_cur);
        }
        
        /**
         * 设置或获取每页显示的记录数
         *
         * @param int $pagesize
         * @return int
         */
        function pagesize($pagesize = 0) {
            if(eregi("[1-9]+", $pagesize)&&$pagesize!=0) {
                $this->pagesize = intval($pagesize);
                return $this->pagesize;
            }else {
                return $this->pagesize;
            }
        }
        
        /**
         * 设置或获取当前要显示的页次
         *
         * @param int $absolute
         * @return int
         */
        function absolute($absolute = 1) {
            if(eregi("[1-9]+", $absolute)&&$absolute>1) {
                $this->absolute = intval($absolute);
                return $this->absolute;
            }else {
                return $this->absolute;
            }
        }
    }
?>

 

 



陳述
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn

熱AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

Video Face Swap

Video Face Swap

使用我們完全免費的人工智慧換臉工具,輕鬆在任何影片中換臉!

熱工具

記事本++7.3.1

記事本++7.3.1

好用且免費的程式碼編輯器

Safe Exam Browser

Safe Exam Browser

Safe Exam Browser是一個安全的瀏覽器環境,安全地進行線上考試。該軟體將任何電腦變成一個安全的工作站。它控制對任何實用工具的訪問,並防止學生使用未經授權的資源。

VSCode Windows 64位元 下載

VSCode Windows 64位元 下載

微軟推出的免費、功能強大的一款IDE編輯器

WebStorm Mac版

WebStorm Mac版

好用的JavaScript開發工具

PhpStorm Mac 版本

PhpStorm Mac 版本

最新(2018.2.1 )專業的PHP整合開發工具