深深领悟php的MySQL连接类,php连接MySQL的二种方法

作者: 韦德国际1946手机版  发布:2019-07-24

懒得在Computer里开掘还应该有如此个Mysql的连接类,也不记得何地收藏的了,贴上来吧。
末尾几个show_databases和show_tables....等办法都用了一群echo,好像一向不希罕在类的主意里直接用输出语句,但是那也只是列举数据库和表名,构造函数的参数也能够给个暗中认可值吧。

php连接MySQL分析,php连接mysql

记录一下PHP连接MySQL的三种方法。

复制代码 代码如下:

Mysql:在PHP脚本中操作MySQL数据库的的多少个步骤如下:

  1、连接MySQL数据库服务器,并认清是或不是连接正确

  2、选用数据库,并安装字符集(可选)

  3、执行SQL命令

  4、管理结果集

  5、关闭数据库连接

先mock一下数额,能够实行一下sql。

<?php
/*
* filename:mysql数据库连接类
*/
class mysql{
 private $db_host;  //数据库主机
 private $db_user;  //数据库用户名
 private $db_pwd;   //数据库用户名密码
 private $db_database;    //数据库名
 private $conn;           //数据库连接标记;
 private $result;         //实施query命令的结果能源标记
 private $sql;   //sql实践语句
 private $row;     //重临的条约数
 private $coding;  //数据库编码,GBK,UTF8,gb2312
 private $bulletin = true;    //是不是开启错误记录
 private $show_error = true;  //测量试验阶段,展现全数错误,具备安全隐患,暗中同意关闭
 private $is_error = false;   //发现错误是或不是及时停下,暗许true,提出不启用,因为当不平日时用户什么也看不到是很困扰的
 /*构造函数*/
 public function __construct($db_host,$db_user,$db_pwd,$db_database,$conn,$coding){
      $this->db_host=$db_host;
      $this->db_user=$db_user;
      $this->db_pwd = $db_pwd;
      $this->db_database=$db_database;
      $this->conn=$conn;
      $this->coding=$coding;
      $this->connect();
    }
 /*数据库连接*/
 public function connect()
 {
  if($this->conn=="pconn"){
   //永远链接
      $this->conn=mysql_pconnect($this->db_host,$this->db_user,$this->db_pwd);
  }else{
   //即时链接
   $this->conn=mysql_connect($this->db_host,$this->db_user,$this->db_pwd);
  }
  if(!mysql_select_db($this->db_database,$this->conn)){
   if($this->show_error){
    $this->show_error("数据库不可用:",$this->db_database);
   }
  }
  mysql_query("SET NAMES $this->coding");
 }
 /*数据库实践语句,可进行查询增加修改删除等任何sql语句*/
 public function query($sql)
 {
  if($sql == ""){
  $this->show_error("sql语句错误:","sql查询语句为空");}
     $this->sql = $sql;
     $result = mysql_query($this->sql,$this->conn);
  if(!$result){
   //调节和测验中应用,sql语句出错开上下班时间会自动打字与印刷出来
   if($this->show_error){
    $this->show_error("错误sql语句:",$this->sql);
   }
  }else{
   $this->result = $result;
  }
     return $this->result;
 }
 /*成立增多新的数据库*/
 public function create_database($database_name){
  $database=$database_name;
深深领悟php的MySQL连接类,php连接MySQL的二种方法比较。  $sqlDatabase = 'create database '.$database;
  $this->query($sqlDatabase);
 }
 /*询问服务器全数数据库*/
 //将系统数据库与用户数据库分开,越来越直观的展示?
 public function show_databases(){
  $rs=$this->query("show databases");
  echo "现存数据库:".$amount =$this->db_num_rows($rs);
  echo "<br />";
  $i=1;
  while($row = $this->fetch_array($rs)){
   echo "$i $row[Database]";
   echo "<br />";
   $i ;
  }
 }
 //以数组方式重返主机中全数数据库名
 public function databases()
 {
  $rsPtr=mysql_list_dbs($this->conn);
  $i=0;
  $cnt=mysql_num_rows($rsPtr);
  while($i<$cnt)
  {
    $rs[]=mysql_db_name($rsPtr,$i);
    $i ;
  }
  return $rs;
 }
 /*查询数据库下具有的表*/
 function show_tables($database_name){
  $this->query("show tables");
  echo "现存数据库:".$amount = $this->db_num_rows($rs);
  echo "<br />";
  $i=1;
  while($row = $this->fetch_array($rs)){
   $columnName="Tables_in_".$database_name;
   echo "$i $row[$columnName]";
   echo "<br />";
   $i ;
  }
 }
 /*
 mysql_fetch_row()    array  $row[0],$row[1],$row[2]
 mysql_fetch_array()  array  $row[0] 或 $row[id]
 mysql_fetch_assoc()  array  用$row->content 字段大小写敏感
 mysql_fetch_object() object 用$row[id],$row[content] 字段大小写敏感
 */
 /*收获结果数据*/
 public function mysql_result_li()
 {
  return mysql_result($str);
 }
 /*赢得记录集,获取数组-索引和关系,使用$row['content'] */
 public function fetch_array()
 {
  return mysql_fetch_array($this->result);
 }
 //获取涉及数组,使用$row['字段名']
 public function fetch_assoc()
 {
  return mysql_fetch_assoc($this->result);
 }
 //获取数字索引数组,使用$row[0],$row[1],$row[2]
 public function fetch_row()
 {
  return mysql_fetch_row($this->result);
 }
 //获取对象数组,使用$row->content
 public function fetch_Object()
 {
  return mysql_fetch_object($this->result);
 }
 //简化查询select
 public function findall($table)
 {
  $this->query("SELECT * FROM $table");
 }
 //简化查询select
 public function select($table,$columnName,$condition)
 {
  if($columnName==""){
   $columnName="*";
  }
  $this->query("SELECT $columnName FROM $table $condition");
 }
 //简化删除del
 public function delete($table,$condition){
  $this->query("DELETE FROM $table WHERE $condition");
 }
 //简化插入insert
 public function insert($table,$columnName,$value){
  $this->query("INSERT INTO $table ($columnName) VALUES ($value)");
 }
 //简化修改update
 public function update($table,$mod_content,$condition){
  $this->query("UPDATE $table SET $mod_content WHERE $condition");
 }
 /*获取上一步 INSERT 操作产生的 ID*/
 public function insert_id(){
  return mysql_insert_id();
    }
 //指向分明的一条数据记录
 public function db_data_seek($id){
  if($id>0){
   $id=$id-1;
  }
  if(!@mysql_data_seek($this->result,$id)){
   $this->show_error("sql语句有误:", "钦定的数目为空");
  }
  return $this->result;
 }
 // 依据select查询结果总括结果集条数
 public function db_num_rows(){
   if($this->result==null){
    if($this->show_error){
     $this->show_error("sql语句错误","权且为空,未有别的内容!");
   }
   }else{
    return  mysql_num_rows($this->result);
   }
 }
 // 依据insert,update,delete实行结果获得影响行数
 public function db_affected_rows(){
   return mysql_affected_rows();
 }
 //输出呈现sql语句
 public function show_error($message="",$sql=""){
  if(!$sql){
   echo "<font color='red'>".$message."</font>";
   echo "<br />";
  }else{
   echo "<fieldset>";
   echo "<legend>错误音信提醒:</legend><br />";
   echo "<div style="font-size:14px; clear:both; font-family:Verdana, Arial, Helvetica, sans-serif;" mce_style="font-size:14px; clear:both; font-family:Verdana, Arial, Helvetica, sans-serif;">";
   echo "<div style='height:20px; background:#000000; border:1px #000000 solid'>";
   echo "<font color='white'>错误号:12142</font>";
   echo "</div><br />";
   echo "错误原因:".mysql_error()."<br /><br />";
   echo "<div style='height:20px; background:#FF0000; border:1px #FF0000 solid'>";
   echo "<font color='white'>".$message."</font>";
   echo "</div>";
   echo "<font color='red'><pre>".$sql."</pre></font>";
    $ip=$this->getip();
    if($this->bulletin){
     $time = date("Y-m-d H:i:s");
     $message=$message."/r/n$this->sql"."/r/n客户IP:$ip"."/r/n时间 :$time"."/r/n/r/n";
     $server_date=date("Y-m-d");
     $filename=$server_date.".txt";
     $file_path="error/".$filename;
     $error_content=$message;
     //$error_content="错误的数据库,不能链接";
     $file = "error"; //设置文件保留目录
     //创建文件夹
     if(!file_exists($file)){
      if(!mkdir($file,0777)){
      //暗中认可的 mode 是 0777,意味着最大恐怕的访谈权
       die("upload files directory does not exist and creation failed");
      }
     }
     //创建txt日期文件
     if(!file_exists($file_path)){
      //echo "创设日期文件";
      fopen($file_path,"w ");
      //首先要规定文件存在并且可写
      if (is_writable($file_path))
      {
       //使用增添形式展开$filename,文件指针将会在文件的启幕
       if (!$handle = fopen($file_path, 'a'))
       {
        echo "不能够展开文件 $filename";
        exit;
       }
        //将$somecontent写入到我们开采的文件中。
       if (!fwrite($handle, $error_content))
       {
        echo "无法写入到文件 $filename";
        exit;
       }
       //echo "文件 $filename 写入成功";
       echo "——错误记录被保存!";
       //关闭文件
       fclose($handle);
      } else {
       echo "文件 $filename 不可写";
      }
     }else{
      //首先要规定文件存在並且可写
      if (is_writable($file_path))
      {
       //使用增加情势展开$filename,文件指针将会在文书的启幕
       if (!$handle = fopen($file_path, 'a'))
       {
        echo "无法开发文件 $filename";
        exit;
       }
        //将$somecontent写入到大家开辟的文件中。
       if (!fwrite($handle, $error_content))
       {
        echo "无法写入到文件 $filename";
        exit;
       }
       //echo "文件 $filename 写入成功";
       echo "——错误记录被封存!";
       //关闭文件
       fclose($handle);
      } else {
       echo "文件 $filename 不可写";
      }
     }
    }
    echo "<br />";
    if($this->is_error){
     exit;
    }
   }
   echo "</div>";
   echo "</fieldset>";
  echo "<br />";
 }
 //释放结果集
 public function free(){
  @mysql_free_result($this->result);
 }
 //数据库选拔
 public function select_db($db_database){
  return mysql_select_db($db_database);
 }
 //查询字段数量
 public function num_fields($table_name){
  //return mysql_num_fields($this->result);
  $this->query("select * from $table_name");
  echo "<br />";
  echo "字段数:".$total = mysql_num_fields($this->result);
  echo "<pre>";
  for ($i=0; $i<$total; $i ){
   print_r(mysql_fetch_field($this->result,$i) );
  }
  echo "</pre>";
  echo "<br />";
 }
 //获得 MySQL 服务器音信
 public function mysql_server($num=''){
  switch ($num){
   case 1 :
   return mysql_get_server_info(); //MySQL 服务器新闻
   break;
   case 2 :
   return mysql_get_host_info();   //获得 MySQL 主机音信
   break;
   case 3 :
   return mysql_get_client_info(); //取得 MySQL 客户端消息
   break;
   case 4 :
   return mysql_get_proto_info();  //猎取 MySQL 协议音信
   break;
   default:
   return mysql_get_client_info(); //私下认可获得mysql版本音信
  }
 }
 //析构函数,自动关闭数据库,垃圾回收机制
 public function __destruct()
 {
  if(!empty($this->result)){
   $this->free();
  }
  mysql_close($this->conn);
 }//function __destruct();
 /*获得客户端真实的IP地址*/
 function getip(){
  if(getenv("HTTP_CLIENT_IP") && strcasecmp(getenv("HTTP_CLIENT_IP"), "unknown"))
  {
   $ip = getenv("HTTP_CLIENT_IP");
  }
  else if (getenv("HTTP_X_FORWARDED_FOR") && strcasecmp(getenv("HTTP_X_FORWARDED_FOR"), "unknown")){
   $ip = getenv("HTTP_X_FORWARDED_FOR");
  }
  else if (getenv("REMOTE_ADDR") && strcasecmp(getenv("REMOTE_ADDR"), "unknown"))
  {
   $ip = getenv("REMOTE_ADDR");
  }
  else if (isset($_SERVER['REMOTE_ADDR']) && $_SERVER['REMOTE_ADDR'] && strcasecmp($_SERVER['REMOTE_ADDR'], "unknown")){
  $ip = $_SERVER['REMOTE_ADDR'];
  }
  else{
   $ip = "unknown";
  }
  return($ip);
 }
}
?>

