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
转载随意!带上文章地址吧。