通过浏览器访问数据库_SQL Server 数据库访问通用类（更新）

  本文关键词：数据库访问，由笔耕文化传播整理发布。

　　对SQL Server数据库的操作，最常见的有如下五种：

　　1.非连接式查询，获取DataTable。

　　2.连接式查询，获取DataReader。

　　3.查询结果只有1行1列，获取单一数据。

　　4.对数据库进行增、删、改操作，进行数据编辑。

　　5.判断与数据库是否已连接。（更新）

　　针对以上情况，分享的一个SQL Server数据库访问通用类。该通用类可用于ASP.NET和C/S系统中开发。

1.非连接式查询，获取DataTable。

利用SqlDataAdapter对象的Fill()返回DataTable的结果集。

View Code

#region 执行一个查询，并返回结果集 执行一个查询，并返回结果集 DataTable ExecuteDataTable(string sql) { return ExecuteDataTable(sql, CommandType.Text, null); } 执行一个查询，并返回结果集 DataTable ExecuteDataTable(string sql, CommandType commandType) { return ExecuteDataTable(sql, commandType, null); } 执行一个查询，并返回结果集 DataTable ExecuteDataTable(string sql, CommandType commandType, SqlParameter[] parameters) { //实例化DataTable，用于装载查询结果集 DataTable data = new DataTable(); using (SqlConnection connection = new SqlConnection(connectionString)) { using (SqlCommand command = new SqlCommand(sql, connection)) { //指定CommandType command.CommandType = commandType; if (parameters != null) { foreach (SqlParameter parameter in parameters) { command.Parameters.Add(parameter); } } //实例化SqlDataAdapter SqlDataAdapter adapter = new SqlDataAdapter(command); //填充DataTable adapter.Fill(data); } } return data; } #endregion

2.连接式查询，获取DataReader。

利用SqlReader()返回DataReader对象实例。

View Code

#region 返回一个DataReader对象实例 返回一个DataReader对象实例 SqlDataReader ExecuteReader(string sql) { return ExecuteReader(sql, CommandType.Text, null); } 返回一个DataReader对象实例 SqlDataReader ExecuteReader(string sql, CommandType commandType) { return ExecuteReader(sql, commandType, null); } 返回一个DataReader对象实例 SqlDataReader ExecuteReader(string sql, CommandType commandType, SqlParameter[] parameters) { SqlConnection connection = new SqlConnection(connectionString); SqlCommand command = new SqlCommand(sql, connection); if (parameters != null) { foreach (SqlParameter parameter in parameters) { command.Parameters.Add(parameter); } } connection.Open(); command.ExecuteReader(CommandBehavior.CloseConnection); } #endregion

3.查询结果只有1行1列，获取单一数据。

利用SqlCommand的ExecuteScalar()。

View Code

#region 执行查询结果，返回第一行的第一列 执行查询结果，返回第一行的第一列 ExecuteScalar(string sql) { return ExecuteScalar(sql, CommandType.Text, null); } 执行查询结果，返回第一行的第一列 ExecuteScalar(string sql, CommandType commandType) { return ExecuteScalar(sql, commandType, null); } 执行查询结果，返回第一行的第一列 ExecuteScalar(string sql, CommandType commandType, SqlParameter[] parameters) { object result = null; using (SqlConnection connection = new SqlConnection(connectionString)) { using (SqlCommand command = new SqlCommand(sql, connection)) { command.CommandType = commandType; if (parameters != null) { foreach (SqlParameter parameter in parameters) { command.Parameters.Add(parameter); } } connection.Open(); result = command.ExecuteScalar(); } } return result; } #endregion

4.对数据库进行增、删、改操作，，进行数据编辑。

利用ExecuteNonQuery()。

View Code

#region 对数据库进行增删改操作 对数据库进行增删改操作 ExecuteNonQuery(string sql) { return ExecuteNonQuery(sql, CommandType.Text, null); } 对数据库进行增删改操作 ExecuteNonQuery(string sql, CommandType commandType) { return ExecuteNonQuery(sql, commandType, null); } 对数据库进行增删改操作 ExecuteNonQuery(string sql, CommandType commandType, SqlParameter[] parameters) { int count = 0; using (SqlConnection connection = new SqlConnection(connectionString)) { using (SqlCommand command = new SqlCommand(sql, connection)) { command.CommandType = commandType; if (parameters != null) { foreach (SqlParameter parameter in parameters) { command.Parameters.Add(parameter); } } connection.Open(); count = command.ExecuteNonQuery(); } } return count; } #endregion

5.判断与数据库是否连接（更新）

View Code

