PHP执行批量mysql语句的解决方法

下面提供一份详细的 “PHP执行批量mysql语句的解决方法” 攻略。

什么是批量处理

批量处理，即一次执行多条 SQL 语句，这种方式可以提高效率，减少数据库服务器的请求次数，避免数据库管理员因为恶意注入等原因造成的数据库崩溃。

如何执行批量处理

使用 PHP fopen 函数实现文件读取

PHP 的函数 fopen() 用于打开文件，可以打开不同模式的文件，并返回资源号。通过 PHP 的 fgets() 函数读取文件内容，将每行的 SQL 语句存储到数组中。

$file = fopen('sql.txt', 'r');
$sqls = array();
while(!feof($file)) {
    $sqls[] = fgets($file);
}
fclose($file);

PDO 执行批量 SQL 语句

PDO（PHP Data Object）是 PHP 中访问数据库的抽象层，可以使用该抽象类来操作不同类型的数据库，比如 MySQL、Oracle 等。

使用 PDO 对象的 prepare() 方法可以预处理一条 SQL 语句，然后再使用 execute() 方法来执行该语句。代码如下：

try {
    $dsn = 'mysql:host=localhost;dbname=test';
    $user = 'root';
    $password = '';
    $pdo = new PDO($dsn, $user, $password);

    $pdo->beginTransaction(); // 开始事务
    $stmt = $pdo->prepare('');
    foreach($sqls as $sql) {
        $stmt->execute(array($sql));
    }
    $pdo->commit(); // 提交事务
} catch(PDOException $e) {
    $pdo->rollBack(); // 回滚事务
    echo $e->getMessage();
}

示例说明

下面提供两个示例来说明如何执行批量处理。

示例一：从文件中读取 SQL 语句

首先在项目根目录下新建一个文件 sql.txt，并输入以下 SQL 语句：

INSERT INTO users(username, password) VALUES('user1', '123456');
INSERT INTO users(username, password) VALUES('user2', '123456');
INSERT INTO users(username, password) VALUES('user3', '123456');

然后在 PHP 文件中加入以下代码：

$file = fopen('sql.txt', 'r');
$sqls = array();
while(!feof($file)) {
    $sqls[] = fgets($file);
}
fclose($file);

try {
    $dsn = 'mysql:host=localhost;dbname=test';
    $user = 'root';
    $password = '';
    $pdo = new PDO($dsn, $user, $password);

    $pdo->beginTransaction(); // 开始事务
    $stmt = $pdo->prepare('');
    foreach($sqls as $sql) {
        $stmt->execute(array($sql));
    }
    $pdo->commit(); // 提交事务
    echo '批量插入成功！';
} catch(PDOException $e) {
    $pdo->rollBack(); // 回滚事务
    echo $e->getMessage();
}

执行该脚本即可在数据库中批量插入数据。

示例二：使用数组执行 SQL 语句

首先在 PHP 文件中定义一个数组，并存储多条 SQL 语句：

$sqls = array(
    "INSERT INTO users(username, password) VALUES('user4', '123456')",
    "INSERT INTO users(username, password) VALUES('user5', '123456')",
    "INSERT INTO users(username, password) VALUES('user6', '123456')",
);

然后使用 PDO 对象执行该数组中的 SQL 语句：

try {
    $dsn = 'mysql:host=localhost;dbname=test';
    $user = 'root';
    $password = '';
    $pdo = new PDO($dsn, $user, $password);

    $pdo->beginTransaction(); // 开始事务
    $stmt = $pdo->prepare('');
    foreach($sqls as $sql) {
        $stmt->execute(array($sql));
    }
    $pdo->commit(); // 提交事务
    echo '批量插入成功！';
} catch(PDOException $e) {
    $pdo->rollBack(); // 回滚事务
    echo $e->getMessage();
}