sqlite.db.class.php

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

<?php
#[类库sql]
class qgSQL
{
	var $queryCount = 0;
	var $host;
	var $user;
	var $pass;
	var $data;
	var $conn;
	var $result;
	var $rsType = SQLITE_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(!file_exists($this->host.$this->data))
		{
			die("DataBase:".$this->host.$this->data." Not Exists!");
		}
		if($dbconn)
		{
			$this->conn = @sqlite_popen($this->host.$this->data,0666) OR die("cann't connect database ".$this->host.$this->data);
		}
		else
		{
			$this->conn = @sqlite_open($this->host.$this->data,0666) OR die("cann't connect database ".$this->host.$this->data);
		}
	}

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

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

	function qgQuery($sql,$type="ASSOC")
	{
		$this->rsType = $type != "ASSOC" ? ($type == "NUM" ? SQLITE_NUM : SQLITE_BOTH) : SQLITE_ASSOC;
		sqlite_query($this->conn,"BEGIN TRANSACTION");#[开始启用事务]
		$this->result = sqlite_query($this->conn,$sql);
		$this->queryCount++;
		if($this->result)
		{
			#[提交事务]
			sqlite_query($this->conn,"COMMIT TRANSACTION");#[提交事务]
			return $this->result;
		}
		else
		{
			sqlite_query($this->conn,"ROLLBACK TRANSACTION");#[回滚事务]
			return false;
		}
	}

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

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

	function qgInsertID()
	{
		return @sqlite_last_insert_rowid($this->conn);
	}

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