msyqli和mysql只有一个字母的差别，真正的含义是msyql的增强版扩展。
MySQL可以处理满足程序员对MySQL数据库操作的各种需要了，为什么还需要mysqli呢？因为mysqli支持面性对象编程，PHP的开发者为了适应当前的发展，不得不对PHP进行升级，并使其慢慢向面向对象看齐。
虽然mysqli支持面向对象，但是mysqli扩展库考虑到PHP老程序员，同时也提供了面向过程的编程风格，这就造成了PHP中的一大奇景：同一个方法既有面向过程风格的，又有面向对象风格的。
比如：关闭数据库连接的方法：
面向对象函数库：
bool mysqli::close(void)
$mysqli=new MySQLi(xx);
$mysqli->close();
面向过程的函数库：
bool mysqli_close(mysql $link)
$conn=mysqli_connect(xxx,xx)
mysqli_close($conn);
同样的，我们首先应该熟练掌握对数据库的增删查改的操作。
值得一提的是，mysqli在连接数据库的时候就必须指定连接那个数据库，而mysql则需要先连接数据库，再选择具体的数据库，使用mysql_select_db()方法。
在案例中学习mysqli
提醒：mysqli_connect_error()方法只能在PHP5.3.0以上的版本中使用
一、crud操作
interface.php
<?php
require_once "mysqli_tool.php";
$mysqli=new mysqli_tool("localhost","root","5a6f38","users");
if(mysqli_connect_error())
{
die("连接数据库失败！");
}
//先查询一次
echo "查询操作：";
printf_all($mysqli); //进行插入操作
$sql="insert into user1(name,password,email,age) values ('艳荣',md5('sssx'),'1649653731@qq.com',23)";
echo "数据插入操作：";
$mysqli->update($sql);
printf_all($mysqli); //进行修改操作
$num=$mysqli->getinsertid();
$sql="update user1 set email='2632979128@sohu.com'where id='".$mysqli->getinsertid()."'";
$mysqli->update($sql);
echo "对刚插入的数据进行修改操作：";
printf_all($mysqli); //进行删除操作
echo "对刚插入的数据进行删除操作：";
$sql="delete from user1 where id='".$num."'";
$res=$mysqli->update($sql);
printf_all($mysqli); function printf_all($mysqli)
{
echo ",查询后结果是：<br/>";
$sql="select * from user1 order by id";
$mysqli->search($sql);
while($row=$mysqli->getres()->fetch_row())
{
foreach($row as $key=>$value)
{
echo "$value--";
}
echo "<br/>";
}
echo "<br/><br/><br/>";
$mysqli->close_res($mysqli->getres());
} $mysqli->close_conn($mysqli->getconn());
?>
mysqli_tool.php
<?php
class mysqli_tool
{
private $host,$name,$pw,$db_name,$mysqli;
private $conn,$res;
public function __construct($host,$name,$pw,$db_name)
{
$this->host=$host;
$this->name=$name;
$this->pw=$pw;
$this->db_name=$db_name;
$this->mysqli=new mysqli($this->host,$this->name,$this->pw,$this->db_name);
$this->mysqli->query("set names utf8");
}
//查询功能
public function search($sql)
{
$this->res=$this->mysqli->query($sql,$this->conn);
if(!$this->res)
{
die("数据查询失败！");
}
else
{
if($this->mysqli->affected_rows==0)
{
echo "没有符合条件的数据！";
}
else
{
return $this->res;
}
}
} public function update($sql)
{
$this->res=$this->mysqli->query($sql,$this->mysqli->conn);
//echo "受影响的行数是：".$this->mysqli->affected_rows."<br/>";
if(!$this->res)
{
echo "数据更新失败！";
}
} public function getinsertid()
{
return $this->mysqli->insert_id;
}
public function getconn()
{
return $this->conn;
}
public function getres()
{
return $this->res;
}
public function close_conn($conn)
{
$this->mysqli->close();
}
public function close_res($res)
{
$this->res->free();
}
} ?>
二、事务回滚操作
如果不能回滚，非常有可能是存储引擎的问题，详情：mysql myisam和innodb的区别
<?php //有疑问：不能实现回滚的原因是什么？数据库的存储引擎不符合要求，不支持事务处理
//创建数据库连接对象
$mysqli=new mysqli('localhost','root','5a6f38','users');
//将mysql数据库的自动提交设置false
$mysqli->autocommit(false);
//设置sql指令
$sql1="update account set account=account-2 where name='zhangsan'";
$sql2="update account set account=account+2 where name='lisi'";
//执行指令
$r1=$mysqli->query($sql1);
$r2=$mysqli->query($sql2);
//判断结果
if(!$r1||!$r2)
{
//两个sql语句执行中至少有一个错误，回滚处理
$mysqli->rollback();
echo "转账失败！回滚处理！";
}
else
{
$mysqli->commit();
$mysqli->close();
echo "转账成功！";
}
?>
三、批量查询
mysqli相对于mysql扩展库，有一个比较大的改进：支持批量查询
实例代码如下：
<?php
//1.创建msyqli对象
$mysqli=new mysqli("localhost","root","5a6f38","users");
if(mysqli_connect_error())
{
die("数据库连接失败：".mysqli_connect_error());
}
//2.创建批量查询语句
$sqls="select * from user1;";
$sqls.="show columns from user1";
//3.处理结果
$res=$mysqli->multi_query($sqls);
if($res)//如果条件成立说明至少有一个结果被返回
{
do
{
echo "*********************查询到的新表******************<br/>";
echo "<br/>标志变量<br/>";
$result=$mysqli->store_result();//$result是mysqli result对象
while($row=$result->fetch_row())
{
foreach($row as $value)
{
echo "--$value";
}
echo "<br/>";
}
$result->free();
if(!$mysqli->more_results())//如果没有下一个查询，则停止取下一个查询的结果。
{
break;
}
echo "<br/><br/>"; }
while($mysqli->next_result());//指针后移，并判断是否为空
}
else
{
echo "数据查询失败！";
}
$mysqli->close();
?>
四、预编译技术
大概有很多人没听说过这个东西，其实我也是不太明白，毕竟sql是一种解释型的语言，不需要编译就可以被dbms执行，但是在这里我们权且将它当做可以被编译，这样理解起来的话就比较容易了。
问题的提出：
现在要向数据库中添加100条数据，我们该怎么实现？
方法1：使用for循环，依次添加100次
方法2：使用批量查询技术，将100个sql语句拼接起来之后最后打包执行。
方法3：使用预编译技术。
这里我们使用预编译技术，使用预编译技术有什么好处？
1.防止sql注入
2.执行速度快
有和两条好处就足够了。
预编译流程：将sql语句发送到dbms，由dbms编译好并保存起来。我们只需要将数据发送到dbms即可，而不需要将整条sql语句发送到dbms，这样就大大提高了执行效率，这对于大量数据的插入尤其明显。
下面将展示各种查询操作，但要先强调：使用完之后要多关闭一个资源：dbms存储的预编译文件。
基本流程：预编译文件-》绑定参数-》执行-》绑定参数-》执行。。。。
使用预编译技术实现批量插入：
<?php
//创建mysqli对象
$mysqli=new mysqli("localhost","root","5a6f38","users");
//创建预编译对象
$sql="insert into user1 (name,password,age,email) values (?,?,?,?)";
$mysqli_stmt=$mysqli->prepare($sql); //创建参数并绑定
$name="lisi";
$password="6f6f6f";
$age=40;
$email="1659653731@qq.com";
$mysqli_stmt->bind_param("ssis",$name,$password,$age,$email); //执行函数
execute_prepared($mysqli_stmt,$mysqli); //创建参数并绑定
$name="zhangsan";
$password="6f6f6f";
$age=40;
$email="1659653731@qq.com";
$mysqli_stmt->bind_param("ssis",$name,$password,$age,$email); //执行函数
execute_prepared($mysqli_stmt,$mysqli); //反复执行即可完成插入操作 $mysqli->close(); function execute_prepared(&$mysqli_stmt,&$mysqli)
{
//执行语句
$result=$mysqli_stmt->execute();
//验证是否成功
if(!$result)
{
die("操作失败！".$mysqli_stmt->error);
}
else
{
echo "操作成功！<br/>";
//打印验证
printf_all($mysqli);
}
}
function printf_all(&$mysqli)
{
$sql="select * from user1";
$res=$mysqli->query($sql);
while($row=$res->fetch_row())
{
foreach($row as $value)
{
echo "$value ";
}
echo "<br/>";
}
$res->free();
}
?>
使用预编译技术实现批量查询
<?php
//创建mysali对象
$mysqli=new mysqli("localhost","root","5a6f38","users");
if(mysqli_connect_error())
{
die("数据库连接失败！".mysqli_connect_error());
}
//创建预编译对象
$sql="select * from user1 where id>?";
$mysqli_stmt=$mysqli->prepare($sql);
//绑定参数
$id=15;
$mysqli_stmt->bind_param("i",$id);
//绑定结果集
$mysqli_stmt->bind_result($id,$name,$password,$email,$age);
//执行
$mysqli_stmt->execute();
//取出绑定的值
while($mysqli_stmt->fetch())
{
echo "$id $name
$password $email $age<br/>";
}
//释放结果集
$mysqli_stmt->free_result();
//删除在数据库中的预编译文件
$mysqli_stmt->close();
//关闭和数据库的连接
$mysqli->close();
?>
五、获取表头信息和行数、列数并打印表格
<?php
$database="users";
$sql="select * from user1";
printf_table($database,$sql);
function printf_table($database,$sql)
{
//创建$mysqli对象。
$mysqli=new mysqli("localhost","root","5a6f38",$database);
if(mysqli_connect_error())
{
die("数据库连接失败！失败信息：".mysqli_connect_error());
}
//获取结果集
$res=$mysqli->query($sql);
//获取行数
$row_nums=$res->num_rows;
//获取列数
$column_nums=$res->field_count;
//打印表头信息
echo "<center><table cellpadding='10' cellspacing='1' bgcolor='black'>";
echo "<tr bgcolor='white'>";
while($field=$res->fetch_field())//$field是列属性对象
{
echo "<th>$field->name</th>";
}
echo "</tr>";
//取出表体数据
while($row=$res->fetch_row())
{
echo "<tr bgcolor='white'>";
foreach($row as $value)
{
echo "<td>$value</td>";
}
echo "</tr>";
}
echo "</table></center>";
//释放资源
$res->free();
//断开连接
$mysqli->close();
}
?>