如何通过ADO.NET实现针对SQL Server数据库的增删改查操作示例？

本文共计767个文字，预计阅读时间需要4分钟。

了解了上一篇关于ADO.NET的简介，我们可以开始对数据库进行增删改查等基本操作了！以下是各种操作的实现方法。

首先，在自定义类的头部定义数据库连接对象和连接字符串：

csharpstring connectionString=你的数据库连接字符串;SqlConnection connection=new SqlConnection(connectionString);

接下来，以下是各种操作的实现：

1. 添加数据：

csharpstring sqlInsert=INSERT INTO 表名 (列1, 列2) VALUES (@列1, @列2);SqlCommand command=new SqlCommand(sqlInsert, connection);command.Parameters.AddWithValue(@列1, 值1);command.Parameters.AddWithValue(@列2, 值2);connection.Open();command.ExecuteNonQuery();connection.Close();

2. 删除数据：

csharpstring sqlDelete=DELETE FROM 表名 WHERE 条件;SqlCommand command=new SqlCommand(sqlDelete, connection);connection.Open();command.ExecuteNonQuery();connection.Close();

3. 修改数据：

csharpstring sqlUpdate=UPDATE 表名 SET 列1=@值1, 列2=@值2 WHERE 条件;SqlCommand command=new SqlCommand(sqlUpdate, connection);command.Parameters.AddWithValue(@值1, 新值1);command.Parameters.AddWithValue(@值2, 新值2);connection.Open();command.ExecuteNonQuery();connection.Close();

4. 查询数据：

csharpstring sqlSelect=SELECT * FROM 表名 WHERE 条件;SqlCommand command=new SqlCommand(sqlSelect, connection);connection.Open();SqlDataReader reader=command.ExecuteReader();while (reader.Read()){ // 读取数据}reader.Close();connection.Close();

了解了上一篇的ADO.NET简介，我们就可以来对数据库进行增删改查等基本操作了！下面是每种操作的具体实现。

先在自定义类的头部定义好数据库连接对象和连接字符串：

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

1.数据库的查询操作，返回一个DataTable

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]; } }

2.数据库插入操作，返回布尔值

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; } } }

3.数据库删除操作，返回布尔值

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; } } }

4.数据库更新操作，返回布尔值

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; } } }

其中为了防止sql注入，用到了SqlParameter类。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持易盾网络。