ExecuteReader 查询，其中有两个 ExecuteNonQuery

Question

我遇到了一些从 c# 到 sql 的查询的问题。我需要有一个查询 executeReare 并在其中有一个 if else 允许我在两个插入查询之间进行选择。我正在调用一个小的外部程序（将 url 收集到数据库中），如果选择了 1（通过），则允许我在 1 和 2 之间进行选择（通过），否则（失败）。我不能这样做，因为调试给了我“命令尚未与打开的 DataReader 相关联，需要关闭。” 我不知道该尝试什么了。

private void btnSTART_Click(object sender, RoutedEventArgs e)
{
  sqliteCon.Open();
  if (sqliteCon.State == System.Data.ConnectionState.Open)
  {
    string path = null;//estrazione1
    SqlCommand cmd = new SqlCommand("select nomeI  FROM tabL where selection=1", sqliteCon);
    SqlDataReader nomeIRdr = null;//estrazione2

                    //qui                  
    var scriptsToRun = new List<string>();

    using (nomeIRdr = cmd.ExecuteReader())
    {
      while (nomeIRdr.Read())//estrazione4
      {
        path = nomeIRdr["nomeI"].ToString();//estrazione5

        Process MyProc = Process.Start(path);//permette la run del path contenuto nel db
        MyProc.WaitForExit();
        var exitCode = MyProc.ExitCode;

        if (exitCode == 1)
        {
          scriptsToRun.Add("insert into tabL resItem values 'PASS'");
        }
        else
        {
          scriptsToRun.Add("insert into tabL resItem values 'FAIL'");
        }
        sqliteCon.Close();
      }

    }

    foreach (var script in scriptsToRun)
    {
      SqlCommand cmd1 = new SqlCommand(script, sqliteCon);
      cmd1.ExecuteNonQuery();
    }

  }

}

Answer 1

不要共享 single 连接并将所有内容都塞进 single 例程中。请保持您的代码简单。

1. 在查询 RDBMS 时创建（和处理）连接
2. 提取方法

代码：

流程执行和返回执行结果集合：

// Item1 - path
// Item2 - true in succeed 
private List<Tuple<string, bool>> ExecuteResults() {
  List<Tuple<string, bool>> result = new List<Tuple<string, bool>>();

  using (var con = new SqlConnection(ConnectionStringHere)) {
    con.Open();

    string sql = 
      @"select nomeItem 
          from tabList 
         where selection = 1";

    using (SqlCommand cmd = new SqlCommand(sql, con)) {
      using (var reader = cmd.ExecuteReader()) {
        while (reader.Read()) {
          string path = Convert.ToString(reader[0]);

          using (Process process = Process.Start(path)) {
            process.WaitForExit();

            result.Add(Tuple.Create(path, process.ExitCode == 1)); 
          }
        }
      } 
    }
  }

  return result;
}

在 RDBMS 中保存 results

private void ApplyExecuteResults(IEnumerable<Tuple<string, bool>> results) {
  using (var con = new SqlConnection(ConnectionStringHere)) {
    con.Open();

    string sql = 
      @"update tabList 
           set resItem = @prm_resItem
         where nomeItem = @prm_nomeItem";

    using (SqlCommand cmd = new SqlCommand(sql, con)) {
      cmd.Parameters.Add("@prm_nomeItem", SqlDbType.VarChar);
      cmd.Parameters.Add("@prm_resItem", SqlDbType.VarChar);

      foreach (var item in results) {
        cmd.Parameters[0].Value = item.Item1; 
        cmd.Parameters[1].Value = item.Item2 ? "PASS" : "FAIL"; 

        cmd.ExecuteNonQuery();
      }
    } 
  }
}

最后，结合两个例程：

private void btnSTART_Click(object sender, RoutedEventArgs e) {
  ApplyExecuteResults(ExecuteResults());
}