您的位置:首页 > 数据库

dataadapter中insert、delete、update的使用方法

2013-01-01 16:49 1106 查看

SqlDataAdapter有关InsertCommand,UpdateCommand,DeleteCommand
实例

Posted on 2012-06-09 15:16 许珅 阅读(226) 评论(0) 编辑 收藏 


//InsertCommand
using (SqlConnection conn = new SqlConnection(connectionstring))
{
conn.Open();
DataTable dtInsert = new DataTable();
dtInsert.Columns.Add("DeptID", typeof(int));
dtInsert.Columns.Add("DeptName", typeof(string));
dtInsert.Rows.Add(new object[] { "1", "技术部" });
dtInsert.Rows.Add(new object[] { "2", "招商部" });
dtInsert.Rows.Add(new object[] { "3", "信息部" });

SqlDataAdapter adapter = new SqlDataAdapter();
adapter.InsertCommand = new SqlCommand("insert into Dept(DeptID,DeptName) values(@DeptID,@DeptName)", conn);
adapter.SelectCommand = new SqlCommand("select * from Dept where 1=0", conn);//仅为了获得框架
adapter.InsertCommand.Parameters.Add("DeptID", SqlDbType.Int);
adapter.InsertCommand.Parameters.Add("DeptName", SqlDbType.VarChar);

adapter.InsertCommand.Parameters["DeptID"].SourceColumn = "DeptID";
adapter.InsertCommand.Parameters["DeptName"].SourceColumn = "DeptName";
//adapter.InsertCommand.Parameters["AddDate"].Value = DateTime.Now;//直接赋值

adapter.InsertCommand.UpdatedRowSource = UpdateRowSource.None;
adapter.Fill(dtInsert);
if (dtInsert.Rows.Count > 0)
{
adapter.Update(dtInsert);
}
}


 
2,UpdateCommand

//UpdateCommand
using (SqlConnection conn = new SqlConnection(connectionstring))
{
conn.Open();
DataSet ds = new DataSet();
string sql = "select * from Dept";
SqlDataAdapter adapate = new SqlDataAdapter(sql, conn);
adapate.Fill(ds, "table1");

foreach (DataRow datarow in ds.Tables[0].Rows)
{
datarow["DeptName"] = "sc";//ai->sc
}
SqlCommandBuilder builder = new SqlCommandBuilder(adapate);
adapate.Update(ds, "table1");
}


 
3,DeleteCommand

//DeleteCommand
using (SqlConnection conn = new SqlConnection(connectionstring))
{
conn.Open();
DataSet ds = new DataSet();
string sql = "select * from Dept";
//string sql = "select * from Dept where deptid=1";
SqlDataAdapter adapter = new SqlDataAdapter(sql, conn);
adapter.Fill(ds, "table1");

adapter.DeleteCommand = new SqlCommand("delete from Dept", conn);
//adapter.DeleteCommand = new SqlCommand("delete from Dept where deptid=@deptid", conn);
//adapter.DeleteCommand.Parameters.Add("deptid", SqlDbType.Int);
//adapter.DeleteCommand.Parameters["deptid"].SourceColumn = "deptid";

ds.Tables["table1"].Rows[ds.Tables["table1"].Rows.Count - 1].Delete();
adapter.Update(ds, "table1");
}


内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  Sql 数据库
相关文章推荐