mysql数据库连接类
本款php连接mysql数据库连接程序代码是一款比较简单实用的连接代码,希望本教程对各位同学会有所帮助,代码如下:
<?php class mysql { public $sqlserver = 'localhost'; public $sqluser = 'root'; public $sqlpassword = ''; public $database; public $last_query = ''; private $connection; private $query_result; public function __construct() { } public function __destruct() { $this->close(); } //+======================================================+ // create a connection to the mysql database //+======================================================+ public function connect($server = null, $user = null, $password = null, $database = null) { if (isset($server)) $this->sqlserver = $server; if (isset($user)) $this->sqluser = $user; if (isset($password)) $this->sqlpassword = $password; if (isset($database)) $this->database = $database; $this->connection = mysql_connect($this->sqlserver, $this->sqluser, $this->sqlpassword); if ($this->connection) { if (mysql_select_db($this->database)) { return $this->connection; } else { return $this->error(); } } else { return $this->error(); } } //+======================================================+ // execute a query //+======================================================+ public function query($query, $die = false) { if ($query != null) { $this->last_query = $query; $this->query_result = mysql_query($query, $this->connection); if (!$this->query_result) { if ($die) die("die: " . $this->query_result); return $this->error(); } else { if ($die) die("die: " . $this->query_result); return $this->query_result; } } else { echo "empty query cannot be executed!"; } } //+======================================================+ // returns the result //+======================================================+ public function getresult() { return $this->query_result; } //+======================================================+ // returns the connection //+======================================================+ public function getconnection() { return $this->connection; } //+======================================================+ // returns an object with properties rep // resenting the result fields www.phprm.com and values //+======================================================+ public function getobject($qry = null) { if (isset($qry)) $this->query($qry); return mysql_fetch_object($this->getresult()); } //+======================================================+ // returns an array with keys representi // ng the result fields and values //+======================================================+ public function getarray($query_id = "") { if ($query_id == null) { $return = mysql_fetch_array($this->getresult()); } else { $return = mysql_fetch_array($query_id); } return $return ? $return : $this->error(); } //+======================================================+ // returns the number of rows in the res // ult //+======================================================+ public function getnumrows($qry = null) { if (isset($qry)) $this->query($qry); $amount = mysql_num_rows($this->getresult()); return emptyempty($amount) ? 0 : $amount; } //+======================================================+ // returns if the result contains rows //+======================================================+ public function hasresults($qry = null) { if (isset($qry)) $this->query($qry); return $this->getnumrows($qry) > 0; } //+======================================================+ // returns the number of rows that where // affected by the last action //+======================================================+ public function getaffectedrows($qry = null, $query_id = null) { if (isset($qry)) $this->query($qry); if (emptyempty($query_id)) { $return = mysql_affected_rows($this->getresult()); } else { $return = mysql_affected_rows($query_id); } return $return ? $return : $this->error(); } //+======================================================+ // returns the auto generated id from th // e last insert action //+======================================================+ public function getinsertid($connection_link = null) { return mysql_insert_id(isset($connection_link) ? $connection_link : $this->connection); } //+======================================================+ // close the connection to the mysql dat // abase //+======================================================+ public function close() { if (isset($this->connection)) { return @mysql_close($this->connection); } else { return $this->error(); } } //+======================================================+ // outputs the mysql error //+======================================================+ private function error() { if (mysql_error() != '') { echo '<b>mysql errorwww.phprm.com</b>: ' . mysql_error() . '<br/>'; } } } //demo // database object initialization $db = new mysql(); $db->connect("localhost", "root", "123456", "user"); // update query //$db->query("update table_name set field_name = value where another_field = another_value"); // select with check for record amount if ($db->hasresults("select * from userinfo")) { // loop through the user records, and get them as objects // note that the getobject method will use the last executed query when not provided with a new one while ($user = $db->getobject()) { echo "user $user->username is called $user->password<br /> "; } //开源代码phprm.com } else { echo "no results where found"; }
永久链接:http://www.phprm.com/mxdx/fs5417.html
转载随意!带上文章地址吧。