如何在.NET 7.0应用中用Npgsql执行Apache Age查询并返回结果？

首先，确保你的连接已经正确加载Apache Age扩展并设置搜索路径，否则MATCH查询会无法被PostgreSQL识别：

using Npgsql;

var connString = "Host=myserver;Username=mylogin;Password=mypass;Database=mydatabase";
using var conn = new NpgsqlConnection(connString);
conn.Open();

// 加载Age扩展并配置搜索路径
using var setupCmd = new NpgsqlCommand("LOAD 'age'; SET search_path = ag_catalog, \"$user\", public;", conn);
setupCmd.ExecuteNonQuery();

接下来处理查询返回的NpgsqlDataReader，可以通过循环读取每一行结果，并根据列名或索引提取数据：

var cmd = new NpgsqlCommand("MATCH (n)-[:LIKES]->(m) RETURN n.name, m.name", conn);
// 用using自动释放reader资源，避免内存泄漏
using var reader = cmd.ExecuteReader();

// 循环读取每一行查询结果
while (reader.Read())
{
    // 方式1：通过列名定位并读取值
    var nNameOrdinal = reader.GetOrdinal("n.name");
    var mNameOrdinal = reader.GetOrdinal("m.name");
    
    // 先判断是否为NULL，避免空值异常
    var nName = reader.IsDBNull(nNameOrdinal) ? null : reader.GetString(nNameOrdinal);
    var mName = reader.IsDBNull(mNameOrdinal) ? null : reader.GetString(mNameOrdinal);

    // 方式2：直接通过列索引读取（索引从0开始，对应SELECT语句的返回顺序）
    // var nName = reader.IsDBNull(0) ? null : reader.GetString(0);
    // var mName = reader.IsDBNull(1) ? null : reader.GetString(1);

    // 处理读取到的数据，比如打印或存入实体对象
    Console.WriteLine($"{nName} likes {mName}");
}

若需读取完整的Age节点/关系 #

如果你的查询返回的是完整节点（如RETURN n）或关系，这些属于PostgreSQL的复合类型，需要额外处理：

var cmd = new NpgsqlCommand("MATCH (n)-[:LIKES]->(m) RETURN n, m", conn);
using var reader = cmd.ExecuteReader();

while (reader.Read())
{
    // 读取复合类型的节点
    var nNode = reader.GetValue(reader.GetOrdinal("n")) as NpgsqlComposite;
    if (nNode != null)
    {
        // 提取节点属性、标签、ID等信息
        var nName = nNode["name"]?.ToString();
        var nLabels = nNode["labels"] as Array;
        var nId = nNode["id"];
    }
}

关键注意事项 #

• 始终用using包裹NpgsqlConnection、NpgsqlCommand和NpgsqlDataReader，确保资源自动释放。
• 若查询可能返回多个结果集，可使用reader.NextResult()切换到下一个结果集。
• 对于可能为NULL的属性，必须先用reader.IsDBNull()判断，再读取值。

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