当前位置：首页 > 行业动态 > 正文

c#将txt导入数据库中

admin
行业动态
2025-02-04
1

C#实现将txt文件导入数据库：该过程涉及读取txt文件内容，通常使用 StreamReader或 File.ReadAllLines等方法按行读取数据。接着创建数据库连接，通过 SqlConnection对象连接SQL Server数据库。然后构建插入数据的SQL语句，利用 SqlCommand执行命令将txt中的数据逐行插入数据库对应表中，从而实现txt到数据库的导入。

在C#中，将TXT文件导入数据库是一个常见的任务，通常涉及读取文本文件的内容并将其插入到数据库表中，以下是一个详细的步骤指南：

一、准备工作

1、创建TXT文件：确保你有一个包含要导入数据的TXT文件，假设我们有一个名为data.txt的文件，内容如下：

 1,John Doe,30
   2,Jane Smith,25
   3,Emily Davis,28

2、设置数据库：创建一个数据库和一个表来存储这些数据，在SQL Server中，你可以执行以下SQL语句来创建数据库和表：

 CREATE DATABASE TestDB;
   USE TestDB;
   CREATE TABLE Users (
       Id INT PRIMARY KEY,
       Name NVARCHAR(50),
       Age INT
   );

二、编写C#代码

1、添加必要的命名空间：

 using System;
   using System.Data.SqlClient;
   using System.IO;

2、定义数据库连接字符串：根据你的数据库配置，定义一个连接字符串，对于SQL Server，可以这样写：

 string connectionString = "Server=myServerAddress;Database=TestDB;User Id=myUsername;Password=myPassword;";

3、读取TXT文件并解析内容：使用StreamReader类读取TXT文件的每一行，并将每行分割成字段。

 string filePath = "path/to/your/data.txt";
   using (StreamReader reader = new StreamReader(filePath))
   {
       string line;
       while ((line = reader.ReadLine()) != null)
       {
           string[] fields = line.Split(',');
           if (fields.Length == 3)
           {
               int id = int.Parse(fields[0]);
               string name = fields[1];
               int age = int.Parse(fields[2]);
               // 插入到数据库
               using (SqlConnection connection = new SqlConnection(connectionString))
               {
                   connection.Open();
                   string query = "INSERT INTO Users (Id, Name, Age) VALUES (@Id, @Name, @Age)";
                   using (SqlCommand command = new SqlCommand(query, connection))
                   {
                       command.Parameters.AddWithValue("@Id", id);
                       command.Parameters.AddWithValue("@Name", name);
                       command.Parameters.AddWithValue("@Age", age);
                       command.ExecuteNonQuery();
                   }
               }
           }
       }
   }

三、完整示例代码

以下是一个完整的示例代码，包括所有必要的部分：

using System;
using System.Data.SqlClient;
using System.IO;
class Program
{
    static void Main()
    {
        string connectionString = "Server=myServerAddress;Database=TestDB;User Id=myUsername;Password=myPassword;";
        string filePath = "path/to/your/data.txt";
        using (StreamReader reader = new StreamReader(filePath))
        {
            string line;
            while ((line = reader.ReadLine()) != null)
            {
                string[] fields = line.Split(',');
                if (fields.Length == 3)
                {
                    int id = int.Parse(fields[0]);
                    string name = fields[1];
                    int age = int.Parse(fields[2]);
                    // 插入到数据库
                    using (SqlConnection connection = new SqlConnection(connectionString))
                    {
                        connection.Open();
                        string query = "INSERT INTO Users (Id, Name, Age) VALUES (@Id, @Name, @Age)";
                        using (SqlCommand command = new SqlCommand(query, connection))
                        {
                            command.Parameters.AddWithValue("@Id", id);
                            command.Parameters.AddWithValue("@Name", name);
                            command.Parameters.AddWithValue("@Age", age);
                            command.ExecuteNonQuery();
                        }
                    }
                }
            }
        }
    }
}