excel 数据导入到mysql c#

将 Excel 数据导入到 MySQL 数据库可以分为以下几个步骤：

1.读取 Excel 数据

可以使用 C# 中的 OLEDB 或者 EPPlus 库来读取 Excel 数据。其中 OLEDB 是基于 COM 的组件，可以读取 Excel 2003 以前的版本，而 EPPlus 是基于 Open XML 标准的库，可以读取 Excel 2007 及以后的版本。

2.连接 MySQL 数据库

使用 MySQL 数据库提供的 .NET Connector 组件来连接 MySQL 数据库。

3.创建表格

在 MySQL 数据库中创建表格，确保表格的字段与 Excel 数据的字段匹配。

4.插入数据

将读取到的 Excel 数据插入到 MySQL 数据库中对应的表格中。

以下是示例代码：

using System.Data;
using System.Data.OleDb;
using MySql.Data.MySqlClient;
using OfficeOpenXml;

public void ImportDataFromExcelToMySQL(string excelFilePath, string mysqlConnectionString)
{
    // 读取 Excel 数据
    DataTable excelData = ReadExcelData(excelFilePath);

    // 连接 MySQL 数据库
    MySqlConnection mysqlConnection = new MySqlConnection(mysqlConnectionString);
    mysqlConnection.Open();

    // 创建表格
    CreateTable(mysqlConnection);

    // 插入数据
    InsertData(mysqlConnection, excelData);

    // 关闭连接
    mysqlConnection.Close();
}

private DataTable ReadExcelData(string excelFilePath)
{
    // 使用 OLEDB 读取 Excel 2003 以前的版本
    string excelConnectionString = "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" + excelFilePath + ";Extended Properties='Excel 8.0;HDR=YES;IMEX=1'";
    using (OleDbConnection excelConnection = new OleDbConnection(excelConnectionString))
    {
        excelConnection.Open();
        OleDbDataAdapter excelDataAdapter = new OleDbDataAdapter("SELECT * FROM [Sheet1$]", excelConnection);
        DataTable excelData = new DataTable();
        excelDataAdapter.Fill(excelData);
        return excelData;
    }

    // 使用 EPPlus 读取 Excel 2007 及以后的版本
    // using (ExcelPackage excelPackage = new ExcelPackage(new FileInfo(excelFilePath)))
    // {
    //     ExcelWorksheet worksheet = excelPackage.Workbook.Worksheets["Sheet1"];
    //     DataTable excelData = worksheet.ConvertSheetToDataTable();
    //     return excelData;
    // }
}

private void CreateTable(MySqlConnection mysqlConnection)
{
    MySqlCommand createTableCommand = new MySqlCommand("CREATE TABLE IF NOT EXISTS `table_name` (`column1` VARCHAR(50), `column2` VARCHAR(50), `column3` INT)", mysqlConnection);
    createTableCommand.ExecuteNonQuery();
}

private void InsertData(MySqlConnection mysqlConnection, DataTable excelData)
{
    foreach (DataRow row in excelData.Rows)
    {
        MySqlCommand insertCommand = new MySqlCommand("INSERT INTO `table_name` (`column1`, `column2`, `column3`) VALUES (@column1, @column2, @column3)", mysqlConnection);
        insertCommand.Parameters.AddWithValue("@column1", row["column1"].ToString());
        insertCommand.Parameters.AddWithValue("@column2", row["column2"].ToString());
        insertCommand.Parameters.AddWithValue("@column3", int.Parse(row["column3"].ToString()));
        insertCommand.ExecuteNonQuery();
    }
}

其中，`excelFilePath` 为 Excel 文件的路径，`mysqlConnectionString` 为 MySQL 数据库的连接字符串。在 `ReadExcelData` 方法中，使用了 OLEDB 来读取 Excel 数据，读取的表格名为 `Sheet1`，如果需要读取其他的表格，可以修改查询语句。在 `CreateTable` 方法中，创建了一个名为 `table_name` 的表格，其中包含三个字段，可以根据自己的需要修改字段名和类型。在 `InsertData` 方法中，使用了参数化查询来插入数据，确保数据的安全性。