エラー
初心者です。
このコマンドに関連付けられている DataReader が既に開かれています。 このコマンドを最初に閉じる必要があります。というエラーが取れず、困っています。
下はDB接続クラスです。
C#
1using System; 2using System.Collections.Generic; 3using System.Configuration; 4using System.Data; 5using System.Data.Common; 6using System.Data.SqlClient; 7using System.Linq; 8using System.Text; 9using System.Threading.Tasks; 10 11namespace EmployeeSystem.DataAccess 12{ 13 class DBManager 14 { 15 private SqlConnection sqlConnection; 16 private SqlTransaction sqlTransaction; 17 18 19 /// <summary> 20 /// DB接続 21 /// </summary> 22 public DBManager() 23 { 24 // 接続文字列を生成 25 String connectionString = ConfigurationManager.ConnectionStrings["sqlsvr"].ConnectionString; 26 27 // SqlConnection の新しいインスタンスを生成 (接続文字列を指定) 28 this.sqlConnection = new SqlConnection(connectionString); 29 30 // データベース接続を開く 31 this.sqlConnection.Open(); 32 } 33 34 /// <summary> 35 /// DB切断 36 /// </summary> 37 public void Close() 38 { 39 this.sqlConnection.Close(); 40 this.sqlConnection.Dispose(); 41 } 42 43 /// <summary> 44 /// トランザクション開始 45 /// </summary> 46 public void BeginTran() 47 { 48 this.sqlTransaction = this.sqlConnection.BeginTransaction(); 49 } 50 51 /// <summary> 52 /// トランザクション コミット 53 /// </summary> 54 public void CommitTran() 55 { 56 if (this.sqlTransaction.Connection != null) 57 { 58 this.sqlTransaction.Commit(); 59 this.sqlTransaction.Dispose(); 60 } 61 } 62 63 /// <summary> 64 /// トランザクション ロールバック 65 /// </summary> 66 public void RollBack() 67 { 68 if (this.sqlTransaction.Connection != null) 69 { 70 this.sqlTransaction.Rollback(); 71 this.sqlTransaction.Dispose(); 72 } 73 } 74 /// <summary> 75 /// クエリ実行(戻り値なし) 76 /// </summary> 77 /// <param name="query"></param> 78 /// <param name="paramDict"></param> 79 public void ExecuteVoidQuery(string query,Dictionary<string, object> paramDict) 80 { 81 SqlCommand command = new SqlCommand(); 82 83 //クエリー送信先、トランザクションの指定 84 command.Connection = this.sqlConnection; 85 command.Transaction = this.sqlTransaction; 86 87 command.CommandText = query; 88 foreach (KeyValuePair<string, Object> item in paramDict) 89 { 90 command.Parameters.Add(new SqlParameter(item.Key, item.Value)); 91 } 92 93 // SQLを実行 94 SqlDataReader reader = command.ExecuteReader(); 95 96 } 97 /// <summary> 98 /// クエリ実行(output項目あり) 99 /// </summary> 100 /// <param name="query"></param> 101 /// <param name="paramDict"></param> 102 /// <returns></returns> 103 public SqlDataReader ExecuteQuery(string query, Dictionary<string, Object> paramDict) 104 { 105 SqlCommand command = new SqlCommand(); 106 107 //クエリー送信先、トランザクションの指定 108 command.Connection = this.sqlConnection; 109 command.Transaction = this.sqlTransaction; 110 111 command.CommandText = query; 112 foreach (KeyValuePair<string, Object> item in paramDict) 113 { 114 command.Parameters.Add(new SqlParameter(item.Key, item.Value)); 115 } 116 117 // SQLを実行 118 SqlDataReader reader = command.ExecuteReader(); 119 120 return reader; 121 } 122 123 /// <summary> 124 /// クエリー実行(OUTPUT項目あり) 125 /// <para name="query">SQL文</para> 126 /// </summary> 127 public SqlDataReader ExecuteQuery(string query) 128 { 129 return this.ExecuteQuery(query, new Dictionary<string, Object>()); 130 } 131 132 /// <summary> 133 /// クエリー実行(OUTPUT項目なし) 134 /// <para name="query">SQL文</para> 135 /// <para name="paramDict">SQLパラメータ</para> 136 /// </summary> 137 public void ExecuteNonQuery(string query, Dictionary<string, Object> paramDict) 138 { 139 SqlCommand sqlCom = new SqlCommand(); 140 141 //クエリー送信先、トランザクションの指定 142 sqlCom.Connection = this.sqlConnection; 143 sqlCom.Transaction = this.sqlTransaction; 144 145 sqlCom.CommandText = query; 146 foreach (KeyValuePair<string, Object> item in paramDict) 147 { 148 sqlCom.Parameters.Add(new SqlParameter(item.Key, item.Value)); 149 } 150 151 // SQLを実行 152 sqlCom.ExecuteNonQuery(); 153 } 154 155 /// <summary> 156 /// DataLoad 157 /// </summary> 158 /// <param name="selectSql"></param> 159 /// <returns></returns> 160 public DataTable DataLoad(SqlDataReader reader) 161 { 162 DataTable dt = new System.Data.DataTable(); 163 dt.Load(reader); 164 return dt; 165 } 166 167 } 168} 169
下のコードは呼び出し元です
C#
1 if (result == DialogResult.Yes) 2 { 3 String data = dataGridView1.CurrentRow.Cells[0].Value.ToString(); 4 String Namedata = dataGridView1.CurrentRow.Cells[1].Value.ToString(); 5 DBManager dBManager = new DBManager(); 6 { 7 try 8 { 9 10 11 // SQLの設定 12 string DeleteSql = "DELETE FROM PostList where PostCode = @postCode and PostName = @postName;"; 13 14 15 Dictionary<String, Object> param = new Dictionary<string, Object>(); 16 param.Add("@postCode", data.ToString()); 17 param.Add("@postName", Namedata.ToString()); 18 // データベースの接続開始 19 dBManager.BeginTran(); 20 dBManager.ExecuteVoidQuery(DeleteSql, param); 21 dBManager.CommitTran(); 22 23 MessageBox.Show("正常終了"); 24 PostData(); 25 } 26 catch (Exception exception) 27 { 28 dBManager.RollBack(); 29 MessageBox.Show("異常終了"+exception.Message); 30 } 31 finally 32 { 33 // データベースの接続終了 34 dBManager.Close(); 35 36 } 37 38 } 39 } 40 else 41 { 42 MessageBox.Show("処理を中断しました"); 43 44 }
この呼び出し元の
C#
1dBManager.CommitTran();
を実行すると、上のエラーが出ます。
初歩的な質問で申し訳ありませんが、教えて頂きたいです。

回答1件
あなたの回答
tips
プレビュー
バッドをするには、ログインかつ
こちらの条件を満たす必要があります。
退会済みユーザー
2018/11/06 04:44