#region 判断数据库是否连接 判断数据库是否连接 IsConnected() { SqlConnection connection = new SqlConnection(connectionString); try { if (connection.State != ConnectionState.Open) { connection.Open(); } return true; } catch { return false; } } #endregion

该类全部代码

View Code

using System; using System.Data; using System.Data.SqlClient; using System.Configuration; SqlDbHelper:操作SQL Server数据库的通用类 /// 作者：李宝亨 /// 日期：2012-03-15 /// Version:1.0 SqlDbHelper { #region 字段 私有字段 connectionString; #endregion #region 属性 公共属性 数据库连接字符串 ConnectiongString { set { connectionString = value; } } #endregion #region 构造函数 构造函数 SqlDbHelper() { //修改connectionString为项目中的数据库连接字符串 //connectionString=""; } 构造函数 SqlDbHelper(string strConnectionString) { connectionString = strConnectionString; } #endregion #region 判断数据库是否连接 判断数据库是否连接 IsConnected() { SqlConnection connection = new SqlConnection(connectionString); try { if (connection.State != ConnectionState.Open) { connection.Open(); } return true; } catch { return false; } } #endregion #region 执行一个查询，并返回结果集 执行一个查询，并返回结果集 DataTable ExecuteDataTable(string sql) { return ExecuteDataTable(sql, CommandType.Text, null); } 执行一个查询，并返回结果集 DataTable ExecuteDataTable(string sql, CommandType commandType) { return ExecuteDataTable(sql, commandType, null); } 执行一个查询，并返回结果集 DataTable ExecuteDataTable(string sql, CommandType commandType, SqlParameter[] parameters) { //实例化DataTable，用于装载查询结果集 DataTable data = new DataTable(); using (SqlConnection connection = new SqlConnection(connectionString)) { using (SqlCommand command = new SqlCommand(sql, connection)) { //指定CommandType command.CommandType = commandType; if (parameters != null) { foreach (SqlParameter parameter in parameters) { command.Parameters.Add(parameter); } } //实例化SqlDataAdapter SqlDataAdapter adapter = new SqlDataAdapter(command); //填充DataTable adapter.Fill(data); } } return data; } #endregion #region 返回一个DataReader对象实例 返回一个DataReader对象实例 SqlDataReader ExecuteReader(string sql) { return ExecuteReader(sql, CommandType.Text, null); } 返回一个DataReader对象实例 SqlDataReader ExecuteReader(string sql, CommandType commandType) { return ExecuteReader(sql, commandType, null); } 返回一个DataReader对象实例 SqlDataReader ExecuteReader(string sql, CommandType commandType, SqlParameter[] parameters) { SqlConnection connection = new SqlConnection(connectionString); SqlCommand command = new SqlCommand(sql, connection); if (parameters != null) { foreach (SqlParameter parameter in parameters) { command.Parameters.Add(parameter); } } connection.Open(); command.ExecuteReader(CommandBehavior.CloseConnection); } #endregion #region 执行查询结果，返回第一行的第一列 执行查询结果，返回第一行的第一列 ExecuteScalar(string sql) { return ExecuteScalar(sql, CommandType.Text, null); } 执行查询结果，返回第一行的第一列 ExecuteScalar(string sql, CommandType commandType) { return ExecuteScalar(sql, commandType, null); } 执行查询结果，返回第一行的第一列 ExecuteScalar(string sql, CommandType commandType, SqlParameter[] parameters) { object result = null; using (SqlConnection connection = new SqlConnection(connectionString)) { using (SqlCommand command = new SqlCommand(sql, connection)) { command.CommandType = commandType; if (parameters != null) { foreach (SqlParameter parameter in parameters) { command.Parameters.Add(parameter); } } connection.Open(); result = command.ExecuteScalar(); } } return result; } #endregion #region 对数据库进行增删改操作 对数据库进行增删改操作 ExecuteNonQuery(string sql) { return ExecuteNonQuery(sql, CommandType.Text, null); } 对数据库进行增删改操作 ExecuteNonQuery(string sql, CommandType commandType) { return ExecuteNonQuery(sql, commandType, null); } 对数据库进行增删改操作 ExecuteNonQuery(string sql, CommandType commandType, SqlParameter[] parameters) { int count = 0; using (SqlConnection connection = new SqlConnection(connectionString)) { using (SqlCommand command = new SqlCommand(sql, connection)) { command.CommandType = commandType; if (parameters != null) { foreach (SqlParameter parameter in parameters) { command.Parameters.Add(parameter); } } connection.Open(); count = command.ExecuteNonQuery(); } } return count; } #endregion }

　　点此下载SqlDbHelper.cs

感谢@酷小孩和各位园友的指正和支持，代码已修正! 

  本文关键词：数据库访问，由笔耕文化传播整理发布。