php与mysql的导入导出

基础概念

PHP是一种广泛使用的开源脚本语言，尤其适用于Web开发。它可以嵌入HTML中，用于创建动态网页内容。MySQL则是一种流行的关系型数据库管理系统（RDBMS），它使用结构化查询语言（SQL）进行数据管理。

导入导出类型

数据导入：将数据从一个文件或另一个数据库导入到MySQL数据库中。
数据导出：将MySQL数据库中的数据导出到一个文件中，通常用于备份或迁移数据。

应用场景

数据备份与恢复。
数据库迁移。
数据共享与交换。
数据分析前的数据准备。

PHP与MySQL导入导出的优势

灵活性：可以处理各种格式的数据文件。
高效性：通过批量操作，可以快速导入导出大量数据。
安全性：可以通过设置权限和验证来保护数据。

常见问题及解决方案

问题1：PHP脚本执行超时

原因：当处理大量数据时，脚本可能会因为默认的执行时间限制而超时。

解决方案：

set_time_limit(0); // 设置脚本执行时间为无限制

问题2：内存不足

原因：导入大文件时，可能会消耗大量内存导致服务器内存不足。

解决方案：

ini_set('memory_limit', '512M'); // 增加内存限制

问题3：CSV文件导入时出现乱码

原因：文件编码与数据库编码不一致。

解决方案：

$f = fopen("file.csv", "r");
while (($line = fgetcsv($f)) !== FALSE) {
    $data[] = mb_convert_encoding($line, 'UTF-8', '原始编码');
}
fclose($f);

问题4：导入数据时违反主键或唯一约束

原因：尝试导入的数据中存在重复的主键值或违反唯一约束。

解决方案：

// 在导入前检查数据
$query = "SELECT COUNT(*) FROM table WHERE primary_key = ?";
$stmt = $pdo->prepare($query);
foreach ($data as $row) {
    $stmt->execute([$row['primary_key']]);
    if ($stmt->fetchColumn() > 0) {
        // 处理重复数据
    }
}

示例代码

导出数据到CSV文件

<?php
$host = 'localhost';
$db   = 'database';
$user = 'user';
$pass = 'password';
$charset = 'utf8mb4';

$dsn = "mysql:host=$host;dbname=$db;charset=$charset";
$options = [
    PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION,
    PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
    PDO::ATTR_EMULATE_PREPARES   => false,
];

try {
     $pdo = new PDO($dsn, $user, $pass, $options);
} catch (\PDOException $e) {
     throw new \PDOException($e->getMessage(), (int)$e->getCode());
}

$query = "SELECT * FROM table";
$stmt = $pdo->query($query);

$fp = fopen('data.csv', 'w');
if ($fp && $stmt) {
    while ($row = $stmt->fetch()) {
        fputcsv($fp, $row);
    }
}
fclose($fp);
?>

从CSV文件导入数据

<?php
$host = 'localhost';
$db   = 'database';
$user = 'user';
$pass = 'password';
$charset = 'utf8mb4';

$dsn = "mysql:host=$host;dbname=$db;charset=$charset";
$options = [
    PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION,
    PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
    PDO::ATTR_EMULATE_PREPARES   => false,
];

try {
     $pdo = new PDO($dsn, $user, $pass, $options);
} catch (\PDOException $e) {
     throw new \PDOException($e->getMessage(), (int)$e->getCode());
}

$fp = fopen('data.csv', 'r');
$data = [];
while (($row = fgetcsv($fp)) !== FALSE) {
    $data[] = $row;
}
fclose($fp);

$query = "INSERT INTO table (column1, column2) VALUES (?, ?)";
$stmt = $pdo->prepare($query);

foreach ($data as $row) {
    $stmt->execute([$row[0], $row[1]]);
}
?>