跨服务器数据库表数据插入咨询：Dataset写入与定时执行方案

一、将Dataset数据写入PostgreSQL表B的可行方案 #

你的原SQL语句失败是因为PostgreSQL无法直接查询内存中的Dataset对象，以下是几种可行实现方式：

方案1：使用NpgsqlDataAdapter自动更新（适合中小量数据） #

利用DataAdapter的Update方法，基于Dataset中的数据自动生成并执行插入语句：

string targetConnStr = "Host=目标服务器地址;Username=用户名;Password=密码;Database=数据库B";
using (NpgsqlConnection conn = new NpgsqlConnection(targetConnStr))
{
    conn.Open();
    // 通过空查询获取目标表结构，用于自动生成插入命令
    using (NpgsqlDataAdapter adapter = new NpgsqlDataAdapter("SELECT id, name FROM tablB WHERE 1=0", conn))
    {
        NpgsqlCommandBuilder cmdBuilder = new NpgsqlCommandBuilder(adapter);
        // 将Dataset中的表数据写入目标表
        int affectedRows = adapter.Update(dataset1.Tables[0]);
        // 可选：输出受影响行数
        Console.WriteLine($"成功插入 {affectedRows} 条记录");
    }
}

方案2：Npgsql批量复制（推荐大量数据场景，效率更高） #

使用NpgsqlBulkCopy直接将DataTable批量写入目标表，性能远优于单条插入：

string targetConnStr = "Host=目标服务器地址;Username=用户名;Password=密码;Database=数据库B";
using (NpgsqlConnection conn = new NpgsqlConnection(targetConnStr))
{
    conn.Open();
    using (NpgsqlBulkCopy bulkCopy = new NpgsqlBulkCopy(conn))
    {
        bulkCopy.DestinationTableName = "tablB";
        // 若Dataset列名与目标表列名完全一致，可省略列映射
        bulkCopy.ColumnMappings.Add("id", "id");
        bulkCopy.ColumnMappings.Add("name", "name");
        // 执行批量写入
        bulkCopy.WriteToServer(dataset1.Tables[0]);
    }
}

方案3：循环构造参数化插入（小数据量临时场景） #

通过遍历Dataset行，执行参数化插入避免SQL注入：

string targetConnStr = "Host=目标服务器地址;Username=用户名;Password=密码;Database=数据库B";
using (NpgsqlConnection conn = new NpgsqlConnection(targetConnStr))
{
    conn.Open();
    string insertSql = "INSERT INTO tablB(id, name) VALUES (@id, @name)";
    using (NpgsqlCommand cmd = new NpgsqlCommand(insertSql, conn))
    {
        // 预定义参数
        cmd.Parameters.Add("@id", NpgsqlDbType.Integer);
        cmd.Parameters.Add("@name", NpgsqlDbType.Varchar);
        
        foreach (DataRow row in dataset1.Tables[0].Rows)
        {
            cmd.Parameters["@id"].Value = row["id"];
            cmd.Parameters["@name"].Value = row["name"];
            cmd.ExecuteNonQuery();
        }
    }
}

二、Visual Studio中实现每小时自动执行 #

方式1：控制台应用 + Windows任务计划（简单易维护） #

1. 在Visual Studio中创建控制台应用程序，将上述数据迁移逻辑封装到Main方法中
2. 编译生成可执行文件（.exe）
3. 打开Windows任务计划程序：
   • 创建基本任务，设置触发器为「每天」，重复间隔1小时，持续时间选「无限期」
   • 操作选择「启动程序」，选择生成的exe文件路径
   • 配置任务选项（如勾选「不管用户是否登录都要运行」）

方式2：Windows服务（适合长期后台运行） #

1. 在Visual Studio中创建Windows服务项目
2. 在服务的OnStart方法中初始化定时器，设置1小时间隔：

private System.Timers.Timer _scheduleTimer;

protected override void OnStart(string[] args)
{
    // 3600000毫秒 = 1小时
    _scheduleTimer = new System.Timers.Timer(3600000);
    _scheduleTimer.Elapsed += ExecuteDataMigration;
    _scheduleTimer.AutoReset = true;
    _scheduleTimer.Start();
}

private void ExecuteDataMigration(object sender, System.Timers.ElapsedEventArgs e)
{
    // 调用数据迁移方法
    MigrateData();
}

protected override void OnStop()
{
    _scheduleTimer?.Stop();
    _scheduleTimer?.Dispose();
}

3. 将数据迁移逻辑封装到MigrateData方法中
4. 编译后使用InstallUtil.exe工具安装服务，设置服务为自动启动

内容的提问来源于stack exchange，提问作者abc