mysql.db.class.php

PHP+IIS+MySQL开发物流管理系统

<?php
#------------------------------------------------------------------------------
#[谢您使用情感家园企业站程序：qgweb]
#[本程序由情感开发完成，当前版本：5.0]
#[本程序基于LGPL授权发布]
#[如果您使用正式版，请将授权文件用FTP上传至copyright目录中]
#[官方网站：www.phpok.com   www.qinggan.net]
#[客服邮箱：[e-mail]]
#[文件：mysql.php]
#------------------------------------------------------------------------------

#[类库sql]
class qgSQL
{
	var $queryCount = 0;
	var $host;
	var $user;
	var $pass;
	var $data;
	var $conn;
	var $result;
	var $rsType = MYSQL_ASSOC;
	
	#[构造函数]
	function qgSQL($dbhost,$dbdata,$dbuser="",$dbpass="",$dbOpenType=false)
	{
		$this->host = $dbhost;
		$this->user = $dbuser;
		$this->pass = $dbpass;
		$this->data = $dbdata;
		$this->connect($dbOpenType);
	}

	#[兼容PHP5]
	function __construct($dbhost,$dbdata,$dbuser="",$dbpass="",$dbOpenType=false)
	{
		$this->qgSQL($dbhost,$dbdata,$dbuser,$dbpass,$dbOpenType);
	}

	#[连接数据库]
	function connect($dbconn = false)
	{
		if($dbconn)
		{
			$this->conn = mysql_pconnect($this->host,$this->user,$this->pass) or die(mysql_errno()." : ".mysql_error());
		}
		else
		{
			$this->conn = mysql_connect($this->host,$this->user,$this->pass) or die(mysql_errno()." : ".mysql_error());
		}

		if(mysql_get_server_info()>"4.1")
		{
			mysql_query("SET NAMES 'gbk'",$this->conn);
		}

		if(mysql_get_server_info()>"5.0.1")
		{
			mysql_query("SET sql_mode=''",$this->conn);
		}

		mysql_select_db($this->data) or die(mysql_errno()." : ".mysql_error());
	}

	#[关闭数据库连接，当您使用持续连接时该功能失效]
	function qgClose()
	{
		return @mysql_close();
	}

	#[兼容PHP5]
	function __destruct ()
	{
		return $this->qgClose();
	}

	function qgQuery($sql,$type="ASSOC")
	{
		$this->rsType = $type != "ASSOC" ? ($type == "NUM" ? MYSQL_NUM : MYSQL_BOTH) : MYSQL_ASSOC;
		$this->result = mysql_query($sql,$this->conn);
		$this->queryCount++;
		if($this->result)
		{
			return $this->result;
		}
		else
		{
			return false;
		}
	}

	function qgGetAll($sql="")
	{
		if($sql)
		{
			$this->qgQuery($sql);
		}
		$rs = array();
		while($rows = @mysql_fetch_array($this->result,$this->rsType))
		{
			$rs[] = $rows;
		}
		return $rs;
	}

	function qgGetOne($sql = "")
	{
		if($sql)
		{
			$this->qgQuery($sql);
		}
		$rows = mysql_fetch_array($this->result,$this->rsType);
		return $rows;
	}

	function qgInsertID()
	{
		return @mysql_insert_id();
	}

	function qgCount($sql = "")
	{
		if($sql)
		{
			$this->qgQuery($sql);
		}
		$rsC = @mysql_num_rows($this->result);
		return $rsC;
	}
}
?>