MYSQL經常使用操做函數的封裝

 

1.mysql經常使用函數封裝文件：mysql.func.php

<?php
/**
 * 鏈接MYSQL函數
 * @param string $host
 * @param string $username
 * @param string $password
 * @param string $dbName
 * @param string $charset
 * @return resource
 */
function connect($host,$username,$password,$dbName,$charset){
    //鏈接mysql
    $link=@mysql_connect($host,$username,$password) or die ('數據庫鏈接失敗<br/>ERROR '.mysql_errno().':'.mysql_error());
    //設置字符集
    mysql_set_charset($charset);
    //打開指定的數據庫
    mysql_select_db($dbName)or die('指定的數據庫打開失敗');    
    return $link;
    
}

/**
 * 鏈接MYSQL函數,須要在鏈接的時候傳遞一個數組
 * @param array $config
 * @return resource
 */
function connect1 ($config){
    //鏈接mysql
    $link=@mysql_connect($config['host'],$config['username'],$config['password']) or die ('數據庫鏈接失敗<br/>ERROR '.mysql_errno().':'.mysql_error());
    //設置字符集
    mysql_set_charset($config['charset']);
    //打開指定的數據庫
    mysql_select_db($config['dbName']) or die('指定的數據庫打開失敗');    
    return $link;
}

/**建議使用該函數
 * 鏈接MYSQL函數,經過常量的形式來鏈接數據庫
 * 自定義配置文件，配置文件中自定義常量，包含須要使用的信息
 * @return resource
 */
function connect2 (){ 
    //鏈接mysql
    $link=@mysql_connect(DB_HOST,DB_USER,DB_PWD) or die ('數據庫鏈接失敗<br/>ERROR '.mysql_errno().':'.mysql_error());
    //設置字符集
    mysql_set_charset(DB_CHARSET);
    //打開指定的數據庫
    mysql_select_db(DB_DBNAME) or die('指定的數據庫打開失敗');
    return $link;
}



/* array(
'username'=>'king',
'password'=>'123123',
'email'=>'dh@qq.com'
) */

/**
 * 插入記錄的操做
 * @param array $array
 * @param string $table
 * @return boolean
 */
function insert($array,$table){
    $keys=join(',',array_keys($array));
    $values="'".join("','", array_values($array))."'";
    $sql="insert {$table}({$keys}) VALUES ({$values})";
    $res=mysql_query($sql);
    if($res){
        return mysql_insert_id();
    }else{
        return false;
    }
}


/**
 * MYSQL更新操做
 * @param array $array
 * @param string $table
 * @param string $where
 * @return number|boolean
 */
function update($array,$table,$where=null){
    foreach ($array as $key=>$val){
        $sets.=$key."='".$val."',";
    }
    $sets=rtrim($sets,','); //去掉SQL裏的最後一個逗號
    $where=$where==null?'':' WHERE '.$where;
    $sql="UPDATE {$table} SET {$sets} {$where}";
    $res=mysql_query($sql);
    if ($res){
        return mysql_affected_rows();
    }else {
        return false;
    }
}


/**
 * 刪除記錄的操做
 * @param string $table
 * @param string $where
 * @return number|boolean
 */
function delete($table,$where=null){
    $where=$where==null?'':' WHERE '.$where;
    $sql="DELETE FROM {$table}{$where}";
    $res=mysql_query($sql);
    if ($res){
        return mysql_affected_rows();
    }else {
        return false;
    }
}



/**
 * 查詢一條記錄
 * @param string $sql
 * @param string $result_type
 * @return boolean
 */
function fetchOne($sql,$result_type=MYSQL_ASSOC){
    $result=mysql_query($sql);
    if ($result && mysql_num_rows($result)>0){
        return mysql_fetch_array($result,$result_type);
    }else {
        return false;
    }
}





/**
 * 獲得表中的全部記錄
 * @param string $sql
 * @param string $result_type
 * @return boolean
 */
function fetchAll($sql,$result_type=MYSQL_ASSOC){
    $result=mysql_query($sql);
    if ($result && mysql_num_rows($result)>0){
        while ($row=mysql_fetch_array($result,$result_type)){
            $rows[]=$row;
        }
        return $rows;
    }else {
        return false;
    }
}


/**取得結果集中的記錄的條數
 * @param string $sql
 * @return number|boolean
 */
function getTotalRows($sql){
    $result=mysql_query($sql);
    if($result){
        return mysql_num_rows($result);
    }else {
        return false;
    }
    
}

/**釋放結果集
 * @param resource $result
 * @return boolean
 */
function  freeResult($result){
    return  mysql_free_result($result);
}



/**斷開MYSQL
 * @param resource $link
 * @return boolean
 */
function close($link=null){
    return mysql_close($link);
}


/**獲得客戶端的信息
 * @return string
 */
function getClintInfo(){
    return mysql_get_client_info();
}


/**獲得MYSQL服務器端的信息
 * @return string
 */
function getServerInfo($link=null){
    return mysql_get_server_info($link);
}



/**獲得主機的信息
 * @return string
 */
function getHostInfo($link=null){
    return mysql_get_host_info($link);
}

/**獲得協議信息
 * @return string
*/
function getProtoInfo($link=null){
    return mysql_get_proto_info($link);
}

 

2. 數據庫配置文件：config.php

<?php
define('DB_HOST', 'localhost');
define('DB_USER', 'root');
define('DB_PWD', '');
define('DB_CHARSET', 'UTF8');
define('DB_DBNAME', 'homework');

 

3. mysql函數使用（測試）文件：testMysqlFunc.php

<?php
header('content-type:text/html;charset=utf-8');
require_once 'mysql.func.php';
require_once 'config.php';
//鏈接
/* $host='localhost';
$username='root';
$password='';
$charset='UTF8';
$dbName='homework';
$link=connect($host, $username, $password, $dbName, $charset);
var_dump($link); */


/* $config=array(
    'host'=>'localhost',
    'username'=>'root',
    'password'=>'',
    'charset'=>'UTF8',
    'dbName'=>'homework'    
);
$link=connect1($config);
var_dump($link); */

$link=connect2();
//var_dump($link);

$array=array(
'username'=>'king1',
'password'=>'1231231',
'email'=>'dh1@qq.com',
'age'=>'12',
'sex'=>'女'    
);

// $table='users2';
// $res=insert($array, $table);
// var_dump($res);

// $table='users2';
// $res=update($array, $table,'id=3');
// var_dump($res);


// $table='users2';
// $res=delete($table,'id=1');
// var_dump($res);


// $sql='SELECT * FROM users2 WHERE id=1 ';
// $row=fetchOne($sql);
// var_dump($row);

$sql='SELECT * FROM users2';
$rows=fetchAll($sql);
var_dump($rows);