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

c#从txt文档读取数据库

admin
行业动态
2025-03-01
7

“

csharp，using (StreamReader sr = new StreamReader("database.txt")) { string line; while ((line = sr.ReadLine()) != null) { Console.WriteLine(line); } }，

“

在C#中，从TXT文档读取数据并存储到数据库是一个常见的任务，通常涉及文件读取、数据处理和数据库操作等步骤，以下是一个详细的指南：

准备工作

确保你有一个包含数据的TXT文件和一个目标数据库（例如SQL Server），假设TXT文件的格式如下：

ID	Name	Age
1	Alice	30
2	Bob	25
3	Carol	27

假设你已经在SQL Server中创建了一个名为People的表，结构如下：

CREATE TABLE People (
    ID INT PRIMARY KEY,
    Name NVARCHAR(50),
    Age INT
);

C#代码实现

1 引入必要的命名空间

在你的C#项目中，需要引入以下命名空间：

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

2 读取TXT文件

使用StreamReader类来读取TXT文件的内容，这里我们假设每行数据都是以制表符（t）分隔的。

string filePath = @"C:pathtoyourdata.txt";
string line;
using (StreamReader reader = new StreamReader(filePath))
{
    while ((line = reader.ReadLine()) != null)
    {
        // 处理每一行数据
        ProcessLine(line);
    }
}

3 解析每行数据

定义一个方法ProcessLine来解析每行数据，并将其转换为适合插入数据库的格式。

c#从txt文档读取数据库

void ProcessLine(string line)
{
    if (string.IsNullOrWhiteSpace(line)) return;
    string[] parts = line.Split('t');
    if (parts.Length != 3) return; // 确保每行都有三个部分
    int id;
    string name;
    int age;
    if (int.TryParse(parts[0], out id) && int.TryParse(parts[2], out age))
    {
        name = parts[1];
        InsertIntoDatabase(id, name, age);
    }
}

4 插入数据到数据库

定义一个方法InsertIntoDatabase来将解析后的数据插入到数据库中。

void InsertIntoDatabase(int id, string name, int age)
{
    string connectionString = "Your_Connection_String_Here";
    using (SqlConnection connection = new SqlConnection(connectionString))
    {
        connection.Open();
        string query = "INSERT INTO People (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();
        }
    }
}

完整代码示例

将上述片段组合在一起，形成一个完整的C#程序：

using System;
using System.Data.SqlClient;
using System.IO;
using System.Linq;
class Program
{
    static void Main()
    {
        string filePath = @"C:pathtoyourdata.txt";
        string line;
        using (StreamReader reader = new StreamReader(filePath))
        {
            while ((line = reader.ReadLine()) != null)
            {
                ProcessLine(line);
            }
        }
    }
    static void ProcessLine(string line)
    {
        if (string.IsNullOrWhiteSpace(line)) return;
        string[] parts = line.Split('t');
        if (parts.Length != 3) return; // 确保每行都有三个部分
        int id;
        string name;
        int age;
        if (int.TryParse(parts[0], out id) && int.TryParse(parts[2], out age))
        {
            name = parts[1];
            InsertIntoDatabase(id, name, age);
        }
    }
    static void InsertIntoDatabase(int id, string name, int age)
    {
        string connectionString = "Your_Connection_String_Here";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            string query = "INSERT INTO People (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();
            }
        }
    }
}