一个C# ADO.NET连接SQL Server数据库的实例

本文是一个利用C# ADO.NET连接SQL Server数据库的程序实例，该实例比较简单，代码如下：

创新互联建站专业为企业提供蒸湘网站建设、蒸湘做网站、蒸湘网站设计、蒸湘网站制作等企业网站建设、网页设计与制作、蒸湘企业网站模板建站服务，十多年蒸湘做网站经验，不只是建网站，更提供有价值的思路和整体网络服务。

 
 
 
  
  
  
usingSystem;  
  
  
  
 
  
  
  
usingSystem.Collections.Generic;  
  
  
  
 
  
  
  
usingSystem.Linq;  
  
  
  
 
  
  
  
usingSystem.Text;  
  
  
  
 
  
  
  
usingSystem.Data;  
  
  
  
 
  
  
  
usingSystem.Data.SqlClient;  
  
  
  
 
  
  
  
namespaceDataAccess  
  
  
  
 
  
  
  
{  
  
  
  
 
  
  
  
///
 
  
  
  
 
  
  
  
///操作数据库公共类  
  
  
  
 
  
  
  
/// 
  
  
  
 
  
  
  
classSqlDataAccess:IDisposable  
  
  
  
 
  
  
  
{  
  
  
  
 
  
  
  
///
 
  
  
  
 
  
  
  
///数据库连接字符串  
  
  
  
 
  
  
  
/// 
  
  
  
 
  
  
  
 
  
  
  
privatereadonlystringSqlConnectionString="连接字符串;";  
  
  
  
 
  
  
  
 
  
  
  
privateSqlConnectionsqlConnection;  
  
  
  
 
  
  
  
 
  
  
  
publicSqlDataAccess()  
  
  
  
 
  
  
  
{  
  
  
  
 
  
  
  
sqlConnection=newSqlConnection(SqlConnectionString);  
  
  
  
 
  
  
  
} 
 
 

 执行SQL语句，并返回受影响的行数，具体代码如下：

 
 
 
  
  
  
///
 
  
  
  
 
  
  
  
///执行SQL语句，并返回数据库受影响的行数  
  
  
  
 
  
  
  
/// 
  
  
  
 
  
  
  
///SQL语句 
  
  
  
 
  
  
  
/// 
  
  
  
 
  
  
  
publicintExcuteNonQuery(stringsql)  
  
  
  
 
  
  
  
{  
  
  
  
 
  
  
  
SqlCommandcmd=newSqlCommand(sql,sqlConnection);  
  
  
  
 
  
  
  
if(sqlConnection.State==ConnectionState.Closed)  
  
  
  
 
  
  
  
{  
  
  
  
 
  
  
  
sqlConnection.Open();  
  
  
  
 
  
  
  
}  
  
  
  
 
  
  
  
intresult=cmd.ExecuteNonQuery();  
  
  
  
 
  
  
  
sqlConnection.Close();  
  
  
  
 
  
  
  
returnresult;  
  
  
  
 
  
  
  
}  
  
  
  
 
  
  
  
//如果更新的数据有特殊字符的用上面那个ExcuteNonQuery()就不行了，需要用到SqlCommand的一个参数SqlParameter。  
  
  
  
 
  
  
  
publicintExcuteNonQuery(stringsql,SqlParameter[]parameters)  
  
  
  
 
  
  
  
{  
  
  
  
 
  
  
  
 
  
  
  
SqlCommandcmd=newSqlCommand(sql,sqlConnection);  
  
  
  
 
  
  
  
cmd.Parameters.AddRange(parameters);  
  
  
  
 
  
  
  
if(sqlConnection.State==ConnectionState.Closed)  
  
  
  
 
  
  
  
{  
  
  
  
 
  
  
  
sqlConnection.Open();  
  
  
  
 
  
  
  
}  
  
  
  
 
  
  
  
intcount=cmd.ExecuteNonQuery();  
  
  
  
 
  
  
  
sqlConnection.Close();  
  
  
  
 
  
  
  
returncount;  
  
  
  
 
  
  
  
} 
 
 

 返回首行首列的代码如下：

 
 
 
  
  
  
///
 
  
  
  
 
  
  
  
///返回首行首列  
  
  
  
 
  
  
  
/// 
  
  
  
 
  
  
  
/// 
  
  
  
 
  
  
  
/// 
  
  
  
 
  
  
  
publicobjectExecuteScalar(stringsql)  
  
  
  
 
  
  
  
{  
  
  
  
 
  
  
  
SqlCommandcmd=newSqlCommand(sql,sqlConnection);  
  
  
  
 
  
  
  
if(sqlConnection.State==ConnectionState.Closed)  
  
  
  
 
  
  
  
{  
  
  
  
 
  
  
  
sqlConnection.Open();  
  
  
  
 
  
  
  
}  
  
  
  
 
  
  
  
objectresult=cmd.ExecuteScalar();  
  
  
  
 
  
  
  
sqlConnection.Close();  
  
  
  
 
  
  
  
returnresult;  
  
  
  
 
  
  
  
} 
 
 

 获取一个DataSet的代码如下：

 
 
 
  
  
  
///
 
  
  
  
 
  
  
  
///获取一个DataSet  
  
  
  
 
  
  
  
/// 
  
  
  
 
  
  
  
/// 
  
  
  
 
  
  
  
/// 
  
  
  
 
  
  
  
publicDataSetGetDataSet(stringsql)  
  
  
  
 
  
  
  
{  
  
  
  
 
  
  
  
SqlDataAdapteradapter=newSqlDataAdapter(sql,sqlConnection);  
  
  
  
 
  
  
  
DataSetds=newDataSet();  
  
  
  
 
  
  
  
adapter.Fill(ds);  
  
  
  
 
  
  
  
returnds;  
  
  
  
 
  
  
  
}  
  
  
  
 
  
  
  
}  
  
  
  
 
  
  
  
} 
 
 

