【发布时间】:2016-05-23 06:07:50
【问题描述】:
我正在尝试使用事务运行 ExecuteNonQuery,但我不断收到此错误
OleDbException : ExecuteNonQuery 要求命令具有 当分配给命令的连接在一个 待处理的本地事务。命令的事务属性 尚未初始化。
这是我的代码:有什么问题?
_dataManager = new DataManager();
bool bTrance = false;
_dataManager.BuildConnectionString("server", "MyId", "MyPwd");
_dataManager.Connect();
try
{
Console.WriteLine("Begin Trans");
var res = _dataManager.BeginTransaction();
if (res)
{
bTrance = true;
Console.WriteLine(" Trans Success");
}
Console.WriteLine("Query Executed");
return _dataManager.ExecuteQuery("call SP_MySp");
}
catch (OleDbException objDBExc)
{
Console.WriteLine("OleDbException : " + objDBExc.Message);
if (bTrance)
{
_dataManager.RollbackTransaction();
}
return false;
}
catch (Exception objExc)
{
Console.WriteLine("OleDbException : " + objExc.Message);
if (bTrance)
{
bTrance = false;
_dataManager.RollbackTransaction();
}
return false;
}
finally
{
Console.WriteLine("Done!");
if (bTrance)
{
_dataManager.CommitTransaction();
}
}
public class DataManager
{
private OleDbConnectionStringBuilder dbConnStr;
private OleDbConnection dbConn;
private OleDbTransaction dbTransaction;
private OleDbCommand dbCommand;
private bool beginTransaction;
public bool BeginTransaction()
{
try
{
if (beginTransaction == false)
{
dbTransaction = dbConn.BeginTransaction();
dbCommand.Transaction = dbTransaction;
beginTransaction = true;
}
else
dbCommand.Transaction = dbTransaction;
}
catch (Exception)
{
throw;
}
return beginTransaction;
}
public bool ExecuteQuery(string command)
{
try
{
dbCommand.ExecuteNonQuery();
}
catch (OleDbException objDbEx)
{
throw;
}
catch (Exception objEx)
{
throw;
}
dbCommand.Parameters.Clear();
dbCommand.Connection = null;
return true;
}
}
【问题讨论】:
-
让框架处理细节要容易得多:
using (var tx = new TransactionScope()) { your DB code goes here }。在块的末尾调用tx.Commit(),除非你想回滚。 -
Datamanager 类代码实际上属于一个 DLL。它被许多其他应用程序使用。
标签: c# transactions ado.net executenonquery