搜索
首页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

使用我们完全免费的人工智能换脸工具轻松在任何视频中换脸!

热工具

mPDF

mPDF

mPDF是一个PHP库,可以从UTF-8编码的HTML生成PDF文件。原作者Ian Back编写mPDF以从他的网站上“即时”输出PDF文件,并处理不同的语言。与原始脚本如HTML2FPDF相比,它的速度较慢,并且在使用Unicode字体时生成的文件较大,但支持CSS样式等,并进行了大量增强。支持几乎所有语言,包括RTL(阿拉伯语和希伯来语)和CJK(中日韩)。支持嵌套的块级元素(如P、DIV),

VSCode Windows 64位 下载

VSCode Windows 64位 下载

微软推出的免费、功能强大的一款IDE编辑器

SublimeText3汉化版

SublimeText3汉化版

中文版,非常好用

禅工作室 13.0.1

禅工作室 13.0.1

功能强大的PHP集成开发环境

ZendStudio 13.5.1 Mac

ZendStudio 13.5.1 Mac

功能强大的PHP集成开发环境