现在的位置: 首页 > 综合 > 正文

ADO内存数据对象SqlDataAdapter类使用SqlDataAdapter在数据库和DataSet之间架起桥梁:

2014年01月15日 ⁄ 综合 ⁄ 共 1290字 ⁄ 字号 评论关闭

ADO内存数据对象SqlDataAdapter类使用SqlDataAdapter在数据库和DataSet之间架起桥梁:

  1. void UseDataAdapter()  
  2. {  
  3. //1 连接数据库  
  4.  
  5. //2 创建一个SqlDataAdapter对象  
  6. SqlDataAdapter adapter = new SqlDataAdapter();  
  7.  
  8. //3 利用SqlDataAdapter查询数据,并把数据放在DataSet中  
  9. SqlCommand selectCmd = new SqlCommand();  
  10. selectCmd.Connection = myCon;  
  11. selectCmd.CommandText = "SELECT SupplierID, CompanyName FROM Suppliers;";  
  12. adapter.SelectCommand = selectCmd;  
  13.  
  14. DataSet dataSet = new DataSet("Suppliers");  
  15. adapter.Fill(dataSet);//Fill数据  
  16. Page.Response.Write("已连查询数据,并放入DataSet中<br />");  
  17.  
  18. //4 利用SqlDataAdapter对象操作语句  
  19. //4.1 Update  
  20. SqlCommand updateCmd = new SqlCommand();  
  21. updateCmd.Connection = myCon;  
  22. updateCmd.CommandText = "UPDATE Customers SET CompanyName='KFC' WHERE CustomerID = 'ALFKI'";  
  23. adapter.UpdateCommand = updateCmd;  
  24. //4.2 Delete  
  25. SqlCommand deleteCmd = new SqlCommand();  
  26. deleteCmd.Connection = myCon;  
  27. deleteCmd.CommandText = "DELETE Customers WHERE CustomerID = 'ALFKI'";  
  28. adapter.DeleteCommanddeleteCmd;  
  29. //4.3 Insert  
  30. SqlCommand insertCmd = new SqlCommand();  
  31. insertCmd.Connection = myCon;  
  32. insertCmd.CommandText = "INSERT INTO Customers(CustomerId) values ('ALFKI')";  
  33. adapter.InsertCommand = insertCmd;  
  34. //4.4 执行操作  
  35. adapter.Update(dataSet);  
  36. Page.Response.Write("已连操作数据,包括:修改、删除、插入<br />");  
  37.  
  38. //5 关闭数据库连接  
  39. myCon.Close();  
  40. Page.Response.Write("已关闭数据库<br />");  
  41. }  

抱歉!评论已关闭.