ADO.NET实现对SQL Server数据库的增删改查示例
了解了上一篇的ADO.NET简介，我们就可以来对数据库进行增删改查等基本操作了！下面是每种操作的具体实现。
先在自定义类的头部定义好数据库连接对象和连接字符串：
stringconnectionString="DataSource=SC-201607131829;InitialCatalog=Animal;IntegratedSecurity=True"; SqlConnectionconn;
1.数据库的查询操作，返回一个DataTable
publicDataTabledoSelect()
{
stringsql="select*fromdetial";
using(conn=newSqlConnection(connectionString))
{
conn.Open();
SqlDataAdapterda=newSqlDataAdapter(sql,conn);
DataSetds=newDataSet();
da.Fill(ds);//填充DataSet
returnds.Tables[0];
}
}
2.数据库插入操作，返回布尔值
publicbooldoInsert(stringname,stringskin,stringweight)
{
stringsql="insertintodetial(name,skin,weight)values(@name,@skin,@weight)";
SqlParameter[]newAnimal={
newSqlParameter("name",name),
newSqlParameter("skin",skin),
newSqlParameter("weight",skin)
};
using(conn=newSqlConnection(connectionString))
{
SqlCommandcom=newSqlCommand(sql,conn);
try
{
if(newAnimal!=null)
{
foreach(SqlParameterparameterinnewAnimal)
{
com.Parameters.Add(parameter);
}
}
conn.Open();
intinfluence=com.ExecuteNonQuery();
if(influence>0)
{
returntrue;
}
else
{
returnfalse;
}
}
catch(Exceptionexception)
{
returnfalse;
}
}
}
3.数据库删除操作，返回布尔值
publicbooldoDelete(stringname)
{
stringsql="deletefromdetialwherename=@name";
SqlParameter[]deleteParameter={newSqlParameter("name",name)};
using(conn=newSqlConnection(connectionString))
{
SqlCommandcom=newSqlCommand(sql,conn);
try
{
if(deleteParameter!=null)
{
foreach(SqlParameterparameterindeleteParameter)
{
com.Parameters.Add(parameter);
}
}
conn.Open();
intinfluence=com.ExecuteNonQuery();
if(influence>0)
{
returntrue;
}
else
{
returnfalse;
}
}
catch(Exceptionexception)
{
returnfalse;
}
}
}
4.数据库更新操作，返回布尔值
publicbooldoUpdate(stringname,stringskin){
stringsql="updatedetialsetskin=@skinwherename=@name";
SqlParameter[]updateParameter={
newSqlParameter("name",name),
newSqlParameter("skin",skin)
};
using(conn=newSqlConnection(connectionString)){
SqlCommandcom=newSqlCommand(sql,conn);
try{
if(updateParameter!=null){
foreach(SqlParameterparameterinupdateParameter){
com.Parameters.Add(parameter);
}
}
conn.Open();
intinfluence=com.ExecuteNonQuery();
if(influence>0)
{
returntrue;
}
else
{
returnfalse;
}
}catch(Exceptionexception){
returnfalse;
}
}
}
其中为了防止sql注入，用到了SqlParameter类。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。