ADO.NET实现对SQL Server数据库的增删改查示例
程序员文章站
2022-04-29 09:41:08
了解了上一篇的ado.net简介,我们就可以来对数据库进行增删改查等基本操作了!下面是每种操作的具体实现。
先在自定义类的头部定义好数据库连接对象和连接字符串:...
了解了上一篇的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类。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。