|
using System; using System.Collections.Generic; using System.Text; using System.Data; using System.Data.SqlClient; namespace ConsoleApplication2 { class Program { static void Main() { string connectionString = GetConnectionString(); //定义数据库连接对象 SqlConnection connection = new SqlConnection(connectionString); //定义SQL字符串 String MySQL = "Select * From student"; //定义数据适配器对象 SqlDataAdapter MyAdapter = new SqlDataAdapter(MySQL, connection); { try { //打开数据库连接 connection.Open(); MyAdapter.SelectCommand = new SqlCommand(MySQL, connection); //定义数据集对象 DataSet MyDataSet = new DataSet(); //填充数据集的数据 MyAdapter.Fill(MyDataSet,"student"); //定义数据适配器对象的DeleteCommand属性,即使用的Delete语句 MyAdapter.DeleteCommand = new SqlCommand("Delete From student Where [url=mailto:xuehao=@StudentID]xuehao=@StudentID",connection); //定义Delete语句中的@StudentID参数 SqlParameter parameter = MyAdapter.DeleteCommand. Parameters.Add("@StudentID",SqlDbType.NVarChar,20); parameter.SourceColumn = "xuehao"; parameter.SourceVersion = DataRowVersion.Original; //可以在此修改学号,将删除不同的记录 parameter.SqlValue="98001"; //执行DeleteCommand定义的Delete语句 MyAdapter.DeleteCommand.ExecuteNonQuery(); //调用Update方法将删除的结果提交到数据源中 MyAdapter.Update(MyDataSet, "student"); Console.WriteLine("成功删除数据库的数据!"); } catch (SqlException ex) { Console.WriteLine(ex.ToString()); Console.ReadLine(); } finally { connection.Close(); Console.ReadLine(); Console.WriteLine("成功关闭到SQL Server 2005数据库的连接"); } } } //返回连接字符串的函数 static private string GetConnectionString() { return "server=(local);database=student;uid=sa;pwd=sql;"; }
} }
|
一共有 0 条评论