db.php

flashget43的源代码 一个比较常用的下载程序

<?php
	define('STATEMENT_SELECT', 'select');
	define('STATEMENT_INSERT', 'insert');
	define('STATEMENT_UPDATE', 'update');
	define('STATEMENT_DELETE', 'delete');
	
	class Statement {
		var $queryArray;
		var $type = STATEMENT_SELECT;
		var $conn = null;
		
		function Statement($queryStr) {
			if( !isset($GLOBAL['fc_config']['db_conn']) ) 
			{
				$GLOBAL['fc_config']['db_conn'] = mysql_connect($GLOBALS['fc_config']['db']['host'], $GLOBALS['fc_config']['db']['user'], $GLOBALS['fc_config']['db']['pass']);
				//mysql_query("SET NAMES utf8", $GLOBAL['fc_config']['db_conn']);
			}	
			$this->conn = $GLOBAL['fc_config']['db_conn'];
			
			$this->queryArray = split('\?', $queryStr);
			$this->type = strtolower(substr($queryStr, 0, 6));
		}

		function process(/*...*/) {
			if(func_num_args() > 0) {
				$params = func_get_args();
			} else {
				$params = array();
			}
			
			if( $this->conn ) {
				if(mysql_select_db($GLOBALS['fc_config']['db']['base'], $this->conn)) {
					$queryStr = '';
					for($i = 0; $i < sizeof($this->queryArray) - 1; $i++) {
						$val = '';

						switch(gettype($params[$i])) {
							case 'object': $val = "'" . mysql_escape_string($params[$i]->toString()) . "'"; break;
							case 'array': $val = "'" . mysql_escape_string(join(',', $params[$i])) . "'"; break;
							case 'boolean': $val = ($params[$i])?-1:0; break;
							case 'NULL': $val = 'NULL'; break;
							default: $val = "'" . mysql_escape_string($params[$i]) . "'"; break;
						}

						$queryStr .= $this->queryArray[$i] . $val;
					}

					$queryStr .= $this->queryArray[$i];
					
					//toLog('QRY', $queryStr);
					
					if($result = mysql_query($queryStr, $this->conn)) {
						switch($this->type) {
							case STATEMENT_SELECT: return new ResultSet($result);
							case STATEMENT_INSERT: return mysql_insert_id($this->conn);
							default: return mysql_affected_rows($this->conn);
						}
					}
				}
			}

			//trigger_error("MySQL error " . mysql_errno() . " : " . mysql_error());
			return null;
		}
	}

	class ResultSet {
		var $result;
		var $numRows = 0;
		var $currRow = 0;

		function ResultSet($result = null) {
			$this->result = $result;
			if($result) $this->numRows = mysql_num_rows($result);
		}

		function hasNext() {
			return ($this->result && $this->numRows > $this->currRow);
		}

		function next() {
			if($this->hasNext()) {
				$this->currRow++;
				return mysql_fetch_assoc($this->result);
			} else {
				return null;
			}
		}
	}
?>