[點晴永久免費OA]C#操作sql server(示例代碼)
當前位置：點晴教程→點晴OA辦公管理信息系統
→『 經驗分享&問題答疑 』
簡介 這篇文章主要介紹了C#操作sql server(示例代碼)以及相關的經驗技巧，值得參考！ C#操作sqlserver跟操作其他數據沒有太大差別，但是又一些細節要注意一下。 在安裝sqlserver時不要選擇默認實例，如果是則需要更改設置，還有遠程連接要去連接服務中設置一下，如端口1433等，這些百度一下就可以了。下面開始介紹一些最基本的數據庫操作。 （一）建立數據庫 static void SQLDBcreate(string dbname) { //通過連接到本身存在的db master連接到sqlserver string connStr = "Server = localhost;User Id=sa;Password=******; database = master"; SqlConnection conn = new SqlConnection(connStr); conn.Open(); //如果當前數據庫是正在狀態是無法刪除的，所以把master設置為當前狀態，若數據庫存在則刪除重建 //此處出問題一般為數據安裝過程中為默認實例，改為特定實例，然后啟動服務中心，在ip3更改相關ip為本機，并把tcp端口改為1433 //其他更改為是，同時在服務中restart即可以 string sql= "use master;" + "IF DB_ID(N‘{0}‘) IS NOT NULL " + "drop DATABASE {0};" + "create DATABASE {0}"; sql = string.Format(sql, dbname); try { SqlCommand cmd = new SqlCommand(sql, conn); cmd.executeNonQuery(); Console.WriteLine("createdb_success"); } catch (Exception ex) { Console.WriteLine("createdb_failed:"+ex.Message); } finally { conn.Close(); } } （二）在建立的數據庫中建表 static void Tablecreate(string dbname,string tablename) { string connStr = "Server = localhost;User Id=sa;Password=********; database = {0}"; connStr = string.Format(connStr, dbname); string sql= "IF OBJECT_ID(N‘{1}..{0}‘, N‘U‘) IS NOT NULL " + "drop TABLE {0};" + "create TABLE {0}" + "(ID [int] NOT NULL Primary Key," + "Name [char] (40) NULL ," + "Price [char] (40) NULL," + "dPrice [char] (40) NULL)"; sql = string.Format(sql, tablename, dbname); SqlConnection conn = new SqlConnection(connStr); conn.Open(); try { SqlCommand cmd = new SqlCommand(sql, conn); cmd.executeNonQuery(); Console.WriteLine("createtable_success"); } catch(Exception ex) { Console.WriteLine("createtable_failed:" + ex.Message); } finally { conn.Close(); } } （三）想表中添加數據 static void FillTable(string dbname,string tablename) { string connStr = "Server = localhost;User Id=sa;Password=********; database = {0}"; connStr = string.Format(connStr, dbname); SqlConnection conn = new SqlConnection(connStr); conn.Open(); string sql= "insert INTO {0}(ID,name,price,dPrice)" + "values(@d,@a,@b,@c)"; sql = string.Format(sql, tablename); try { for(int i=0;i<100;i++) { SqlCommand cmd = new SqlCommand(sql, conn); cmd.Parameters.AddWithValue("@d", i); cmd.Parameters.AddWithValue("@a", Guid.NewGuid()); cmd.Parameters.AddWithValue("@b", i.ToString()); cmd.Parameters.AddWithValue("@c", i.ToString()); cmd.executeNonQuery(); } Console.WriteLine("filltable_success"); } catch(Exception ex) { Console.WriteLine("filltable_failed:" + ex.Message); } finally { conn.Close(); } } （四）刪除表格 static void deleteTable(string dbname,string tablename) { string connStr = "Server = localhost;User Id=sa;Password=*********; database = {0}"; connStr = string.Format(connStr, dbname); SqlConnection conn = new SqlConnection(connStr); conn.Open(); string sql= "IF OBJECT_ID(N‘{0}..{1}‘, N‘U‘) IS NOT NULL " + "drop TABLE {1};"; sql = string.Format(sql, dbname, tablename); try { SqlCommand cmd = new SqlCommand(sql, conn); cmd.executeNonQuery(); Console.WriteLine("deletetable_success"); } catch(Exception ex) { Console.WriteLine("deletetable_failed:" + ex.Message); } finally { conn.Close(); } } （五）讀取數據庫中數據 static void TransToDS(string dbname,string tablename) { string connStr = "Server =.;User Id=sa;Password=*******; database = {0}"; connStr = string.Format(connStr, dbname); SqlConnection conn = new SqlConnection(connStr); conn.Open(); string sql = "select *from {0}"; sql = string.Format(sql, tablename); SqlCommand cmd = new SqlCommand(sql, conn); SqlDataAdapter apt = new SqlDataAdapter(cmd); SqlCommandBuilder sb = new SqlCommandBuilder(apt); DataSet ds = new DataSet(); try { apt.Fill(ds); Console.WriteLine("transTods_success"); } catch (Exception ex) { Console.WriteLine("transTods_failed:" + ex.Message); } finally { conn.Close(); } DataTable dt = ds.Tables[0]; //int i = 0; //foreach(DataRow dr in ds.Tables[0].Rows) //{ // if(i>50) // { // ds.Tables[0].Rows.RemoveAt(i); // } // i++; //} int count = dt.Rows.Count; for(int i=0;i<count;i++) { if(i>50) { //dt.Rows.RemoveAt(51); dt.Rows[i].delete(); } } apt.update(ds); int j = 0; foreach (DataRow dr in ds.Tables[0].Rows) { Console.WriteLine(dr["Price"]+" "+j+" "+dr.RowState); j++; } } 關于數據操作在此多說一點，可以用sqldatareader進行讀取，插入修改數據等也可以采用insert等方法進行處理，在此采用dataset先把數據表緩存到本地表中進行操作，如果只需要。看需要自己選擇，采用dataset包括更新數據表等都很方便，只需要用sqldataadapter進行一下update就可以。 注意： 1、在對datatable進行遍歷并進行刪除操作時，不要用foreach，其不允許進行增加和刪除 2、如果數據表需要update，那么數據表進行增刪是要用add和delete，不要用import和remove，因為在進行update時，是根據datarow的rowstate屬性進行操作的。比如delete時，并不是刪除row，而是把相應行的rowstate進行了修改，update時就根據此屬性進行處理，本地數據表只有當采用acceptchange時才會根據rowstate屬性進行數據表的相應刪除。而采用import或者remove時則rowstate屬性則會存在問題，比如采用remove時，整行移除后相應的rowstate也不存在，而update時，由于相應的行沒有rowstate屬性值，所以遠程數據庫不會進行刪除。import倒入后rowstate狀態不明，所以也無法進行遠程數據庫的數據更新。 總之，采用update時并不是拿本地datatable與sqlserver數據表進行對比然后更新，而是根據datatable中的datarow的rowstate屬性直接修改sqlserver數據表。 該文章在 2022/7/5 0:50:36 編輯過 |
關鍵字查詢
相關文章
正在查詢... 
|
400 186 1886
