如何计算 MySqlDataReader 中的行数？

Question

我已成功将项目从 odbc.datareader 切换到 mysql.datareader。问题是，对于第一个 /odbc datareader），AffectedRows 属性即使是纯查询也能正确检索行数。但它不适用于 mysql.datareader，那么它是-1。 所以我看不到如何检索行数，即“结果视图”。 编辑：我知道它的仅向前阅读器，但我不明白如下：如果在 DBreader=command.ExecuteRader() 行上放置断点，我可以看到 DBreader - 在结果视图中 - 与行一样多的对象应该是。怎么跑完就知道了？ 谢谢

Answer 1

DataReader 不包含行计数的原因是计算成本可能非常高。例如，假设您执行一个查询，返回今年输入且未删除的采购订单：

SELECT * FROM PurchaseOrders 
WHERE PurchaseDt > '2009-01-01'
AND IsDeleted = 0

并且您将此查询与 DataReader 结合使用并读出前 10 行。 SQL Server 根据请求将行“流”到客户端。每当您请求另一行时，SQL Server 将执行下一步的查询。因此，在您实际读出所有行之前，甚至 SQL Server 也不知道总行数。

Answer 2

要计算表中的行数（例如名称为 StudentTable），首先我使用以下 SQL 语句：

SELECT COUNT(*) FROM studentTable

我使用该语句作为 MySqlCommand 对象的命令文本。

然后，要使用 MySqlDataReader 对象（例如其名称为 reader）了解值（有多少行），我使用以下代码：

reader.GetString(0);

下面是我使用的代码：

...            
MySqlConnection conn = new MySqlConnection(connString);
MySqlCommand command = conn.CreateCommand();
command.CommandText = "SELECT COUNT(*) FROM studentTable";
try
{
    conn.Open();
}
catch (Exception ex)
{
    label1.Content = ex.Message;
}

reader = command.ExecuteReader();
while (reader.Read())
{
    label1.Content = "";
    label1.Content = reader.GetString(0);
}

reader.Close();
conn.Close();

Answer 3

很简单，阅读器没有任何选项来限制现有的选项，数据表也没有选项。 Entonces lo que hacemos es pasar todos los datos del Reader al Datatable y trabajamos con este (se muestra como recuperar el Total de filas, y como recuperar un registro especico)。

String consulta = "SELECT * FROM xxx";
conexion.Open();
comando.CommandText = consulta;

reader = command.ExecuteReader();

DataTable dt = new DataTable();
dt.Load(reader);

int nrofilas = dt.Rows.Count;

foreach (DataRow dr in dt.Rows)
{
    var value = dr["nameField"];
}

Answer 4

下面是我使用的功能。请随意根据您的需要进行调整。

    /// <summary>
    /// Counts the number of rows in a given table.
    /// </summary>
    /// <param name="tableName">The name of the table to query.</param>
    /// <param name="closeConnectionWhenDone">A flag indicating whether the connection should be closed once the query is executed.</param>
    /// <returns>The number of rows in the table.</returns>
    private static int GetNumRowsInTable(string tableName, bool closeConnectionWhenDone = false)
    {
        string selectQueryString = String.Format("select 1 from {0};", tableName);
        int numRows = 0;
        CommandBehavior behavior = closeConnectionWhenDone ? CommandBehavior.CloseConnection : CommandBehavior.Default;
        using (var command = new OdbcCommand(selectQueryString, ODBCHelper.Connection))
        using (var reader = command.ExecuteReader(behavior))
        {
            while (reader.Read())
            {
                numRows++;
            }
        }

        return numRows; 
    }