nbsp; }
catch(Exception e)
{
/// 回滚事务
string a=e.Message;
dsTransaction.Rollback();
return false;
}
finally
{
/// 无论更新是否成功,及时释放数据库连接
dbConnection.Close();
}
/// 刷新 DataSet 更新标志
myDataSet.AcceptChanges();
return true;
}
catch(Exception e)
{
string a=e.Message;
return false;
}
}
/// <summary>
/// 根据指定的对象数据集,删除相应的数据库记录。
/// </summary>
/// <param name="myDataSet">对象数据集</param>
/// <returns>返回是否成功的布尔值</returns>
public bool DeleteObjectData(BaseDataSet myDataSet)
{
if ( dsAdapter == null )
{
throw new System.ObjectDisposedException( GetType().FullName );
}
try
{
dbConnection.Open();
try
{
dsTransaction = dbConnection.BeginTransaction();
}
catch
{
dbConnection.Close();
return false;
}
/// 遍历 DataSet 中的每一个表单进行更新处理
try
{
foreach (DataTable dt in myDataSet.Tables)
{
dsAdapter.DeleteCommand = GetDeleteByIdCommand(dt);
/// 设置记录更新的事务句柄
dsAdapter.DeleteCommand.Transaction = dsTransaction;
/// 根据传入DataSet的表和表中的内容更新相应的数据库
dsAdapter.Update( myDataSet, dt.TableName);
}
dsTransaction.Commit();
}
catch(Exception e)
{
string a=e.Message;
dsTransaction.Rollback();
return false;
}
finally
{
/// 无论更新是否成功,及时释放数据库连接
dbConnection.Close();
}
/// 刷新 DataSet 更新标志
myDataSet.AcceptChanges();
return true;
}
catch
{
return false;
}
}
/// <summary>
/// 根据指定的对象数据集,同时删除、修改、添加相应的数据库记录。
/// </summary>
/// <param name="myDataSet">对象数据集</param>
/// <returns>返回是否成功的布尔值</returns>
public bool SynchronizeObjectData(BaseDataSet dataSet)
{
if ( dsAdapter == null )
{
throw new System.ObjectDisposedException( GetType().FullName );
}
try
{
dbConnection.Open();
try
{
dsTransaction = dbConnection.BeginTransaction();
}
catch
{
dbConnection.Close();
return false;
}
/// 遍历 DataSet 中的每一个表单进行更新处理
try
&