ADO.NET實現對SQL Server數據庫的增刪改查示例

 string connectionString = "Data Source=SC-201607131829;Initial Catalog=Animal;Integrated Security=True";
 SqlConnection conn;

 public DataTable doSelect()
 {

 string sql = "select * from detial";

 using (conn = new SqlConnection(connectionString))
 {

 conn.Open();

 SqlDataAdapter da = new SqlDataAdapter(sql, conn);

 DataSet ds = new DataSet();

 da.Fill(ds); //填充DataSet

 return ds.Tables[0];

 }
 }

public bool doInsert(string name, string skin, string weight)
 {

 string sql = "insert into detial(name,skin,weight)values(@name,@skin,@weight)";

 SqlParameter[] newAnimal = {
 new SqlParameter("name",name),
 new SqlParameter("skin",skin),
 new SqlParameter("weight",skin)
 };

 using (conn = new SqlConnection(connectionString))
 {
 SqlCommand com = new SqlCommand(sql, conn);
 try
 {
 if (newAnimal != null)
 {
 foreach (SqlParameter parameter in newAnimal)
 {
 com.Parameters.Add(parameter);

 }
 }
 conn.Open();

 int influence = com.ExecuteNonQuery();

 if (influence > 0)
 {

 return true;
 }
 else
 {

 return false;
 }
 }
 catch (Exception exception)
 {
 return false;
 }
 }
 }

public bool doDelete(string name)
 {

 string sql = "delete from detial where name = @name";

 SqlParameter[] deleteParameter = { new SqlParameter("name", name) };

 using (conn = new SqlConnection(connectionString))
 {

 SqlCommand com = new SqlCommand(sql, conn);
 
 try
 {

 if (deleteParameter != null)
 {
 foreach (SqlParameter parameter in deleteParameter)
 {
 com.Parameters.Add(parameter);
 }
 
 }

 conn.Open();

 int influence = com.ExecuteNonQuery();

 if (influence > 0)
 {

 return true;
 }
 else
 {

 return false;
 }
 }
 catch (Exception exception)
 {
 return false;
 }
 }
 }

public bool doUpdate(string name , string skin) {

 string sql = "update detial set skin = @skin where name = @name";
 SqlParameter[] updateParameter = {
 new SqlParameter("name",name),
 new SqlParameter("skin",skin)
 };

 using (conn = new SqlConnection(connectionString)) {

 SqlCommand com = new SqlCommand(sql,conn);

 try {

 if (updateParameter != null) { 
 
 foreach(SqlParameter parameter in updateParameter){

 com.Parameters.Add(parameter);

 } 
 }

 conn.Open();

 int influence = com.ExecuteNonQuery();

 if (influence > 0)
 {

 return true;
 }
 else
 {

 return false;
 }
 
 }catch(Exception exception){

 return false;
 }
 }

 }