当前位置: 移动技术网 > IT编程>开发语言>PHP > php数据库接口

php数据库接口

2018年09月13日  | 移动技术网IT编程  | 我要评论

三套方案 mysql mysqli pdo
1、mysql扩展库 效率不怎么高的
2、mysqli扩展库
3、pdo 可以操作任何一种数据库
mysql扩展库和mysqli的扩展库,扩展库就是操作数据库的一个集合
my是用于存放数据的
可以查看php可以使用的扩展库 phpinfo();
创建新表

create table  user(
  id int primary key auto_increment,
  name varchar(32) not null,
  password  varchar(64) not null,
   emial varchar(128) not null,
  age   tinyint unsigned not null
) 

预先加载数据
mysql中密码的处理,对一个明文成一个密文,而且这个过程是不可逆的。由密文推不出明文。
insert into user(name,password,emial,age) values(‘zs’,md5(‘123456’),’1051743154@qq.com’,12)其中md5这个函数就是实现对密码的加密
解决数据库不能插入中文
insert into user(name,password,emial,age) values(‘赵文娟’,md5(‘123432326’),’1051743154@qq.com’,12)
中文在数据库就不能正常的显示
新建数据库的时候一定要选择正确的编码格式
php利用扩展库操作mysql
1、获取连接
connection=mysqlconnect(“127.0.0.1”,”root”,”“);if(!connection){
die(“连接失败”.mysql_error);
}
2、选择数据库
mysql_select_db(“senjintang”);
3、设置操作编码
mysql_query(“set names utf8”); 出现中文乱码的时候可以尝试使用
4、向数据库发送指令sql(ddl数据定义语言 创建表 dml数据操作语言 dql数据查询语句select dtl数据事物语句 rollback commit)
res=mysqlquery(sql,connection);5、接受返回的结果并处理while(row=mysql_fetch_row(res))echo“$row[0]??$row[1]–$row[2]??$row[3]–$row[4]”;mysqlfetchrow(res) 返回一个索引数组
mysql_fetch_assoc(res)返回一个关联数组mysqlfetcharray(res) 返回索引数组和关联数组两套
mysql_fetch_object(res)把一行数据当作一个对象mysqlfetchrow(res)返回的是结果集的下一行,会一次取出结果集中的下一行
但是这资格函数使用完以后,都必须释放资源
6、释放资源,关闭连接
mysql_free_result($res); //释放结果集
mysql_close(); //关闭连接 不是必须的,会在脚本执行完以后自动关闭
mysqli_error() 可以打印连接的错误
注意:在对数据库执行dml(非select的数据库查询以后),一定不要再进行释放资源,也就是 mysql_free_result(res);因为当前的res是一个布尔值。所以:对数据的操作严格的区分有无结果集的的返回。

对mysql数据库进行crud操作 使用的是mysql_

实现对数据库的插入操作

 //server的名称  数据库的用户名和密码
    $connection=mysql_connect("127.0.0.1","root","");
    if(!$connection){
       die("连接失败".mysql_error);
    }
    mysql_select_db("senjintang");
    mysql_query("set names utf8");
    $sql="insert into user(name,password,emial,age) values ('小敏',md5('123'),'xiaoming',34)";
    //如果是dml操作,调用这个函数以后返回的是一个布尔值
    $res=mysql_query($sql,$connection);
    $affected_number=mysql_affected_rows($connection);
    if(!$res){
       die("操作失败".mysql_error());
    }
     if($affected_number>0){
           echo "对数据库的影响为$affected_number";
         }else{
           echo "操作没成功";
         }
    mysql_close($connection);

实现对数据库删除数据的操作

 //server的名称  数据库的用户名和密码
    $connection=mysql_connect("127.0.0.1","root","");
    if(!$connection){
       die("连接失败".mysql_error);
    }
    mysql_select_db("senjintang");
    mysql_query("set names utf8");
    $sql="delete from user where id=5";
    //如果是dml操作,调用这个函数以后返回的是一个布尔值
    $res=mysql_query($sql,$connection);
    $affected_number=mysql_affected_rows($connection);
    if(!$res){
       die("操作失败".mysql_error());
    }
     if($affected_number>0){
           echo "对数据库的影响为$affected_number";
         }else{
           echo "操作没成功";
         }
    mysql_close($connection);

