DbDataAdapter 的Fill(DataTable dataTable) 和 Update(DataSet dataSet);方法的使用
方法定义:
public int Fill(DataTable dataTable);
在 System.Data.DataSet 的指定范围中添加或刷新行，以与使用 System.Data.DataTable 名称的数据源中的行匹配。
public override int Update(DataSet dataSet);
为指定 System.Data.DataTable 中每个已插入、已更新或已删除的行调用相应的 INSERT、UPDATE 或 DELETE 语句。
下面我们先使用Fill(DataTable dataTable);方法把数据从数据库中提取到DataSet中,数据修改之后,我们可以再使用Update方法,将我们对DataSet
中数据的修改提交至数据库.
示例代码如下
DataSet ds = new DataSet();
using (SqlConnection connection = new SqlConnection(PubConstant.ConnectionString))
{
try
{
connection.Open();
SqlDataAdapter command = new SqlDataAdapter(“SELECT * FROM [jarlinfowkk].[dbo].[oSensorData1]”, connection);
command.Fill(ds);
DataTable table = ds.Tables[0];
int count = table.Rows.Count;
for (int s = 0; s < table.Columns.Count; s++)
{
DataRow row = table.Rows[s];
DataRow newRow = table.NewRow();
for (int k = 0; k < table.Columns.Count – 1; k++)
{
newRow[k] = row[k];
}
DateTime dt = DateTime.Parse(row[“pAcquisitionTime”].ToString());
newRow[“pAcquisitionTime”] = dt.AddYears(3);
//修改 DataSet数据集
ds.Tables[0].Rows.Add(newRow);
}
//因为我们只是插入了数据,所以只需要生成InsertCommand,否则 还需要 UpdateCommand ,DeleteCommand
//由SqlCommandBuilder为我们生成 InsertCommand
SqlCommandBuilder myCommandBuilder = new SqlCommandBuilder(command);
command.InsertCommand = myCommandBuilder.GetInsertCommand();
command.Update(ds);
connection.Close();
MessageBox.Show(“OK”);
}
catch (System.Data.SqlClient.SqlException ex)
{
throw new Exception(ex.Message);
}
}