示例：用上面的数据库连接类，新增一个商品，包括商品名称和单价，代码如下：

 
 
 
  
  
  
stringinsertSql=@"INSERTINTOPRODUCTINFO  
  
  
  
 
  
  
  
VALUES  
  
  
  
 
  
  
  
(  
  
  
  
 
  
  
  
@PRODUCTNAME,  
  
  
  
 
  
  
  
@PRODUCTPRICE,  
  
  
  
 
  
  
  
);  
  
  
  
 
  
  
  
SqlParameter[]parameters=newSqlParameter[]  
  
  
  
 
  
  
  
{  
  
  
  
 
  
  
  
newSqlParameter("@PRODUCTNAME",商品名称){SqlDbTypeSqlDbType=SqlDbType.NVarChar},  
  
  
  
 
  
  
  
newSqlParameter("@PRODUCTPRICE",商品单价){SqlDbTypeSqlDbType=SqlDbType.Money}  
  
  
  
 
  
  
  
}  
  
  
  
 
  
  
  
DataAccessdataAccess=newDataAccess();  
  
  
  
 
  
  
  
intresult=dataAccess.ExcuteNonQuery(insertSql,parameters);  
  
  
  
 
  
  
  
if(result>0)  
  
  
  
 
  
  
  
{  
  
  
  
 
  
  
  
MessageBox.Show("新增成功");  
  
  
  
 
  
  
  
}  
  
  
  
 
  
  
  
else  
  
  
  
 
  
  
  
{  
  
  
  
 
  
  
  
MessageBox.Show("新增失败");  
  
  
  
 
  
  
  
} 
 
 

 本实例就介绍到这里，如果想了解更多SQL Server数据库的知识，这里的文章很值得一看：http://database./sqlserver/，千万不要错过哦！

【编辑推荐】

1. 误删SQL Server日志文件后怎样附加数据库
2. SQL Server 2005数据库用户权限管理的设置
3. 在SQL SERVER 2005执行存储过程的权限分配问题
4. 浅析SQL Server数据库专用管理员连接DAC的使用
5. T-SQL行列相互转换命令：PIVOT和UNPIVOT使用详解

当前名称：一个C# ADO.NET连接SQL Server数据库的实例
地址分享：http://www.cdxtjz.cn/article/dpeehoi.html