下面给出了一个C#操作MS SQL Server 数据库的通用类,通过该类可以对数据库进行任何操作,包括执行SQL语句、执行存储过程。以下是其详细实现过程,希望大家共同修改优化之。稍后将介绍如何使用它实现N层的程序设计。
配置web.config文件的链接参数
<appSettings>
<!--
connStr参数设置,事例说明:
(1)Sql server数据库,例如“server=local;database=test;uid=sa;pwd=;”
(2)Access数据库,例如“data/ex.mdb; user id='admin';Jet OLEDB:database password='admin';”
-->
<add key="connStr" value="server=127.0.0.1;database=DbName;uid=sa;pwd=;" />
</appSettings>
C#代码
using System;
using System.Data;
using System.Data.SqlClient;
namespace Com.LXJ.Database
{
/// <summary>
/// ConnDB 的摘要说明。
/// </summary>
public class ConnDB
{
protected SqlConnection Connection;
private string connectionString;
/// <summary>
/// 默认构造函数
/// </summary>
public ConnDB()
{
string connStr;
connStr = System.Configuration.ConfigurationSettings.AppSettings["connStr"].ToString();
connectionString = connStr;
Connection = new SqlConnection(connectionString);
}
/// <summary>
/// 带参数的构造函数
/// </summary>
/// <param name="newConnectionString">数据库联接字符串</param>
public ConnDB(string newConnectionString)
{
connectionString = newConnectionString;
Connection = new SqlConnection(connectionString);
}
/// <summary>
/// 完成SqlCommand对象的实例化
/// </summary>
/// <param name="storedProcName"></param>
/// <param name="parameters"></param>
/// <returns></returns>
private SqlCommand BuildCommand(string storedProcName,IDataParameter[] parameters)
{
SqlCommand command = BuildQueryCommand(storedProcName,parameters);
command.Parameters.Add(new SqlParameter("ReturnValue",SqlDbType.Int,4,ParameterDirection.ReturnValue,false,0,0,string.Empty,DataRowVersion.Default,null));
return command;
}
/// <summary>
/// 创建新的SQL命令对象(存储过程)
/// </summary>
/// <param name="storedProcName"></param>
/// <param name="parameters"></param>
/// <returns></returns>
private SqlCommand BuildQueryCommand(string storedProcName,IDataParameter[] parameters)
{
SqlCommand command = new SqlCommand(storedProcName,Connection);
command.CommandType = CommandType.StoredProcedure;
foreach (SqlParameter parameter in parameters)
{
command.Parameters.Add(parameter);
}
return command;
}
/// <summary>
/// 执行存储过程,无返回值
/// </summary>
/// <param name="storedProcName"></param>
/// <param name="parameters"></param>
public void ExecuteProcedure(string storedProcName,IDataParameter[] parameters)
{
Connection.Open();
SqlCommand command;
command=BuildQueryCommand(storedProcName,parameters);
command.ExecuteNonQuery();
Connection.Close();
}
/// <summary>
/// 执行存储过程,返回执行操作影响的行数目
/// </summary>
/// <param name="storedProcName"></param>
/// <param name="parameters"></param>
/// <param name="rowsAffected"></param>
/// <returns></returns>
public int RunProcedure(string storedProcName,IDataParameter[] parameters,out int rowsAffected)
{
int result;
Connection.Open();
SqlCommand command = BuildCommand(storedProcName,parameters);
rowsAffected = command.ExecuteNonQuery();
result = (int)command.Parameters["ReturnValue"].Value;
Connection.Close();
return result;
}
/// <summary>
/// 重载RunProcedure把执行存储过程的结果放在SqlDataReader中
/// </summary>
/// <param name="storedProcName"></param>
/// <param name="parameters"></param>
/// <returns></returns>
public SqlDataReader RunProcedure(string storedProcName,IDataParameter[] parameters)
{
SqlDataReader returnReader;
Connection.Open();
SqlCommand command = BuildQueryCommand(storedProcName,parameters);
command.CommandType = CommandType.StoredProcedure;
returnReader = command.ExecuteReader(CommandBehavior.CloseConnection);
return returnReader;
}
/// <summary>
/// 重载RunProcedure把执行存储过程的结果存储在DataSet中和表tableName为可选参数
/// </summary>
/// <param name="storedProcName"></param>
/// <param name="parameters"></param>
/// <param name="tableName"></param>
/// <returns></returns>
public DataSet RunProcedure(string storedProcName,IDataParameter[] parameters,params string[] tableName)
{
DataSet dataSet = new DataSet();
Connection.Open();
SqlDataAdapter sqlDA = new SqlDataAdapter();
sqlDA.SelectCommand = BuildQueryCommand(storedProcName,parameters);
string flag;
flag = "";
for(int i=0;i<tableName.Length;i++)
flag = tableName[i];
if (flag!="")
sqlDA.Fill(dataSet,tableName[0]);
else
sqlDA.Fill(dataSet);
Connection.Close();
return dataSet;
}
/// <summary>
/// 执行SQL语句,返回数据到DataSet中
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public DataSet ReturnDataSet(string sql)
{
DataSet dataSet=new DataSet();
Connection.Open();
SqlDataAdapter sqlDA=new SqlDataAdapter(sql,Connection);
sqlDA.Fill(dataSet,"objDataSet");
Connection.Close();
return dataSet;
}
/// <summary>
/// 执行SQL语句,返回 DataReader
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public SqlDataReader ReturnDataReader(String sql)
{
Connection.Open();
SqlCommand command = new SqlCommand(sql,Connection);
SqlDataReader dataReader = command.ExecuteReader();
return dataReader;
}
/// <summary>
/// 执行SQL语句,返回记录数
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public int ReturnRecordCount(string sql)
{
int recordCount = 0;
Connection.Open();
SqlCommand command = new SqlCommand(sql,Connection);
SqlDataReader dataReader = command.ExecuteReader();
while(dataReader.Read())
{
recordCount++;
}
dataReader.Close();
Connection.Close();
return recordCount;
}
/// <summary>
/// 执行SQL语句
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public bool EditDatabase(string sql)
{
bool successState = false;
Connection.Open();
SqlTransaction myTrans = Connection.BeginTransaction();
SqlCommand command = new SqlCommand(sql,Connection,myTrans);
try
{
command.ExecuteNonQuery();
myTrans.Commit();
successState = true;
}
catch
{
myTrans.Rollback();
}
finally
{
Connection.Close();
}
return successState;
}
/// <summary>
/// 关闭数据库联接
/// </summary>
public void Close()
{
Connection.Close();
}
}//end class
}//end namespace
分享到:
相关推荐
C#.NET万能数据库访问封装类(ACCESS、SQLServer、Oracle) 这个类封装成dll后,相关数据库连接可在,引用该dll项目的app.config文件中写,如果是web程序,这需要修改代码,将构造函数中获取app.config的信息换成获取...
数据库操作类: 支持 SQLServer mysql sqlite Sybase Oracle等DB 数据库操作类 包括执行SQL或者存储过程,返回DataSet、DataTable等功能 完全支持存储过程和参数调用 javascriptClassLibrary 包括一些JavaScript 类...
asp.net(C#)通用数据库操作类,下载后在您的程序中就可以使用。
c# .net 通用sql数据库访问的类 比较全,有注释
算是一个通用类,在利用ASP.NET网站和系统开发中可以实现对数据库常用操作
.NET数据库通用接口SQLSERVER和ORACLE.net,c#,SQLSERVER,ORACLE 支持两种数据的通用类
ASP.NET 2.0 数据库(ORACLE)通用操作类
根据接口实现访问数据库访问类。c#代码,免费赠送、别扔砖头就行
ASP.NET是新一代的B/S系统编程工具,集众多优点于一身,在时数据库的操作上更是功能强大...本文以C#语言、SQLServer数据库为例,利用ADO.NET数据库访问组件.介绍了一种基于ASP.NET技术的数据库访问通用类设计方法
企业人事管理系统(c#.net SQL 含数据库 源代码) 企业人事管理系统(c#.net SQL 含数据库 源代码)
内容包括:Visual C#.NET集成环境,常用Windows窗体控件,工程界面设计,C#.NET程序设计基础,图形、图像处理、数据库应用、Web应用及应用程序设计实践等。在完成本书的学习和实践后,学生可以在C#的应用程序开发技能方面...
Database、Linq操作DataSet、Linq操作SQL、Linq操作Xml、Linq操作数组集合、触发器SQL文件、读取数据库表结构、二进制存取图片、交叉表、数据库管理、通过存储过程管理信息、通过视图修改信息、通用数据库连接等...
c#写的数据访问类 /// /// 通用数据库访问类-UniversalDAL类, /// 支持SqlClient、OleDb、Odbc、OracleClient等 /// 不同类型的数据源
Socut.Data.dll 通用ASP.net数据库连接
经常操作数据库,操作类写起来很不便,我将常用的数据库操作类做了封装,只需导入这个操作公类,数据库的常用操作就像使用系统内置函数一样. 采用C#2005开发,适用于SqlServer和Access的数据库, Asp.Net系统,WinForm系统,...
自己写的一个小东西,第一次上传,欢迎大家一起来交流下
C# 链接Oracle数据库操作类 SqlHelper.cs,.NET3.0以上即可使用,涵盖了oracle数据库的增删改查操作,并可调用存储过程,因是源码,可根据自己实际需要再修改,灵活性较大
C#通用数据库访问层源码,通用数据库访问层源码,通用数据库访问层源码通用数据库访问层源码,通用数据库访问层源码
通用C#权限管理系统,包括源代码和数据库。实现用户、角色、权限的整合。
本组件支持多种主流数据库(Oracle、sqlsever、db2、mysql),功能强大,使用方便,代码简洁,思路严谨,被广大支持者称为权限管理系统中的“走火入魔级权限管理系统”。 精心维护通用权限管理系统组件(GPM - ...