对数据库的更新操作

 //server的名称  数据库的用户名和密码
    $connection=mysql_connect("127.0.0.1","root","");
    if(!$connection){
       die("连接失败".mysql_error);
    }
    mysql_select_db("senjintang");
    mysql_query("set names utf8");
    $sql="update user set age=100  where id=4";
    //如果是dml操作,调用这个函数以后返回的是一个布尔值
    $res=mysql_query($sql,$connection);
    $affected_number=mysql_affected_rows($connection);
    if(!$res){
       die("操作失败".mysql_error());
    }
     if($affected_number>0){
           echo "对数据库的影响为$affected_number";
         }else{
           echo "操作没成功";
         }
    mysql_close($connection);

上面可见代码的复用性不高,所以将对数据库的操作封装成一个工具类。
mysqltool.php

conn=mysql_connect($this->host,$this->user,$this->password);
       if(!($this->conn)){
          die("连接数据库发生错误".mysql_error());
       }
       mysql_select_db($this->db,$this->conn);
       mysql_query("set names utf8");
     }
     //完成slect
     public  function execute_dql($sql){
     //失败的时候就退出了
        $res=mysql_query($sql) or die(mysqli_error());
        return $res;
     }
     //完成dml
     public  function execute_dml($sql){
       $b=mysql_query($sql,$this->conn);
       if(!$b){
         return 0;   //表示失败
       }else{
         if(mysql_affected_rows($this->conn)>0){
            return 1;//表示成功
         }
         else{
            return 2;  //表示没有对数据库影响
         }
       }
     }
  }
?>

使用mysqli(improvement)来操作数据库

相当于上面的mysql的扩展库的一个增强版
mysql和mysqli的比较
1、稳定性、安全性、效率有所提高
2、mysqli提供了面向对象的思想。
mysqli有两套编程风格
面向对象
1、创建mysqli对象

$mysqli=new mysqli("127.0.0.1","root","","senjintang");
     //按章是否ok
     if($mysqli->connect_error){
        die("连接失败".$mysqli->connect_error);
     }
     else{
       echo  "连接成功";
     }

2、操作数据库

 $sql="select * from user";
     $res=$mysqli->query($sql);

3、处理结果

  while($row=$res->fetch_row()){
        foreach($row as $key=>$val){
           echo $val;
        }
        echo  "
";
     }

4、关闭资源

  //关闭资源   这一个步骤是必须的
     $res->free();
     //断开连接
     $mysqli->close();

使用面向对象的方式,实现利用扩展库对数据库的操作

connect_error){
        die("连接失败".$mysqli->connect_error);
     }
     else{
       echo  "连接成功";
     }
      $mysqli->query("set names utf8");
     $sql="select * from user";
     $res=$mysqli->query($sql);
     //返回的是一个对象  mysqliresult
      echo "
";
     var_dump($res);
      echo "
";
     //fetch_row这是mysqliresult的一个方法
     while($row=$res->fetch_row()){
        foreach($row as $key=>$val){
           echo $val;
        }
        echo  "
";
     }
     //关闭资源   这一个步骤是必须的
     $res->free();
     //断开连接
     $mysqli->close();
     //对于这种面向对象的方式,
?>

注意:防乱码
//防止乱码
header(“content-type:text-html;charset=utf-8”);
可以保证往数据库里边插入正确的汉字
$mysqli->query(“set names utf8”);
mysql中sql语句的特别说明:
如果操作的字段类型是字符串类型的则要求我们要使用”包括,
如果操作的字段是数值型的,则可以用”包括,也可以不使用

分装mysqli的操作,实现对数据库的crud

