Npgsql：一个连接上的嵌套 sql 命令

Question

我正在将应用程序从 firebird 移植到 postgres，并且有一堆嵌套的 sql 命令。第一个命令是运行第二个命令所必需的，有些函数有 5 或 6 个嵌套命令，它们都使用相同的连接。我只是想知道是否有一种方法可以在一个连接上完成所有这些操作，而无需重写整个事情。

    static void NestedCommandsOnOneConnection()
    {
        using (NpgsqlConnection connection = new NpgsqlConnection(ConnectionString))
        {
            using (NpgsqlCommand command = new NpgsqlCommand("SELECT * FROM tableA", connection))
            {
                using (NpgsqlDataReader reader = command.ExecuteReader())
                {
                    using (NpgsqlCommand command2 = new NpgsqlCommand("SELECT * FROM tableB where column1 = @column1", connection))
                    {
                        command2.Parameters.AddWithValue("@column1", reader["column1"]);

                        using (NpgsqlDataReader reader2 = command2.ExecuteReader())
                        {
                            while (reader2.Read())
                            {
                                //Do things
                            }
                        }
                    }
                }
            }
        }
    }

//编辑：如果我这样做会更好吗？

    static void NestedCommandsOnOneConnection()
    {
        using (NpgsqlConnection connection = new NpgsqlConnection(ConnectionString))
        {
            var column1 = "";
            using (NpgsqlCommand command = new NpgsqlCommand("SELECT * FROM tableA LIMIT 1", connection))
            {
                using (NpgsqlDataReader reader = command.ExecuteReader())
                {
                    while(reader.Read())
                    {
                       column1 = reader["column1"].ToString();
                    }

                }
            }
            using (NpgsqlCommand command2 = new NpgsqlCommand("SELECT * FROM tableB where column1 = @column1", connection))
            {
                command2.Parameters.AddWithValue("@column1", column1);

                using (NpgsqlDataReader reader2 = command2.ExecuteReader())
                {
                    while (reader2.Read())
                    {
                        //Do things
                    }
                }
            }
        }
    }

当第二个命令被执行时，我收到错误消息“命令已经在进行中：SELECT * FROM tableA”那么有什么方法可以做到这一点而不必为每个命令建立连接？

Answer 1

问题在于，当您在第一个命令/阅读器的上下文中时，会为此建立连接。在您从第一个命令/阅读器释放连接之前，您无法运行第二个命令，依此类推。

解决方案是将要获取的数据加载到列表中，并根据该列表进行迭代并运行第二个命令/读取器。在第二个命令/阅读器上，您还将结果加载到另一个列表中，并对其进行迭代。

最后，我的建议是让您评估您想要从数据库中获取的数据以及您正在执行的查询。您的想法是正确的，但它会增加数据库的巨大过载，这会在其他并发用户尝试从同一个表中获取数据时产生问题。

Answer 2

要添加到上述@paulo-correia 的回复，打开第二个连接可能没问题，具体取决于您的用例。假设您正在使用池并且您并不缺少连接（即大规模并发场景），这样做没有任何问题，并且可以节省缓冲第一个查询结果所需的客户端内存。但是请注意，如果两个查询需要在一个事务中，这是不可能的。