您的位置:首页 > 数据库

使用DataSet Datatable 更新数据库的三种方式及DataTable不同状态的取值

2011-07-28 16:17 816 查看
1:自动生成命令的条件 CommandBuilder 方法

a)动态指定 SelectCommand 属性

b)利用 CommandBuilder 对象自动生成 DataAdapter 的 DeleteCommand、InsertCommand 和 UpdateCommand。

c)为了返回构造 INSERT、UPDATE 和 DELETE 。SQL CommandBuilder 必须执行 SelectCommand。

即:必须额外经历一次到数据源的行程,这可能会降低性能。这也是

自动生成命令的缺点。

d)SelectCommand 还必须返回至少一个主键或唯一列.

当CommandBuilder和DataAdapter关联时,就会自动生成DeleteCommand、

InsertCommand 和 UpdateCommand中为空的命令。即不空的不生成。

e)必须是一个表,SELECT的不能是多个表的联合。

#动生成命令的规则#

在数据源处为表中所有 RowState 为 Added 的行插入一行(不包括标识、表达式或时间戳等列)。

为 Modified 的行更新行(列值匹配行的主键列值) 。

Deleted 的行删除行(列值匹配行的主键列值).这就是为什么要求条件c.d

注意:

a)因为从SELECT数据到UPDATE数据,中间这段时间有可能别的用户已经对数据进行了修改。

自动生成命令这种UPDATE只对在行包含所有原始值并且尚未从数据源中删除时更新。

b)自动命令生成逻辑为独立表生成 INSERT、UPDATE 或 DELETE 语句,

而不考虑与数据源中其他表的任何关系。因此,当调用 Update

来为参与数据库中外键约束的列提交更改时,可能会失败。若要避免这一异常,

请不要使用 CommandBuilder 来更新参与外键约束的列,而应显式地指定用于执行该操作的语句。

下面是自动生成命令的例子

// Assumes that connection is a valid SqlConnection object.

SqlDataAdapter adapter = new SqlDataAdapter(

"SELECT * FROM dbo.Customers", connection);

SqlCommandBuilder builder = new SqlCommandBuilder(adapter);

builder.QuotePrefix = "[";

builder.QuoteSuffix = "]";

DataSet custDS = new DataSet();

connection.Open();

adapter.Fill(custDS, "Customers");

// Code to modify data in the DataSet here.

// Without the SqlCommandBuilder, this line would fail.

adapter.Update(custDS, "Customers");

connection.Close();

2:使用 DataAdapter 更新数据源

注意:

a)如果 SelectCommand 返回 OUTER JOIN 的结果,则 DataAdapter

不会为生成的 DataTable 设置 PrimaryKey 值。您必须自己定义

PrimaryKey 以确保正确解析重复行.

b)如果对 DataSet、DataTable 或 DataRow 调用 AcceptChanges,

则将使 DataRow 的所有 Original 值都将被重写为该 DataRow 的 Current 值。

如果已修改将该行标识为唯一行的字段值,那么当调用 AcceptChanges 后,

Original 值将不再匹配数据源中的值。

下面例子

// Assumes connection is a valid SqlConnection.

SqlDataAdapter dataAdpater = new SqlDataAdapter(

"SELECT CategoryID, CategoryName FROM Categories", connection);

dataAdpater.UpdateCommand = new SqlCommand(

"UPDATE Categories SET CategoryName = @CategoryName " +

"WHERE CategoryID = @CategoryID" , connection);

dataAdpater.UpdateCommand.Parameters.Add(

"@CategoryName", SqlDbType.NVarChar, 15, "CategoryName");

SqlParameter parameter = dataAdpater.UpdateCommand.Parameters.Add(

"@CategoryID", SqlDbType.Int);

parameter.SourceColumn = "CategoryID";

parameter.SourceVersion = DataRowVersion.Original;

DataSet dataSet = new DataSet();

dataAdpater.Fill(dataSet, "Categories");

DataRow row = dataSet.Tables["Categories"].Rows[0];

row ["CategoryName"] = "New Category";

dataAdpater.Update(dataSet, "Categories");

------------------------------------------------------------------------------------------------

插入、更新和删除的排序

在许多情况下,以何种顺序向数据源发送通过 DataSet 作出的更改是相当重要的。

例如,如果已更新现有行的主键值并且添加了具有新主键值的新行,

则务必要在处理插入之前处理更新。

可以使用 DataTable 的 Select 方法来返回仅引用具有特定 RowState 的 DataRow 数组。

然后可以将返回的 DataRow 数组传递到 DataAdapter 的 Update 方法来处理已修改的行。

通过指定要更新的行的子集,可以控制处理插入、更新和删除的顺序。

DataTable table = dataSet.Tables["Customers"];

// First process deletes.

adapter.Update(table.Select(null, null, DataViewRowState.Deleted));

// Next process updates.

adapter.Update(table.Select(null, null,

DataViewRowState.ModifiedCurrent));

// Finally, process inserts.

adapter.Update(table.Select(null, null, DataViewRowState.Added));

3.使用sql语句更新

例如:

cmd = new OleDbCommand(string.Format(@"insert into worker(workerid,workername,password,phoneno) values ('{0}','{1}','{2}','{3}') ", textBox1.Text, textBox2.Text, textBox3.Text, textBox4.Text),oc);

oc.Open();

try

{

int i = cmd.ExecuteNonQuery();

}

catch (Exception ex)

{

}

性能的优劣及使用的情形,还未完全明白。

一般的,绑定bindingsource,用datatable绑定bindingsource (实质上绑定的是datatable。defaultview,同时可用到dataview的筛选功能,但但在筛选完后,filter要重置为null,否则出现的一直是经过筛选的数据)

其他:

1.使用builder 的作用:

OleDbCommandBuilder cb = new OleDbCommandBuilder(da);

这个主要是为了让C#自动为OleDbDataAdapter da生成相对应的DeleteCommand,UpdateCommand!

2.DataTable.RowState 有如下幾種狀態:

DataRowState.Added,DataRowState.Deleted,DataRowState.Detached DataRowState.Modified,DataRowState.Unchanged

我們對datatable的row 進行操作,如刪除,添加...都會在RowState 裡做上標記

我們要知道我們的那些行做什過什麼操作,我們可以這樣來實現:

foreach(DataRow dr in ds.Tables[ "Hosts "].GetChanges(DataRowState.Deleted).Rows)

{

//if(dr.HasVersion(DataRowVersion.Current))

//{

Console.WriteLine((string)dr[ "HId "]);

Console.WriteLine(dr[ "IsLocal ",DataRowVersion.Original].ToString());

//}

}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: