使用C#连接Snowflake数据库：读取整行及ODBC场景问询

1. 读取整行数据 #

如果你的代码只能拿到第一行第一列，大概率是用了ExecuteScalar()方法（仅返回单值）。要读取整行或全表数据，推荐用DbDataReader逐行读取，或用DataTable批量加载，示例如下：

用Snowflake .NET驱动读取整行 #

using Snowflake.Data.Client;
using System.Collections.Generic;

// 定义实体类映射表结构
public class EmailParserRecord
{
    public int Id { get; set; }
    public string Email { get; set; }
    public DateTime ParsedDate { get; set; }
}

// 读取逻辑
var connectionString = "account=你的账户;user=你的用户名;password=你的密码;db=目标库;schema=目标 schema;warehouse=目标仓库";
var records = new List<EmailParserRecord>();

using (var conn = new SnowflakeDbConnection())
{
    conn.ConnectionString = connectionString;
    conn.Open();

    var cmd = conn.CreateCommand();
    cmd.CommandText = "SELECT ID, EMAIL, PARSED_DATE FROM EMAILPARSER_TABLE";

    using (var reader = cmd.ExecuteReader())
    {
        // 循环遍历每一行
        while (reader.Read())
        {
            // 通过列名或索引获取字段值
            var record = new EmailParserRecord
            {
                Id = reader.GetInt32(reader.GetOrdinal("ID")),
                Email = reader.GetString(reader.GetOrdinal("EMAIL")),
                ParsedDate = reader.GetDateTime(reader.GetOrdinal("PARSED_DATE"))
            };
            records.Add(record);
        }
    }
}

用DataTable批量加载 #

如果不需要映射实体类，可直接用DataAdapter填充表：

using (var adapter = new SnowflakeDbDataAdapter(cmd))
{
    var dt = new DataTable();
    adapter.Fill(dt);
    // 遍历DataTable处理数据
    foreach (DataRow row in dt.Rows)
    {
        var email = row["EMAIL"].ToString();
        // ...业务逻辑
    }
}

2. 合并两张表的数据 #

优先推荐在Snowflake端用SQL完成合并（数据库端处理效率远高于客户端），小数据集也可在C#内存中合并。

数据库端合并（推荐） #

根据需求选择JOIN（关联合并）或UNION（同结构合并）：

• 关联合并（按ID关联两张表）：

SELECT 
    a.ID, a.EMAIL, a.PARSED_DATE,
    b.OTHER_FIELD, b.CREATE_DATE
FROM EMAILPARSER_TABLE a
JOIN 另一张表 b ON a.ID = b.PARSER_ID

• 同结构合并（合并同字段类型的数据）：

SELECT ID, EMAIL, PARSED_DATE AS RECORD_DATE FROM EMAILPARSER_TABLE
UNION ALL
SELECT ID, EMAIL, CREATE_DATE AS RECORD_DATE FROM 另一张表

直接在C#中读取上述SQL的查询结果即可。

客户端内存合并（仅小数据集） #

如果必须在C#中合并，先读取两张表的数据到集合，再用LINQ处理：

// 假设已读取两张表的数据到集合
List<EmailParserRecord> parserRecords = GetParserRecords();
List<OtherTableRecord> otherRecords = GetOtherRecords();

// 关联合并
var merged = from p in parserRecords
             join o in otherRecords on p.Id equals o.ParserId
             select new MergedRecord
             {
                 Id = p.Id,
                 Email = p.Email,
                 ParsedDate = p.ParsedDate,
                 OtherField = o.OtherField
             };

// 同结构合并
var combined = parserRecords.Select(p => new CommonRecord
{
    Id = p.Id,
    Email = p.Email,
    RecordDate = p.ParsedDate
}).Concat(otherRecords.Select(o => new CommonRecord
{
    Id = o.Id,
    Email = o.Email,
    RecordDate = o.CreateDate
})).ToList();

3. 何时使用Snowflake ODBC驱动及代码示例 #

使用场景 #

• 项目基于旧版.NET Framework（如4.0及以下），官方Snowflake .NET驱动不支持；
• 需要兼容依赖ODBC的第三方工具（如老旧BI/ETL工具）；
• 团队已有成熟的ODBC数据访问框架，不想引入新驱动依赖。

C# ODBC代码示例 #

using System.Data.Odbc;

// 方式1：使用预配置的DSN
var connectionString = "DSN=SnowflakeDSN;UID=你的用户名;PWD=你的密码";

// 方式2：直接指定驱动参数（无需DSN）
// var connectionString = "Driver={SnowflakeDSIIDriver};Server=你的账户.snowflakecomputing.com;Database=目标库;Schema=目标schema;Warehouse=目标仓库;UID=你的用户名;PWD=你的密码;Role=你的角色";

using (var conn = new OdbcConnection(connectionString))
{
    conn.Open();

    var cmd = new OdbcCommand("SELECT * FROM EMAILPARSER_TABLE", conn);
    using (var reader = cmd.ExecuteReader())
    {
        while (reader.Read())
        {
            var email = reader["EMAIL"].ToString();
            // ...处理逻辑
        }
    }
}

注意：需先安装Snowflake ODBC驱动，可从Snowflake官方下载对应版本。

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