SQLCommand.ExecuteReader() 不限制只读语句

Question

显然，ExecuteReader 用于只读，而 ExecuteNonQuery 用于事务。但由于某种原因，即使我使用 ExecuteReader，我仍然能够运行写入（插入、更新、删除）命令（在 textbox1 中键入）。我的代码有问题还是我误解了 ExecuteReader 的工作方式？

//MY CODE

string sqlStatement = textbox1.Text;

System.Data.SqlClient.SqlConnectionStringBuilder builder =
  new System.Data.SqlClient.SqlConnectionStringBuilder();
builder.DataSource = ActiveServer;
builder.IntegratedSecurity = true;

System.Data.SqlClient.SqlConnection Connection = new 
   System.Data.SqlClient.SqlConnection(builder.ConnectionString);
Connection.Open();

System.Data.SqlClient.SqlCommand command = new 
  System.Data.SqlClient.SqlCommand(sqlStatement, Connection);
System.Data.SqlClient.SqlDataReader reader = command.ExecuteReader();

dataGridView1.AutoGenerateColumns = true;

bindingSource1.DataSource = reader;
dataGridView1.DataSource = bindingSource1;

reader.Close();
Connection.Close();

Answer 1

ExecuteReader 只是返回一个读取器，该读取器可以读取从 SQL 过程返回的行 - 它不会阻止您在提供该结果集的过程中运行任意 SQL。

执行插入/更新/删除，然后立即返回结果集（因此从看起来像读取的代码来看）可以说有点奇怪（读取：代码气味），应该进行审查以查看是否可以将其拆分为不同的操作。

Answer 2

尽管两者都执行 SQL，但 ExecuteReader 预计会返回记录，而 ExecuteNonQuery 受影响的记录数。因此，两者是不同的。但在内部，它们的不同程度取决于供应商的特定实现。您可以单独使用 ExecuteReader 来执行所有数据库操作因为它刚刚工作（到目前为止），但由于它没有记录它并不是真正正确的方法< /em>.通过ExecuteNonQuery，您可以更清楚地了解您的意图。

就性能而言，我认为根本没有区别。我尝试使用 SQLite、MySqlClient、SqlClient、SqlServerCe 和 VistaDb 并没有看到明显的差异有利于任何一个。他们都应该以某种方式在内部使用 ExecuteReader。

要点：

SqlClient：

private int InternalExecuteNonQuery(DbAsyncResult result, string methodName, bool sendToPipe)
{
    if (!this._activeConnection.IsContextConnection)
    {
        if (this.BatchRPCMode || CommandType.Text != this.CommandType || this.GetParameterCount(this._parameters) != 0)
        {
            Bid.Trace("<sc.SqlCommand.ExecuteNonQuery|INFO> %d#, Command executed as RPC.\n", this.ObjectID);
            SqlDataReader sqlDataReader = this.RunExecuteReader(CommandBehavior.Default, RunBehavior.UntilDone, false, methodName, result);
            if (sqlDataReader == null)
            {
                goto IL_E5;
            }
            sqlDataReader.Close();
            goto IL_E5;
        }
    IL_B5:
        this.RunExecuteNonQueryTds(methodName, flag);
    }
    else
    {
        this.RunExecuteNonQuerySmi(sendToPipe);
    }
IL_E5:
    return this._rowsAffected;
}

和

MySqlClient：

public override int ExecuteNonQuery()
{
  int records = -1;

  #if !CF
  // give our interceptors a shot at it first
  if ( connection != null && 
       connection.commandInterceptor != null &&
       connection.commandInterceptor.ExecuteNonQuery(CommandText, ref records))
    return records;
  #endif

  // ok, none of our interceptors handled this so we default
  using (MySqlDataReader reader = ExecuteReader())
  {
    reader.Close();
    return reader.RecordsAffected;
  }
}

如您所见，MySqlClient 直接调用 ExecuteReader，而 SqlClient 仅在某些条件下调用。 请注意，insert 和 update 很少是瓶颈（通常是 select）。

正如我所说，在 ExecuteReader 的帮助下您不会获得受影响的行数，因此最好使用 ExecuteNonQuery 来执行查询。 ExecuteReader 更直接的替换是 ExecuteScalar，它返回读取的第一行的第一列中的数据。

要点：

SqlClient：

override public object ExecuteScalar()
{
    SqlConnection.ExecutePermission.Demand();

    // Reset _pendingCancel upon entry into any Execute - used to synchronize state
    // between entry into Execute* API and the thread obtaining the stateObject. 
    _pendingCancel = false;

    SqlStatistics statistics = null;
    IntPtr hscp;
    Bid.ScopeEnter(out hscp, "<sc.sqlcommand.executescalar|api> %d#", ObjectID);
    try
    {
        statistics = SqlStatistics.StartTimer(Statistics);
        SqlDataReader ds = RunExecuteReader(0, RunBehavior.ReturnImmediately, true, ADP.ExecuteScalar);

        object retResult = null;
        try
        {
            if (ds.Read())
            {
                if (ds.FieldCount > 0)
                {
                    retResult = ds.GetValue(0);
                }
            }
            return retResult;
        }
        finally
        {
            // clean off the wire 
            ds.Close();
        }
    }
    finally
    {
        SqlStatistics.StopTimer(statistics);
        Bid.ScopeLeave(ref hscp);
    }
}

和

MySqlClient ：

public override object ExecuteScalar()
{
    lastInsertedId = -1;
    object val = null;

    #if !CF
    // give our interceptors a shot at it first
    if (connection != null &&
        connection.commandInterceptor.ExecuteScalar(CommandText, ref val))
        return val;
    #endif

    using (MySqlDataReader reader = ExecuteReader())
    {
        if (reader.Read())
            val = reader.GetValue(0);
    }

    return val;
}

所以使用 ExecuteReader 进行 ExecuteScalar 并没有什么坏处，并且没有任何性能差异。

Answer 3

这些方法的底层实现只是执行给定的 SQL 语句，因此您可以使用这些方法中的任何一个来运行几乎任何语句。只是最终的结果是一个读者试图返回一个期望的结果集，而另一个方法并不期望返回一个结果集。使用 ExecuteReader 运行不生成结果集的语句可能效率稍低。提供者仍然会创建一个数据读取器对象，这会增加一点成本（在大多数情况下可能可以忽略不计，除非提供者最终对服务器进行另一个往返调用）。