如何使用 PHP 和 MySQL 实现 CSV 数据自动上传？

2024-04-25 20:26:58

使用 PHP 和 MySQL 实现 CSV 数据自动上传

引言

在当今快速发展的数字时代，自动化已经成为现代软件开发的基石。通过自动化，我们能够简化复杂的任务、提高效率并释放宝贵的人力资源。本文将引导你使用 PHP 和 MySQL 创建一个自动化管道，实现 CSV 数据的自动上传，从而实现准实时的整合。

需求

踏上这段旅程，你将需要以下装备：

一份 CSV 数据源
一个 MySQL 数据库
PHP 编程环境

解决方案

我们的解决方案将利用 PHP 的强大功能和 MySQL 的可靠性，创建一个自动化的管道，将 CSV 数据加载到 MySQL 表中。

步骤 1：创建 MySQL 表

首先，我们需要创建一个 MySQL 表来容纳我们的 CSV 数据。使用以下 SQL 语句：

CREATE TABLE tweets (
  id INT NOT NULL AUTO_INCREMENT,
  tweet_text VARCHAR(255) NOT NULL,
  created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (id)
);

步骤 2：编写 PHP 脚本

下一步，我们将编写一个 PHP 脚本来处理 CSV 文件并将其上传到 MySQL 数据库。这个脚本将扮演以下角色：

打开 CSV 文件： 使用 PHP 的 fopen() 函数打开 CSV 文件。
读取 CSV 数据： 逐行读取 CSV 文件并将其存储在数组中。
连接到 MySQL 数据库： 使用 PHP 的 mysqli 扩展连接到 MySQL 数据库。
准备 SQL 语句： 准备一条 SQL 语句以将 CSV 数据插入到 MySQL 表中。
执行 SQL 语句： 使用 mysqli_stmt_execute() 函数执行准备好的 SQL 语句。
关闭连接： 关闭到 MySQL 数据库的连接。

以下是一个 PHP 脚本示例：

<?php

// 打开 CSV 文件
$csvFile = fopen("tweets.csv", "r");

// 读取 CSV 数据
$data = [];
while (($line = fgetcsv($csvFile)) !== FALSE) {
  $data[] = $line;
}

// 连接到 MySQL 数据库
$mysqli = new mysqli("localhost", "username", "password", "database");

// 准备 SQL 语句
$stmt = $mysqli->prepare("INSERT INTO tweets (tweet_text) VALUES (?)");

// 执行 SQL 语句
foreach ($data as $row) {
  $stmt->bind_param("s", $row[0]);
  $stmt->execute();
}

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

?>