php mysqli

Posted 2020-10-26 那天ws

1、基本操作

<?php
//支持预处理、支持事务

//检测拓展是否已经加载
// var_dump(extension_loaded(‘mysqli‘));
//检测函数是否已经存在
// var_dump(function_exists(‘mysqli_connect‘));
//得到已经开启的拓展
// print_r(get_loaded_extensions());

/********步骤：
1、建立到mysql的连接
2、打开指定的数据库
3、设置默认客户端的字符集
4、执行sql查询
5、释放结果集
6、关闭连接
********/
// 1、建立到mysql的连接
$mysqli = new mysqli(‘localhost‘,‘root‘,‘123456‘);
if($mysqli->connect_errno){
    die("连接错误：".$mysqli->connect_error);
} 
//2、打开指定的数据库
$mysqli->select_db(‘test‘);
//3、设置默认客户端的字符集
$mysqli->set_charset(‘utf8‘);
//4、执行sql查询
$sql = <<<EOF
    select * from test;
EOF;
$res = $mysqli->query($sql);//query执行一条语句
//多结果集
//more_results()检查是否有更多的结果集
//next_result()将结果集指针向下移动一位
// $res = $mysqli->multi_query($sql);//执行多条或一条
// if($mysqli->multi_query($sql)){
//     do{
//         if($res = $mysqli->store_result()){//获取结果集
//             $rows[] = $res->fetch_all(MYSQLI_ASSOC);
//         }
//     }while($mysqli->more_results() && $mysqli->next_result());//检查下一个结果集，并移动指针
// }else{
//     echo $mysqli->error;
// }
//5、释放结果集
if($res){
    if($mysqli->num_rows>0){
        $rows = $res->fetch_all();//所有数据，索引数组
        $rows = $res->fetch_all(MYSQLI_NUM);//同上
        $rows = $res->fetch_all(MYSQLI_ASSOC);//关联数组，带字段
        $rows = $res->fetch_all(MYSQLI_BOTH);//索引数组和关联数组
        
        $row = $res->fetch_row();//第一条数据，一维，索引
        $row = $res->fetch_assoc();//取得结果集中的一条记录作为关联数组返回
        
        $res->free();//释放一个与结果集相关的内存
    }
    //得到上条语句影响记录数。
    //受影响记录的条数
    //返回-1.代表sql语句有问题
    //返回0，代表没有受影响记录的条数
    echo ‘有‘.$mysqli->affected_rows.‘记录被影响‘;
}else{
    //
    echo "执行sql语句错误".$mysqli->errno.‘:‘.$mysqli->error;
}
//6、关闭连接
$mysqli->close();
?>

2、预处理

<?php
//预处理
//含有占位符的sql语句被直接发送至数据库引擎，数据库引擎执行编译等准备工作后确定sql语句，
//随后绑定值也被发送至数据库引擎，数据库引擎将收到的值填充进sql语句后将其执行
$mysqli = new mysqli(‘localhost‘,‘root‘,‘123456‘,‘test‘);
$mysqli->set_charset(‘utf8‘);
$sql = "insert user(id,firstname,lastname,sex) values(?,?,?,?)";
//准备预处理语句
$mysqli_stmt = $mysqli->prepare($sql);
// print_r($mysqli_stmt);
//绑定参数 i - integer（整型） d - double（双精度浮点型） s - string（字符串） b - BLOB（布尔值）
$id = 5;
$firstname = ‘wang‘;
$lastname = ‘wan‘;
$sex = 2;
$mysqli_stmt->bind_param(‘issi‘,$id,$firstname,$lastname,$sex);
//执行预处理语句
if($mysqli_stmt->execute()){
    echo $mysqli_stmt->insert_id;
}else{
    $mysqli_stmt->error;
}
?>

3、事务

<?php
//事务
$mysqli = new mysqli(‘localhost‘,‘root‘,‘123456‘,‘test‘);
$mysqli->set_charset(‘utf8‘);
$mysqli->autocommit(false);
$sql = "update account set money=money-100 where user=‘xiaoming‘";
$res = $mysqli->query($sql);
$res_affect = $mysqli->affected_rows;

$sql2 = "update account set money=money+100 where user=‘xiaohua‘";
$res2 = $mysqli->query($sql);
$res_affect2 = $mysqli->affected_rows;
if($res && $res_affect && $res2 && $res_affect2){
    $mysqli->commit();
    echo "转账成功";
    $mysqli->autocommit(ture);
}else{
    $mysqli->rollback();
    echo "转账失败";
}
$mysqli->close();
?>