数据|数据库|数据库连接
原文说明：目前此类只支持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;
}
}
}
?>
Cara menggunakan return dalam bahasa C
Penggunaan pulangan nilai pulangan Python
Pengesyoran kedudukan perisian pengesanan perkakasan komputer
Apakah fungsi tetingkap?
Bagaimana untuk memulakan perkhidmatan svn
Adakah sistem Hongmeng mudah digunakan?
Perbezaan antara eksport dan eksport lalai
langkah perlindungan keselamatan pelayan cdn
![[Web front-end] Permulaan pantas Node.js](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
