使用OPENROWSET向DB2表插入数据时遇错误的技术求助

首先得戳破一个核心误区：OPENROWSET是SQL Server的专属函数，DB2数据库根本不支持这个语法——你把SQL Server的用法直接套到DB2上，肯定会触发报错。下面给你两种可行的解决方案，以及排查问题的关键点：

一、常规方案：客户端读取CSV后批量插入DB2 #

既然DB2不认OPENROWSET，我们换个思路：用C#先读取本地CSV文件，再把数据逐条/批量写入DB2。这里用TextFieldParser（需要引用Microsoft.VisualBasic程序集）来处理CSV，示例代码如下：

using System.Data.Odbc;
using Microsoft.VisualBasic.FileIO;
using System;

namespace Db2CsvInsert
{
    class Program
    {
        static void Main(string[] args)
        {
            string csvFilePath = @"D:\your\target\file.csv"; // 替换成你的CSV实际路径
            string db2ConnectionString = "DSN=DBHUBD";

            using (OdbcConnection connection = new OdbcConnection(db2ConnectionString))
            {
                connection.Open();
                // 开启事务避免部分插入失败导致数据不一致
                using (OdbcTransaction transaction = connection.BeginTransaction())
                {
                    try
                    {
                        // 替换成你的表字段，注意和CSV列顺序、数据类型严格匹配
                        string insertSql = @"INSERT INTO trgisl.LCR_HQLA_WEIGHT 
                                            (COLUMN_NAME_1, COLUMN_NAME_2, COLUMN_NAME_3) 
                                            VALUES (?, ?, ?)";

                        using (OdbcCommand cmd = new OdbcCommand(insertSql, connection, transaction))
                        {
                            // 按字段类型添加参数，数量和SQL里的?一一对应
                            cmd.Parameters.Add("Param1", OdbcType.VarChar, 50);
                            cmd.Parameters.Add("Param2", OdbcType.Decimal);
                            cmd.Parameters.Add("Param3", OdbcType.Date);

                            // 解析CSV文件
                            using (TextFieldParser parser = new TextFieldParser(csvFilePath))
                            {
                                parser.TextFieldType = FieldType.Delimited;
                                parser.SetDelimiters(",");
                                parser.HasFieldsEnclosedInQuotes = true; // 处理带引号的字段（比如包含逗号的内容）
                                parser.ReadLine(); // 跳过表头行

                                while (!parser.EndOfData)
                                {
                                    string[] rowData = parser.ReadFields();
                                    if (rowData == null || rowData.Length != 3)
                                    {
                                        Console.WriteLine($"跳过异常行：{string.Join(",", rowData ?? Array.Empty<string>())}");
                                        continue;
                                    }

                                    // 给参数赋值，注意处理空值和类型转换（根据你的实际数据调整）
                                    cmd.Parameters[0].Value = string.IsNullOrWhiteSpace(rowData[0]) ? DBNull.Value : rowData[0];
                                    cmd.Parameters[1].Value = decimal.TryParse(rowData[1], out decimal numVal) ? numVal : DBNull.Value;
                                    cmd.Parameters[2].Value = DateTime.TryParse(rowData[2], out DateTime dateVal) ? dateVal : DBNull.Value;

                                    cmd.ExecuteNonQuery();
                                }
                            }

                            transaction.Commit();
                            Console.WriteLine("数据全部插入成功！");
                        }
                    }
                    catch (Exception ex)
                    {
                        transaction.Rollback();
                        Console.WriteLine($"插入失败，已回滚：{ex.Message}");
                        throw;
                    }
                }
            }
        }
    }
}

二、大数据量优化方案：用DB2的LOAD命令 #

如果CSV文件非常大（比如几十万行以上），逐行插入效率太低，可以用DB2原生的LOAD命令直接导入：

1. 把CSV文件放到DB2服务器可访问的路径（或者开启客户端LOAD模式）
2. 执行类似以下的DB2命令（可以通过C#的OdbcCommand执行）：

LOAD FROM 'D:\csv_path\file.csv' OF DEL 
MODIFIED BY COLDEL, CHARDEL"" DATEFORMAT="YYYY-MM-DD" 
INSERT INTO trgisl.LCR_HQLA_WEIGHT;

注意：执行LOAD命令需要DB2账号拥有对应的LOAD权限。

三、顺便提下你原代码的其他语法问题（虽不影响核心，但可以参考） #

就算是在SQL Server里用OPENROWSET，你的代码也有语法错误：

• MSDAQL拼写错误，正确的驱动名是MSDASQL
• 连接字符串里的引号嵌套混乱，正确写法需要用双引号转义或处理好单引号拼接
• select * ...语句未完成，缺少CSV文件的路径参数

但核心问题始终是DB2不支持OPENROWSET函数，所以这些语法修正也解决不了根本问题。

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