接连MySQL数据库服务器,并剖断是或不是连接准确

mysql_connect()

mysql_connect()函数用来开采二个到 MySQL 服务器的一而再。固然成功则赶回贰个财富, 大概在曲折时回来FALSE

resource mysql_connect ([ string $server [, string $username [, string $password [, bool $new_link [, int $client_flags ]]]]] )

mysql_errno()

mysql_errno()函数用于重回上贰个 MySQL 操作中的错误音讯的数字编码

int mysql_errno ([ resource $link_identifier ] )

mysql_error()

mysql_error()函数用于重返上三个 MySQL 操作产生的公文错误新闻。若无一些名连接财富号,则选拔上叁个得逞开采的接连从 MySQL 服务器提取错误新闻

string mysql_error ([ resource $link_identifier ] )

图片 1

<?php
$link = mysql_connect('localhost','root','123456');
var_dump($link);//resource(3, mysql link)
if(!$link){
    die('连接失败:'.mysql_error());
}
?>

图片 2

/*创建数据库*/
CREATE DATABASE IF NOT EXISTS `test`;
/*选择数据库*/
USE `test`;
/*创建表*/
CREATE TABLE IF NOT EXISTS `user` (
  name varchar(50),
  age int
);
/*插入测试数据*/
INSERT INTO `user` (name, age) VALUES('harry', 20), ('tony', 23), ('harry', 24);

你或然感兴趣的稿子:

  • 一款轻易实用的php操作mysql数据库类
  • PHP以mysqli情势连接类完整代码实例
  • php达成mysql封装类示例
  • PHP数据库操作之基于Mysqli的数据库操作类库
  • php操作mysql数据库的基本类代码
  • 依据php和mysql的大致的dao类落成crud操作作用
  • php写的带缓存数据成效的mysqli类
  • 斩新的PDO数据库操作类php版(仅适用Mysql)
  • 详解MYSQL的备份还原(PHP完成)
  • PHP备份/还原MySQL数据库的代码
  • php达成MySQL数据库备份与还原类实例

慎选数据库,并设置字符集(可选)

先是种是行使PHP原生的不二等秘书诀去老是数据库。代码如下:

本文由韦德国际1946发布于韦德国际1946手机版,转载请注明出处:深深领悟php的MySQL连接类,php连接MySQL的二种方法

关键词: