php中连接MySQL数据库用到的接口定义如下：
php
/*
* 建立连接, mysql_connect,打开一个到MySQL服务器的连接,
* 失败返回false,
* 成功返回一个MySQL连接标识
*/
if(!$db){
die('连接建立错误: ' . mysql_error());
}
if(!mysql_select_db("php")){//选择数据库,成功返回true,失败返回false
die('数据库选择错误: ' . mysql_error());
* 发送一条MySQL查询,仅对SELECT,SHOW,EXPLAIN,DESCRIBE语句返回一个资源标识符,查询不正确则返回false,
* 对于其它类型的SQL语句,mysql_query()执行成功时返回true,出错时返回false.
* 非false的返回值代表查询时合法的并且能被服务器执行,但并不表示影响到的行数或返回的行数,
* 因为一条查询有可能执行成功了但并不返回或者影响到任何行.
$insertresult = mysql_query($insertSQL);
if($insertresult != false){//查询成功
* 取得最近一次与 link_identifier 关联的 INSERT,UPDATE 或 DELETE 查询所影响的记录行数.
* 执行成功则返回受影响的行的数目,如果最近一次查询失败的话,函数返回 -1.
$number = mysql_affected_rows();
echo "插入影响行数:".$number."br /";
* 取得上一步 INSERT 操作产生的 ID ,返回上一步 INSERT 查询中产生的 AUTO_INCREMENT 的 ID 号,
* 如果上一查询没有产生 AUTO_INCREMENT 的值,则 mysql_insert_id() 返回 0.
* 如果需要保存该值以后使用,要确保在产生了值的查询之后立即调用 mysql_insert_id().
* 此处由于没有 AUTO_INCREMENT,所以返回0.
echo mysql_insert_id()."br /";
$updateresult = mysql_query($updateSQL);
if($updateresult !=FALSE){//更新操作
$number = mysql_affected_rows();//大于0则成功
echo "更新影响行数:".$number."br /";
$deleteresult = mysql_query($deleteSQL);
if($deleteresult !=FALSE){//更新操作
$number = mysql_affected_rows(); //大于0则成功
echo "删除影响行数:".$number."br /";
mysql_close($db);//关闭连接,成功返回true,失败返回false.
统一的数据访问接口PDO
PDO（PHP Data Objects） 扩展为 PHP 访问数据库定义了一个轻量级的、一致性的接口,它提供了一个数据访问抽象层,这样,无论使用什么数据库,用户都可以通过统一的函数执行来查询和获取数据.注意,你并不能使用 PDO 扩展本身执行任何数据库操作,必须使用一个 database-specific PDO driver （针对特定数据库的 PDO 驱动）访问数据库服务器.
我自己封装的一个
class AppConfig{
public static $dbParam = array(
'dbHost' = 'localhost',
'dbUser' = 'root',
'dbPassword' ='',
'dbName' = '数据库名',
'dbPrefix' = 'test_',
'dbPconnect' = 0,
'dbDebug' = true,
);
class Model {
private $version = ''; //mysql版本
private $config = array(); //数据库配置数组
private $class; //当前类名
public $tablepre = 'ts_'; //表前缀
public $db = ''; //库名
public $table = ''; //表名
private static $link; //数据库链接句柄
private $data = array(); //中间数据容器
private $condition = ''; //查询条件
private $fields = array(); //字段信息
private $sql = array(); //sql集合,调试用
public $primaryKey = 'id'; //表主键
//构造函数初始化
public function __construct($dbParam = array()) {
$this-config = (is_array($dbParam) !empty($dbParam)) ? $dbParam : AppConfig::$dbParam;
$this-connect();
$this-init();
//链接数据库
private function connect() {
if($this-config['dbPconnect']) {
self::$link = @mysql_pconnect($this-config['dbHost'], $this-config['dbUser'], $this-config['dbPassword']);
}else{
self::$link = @mysql_connect($this-config['dbHost'], $this-config['dbUser'], $this-config['dbPassword'], true);
mysql_errno(self::$link) != 0 $this-errdie('Could not connect Mysql: ');
$this-db= !empty($this-db) ? $this-db : $this-config['dbName'];
$serverinfo = $this-version();
mysql_query("SET character_set_connection=".$this-config['dbCharset'].",character_set_results=".$this-config['dbCharset'].",character_set_client=binary", self::$link);
mysql_query("SET sql_mode=''", self::$link);
@mysql_select_db($this-db, self::$link) or $this-errdie('Cannot use database');
return self::$link;
//表基本信息初始化
protected function init() {
$this-class = get_class($this);
$this-table = !empty($this-table) ? $this-table : strtolower($this-class);
$this-table = $this-tablepre . $this-table;
return $this;
//设置属性值
public function __set($name, $value) {
//exit($value);
$this-data['fields'][$name] = $value;
//获取属性值
public function __get($name) {
if(isset($this-data['fields'][$name])) {
return($this-data['fields'][$name]);
}else {
return NULL;
//字段信息处理
private function implodefields($data) {
if (!is_array($data)) {
$data = array();
$this-fields = !empty($this-data['fields']) ? array_merge($this-data['fields'], $data) : $data;
foreach($this-fields as $key = $value) {
$fieldsNameValueStr[] = "+$key+='$value'";
$fieldsNameStr[] = "+$key+";
$fieldsValueStr[] = "'$value'";
return array($fieldsNameValueStr, $fieldsNameStr, $fieldsValueStr);
//条件判断组装
private function condition($where = NULL) {
if (is_numeric($where)) {
$where = "WHERE +{$this-primaryKey}+='{$where}' LIMIT 1";
}elseif (is_array($where)){
$where = "WHERE +{$this-primaryKey}+ in (".implode(',',$where).")";
}elseif(!empty($this-data['condition'])){
//'预留WHERE', 'order', 'group', 'limit' ............等条件关键词处理接口
$where = $where ? "WHERE {$where}" : "WHERE 1";
isset($this-data['condition']['where']) $where .= ' AND '.$this-data['condition']['where'];
isset($this-data['condition']['group']) $where .= ' GROUP BY '.$this-data['condition']['group'];
isset($this-data['condition']['order']) $where .= ' ORDER BY '.$this-data['condition']['order'];
isset($this-data['condition']['limit']) $where .= ' LIMIT '.$this-data['condition']['limit'];
$where = "WHERE {$where}";
$this-condition = $where;
//插入数据
public function insert($data = array(), $replace = false) {
$fields = $this-implodefields($data);
$insert = $replace ? 'REPLACE' : 'INSERT';
$this-query($sql);
return $this-getInsertId();
//更新数据
public function update($data = array() ,$where = '') {
$numargs = func_num_args();
if ($numargs == 1) {
$where = $data;
$this-condition($where);
$sql = "UPDATE +{$this-db}+.+{$this-table}+ SET ".implode(', ',$fields[0])." {$this-condition}";
return $this-getAffectedRows();
//删除数据
public function delete($where = NULL) {
$sql = $where;
$sql = "DELETE FROM +{$this-db}+.+{$this-table}+ {$this-condition}";
//查询数据
public function select($where = NULL, $fields = '*') {
$sql = "SELECT {$fields} FROM +{$this-db}+.+{$this-table}+ {$this-condition}";
return $this-fetch($this-query($sql));
//查询一条数据
public function getOne($where, $fields = '*') {
$data = $this-select($where, $fields = '*');
if($data) {
return $data[0];
return array();
//查询多条数据
public function getAll($where, $fields = '*') {
return $data;
//结果数量
public function getCount($where = '', $fields = '*') {
$sql = "SELECT count({$fields}) as count FROM +{$this-db}+.+{$this-table}+ {$this-condition}";
$data = $this-query($sql);
if($data){
return @mysql_result($data,0);
return 0;
public function query($sql, $flag = '0', $type = '') {
if ($this-config['dbDebug']) {
$startime = $this-microtime_float();
//查询
if ($type == 'UNBUFFERED' function_exists('mysql_unbuffered_query')) {
$result = @mysql_unbuffered_query($sql, self::$link);
} else {
//exit($sql);
$result = @mysql_query($sql, self::$link);
//重试
$result = $this-query($sql);
if ($result === false) {
$this-errdie($sql);
$endtime = $this-microtime_float();
$this-sql[] = array($sql,$endtime-$startime);
//清空操作数据
$this-data = array();
return $flag == '0' ? $result : ($flag == '1' ? $this-getInsertId() : $this-getAffectedRows());
//返回结果$onlyone为true返回一条否则返回所有,$type有MYSQL_ASSOC,MYSQL_NUM,MYSQL_BOTH
public function fetch($result, $onlyone = false, $type = MYSQL_ASSOC) {
if($result){
if ($onlyone) {
$row = @mysql_fetch_array($result, $type);
return $row;
$rowsRs = array();
$rowsRs[] = $row;
return $rowsRs;
//可以运行SELECT,SHOW,EXPLAIN 或 DESCRIBE 等返回一个资源标识符的语句得到返回结果数组
public function show($sql, $onlyone = false) {
return $this-fetch($this-query($sql), $onlyone);
// 使用call函数处理同类型函数
private function __call($name, $arguments) {
$callArr = array('on', 'where', 'order', 'between', 'group', 'limit');
if (in_array($name, $callArr)) {
$this-data['condition'][$name] = $arguments[0];
$this-errdie("function error: function {$name} is not in ($this-class) class exist");
//返回最后一次插入ID
public function getInsertId() {
return @mysql_insert_id(self::$link);
//返回受影响行数
public function getAffectedRows() {
return @mysql_affected_rows(self::$link);
//获取错误信息
private function error() {
return ((self::$link) ? @mysql_error(self::$link) : @mysql_error());
//获取错误信息ID
private function errno() {
return ((self::$link) ? @mysql_errno(self::$link) : @mysql_errno());
//获取版本信息
function version() {
if(empty($this-version)) {
$this-version = mysql_get_server_info(self::$link);
return $this-version;
//打印错误信息
private function errdie($sql = '') {
die('/BRBMySQL ERROR/B/BR
SQL:'.$sql.'/BR
ERRNO:'.$this-errno().'/BR
ERROR:'.$this-error().'/BR');
die('DB ERROR！！！');
//获取时间微妙数
private function microtime_float()
{
list($usec, $sec) = explode(" ", microtime());
return ((float)$usec + (float)$sec);
//析构函数
public function __destruct() {
echo 'hr';
$this-config['dbDebug'] print_r($this-sql);
//unset($this-result);
//unset($this-condition);
//unset($this-data);
class user extends Model {
//public $db = 'qsf_mvc';
//public $table = 'user';
public $primaryKey = 'uid';
$userObj = new user();
//---------------------------------------插入数据方法一-----------------------------------------
//模拟ActiveRecord模式 插入数据
$userObj-username = 'hoho';
$userObj-sex = 1;
$userObj-desc = '清洁工';
$insetId = $userObj-insert();
if ($insetId 0) {
echo "插入ID为:{$insetId}BR";
//---------------------------------------插入数据方法二-----------------------------------------
//直接数组做参数插入数据
$userArr = array(
'username' = 'hoho',
'sex' = '1',
'desc' = '厨师',
$insetId = $userObj-insert($userArr);
//---------------------------------------更新数据方法一----------------------------------------
$userObj-username = 'h111oho';
if ($affectedRows1 0) {
echo "影响行数为:{$affectedRows1}BR";
//---------------------------------------更新数据方法二----------------------------------------
//更新记录（传递参数的方式和insert操作一样）
'username' = 'hohoho',
'sex' = '0',
'desc' = '厨师qq',
$affectedRows = $userObj-update($userArr, $insetId);
if ($affectedRows 0) {
echo "影响行数为:{$affectedRows}BR";
//----------------------------------------查询数据----------------------------------------------
//print_r($userRs0);
//print_r($userRs1);
//----------------------------------------删除数据-----------------------------------------------
//删除操作传递参数的方式和select操作一样
$userObj-delete('delete from user where uid 100'); //直接完整sql语句
$userObj-delete("+uid+ 100"); //where条件
//----------------------------------------特殊查询-----------------------------------------------
$userShowRs = $userObj-show('show create table user', true); //获取特殊查询的结果,第二个参数代表返回一条结果还是所有的结果
以上就是土嘎嘎小编为大家整理的php数据库接口相关主题介绍,如果您觉得小编更新的文章只要能对粉丝们有用,就是我们最大的鼓励和动力,不要忘记讲本站分享给您身边的朋友哦！！