mysqli=new mysqli(self::$host,self::$user,self::$password,self::$db);
            if($this->mysqli->connect_error){
                die("连接失败").$this->mysqli->connect_error;
            }
            //设置访问数据库的字符集
            //这句话的作用是保证php是以utf8的方式来操作mysql数据库
            $this->mysqli->query("set names utf8");
         }

         public function execute_dql($sql){
             $res=$this->mysqli->query($sql) or die("操作dql".$this->mysqli->error);
             return $res;
        }
          public function execute_dml($sql){
            $res=$this->mysqli->query($sql) or die("操作dql".$this->mysqli->error);
                 if(!$res){
                    return 0;  //表示失败
                 }
                 else if($this->mysqli->affected_rows>0){
                     return 1;   //表示成功执行
                 }
                 else{
                     return 2;   //表示没有收影响的行数
                 }
        }
      }

?>

mysqli的增强

mysql可以批量执行sql语句
1、批量执行dml语句
基本语法:
sqls="sql1;sql2…..”;mysqli::multiquery(sqls);
批量添加、更新、删除

connect_error){
     die("连接错误".$mysqli->connect_error);
   }
    $mysqli->query("set names utf8");
   $sqls=" insert into  user (name,password,emial,age) values('松江',md5('aaa'),'1051743154@qqq.com',21);";
   $sqls.="insert into  user (name,password,emial,age) values('卢俊义',md5('aaa'),'1051743154@qqq.com',21);";
      $sqls.="insert into  user (name,password,emial,age) values('赵文娟',md5('aaa'),'1051743154@qqq.com',21);";
    $b=$mysqli->multi_query($sqls);
    if(!$b){
       echo  "执行失败".$mysqli->error;
    }
    else{
       echo  "执行成功";
    }
?>

这里的$sqls可以是增加、更新、删除这三种语句,但是最好不要使用select语句,接下来就是批量的执行dql语句
2、批量执行dql语句
批量执行select语句、可以一次性的返回多个结果集

connect_error){
     die("连接错误".$mysqli->connect_error);
   }
    $mysqli->query("set names utf8");
    //这里的sqls可以是多个sql语句但是必须用;隔开
   $sqls=" select * from user;";
   $sqls.="select * from users;";  
   //如果就会取出至少一个结果集
    if($res=$mysqli->multi_query($sqls)){
    do{
           //从mysqli连接取出第一个结果集  也就是结果集的第一行
           $result=$mysqli->store_result();
           //显示mysqli result对象
           while($row=$result->fetch_row()){
              foreach($row as $key=>$val)
              {
                 echo "$key.$val
";
              }
             echo "
";

           }
           $result->free();
           if(!$mysqli->more_results()){
               break;
           }
           echo "新的结果集
";
    }while($mysqli->next_result());
     $mysqli->close();

    };
?>

mysql的事务处理

应用场景:有一张银行账号表,id balance一段php程序来实现转账
1号账户10 元转到2号账户

connect_error){
     die("连接错误".$mysqli->connect_error);
   }
   $sql1="update account set balance=balance-2 where id=1";
   $sql2="update account set balance=balance+2 where id=2";
     $b1=$mysqli->query($sql1);
     $b2=$mysqli->query($sql2);
     if(!$b1||!$b2){
        echo "转账失败".$mysqli->error;
     }else{
        echo "转账成功";
     }
?>

这种情况貌似是正确的,但是现在假设一种情况,假设我们执行了第一个query以后,第二个query没有执行,这时我们需要有一种方法来控制两个query必须同时成功执行或者同时失败,
事务:用于保证数据的一致性,它由一组相关的dml语句组合成,该组的dml语句要么全部成功,要么全部失败。
1、将提交设为false
2、其中一句失败,执行回滚。两句都没有错误,实现提交
实现代码

