class1.cs

数据库断开式连接

using System;
using System.Data;
using System.Data.SqlClient;

namespace DataSetDemo
{
	/// <summary>
	/// Class1 的摘要说明。
	/// </summary>
	class Class1
	{
		/// <summary>
		/// 应用程序的主入口点。
		/// </summary>
		[STAThread]
		static void Main(string[] args)
		{
			SqlConnection conn = new SqlConnection("server=.;uid=sa;pwd=sa;database=DBTest");
			SqlDataAdapter adapter = new SqlDataAdapter();

			adapter.SelectCommand = new SqlCommand("select * from bank",conn);

			SqlCommand updateComm = new SqlCommand("update bank set name=@name,balance=@balance where name=@oldname",conn);
			updateComm.Parameters.Add("@name",SqlDbType.Char,10,"name");
			updateComm.Parameters.Add("@balance",SqlDbType.Int,4,"balance");

			SqlParameter p = new SqlParameter("@oldname",SqlDbType.Char,10,ParameterDirection.Input,false,((System.Byte)(0)),((System.Byte)(0)),"name",DataRowVersion.Original,null);
			updateComm.Parameters.Add(p);

			adapter.UpdateCommand = updateComm;

			SqlCommand deleteComm = new SqlCommand("delete bank where name=@oldname and balance=@oldbalance",conn);
			deleteComm.Parameters.Add("@oldname",SqlDbType.Char,10,"name");
			deleteComm.Parameters.Add("@oldbalance",SqlDbType.Int,4,"balance");
			adapter.DeleteCommand = deleteComm;

			SqlCommand insertComm = new SqlCommand("insert into bank values(@name,@balance)",conn);
			insertComm.Parameters.Add("@name",SqlDbType.Char,10,"name");
			insertComm.Parameters.Add("@balance",SqlDbType.Int,4,"balance");
			adapter.InsertCommand = insertComm;

			DataSet ds = new DataSet();
			adapter.Fill(ds);

//			for(int i = 0;i<ds.Tables[0].Rows.Count;++i)
//			{
//				for(int j=0;j<ds.Tables[0].Columns.Count;++j)
//				{
//					Console.Write(ds.Tables[0].Rows[i].ItemArray.GetValue(j)+" ");
//				}
//				Console.WriteLine("\n");
//			}

			//更新DataSet
//			ds.Tables[0].Rows[0][0] = "李四";
//
//			adapter.Update(ds);
//
//			for(int i = 0;i<ds.Tables[0].Rows.Count;++i)
//			{
//				for(int j=0;j<ds.Tables[0].Columns.Count;++j)
//				{
//					Console.Write(ds.Tables[0].Rows[i].ItemArray.GetValue(j)+" ");
//				}
//				Console.WriteLine("\n");
//			}


			//删除DataSet
//			ds.Tables[0].Rows[0].Delete();
//			adapter.Update(ds);
//
//			for(int i = 0;i<ds.Tables[0].Rows.Count;++i)
//			{
//				for(int j=0;j<ds.Tables[0].Columns.Count;++j)
//				{
//					Console.Write(ds.Tables[0].Rows[i].ItemArray.GetValue(j)+" ");
//				}
//				Console.WriteLine("\n");
//			}

			//增加新行
			DataRow dr = ds.Tables[0].NewRow();
			dr[0] = "王五";
			dr[1] = 1024;

			ds.Tables[0].Rows.Add(dr);
			adapter.Update(ds);

			for(int i = 0;i<ds.Tables[0].Rows.Count;++i)
			{
				for(int j=0;j<ds.Tables[0].Columns.Count;++j)
				{
					Console.Write(ds.Tables[0].Rows[i].ItemArray.GetValue(j)+" ");
				}
				Console.WriteLine("\n");
			}
			
		}
	}
}