数据|数据库|数据库连接
原文说明：目前此类只支持sybase，稍加扩展就可以同时支持其它多种数据库，功能还不完善，但是基本上够用
，另外，还没有写说明文档，先放上来，有需要的朋友可以拿去看看，需要sql relay支持哦。
【操作类代码】
// pdbconn.inc.php
_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;
            }
        }
    }
?>