PHP MySQL 插入多条数据

使用 MySQLi 和 PDO 向 MySQL 插入多条数据

mysqli_multi_query() 函数可用来执行多条SQL语句。

以下实例向 "MyGuests" 表添加了三条新的记录:

实例 (MySQLi - 面向对象)

<?php  
$servername = "localhost";  
$username = "username";  
$password = "password";  
$dbname = "myDB";  

// 创建链接  
$conn = new mysqli($servername, $username, $password, $dbname);  
// 检查链接  
if ($conn->connect_error) {  
    die("Connection failed: " . $conn->connect_error);  
}  

$sql = "INSERT INTO MyGuests (firstname, lastname, email)  
VALUES ("John", "Doe", "john@example.com");";  
$sql .= "INSERT INTO MyGuests (firstname, lastname, email)  
VALUES ("Mary", "Moe", "mary@example.com");";  
$sql .= "INSERT INTO MyGuests (firstname, lastname, email)  
VALUES ("Julie", "Dooley", "julie@example.com")";  

if ($conn->multi_query($sql) === TRUE) {  
    echo "New records created successfully";  
} else {  
    echo "Error: " . $sql . "<br>" . $conn->error;  
}  

$conn->close();  
?>

请注意，每个SQL语句必须用分号隔开。

实例 (MySQLi - 面向过程)

<?php  
$servername = "localhost";  
$username = "username";  
$password = "password";  
$dbname = "myDB";  

// 创建链接  
$conn = mysqli_connect($servername, $username, $password, $dbname);  
// 检查链接  
if (!$conn) {  
    die("Connection failed: " . mysqli_connect_error());  
}  

$sql = "INSERT INTO MyGuests (firstname, lastname, email)  
VALUES ("John", "Doe", "john@example.com");";  
$sql .= "INSERT INTO MyGuests (firstname, lastname, email)  
VALUES ("Mary", "Moe", "mary@example.com");";  
$sql .= "INSERT INTO MyGuests (firstname, lastname, email)  
VALUES ("Julie", "Dooley", "julie@example.com")";  

if (mysqli_multi_query($conn, $sql)) {  
    echo "New records created successfully";  
} else {  
    echo "Error: " . $sql . "<br>" . mysqli_error($conn);  
}  

mysqli_close($conn);  
?>

实例 (PDO)

<?php  
$servername = "localhost";  
$username = "username";  
$password = "password";  
$dbname = "myDBPDO";  

try {  
    $conn = new PDO("mysql:host=$servername;dbname=$dbname", $username, $password);  
    // set the PDO error mode to exception  
    $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);  

    // 开始事务  
    $conn->beginTransaction();  
    // SQL 语句  
    $conn->exec("INSERT INTO MyGuests (firstname, lastname, email)  
    VALUES ("John", "Doe", "john@example.com")");  
    $conn->exec("INSERT INTO MyGuests (firstname, lastname, email)  
    VALUES ("Mary", "Moe", "mary@example.com")");  
    $conn->exec("INSERT INTO MyGuests (firstname, lastname, email)  
    VALUES ("Julie", "Dooley", "julie@example.com")");  

    // commit the transaction  
    $conn->commit();  
    echo "New records created successfully";  
    }  
catch(PDOException $e)  
    {  
    // roll back the transaction if something failed  
    $conn->rollback();  
    echo $sql . "<br>" . $e->getMessage();  
    }  

$conn = null;  
?>

使用预处理语句

mysqli 扩展提供了第二种方式用于插入语句。

我们可以预处理语句及绑定参数。

mysql 扩展可以不带数据发送语句或查询到mysql数据库。 你可以向列关联或 "绑定" 变量。

Example (MySQLi 使用预处理语句)

<?php  
$servername = "localhost";  
$username = "username";  
$password = "password";  
$dbname = "myDB";  

// Create connection  
$conn = new mysqli($servername, $username, $password, $dbname);  
// Check connection  
if ($conn->connect_error) {  
    die("Connection failed: " . $conn->connect_error);  
} else {  
    $sql = "INSERT INTO MyGuests VALUES(?, ?, ?)";  

    // 为 mysqli_stmt_prepare() 初始化 statement 对象  
    $stmt = mysqli_stmt_init($conn);  

    //预处理语句  
    if (mysqli_stmt_prepare($stmt, $sql)) {  
        // 绑定参数  
        mysqli_stmt_bind_param($stmt, "sss", $firstname, $lastname, $email);  

        // 设置参数并执行  
        $firstname = "John";  
        $lastname = "Doe";  
        $email = "john@example.com";  
        mysqli_stmt_execute($stmt);  

        $firstname = "Mary";  
        $lastname = "Moe";  
        $email = "mary@example.com";  
        mysqli_stmt_execute($stmt);  

        $firstname = "Julie";  
        $lastname = "Dooley";  
        $email = "julie@example.com";  
        mysqli_stmt_execute($stmt);  
    }  
}  
?>

我们可以看到以上实例中使用模块化来处理问题。我们可以通过创建代码块实现更简单的读取和管理。

注意参数的绑定。让我们看下 mysqli_stmt_bind_param() 中的代码：

mysqli_stmt_bind_param($stmt, "sss", $firstname, $lastname, $email);

该函数绑定参数查询并将参数传递给数据库。第二个参数是 "sss" 。以下列表展示了参数的类型。 s 字符告诉 mysql 参数是字符串。

This argument may be one of four types:

• i - integer
• d - double
• s - string
• b - BLOB

每个参数必须指定类型，来保证数据的安全性。通过类型的判断可以减少SQL注入漏洞带来的风险。