为什么我成功读取的Npgsql数据会消失？

Question

为什么我成功读取的Npgsql数据会消失？

3

我有以下代码结构。看起来我误解了C#方法返回值。一个“完整的”枚举器如何可能作为空枚举器返回？

class ThingDoer
{
    public NpgsqlDataReader DoQuery()
    {
        NpgsqlCommand c = new NpgsqlCommand(...);
        NpgsqlDataReader dataread = c.ExecuteReader();
        return dataread;  // Debugger confirms that six data are enumerable here.
    }
}

...

class OtherThing
{
    public void higherLevelFunction()
    {
        NpgsqlDataReader result = myThingDoer.DoQuery();
        result.Read();  // No data! result's enumerable returns nothing!
    }
}

- Andres Jaan Tack

调试器如何“确认”这一点？您在调试器中调用了什么？空结果仍然具有字段，但没有行。此外，在所有这些内容中，NpgsqlConnection 在哪里？ - Jon Hanna

@Jon Hanna 我已经消除了所有额外的工作，包括连接等琐碎细节，以突出实际问题。通过设置断点，我能够检查在返回之前和之后读取的数据。 - Andres Jaan Tack

2个回答

1

NpgsqlCommand c = new NpgsqlCommand(...);
        NpgsqlDataReader dataread = c.ExecuteReader();

以上代码行与方法DoQuery非常相关。因此，一旦控制权从该方法中退出，该方法内部创建的每个对象都会失去其作用域。因此，您正在失去数据，因为您在调用方方法中引用了引用类型。

- Zenwalker

那么我该如何避免失去这个对象呢？ - Andres Jaan Tack

将连接对象设为类变量，这样它就不会失去作用域。同样的，对于DataReader也是如此，你可以在需要时实例化它，即当你执行DoQuery时，实例化它，例如new SqlCommand()，但让变量保持在类作用域内。无论如何，在你的消费者代码中创建DoQuery的类对象，所以没问题！ - Zenwalker

1

亲爱的神啊！不要把连接作为类变量。 - Jon Hanna

如果OP在全局作用域中创建了连接，那么您是正确的，但是在他的代码中，似乎他正在做一些类似于new SqlCommand(new SqlConnection....)的事情，因此很明显它失去了它的作用域，并且自动地可能会或可能不会关闭连接。我认为，除非使用Using(){}，否则连接不会在本地范围内自动关闭。如果我错了，请纠正我。 - Zenwalker

@AndresJaanTack 是的，Jon 在这里是正确的，不要将连接设为全局，而是将数据收集设为全局。抱歉，我在想什么！请原谅！ - Zenwalker

显示剩余4条评论

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Jon Hanna · Accepted Answer

您没有详细说明您的连接来源。假设它是这样的：

public NpgsqlDataReader DoQuery()
{
    using(NpgsqlConnection = GetConnectionCode())
    {
        NpgsqlCommand c = new NpgsqlCommand(...);
        NpgsqlDataReader dataread = c.ExecuteReader();
        return dataread;
    }//Connection closes at this using-scope being left because that triggers Dispose()
}

然后将其更改为：

public NpgsqlDataReader DoQuery()
{
    bool ownershipPassed = false;
    NpgsqlConnection conn = GetConnectionCode();
    try
    {
        NpgsqlCommand c = new NpgsqlCommand(...);
        NpgsqlDataReader dataread = c.ExecuteReader(CommandBehavior.CloseConnection);
        ownershipPassed = true;
        return dataread;
    }
    finally
    {
        if(!ownershipPassed)//only if we didn't create the reader than takes charge of the connection
          conn.Dispose();
    }
}

当您使用阅读器时，您必须对其进行处理，以便依次处理连接到数据库的底层连接：

public void higherLevelFunction()
{
    using(NpgsqlDataReader result = myThingDoer.DoQuery())
      result.Read();
}