如何在C# Windows服务中通过JDBC/ODBC连接Databricks Delta表并解决驱动相关错误

首先，你碰到的Data source name not found and no default driver specified错误，主要原因通常是驱动架构不匹配或者连接字符串里的驱动名称/DSN配置有问题。下面给你修正后的可运行代码，以及关键的注意事项：

修正后的C#代码（支持查询/插入/更新） #

using System;
using System.Data.Odbc;

namespace DatabricksDeltaOperations
{
    public class DeltaTableHandler
    {
        public static void Main(string[] args)
        {
            try
            {
                // 采用无DSN连接方式，避免依赖预配置的数据源，更适合服务部署
                OdbcConnectionStringBuilder connBuilder = new OdbcConnectionStringBuilder
                {
                    // 重点：驱动名称必须和你安装的完全一致！x64驱动通常叫这个名字
                    Driver = "{Simba Spark ODBC Driver 64-bit}",
                };

                // Databricks核心连接参数
                connBuilder.Add("Host", "sas-tes-dev.cloud.databricks.com");
                connBuilder.Add("Port", "443");
                connBuilder.Add("SSL", "1"); // 强制SSL加密
                connBuilder.Add("ThriftTransport", "2"); // 使用HTTP传输（Databricks推荐）
                connBuilder.Add("AuthMech", "3"); // Token认证方式
                connBuilder.Add("UID", "token");
                connBuilder.Add("PWD", "dapisds62728299255b4"); // 注意：生产环境别硬编码Token，用安全存储！
                connBuilder.Add("HTTPPath", "sql/protocolv1/o/6709534942857832/0208-221830-graph177");
                connBuilder.Add("SparkSQLDialect", "Databricks"); // 指定适配Databricks的SQL方言

                using (OdbcConnection connection = new OdbcConnection(connBuilder.ConnectionString))
                {
                    connection.Open();
                    Console.WriteLine("✅ 成功连接到Databricks Delta表！");

                    // 1. 示例：查询数据
                    string querySql = "SELECT * FROM mpre_sm.innsme LIMIT 5";
                    using (OdbcCommand queryCmd = new OdbcCommand(querySql, connection))
                    using (OdbcDataReader reader = queryCmd.ExecuteReader())
                    {
                        // 打印列名
                        for (int i = 0; i < reader.FieldCount; i++)
                        {
                            Console.Write($"{reader.GetName(i)}\t");
                        }
                        Console.WriteLine("\n---");

                        // 打印数据行
                        while (reader.Read())
                        {
                            for (int i = 0; i < reader.FieldCount; i++)
                            {
                                Console.Write($"{reader[i] ?? "NULL"}\t");
                            }
                            Console.WriteLine();
                        }
                    }

                    // 2. 示例：插入数据（用参数化查询防注入）
                    string insertSql = "INSERT INTO mpre_sm.innsme (column_name1, column_name2) VALUES (?, ?)";
                    using (OdbcCommand insertCmd = new OdbcCommand(insertSql, connection))
                    {
                        insertCmd.Parameters.AddWithValue("@val1", "测试数据1");
                        insertCmd.Parameters.AddWithValue("@val2", 2024);

                        int insertedRows = insertCmd.ExecuteNonQuery();
                        Console.WriteLine($"✅ 成功插入 {insertedRows} 条数据");
                    }

                    // 3. 示例：更新数据（同样用参数化）
                    string updateSql = "UPDATE mpre_sm.innsme SET column_name2 = ? WHERE column_name1 = ?";
                    using (OdbcCommand updateCmd = new OdbcCommand(updateSql, connection))
                    {
                        updateCmd.Parameters.AddWithValue("@newVal", 2025);
                        updateCmd.Parameters.AddWithValue("@conditionVal", "测试数据1");

                        int updatedRows = updateCmd.ExecuteNonQuery();
                        Console.WriteLine($"✅ 成功更新 {updatedRows} 条数据");
                    }
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine($"❌ 操作失败：{ex.Message}");
                Console.WriteLine($"详细错误信息：{ex.ToString()}");
            }
        }
    }
}

关键建议 #

• 驱动安装要精准：

  • 必须安装和你的Windows服务架构完全匹配的SIMBA Spark ODBC驱动（x64服务装x64驱动，x86装x86），驱动名称要严格对应（比如x64版本的名称是{Simba Spark ODBC Driver 64-bit}）
  • 安装驱动时选择"安装为系统驱动"，确保Windows服务（通常以Local System账户运行）能访问到驱动文件

• 连接字符串避坑：

  • 优先用无DSN的连接方式，避免依赖预配置的数据源，减少部署时的配置环节
  • 绝对不要硬编码Token！生产环境建议用Windows Credential Manager、Azure Key Vault这类安全存储来读取Token

• Delta表操作最佳实践：

  • 执行写入操作前，确认你的Token拥有对应Delta表的写入权限
  • 所有SQL操作都用参数化查询，既防SQL注入，又能提升执行效率
  • 如果是批量写入/更新，建议用OdbcDataAdapter或者批量提交的方式，减少网络往返次数

• Windows服务调试技巧：

  • 先把代码以控制台程序运行测试，确认连接和操作正常后再部署为Windows服务
  • 在服务中添加日志记录（比如用NLog、Serilog），方便排查运行时的异常问题

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