首先构建一个MySQL类库…满足以下示例中的要求:
<?phpinclude '../config/Dbconfig.php';class Mysql extends Dbconfig {public $connectionString;public $dataSet;private $sqlQuery; protected $databaseName; protected $hostName; protected $userName; protected $passCode;function Mysql() { $this -> connectionString = NULL; $this -> sqlQuery = NULL; $this -> dataSet = NULL; $dbPara = new Dbconfig(); $this -> databaseName = $dbPara -> dbName; $this -> hostName = $dbPara -> serverName; $this -> userName = $dbPara -> userName; $this -> passCode = $dbPara ->passCode; $dbPara = NULL;}function dbConnect() { $this -> connectionString = mysql_connect($this -> serverName,$this -> userName,$this -> passCode); mysql_select_db($this -> databaseName,$this -> connectionString); return $this -> connectionString;}function dbDisconnect() { $this -> connectionString = NULL; $this -> sqlQuery = NULL; $this -> dataSet = NULL; $this -> databaseName = NULL; $this -> hostName = NULL; $this -> userName = NULL; $this -> passCode = NULL;}function selectAll($tableName) { $this -> sqlQuery = 'SELECT * FROM '.$this -> databaseName.'.'.$tableName; $this -> dataSet = mysql_query($this -> sqlQuery,$this -> connectionString); return $this -> dataSet;}function selectWhere($tableName,$rowName,$operator,$value,$valueType) { $this -> sqlQuery = 'SELECT * FROM '.$tableName.' WHERe '.$rowName.' '.$operator.' '; if($valueType == 'int') { $this -> sqlQuery .= $value; } else if($valueType == 'char') { $this -> sqlQuery .= "'".$value."'"; } $this -> dataSet = mysql_query($this -> sqlQuery,$this -> connectionString); $this -> sqlQuery = NULL; return $this -> dataSet; #return $this -> sqlQuery;}function insertInto($tableName,$values) { $i = NULL; $this -> sqlQuery = 'INSERT INTO '.$tableName.' VALUES ('; $i = 0; while($values[$i]["val"] != NULL && $values[$i]["type"] != NULL) { if($values[$i]["type"] == "char") { $this -> sqlQuery .= "'"; $this -> sqlQuery .= $values[$i]["val"]; $this -> sqlQuery .= "'"; } else if($values[$i]["type"] == 'int') { $this -> sqlQuery .= $values[$i]["val"]; } $i++; if($values[$i]["val"] != NULL) { $this -> sqlQuery .= ','; } } $this -> sqlQuery .= ')'; #echo $this -> sqlQuery; mysql_query($this -> sqlQuery,$this ->connectionString); return $this -> sqlQuery; #$this -> sqlQuery = NULL;}function selectFreeRun($query) { $this -> dataSet = mysql_query($query,$this -> connectionString); return $this -> dataSet;}function freeRun($query) { return mysql_query($query,$this -> connectionString); }}?>
和配置文件…
<?phpclass Dbconfig { protected $serverName; protected $userName; protected $passCode; protected $dbName; function Dbconfig() { $this -> serverName = 'localhost'; $this -> userName = 'root'; $this -> passCode = 'pass'; $this -> dbName = 'dbase'; }}?>
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)