connect_error){
     die("连接错误".$mysqli->connect_error);
   }
   $mysqli->autocommit(false);
   $sql1="update account set balance=balance-2 where id=1";
   $sql2="update account set balance=balance+2 where id=2";
     $b1=$mysqli->query($sql1);
     $b2=$mysqli->query($sql2);
     if(!$b1||!$b2){
        echo "转账失败".$mysqli->error;
        //其中有一个语句没有执行成功,执行回滚操作
        $mysqli->rollback();
     }else{
        echo "转账成功";
          //两句都成功执行实现提交操作
                $mysqli->commit();   //一旦提交就没有机会再回滚
        }
?>

在mysql的控制台中,也可以使用事务:
1、开启一个事务 : start transaction
2、做保存点 : savepoint
3、操作 : delete insert update
4.1没有问题做提交操作 commit
4.2有问题做回滚操作 rollback to savepoint
事务的特点:
1、原子性 一个事务不可以分割
2、一致性
3、隔离性
4、持久性 一旦提交,变化永久存在于数据库中

mysqli的扩展库增强之处 预处理技术

预处理:代表的是一种处理数据的技术 mysqli_stmt
需要向mysql数据库添加100个用户
1、使用for循环,循环100次,向数据库中添加100个用户
2、使用批量插入,用.连接100条sql语句,但是只执行一次sql,使用mysqli?>mutilquery(sql1);
3、使用预编译技术,该方案还可以防止sql注入攻击
补充一个关于sql语句原理的知识点:
减少连接的次数可以提高效率、减少编译的时间来提高效率,提出预编译的思想。把sql语句预先编译好,后面只需程序发送数据即可。、
步骤:
1、创建mysqli对象
2、创建预编译对象
实现代码:

prepare($sql) or die($mysqli->error);
    //设置参数
    $name="小倩";
    $password="xiaoqian";
    $emial="1051743154@qq.com";
    $age=20;
    //参数绑定  给?赋值  这里类型和顺序都要对应
    //sssi表示字符串、字符串、字符串、整形类型
    $mysqli_stmt->bind_param("sssi",$name,$password,$emial,$age);
    //执行
    $b=$mysqli_stmt->execute();
    //其中一个不成功,会直接执行下一个
    if(!$b){
       die("操作失败21".$mysqli->error);
    }
    else{
      echo "操作成功12";
    }
    //释放资源  因为这里只是dml所以只需关闭
    $mysqli->close();

?>

从数据库查询所有id>5的用户,同时id可能会发生变化

代码实现

connect_error){
       die($mysqli->connect_error);
    }
    //2、创建预编译对象
    $sql="select id,name,emial from user where id>?";
    $mysqli_stmt=$mysqli->prepare($sql) or die($mysqli->error);
    //设置参数
    $id=5;
    //参数绑定  给?赋值  这里类型和顺序都要对应
    //sssi表示字符串、字符串、字符串、整形类型
    $mysqli_stmt->bind_param("i",$id);
    //绑定结果集
    $mysqli_stmt->bind_result($id,$name,$emial);
    //取出绑定的结果集
    $mysqli_stmt->execute();
    while($mysqli_stmt->fetch()){
       echo  "
--$id--$name--$emial";
    }
    //释放资源  1、释放资源   2、关闭预编译语句   3、关闭连接
    $mysqli_stmt->free_result();
    $mysqli_stmt->close();
    $mysqli->close();

?>

注入攻击

预编译可以自行放置注入攻击,
万能密码:
select * from user where name=”12” and password=’aa’ or 1=’1’;
输入的密码为aa’ or 1=’1这样就会把所有的用户都查询到

mysqli扩展库的其他函数:

编写一函数,接受一个表名,然后把表头和数据显示在页面
代码实现

connect_error);
           }
           $sql="select * from $table_name";
           $res=$mysqli->query($sql);
           echo "共有".$res->num_rows."行212";
           echo "共有".$res->field_count."列213";
           //关闭资源
           $res->free();
           $mysqli->close();
     }
     showtable("user");
?>

如对本文有疑问,请在下面进行留言讨论,广大热心网友会与你互动!! 点击进行留言回复

相关文章:

验证码:
移动技术网