C#实现IDbConnection/IDbCommand等相关通用数据接口_C#

关于数据接口

在.net 应用中，与数据库进行连接、访问和执行经常会用到数据接口的相关对象，如下：

1、 connection

表示一个到数据库的打开的连接，是连接数据必不可少的对象。

2、 command

命令对象，表示要对数据源连接执行的 sql 语句或存储过程，以获取返回结果或执行返回值。

3、 dataparameter

用于表示command命令对象需要的参数设置，虽然这是一个可选项，但在实际的应用中几乎都会使用到

ado.net 中的数据提供者对象提供了idbconnection、idbcommand、idbdataparameter等通用数据接口，本文将利用这些对象实现一个通用方法以访问和操作数据库内容。

对象执行流程

首先需要创建连接对象，成功后下达符合对应数据库规范的命令指令，该指令可能包括需要的参数对象（需要定义名称和赋值等操作），大体流程如下图：

范例运行环境

操作系统： 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;

getconnection方法

getconnection 方法返回 system.data.idbconnection 对象，其参数说明见下表：

序号	参数名	类型	说明
1	dbservertype	string	目前支持 "oracle"、 "dm8"，其它字符串均视为 ms sql server
2	connectionstring	string	对应数据库的连接字符串

实现代码如下：

public system.data.idbconnection getconnection(string dbservertype,string connectionstring)
{
	idbconnection con = null;
	switch (dbservertype.tolower())
	{
		case "oracle":
			con = new oracleconnection(connectionstring);break;
        case "dm8":
            con = new dmconnection(connectionstring); break;
        default:
			con = new sqlconnection(connectionstring);   break;
	}
 
	return con;
 
}

getcommand方法

getcommand 方法返回 system.data.idbcommand 对象，其参数说明见下表：

序号	参数名	类型	说明
1	dbservertype	string	目前支持 "oracle"、 "dm8"，其它字符串均视为 ms sql server
2	cmdtext	string	要执行的sql语句命令行
3	paras	arraylist	要赋值的参数对象，逐个添加到arraylist里，请注意参数为实体数据参数对象，如 ms sql server ，请传递如下代码： arraylist.add(new sqlparameter("参数名",参数值));
4	con	idbconnection	要传递的connection对象，可能过前面所述的getconnection方法获取

实现代码如下：

public idbcommand getcommand(string dbservertype,string cmdtext,arraylist paras,idbconnection con)
		{
			idbcommand cmd = null;
			switch (dbservertype.tolower())
			{
				case "oracle": cmd = new oraclecommand(cmdtext,(oracleconnection)con);
					break;
                case "dm8":
                    cmd = new dmcommand(cmdtext, (dmconnection)con);
                    break;
                default:    cmd = new sqlcommand(cmdtext,(sqlconnection)con);        break;
			}
			if(paras!=null)
			{
				for(int i=0;i<paras.count;i++)
				{
					cmd.parameters.add(getparameter(dbservertype,paras[i]));
				}
			}
			return cmd;
		}

请注意，代码中的 getparameter 方法我们将后续做介绍。

getparameter方法

getparameter 方法返回 system.data.idbdataparameter 对象，其参数说明见下表：

序号	参数名	类型	说明
1	dbservertype	string	目前支持 "oracle"、 "dm8"，其它字符串均视为 ms sql server
2	para	object	传递的单一参数对象

实现代码如下：

public system.data.idbdataparameter getparameter(string dbservertype,object para)
{
	idbdataparameter pa = null;
	switch (dbservertype.tolower())
	{
 
		case "oracle": pa =(oracleparameter)para; 
			break;
        case "dm8":
            para =  (dmparameter)pa;
            break;
        default: para =(sqlparameter)pa;
            break;
	}
	return pa;
}