C#利用IDbDataAdapter/IDataReader实现通用数据集获取_C#

关于数据集

在.net 应用中，与数据库进行连接并查询相关数据，填充到数据集是我们经常用到的功能，数据集的表现形式基本包括如下：

1、 dataset

dataset 是 ado.net 中的数据集合对象，可以通过 idbdataadapter 接口对象，其表示一组与命令有关的属性，用于填充 dataset 和更新数据源。dataset 相当于内存中的数据库，可以容纳复杂关系的数据，而且即使断开数据链路，依然可以继续独立的操作。生成的 dataset 由一组 datatable 对象组成，即数据表集合。

2、 datareader

datareader 也是数据集的一种形式，它与 dataset 的区别在于，其只允许以只读、顺序向下的方式查看其中所存储的数据，高效和简单，是一种非常节省资源的数据对象，如果我们不考虑后续操作，只是显示数据，则 datareader 对象几乎是首选。

生成数据集对象需要利用 ado.net 中的数据提供者对象包括idbconnection、idbcommand、idbdataparameter等，如何使用这些对象请参考我的文章：

《c#实现 idbconnection / idbcommand 等相关通用数据接口》

本文将介绍如何通过利用idbdataadapter / idatareader 实现通用数据集获取。

获取数据集的执行流程

首先需要创建连接对象，成功后下达符合对应数据库规范的命令指令，该指令可能包括需要的参数对象（需要定义名称和赋值等操作），通过数据适配器 idbdataadapter 接口对象填充到dataset或通过命令对象() executereader 填充到 datareader，大体流程如下图：

范例运行环境

操作系统： windows server 2019 datacenter

.net版本： .netframework4.7.1 或以上

开发工具：vs2019 c#

数据库：在这里我们以支持 oracle 9i、ms sql server 2016、国产达梦数据 8 为例

通用对象的设计与实现

引用

在实现方法前请引用如下代码：

using system.data;
using system.data.sqlclient;
using system.data.oracleclient;
using dm;
using system.collections;

getdataadapter方法

getdataadapter 方法返回 system.data.idbdataadapter 数据适配器对象，其参数说明见下表：

序号	参数名	类型	说明
1	dbservertype	string	目前支持 "oracle"、 "dm8"，其它字符串均视为 ms sql server

实现代码如下：

public system.data.idbdataadapter getdataadapter(string dbservertype)
{
    idbdataadapter adp = null;
    switch (dbservertype.tolower())
    {
        case "oracle": adp =new oracledataadapter(); break;
        case "dm8": adp = new  dmdataadapter(); break;
        default: adp =new sqldataadapter(); break;
    }
    return adp;
}

获取数据集的设计与实现

getdataset方法

getdataset 方法返回 object 对象，如果生成成功则返回 dataset 对象，失败则返回错误信息字符串，其参数说明见下表：

序号	参数名	类型	说明
1	dbservertype	string	目前支持 "oracle"、 "dm8"，其它字符串均视为 ms sql server
2	strconn	string	对应数据库的连接字符串
3	_sql	string	要执行的sql语句命令行
4	paras	arraylist	要赋值的参数对象，逐个添加到arraylist里，请注意参数为实体数据参数对象，如 ms sql server ，请传递如下代码： arraylist.add(new sqlparameter("参数名",参数值));
5	ct	commandtype	system.data.commandtype 枚举，可包括： storedprocedure（存储过程） tabledirect（直接表查询） text（文本查询）该值为默认值

有关 commandtype 的更多资料请参考如下链接：

https://learn.microsoft.com/zh-cn/dotnet/api/system.data.commandtype

实现代码如下：

public object getdataset(string dbservertype,string strconn,string _sql,arraylist paras,commandtype ct)
{
            system.data.idbconnection conn=getconnection(dbservertype,strconn);
            system.data.idbcommand cmd=getcommand(dbservertype,_sql,paras,conn);
            cmd.commandtype=ct;
            dataset ds=new dataset();
            try
            {
                ds.enforceconstraints=false;
                conn.open();
                system.data.idbdataadapter adp=getdataadapter(dbservertype);
                adp.selectcommand=cmd;
                
                adp.fillschema(ds,system.data.schematype.mapped);
                adp.fill(ds);
                return ds;
            }
            catch (exception e)
            {
                return e.message;
            }
            finally
            {
                if(conn.state==connectionstate.open)
                {
                    conn.close();
                }
            }
}

getreaderdata方法

getreaderdata 方法返回 idatareader 对象，其参数说明见下表：

序号	参数名	类型	说明
1	dbservertype	string	目前支持 "oracle"、 "dm8"，其它字符串均视为 ms sql server
2	strconn	string	对应数据库的连接字符串
3	_sql	string	要执行的sql语句命令行
4	paras	arraylist	要赋值的参数对象，逐个添加到arraylist里，请注意参数为实体数据参数对象，如 ms sql server ，请传递如下代码： arraylist.add(new sqlparameter("参数名",参数值));
5	ct	commandtype	system.data.commandtype 枚举，可包括： storedprocedure（存储过程） tabledirect（直接表查询） text（文本查询）该值为默认值

有关 commandtype 的更多资料请参考如下链接：

https://learn.microsoft.com/zh-cn/dotnet/api/system.data.commandtype

实现代码如下：

public system.data.idatareader getdatareader2(string dbservertype,string strconn,string _sql, arraylist paras, commandtype ct)
{
      system.data.idbconnection conn = getconnection(dbservertype, strconn);
      system.data.idbcommand cmd = getcommand(dbservertype, _sql, paras, conn);
      cmd.commandtype = ct;
      cmd.connection = conn;
      conn.open();
      return cmd.executereader();
 
}