C#定时读取写入指定行内容

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

class Program
{
    private const string connectionString = "Your_Connection_String"; // 替换为你的数据库连接字符串
    private const string configFilePath = "d:\\config.txt";
    private const int intervalInSeconds = 30;

    static void Main(string[] args)
    {
        Timer timer = new Timer(ExecuteTask, null, TimeSpan.Zero, TimeSpan.FromSeconds(intervalInSeconds));

        Console.WriteLine("Press any key to stop the program...");
        Console.ReadKey();

        timer.Dispose();
    }

    private static void ExecuteTask(object state)
    {
        try
        {
            int configValue = GetConfigValue();

            using (SqlConnection connection = new SqlConnection(connectionString))
            {
                connection.Open();

                string query = $"SELECT * FROM record WHERE ID > {configValue}";

                using (SqlCommand command = new SqlCommand(query, connection))
                {
                    SqlDataReader reader = command.ExecuteReader();

                    using (StreamWriter writer = File.CreateText("A_table.txt"))
                    {
                        while (reader.Read())
                        {
                            string rowData = $"{reader["ID"]}\t{reader["Column1"]}\t{reader["Column2"]}\t..."; // 替换为你的表结构

                            writer.WriteLine(rowData);
                        }
                    }
                }

                int lastID = GetLastID();

                UpdateConfigValue(lastID);
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine("An error occurred: " + ex.Message);
        }
    }

    private static int GetConfigValue()
    {
        string line = File.ReadLines(configFilePath).Skip(2).FirstOrDefault();
        if (!string.IsNullOrEmpty(line))
        {
            int value;
            if (int.TryParse(line, out value))
            {
                return value;
            }
        }

        throw new Exception("Invalid config file format");
    }

    private static int GetLastID()
    {
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();

            string query = "SELECT TOP 1 ID FROM record ORDER BY ID DESC";

            using (SqlCommand command = new SqlCommand(query, connection))
            {
                return (int)command.ExecuteScalar();
            }
        }
    }

    private static void UpdateConfigValue(int value)
    {
        string[] lines = File.ReadAllLines(configFilePath);

        lines[2] = value.ToString();

        File.WriteAllLines(configFilePath, lines);
    }
}