Mysqli新增 更新 查询删除

实例

<?php
/**
 * 新增数据
 */

//连接数据库
require 'demo1.php';

//准备SQL语句:带有占位符
$sql = "INSERT IGNORE `staff` SET `name`= ?, `salary`= ?;";

//创建一个SQL语句的预处理对象
$stmt = $mysqli->prepare($sql);


// 参数绑定,将用户数组与SQL语句中的点位符进行绑定
$name = '波波';
$salary = 4300;
$stmt->bind_param('si',$name, $salary);

//执行SQL语句
if ($stmt->execute()) {
    //执行成功

    //检测是否有数据被新增
    if ($stmt->affected_rows > 0) {
        echo '<br>成功的插入'.$stmt->affected_rows.' 条记录,新增记录的主键id是: ' . $stmt->insert_id;
    } else {
        echo '<br>没有新增记录';
    }
} else {
    exit($stmt->errno. ':' .$stmt->error);
}

//$name = '涛涛';
//$salary = 9300;
//$stmt->bind_param('si',$name, $salary);
//$stmt->execute();
//
//
//$name = '涛涛333333';
//$salary = 1300;
//$stmt->bind_param('si',$name, $salary);
//$stmt->execute();

//注销stmt对象
$stmt->close();

//关闭连接
$mysqli->close();

实例

<?php
/**
 * 新增数据
 */

//连接数据库
require 'demo1.php';

//准备SQL语句:带有占位符
$sql = "INSERT IGNORE `staff` SET `name`= ?, `salary`= ?;";

//创建一个SQL语句的预处理对象
$stmt = $mysqli->prepare($sql);

//用数组准备要添加的数据
$data[] = ['name'=>'杨过','salary'=>4000];
$data[] = ['name'=>'小龙女','salary'=>5000];
$data[] = ['name'=>'金轮法王','salary'=>8000];


//参数绑定
$stmt->bind_param('si',$name,$salary);

foreach ($data as $staff) {
    //准备一下要插入的数据
    $name = $staff['name'];
    $salary = $staff['salary'];


//执行SQL语句
    if ($stmt->execute()) {
        //执行成功

        //检测是否有数据被新增
        if ($stmt->affected_rows > 0) {
            echo '<br>成功的插入'.$stmt->affected_rows.' 条记录,新增记录的主键id是: ' . $stmt->insert_id;
        } else {
            echo '<br>没有新增记录';
        }
    } else {
        exit($stmt->errno. ':' .$stmt->error);
    }
}

//注销stmt对象
$stmt->close();

//关闭连接
$mysqli->close();

实例

<?php
/**
 * 更新数据
 */

//连接数据库
require 'demo1.php';

//准备SQL语句:带有占位符
$sql = "UPDATE `staff` SET `salary`= ? WHERE `id`=?;";

//创建一个SQL语句的预处理对象
$stmt = $mysqli->prepare($sql);

//参数绑定
$salary = 9999;
$id = 25;
$stmt->bind_param('ii',$salary, $id);

//执行SQL语句
    if ($stmt->execute()) {
        //执行成功

        //检测是否有数据被新增
        if ($stmt->affected_rows > 0) {
            echo '<br>成功的更新'.$stmt->affected_rows.' 条记录';
        } else {
            echo '<br>没有更新记录';
        }
    } else {
        exit($stmt->errno. ':' .$stmt->error);
    }


//注销stmt对象
$stmt->close();

//关闭连接
$mysqli->close();

实例

<?php
/**
 * 删除数据
 */

//连接数据库
require 'demo1.php';

//准备SQL语句:带有占位符
$sql = "DELETE FROM `staff`  WHERE `id`= ?;";

//创建一个SQL语句的预处理对象
$stmt = $mysqli->prepare($sql);

//参数绑定
$id = 26;
$stmt->bind_param('i',$id);

//执行SQL语句
if ($stmt->execute()) {
    //执行成功

    //检测是否有数据被新增
    if ($stmt->affected_rows > 0) {
        echo '<br>成功的删除'.$stmt->affected_rows.' 条记录';
    } else {
        echo '<br>没有删除记录';
    }
} else {
    exit($stmt->errno. ':' .$stmt->error);
}


//注销stmt对象
$stmt->close();

//关闭连接
$mysqli->close();

实例

<?php
/**
 * 预处理查询操作
 */

//连接数据库
require 'demo1.php';

//准备SQL语句
$sql = "SELECT `id`,`name`,`salary`  FROM `staff` WHERE `salary` > ? ;";

// 创建预处理对象
$stmt = $mysqli->stmt_init();

if ($stmt->prepare($sql)) {
    //绑定参数
    $stmt->bind_param('i', $salary);

    //设置参数
    $salary = 5000;

    if ($stmt->execute()) {

        //获取结果集并放到缓存区
        $stmt->store_result();

        //将结果集中的列绑定到变量上
        $stmt->bind_result($id,$name, $salary);

        //结果集是否不为,只有不为空的时候才遍历
        if ($stmt->num_rows > 0) {
            // 循环遍历结果集
            // fetch()每次获取一条记录，并将指针自动下移
            while ($stmt->fetch()) {
                echo '<p>id:'.$id.'---姓名:' .$name.'---工资:'.$salary.'</p>';
            }
        } else {
            exit('<p>当前表中没有数据</p>');
        }

        // 释放结果集
        $stmt->free_result();
    } else {
        //返回执行阶段的出错信息
        exit($stmt->errno. ': ' . $stmt->error);
    }
} else {
    //返回sql语句检测阶段的出错信息
    exit($stmt->errno. ': ' . $stmt->error);
}


//注销stmt对象
$stmt->close();

//关闭连接
$mysqli->close();