/// <summary>
/// 文件名称:SqlDataUpdater.cs
/// 摘 要:SQL数据更新器,可方便对单数据表进行读,写,删操作,构造函数按引用传出结果集.
/// SqlDataUpdater du = new SqlDataUpdater(sqlHere,ref yourDataSet)
/// 调用Update(ds)更新数据,自动事务处理,出错信息存在 ErrorMessage.
///
/// 完成日期:2005-4-21
/// 作 者:魏孙鼎
/// 当前版本:1.0
/// </summary>
public class SqlDataUpdater
{
private SqlConnection cn;
private SqlCommand cmd;
private SqlDataAdapter da;
private SqlTransaction tran;
private SqlCommandBuilder cmdBuilder;
private string err;
public string ErrorMessage
{
get
{
return err;
}
}
/// <summary>
/// 初始化数据更新器
/// </summary>
/// <param name="sql">用于返回schema的SQL</param>
/// <param name="dataSet">按引用传递的数据集</param>
public SqlDataUpdater(string sql,ref DataSet dataSet)
{
err = "";
if (dataSet == null) dataSet = new DataSet();
cn = new SqlConnection(ZMarketData.DataSetting.ConnectionString);
cmd = new SqlCommand(sql,cn);
da = new SqlDataAdapter(cmd);
cmdBuilder = new SqlCommandBuilder(da);
da.Fill(dataSet);
}
public bool Update(DataSet ds)
{
bool success = false;
cn.Open();
tran = cn.BeginTransaction();
cmd.Transaction = tran;
try
{
if(ds.GetChanges() != null)
{
da.Update(ds.GetChanges());
}
success = true;
tran.Commit();
}
catch(Exception ex)
{
tran.Rollback();
err = ex.Message;
success = false;
}
return success;
}
~SqlDataUpdater()
{
da.Dispose();
cmd.Dispose();
cn.Dispose();
}
}
// 应用示例
DataSet ds = new DataSet();
SqlDataUpdater du = new SqlDataUpdater("select * from Public_Feedback where 1=2",ref ds);
DataRow dr = ds.Tables[0].NewRow();
dr["CreateDate"] = DateTime.Now;
dr["FirstName"] = Request["txtName"];
dr["CompanyName"] = Request["txtCompany"];
dr["Email"] = Request["txtEmail"];
ds.Tables[0].Rows.Add(dr);
if (du.Update(ds))
{
//成功
}
else
{
Response.Write(du.ErrorMessage);
}
