using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data.SqlClient;
using System.Data;
namespace 上課内容1
{
class 對資料的操作
{
static void Main(string[] args)
{
//ReadDataBySqlDataReader();
//OperateDataBySqlCommand();
//ReadDataBySqlDataAdapter();
//OperateDataSqlDataAdapter();
OperateDataSqlDataAdapter2();
}
/// <summary>
/// 使用 SqlDataAdapter 來實作操作資料(新增,修改,删除)。
/// </summary>
private static void OperateDataSqlDataAdapter()
{
//第一步:構造資料庫連接配接字元串(伺服器,資料庫,連接配接認證方式:使用者名,密碼)。
string connectionString = "Data Source=.;Initial Catalog=Business;User Id=sa;Password=011;";
//第二步:執行個體化 SqlConnection。
using (SqlConnection connection = new SqlConnection(connectionString))
{
//第三步:建立 SQL 語句。并構造 SqlDataAdapter 執行個體。
SqlDataAdapter adapter = new SqlDataAdapter();
string queryString = "SELECT TaskID,ProjectID,ModifiedBy,AssignedTo,TaskSummary,TaskDescription,PriorityID,StatusID,Progress,IsDeleted,DateDue,DateModified,DateCreated FROM Tasks";
adapter.SelectCommand = new SqlCommand(queryString, connection);
//第四步:使用 SqlDataAdapter 往 DataSet 裡填充資料(Fill方法)。
DataSet dataset = new DataSet();
adapter.Fill(dataset, "hello");
//第五步:往 DataSet 裡添加資料(往資料表 DataTable 裡添加資料行 DataRow)。
DataRow dr = dataset.Tables["hello"].NewRow();
dr["TaskID"] = Convert.ToInt32(dataset.Tables["hello"].Compute("max(TaskID)","true"))+1;
dr["ProjectID"]=1;
dr["ModifiedBy"]=2;
dr["AssignedTo"]=1;
dr["TaskSummary"]="This is the detail summary";
dr["TaskDescription"]="This is the detail description";
dr["PriorityID"]=1;
dr["StatusID"]=1;
dr["Progress"]=25;
dr["IsDeleted"]=0;
dr["DateDue"]=DateTime.Now;
dr["DateModified"]=DateTime.Now;
dr["DateCreated"]=DateTime.Now;
dataset.Tables["hello"].Rows.Add(dr);
//第六步:構造 Insert 語句,調用 SqlDataAdapter 的 Update 方法更新資料庫。
string sqlInsert = "INSERT INTO Tasks(ProjectID,ModifiedBy,AssignedTo,TaskSummary,TaskDescription,PriorityID,StatusID,Progress,IsDeleted,DateDue,DateModified,DateCreated) VALUES(1,2,1,'This is the detail summary','This is the detail description',1,1,25,0,'2013-10-22','2013-10-22','2013-10-22')";//字元類型用單引号
adapter.InsertCommand = new SqlCommand(sqlInsert, connection);//此處不是SqlCommand com=new SqlCommand
adapter.Update(dataset, "hello");
//第七步:修改 DataSet 中虛表的資料。
dataset.Tables["hello"].Rows[0]["ProjectID"] = 2;//注意此時為Rows[0]["ProjectId"]
//第八步:構造 Update 語句,調用 SqlDataAdapter 的 Update 方法更新資料庫中的實表。
string sqlUpdate = "Update Tasks set ProjectID = 2 where TaskID = 1";
adapter.UpdateCommand = new SqlCommand(sqlUpdate,connection);
adapter.Update(dataset, "hello");
//第九步:删除 DataSet 中虛表的資料。
dataset.Tables["hello"].Rows[31].Delete();
//第十步:構造 Delete 語句,調用 SqlDataAdapter 的 Update 方法更新資料庫中的實表。
string sqlDelete = "Delete from Tasks where TaskID = 46";
adapter.DeleteCommand = new SqlCommand(sqlDelete, connection);
adapter.Update(dataset, "hello");
}
}
/// <summary>
/// 使用 SqlDataAdapter 來讀取資料。
/// </summary>
private static void ReadDataBySqlDataAdapter()
{
//第一步:構造資料庫連接配接字元串(伺服器,資料庫,連接配接認證方式:使用者名,密碼)。
string connectionString = "Data Source=.;Initial Catalog=Business;User Id=sa;Password= //第二步:執行個體化 SqlConnection。 using (SqlConnection connection = new SqlConnection(connectionString)) { //第三步:建立 SQL 語句。并構造 SqlDataAdapter 執行個體。 SqlDataAdapter adapter = new SqlDataAdapter(); string queryString = "SELECT TaskID,ProjectID,ModifiedBy,AssignedTo,TaskSummary,TaskDescription,PriorityID,StatusID,Progress,IsDeleted,DateDue,DateModified,DateCreated FROM Tasks"; adapter.SelectCommand = new SqlCommand(queryString, connection); //connection.Open(); //第四步:使用 SqlDataAdapter 往 DataSet 裡填充資料(Fill方法)。 DataSet dataset = new DataSet(); adapter.Fill(dataset, "Tasks"); //第五步:讀取資料,傳回結果。 foreach (DataRow row in dataset.Tables["Tasks"].Rows) { string strTemp = string.Format("{0},{1}", row[0], row[1]); Console.WriteLine(strTemp); } Console.Read(); } } /// <summary> /// 使用 SqlDataAdapter 來實作操作資料(新增,修改,删除)方法2(節省中間的 SQL 語句). /// </summary> private static void OperateDataSqlDataAdapter2() { //第一步:構造資料庫連接配接字元串(伺服器,資料庫,連接配接認證方式:使用者名,密碼)。 string connectionString = "Data Source=.;Initial Catalog=Business;User Id=sa;Password= //第二步:執行個體化 SqlConnection。 using (SqlConnection connection = new SqlConnection(connectionString)) { //第三步:建立 SQL 語句。并構造 SqlDataAdapter 執行個體。 SqlDataAdapter adapter = new SqlDataAdapter(); string queryString = "SELECT TaskID,ProjectID,ModifiedBy,AssignedTo,TaskSummary,TaskDescription,PriorityID,StatusID,Progress,IsDeleted,DateDue,DateModified,DateCreated FROM Tasks"; adapter.SelectCommand = new SqlCommand(queryString, connection); //第四步:構造 SqlCommandBuilder 執行個體(背景自動完成SQL語句)。 SqlCommandBuilder builder = new SqlCommandBuilder(adapter); //第五步:使用 SqlDataAdapter 往 DataSet 裡填充資料(Fill方法)。 DataSet dataset = new DataSet(); adapter.Fill(dataset, "Tasks"); //第六步:添加 DataSet 虛表中的資料。 DataRow dr = dataset.Tables["Tasks"].NewRow(); dr["TaskID"] = Convert.ToInt32(dataset.Tables["Tasks"].Compute("max(TaskID)","true")) +1; dr["ProjectID"] = 1; dr["ModifiedBy"] = 2; dr["AssignedTo"] = 1; dr["TaskSummary"] = "This is the detail summary"; dr["TaskDescription"] = "This is the detail description"; dr["PriorityID"] = 1; dr["StatusID"] = 1; dr["Progress"] = 25; dr["IsDeleted"] = 0; dr["DateDue"] = DateTime.Parse("2013-10-23"); dr["DateModified"] = DateTime.Parse("2013-10-23"); dr["DateCreated"] = DateTime.Parse("2013-10-23"); dataset.Tables["Tasks"].Rows.Add(dr); //第七步:修改 DataSet 虛表中的資料。 dataset.Tables["Tasks"].Rows[0]["ProjectID"] = 1; //第八步:删除 DataSet 虛表中的資料。 dataset.Tables["Tasks"].Rows[30].Delete(); //第九步:整體更新資料庫實表。 builder.GetUpdateCommand(); adapter.Update(dataset, "Tasks"); //第十步:顯示 dataset 中虛表中的内容。 foreach (DataRow row in dataset.Tables["Tasks"].Rows) { string strTemp = string.Format("{0},{1}", row[0], row[1]); Console.WriteLine(strTemp); } Console.Read(); } } /// <summary> /// 使用 SqlDataReader 讀資料 /// </summary> private static void ReadDataBySqlDataReader() { //第一步:構造資料庫連接配接字元串(伺服器,資料庫,連接配接認證方式:使用者名,密碼)。 string connectionString = "Data Source=.;Initial Catalog=Business;User Id=sa;Password= //第二步:執行個體化 SqlConnection。 using (SqlConnection connection = new SqlConnection(connectionString)) { //第三步:建立 SQL 語句。并構造 SqlCommand 執行個體。 string queryString = "SELECT TaskID,ProjectID,ModifiedBy,AssignedTo,TaskSummary,TaskDescription,PriorityID,StatusID,Progress,IsDeleted,DateDue,DateModified,DateCreated FROM Tasks"; SqlCommand command = new SqlCommand(queryString, connection); //第四步:打開資料庫。 connection.Open(); //第五步:執行指令。 SqlDataReader reader = command.ExecuteReader(); //第六步:讀取資料,傳回結果。 try { while (reader.Read()) { string strTemp = string.Format("{0},{1}", reader["TaskID"].ToString(), reader["AssignedTo"].ToString()); Console.WriteLine(strTemp); } Console.Read(); } finally { // Always call Close when done reading. reader.Close(); } } } /// <summary> /// 修改資料庫中的資料。 /// </summary> private static void OperateDataBySqlCommand() { //第一步:構造資料庫連接配接字元串(伺服器,資料庫,連接配接認證方式:使用者名,密碼)。 string connectionString = "Data Source=.;Initial Catalog=Business;User Id=sa;Password= //第二步:執行個體化 SqlConnection。 using (SqlConnection connection = new SqlConnection(connectionString)) { //第三步:建立 SQL 語句。并構造 SqlCommand 執行個體。 string sqlInsert = "INSERT INTO Tasks(ProjectID,ModifiedBy,AssignedTo,TaskSummary,TaskDescription,PriorityID,StatusID,Progress,IsDeleted,DateDue,DateModified,DateCreated) VALUES(1,2,1,'This is the detail summary','This is the detail description',1,1,25,0,'2013-10-23','2013-10-23','2013-10-23')"; SqlCommand com = new SqlCommand(sqlInsert, connection); com.CommandType = CommandType.Text;//此處不要忘記 //第四步:打開資料庫。 connection.Open(); //第五步:執行指令。 int intResult = com.ExecuteNonQuery(); //第六步:讀取資料,傳回結果。 if (intResult >= 1) { Console.WriteLine("資料插入成功!"); Console.Read(); } else { Console.WriteLine("資料插入失敗!"); Console.Read(); } } } }}