C#利用IDbCommand实现通用数据库脚本执行程序_C#

关于 executenonquery

在.net 应用中，在数据库中执行脚本程序是经常用到的功能，如数据操作（新增、修改、删除等），执行一个存储过程等，实现的核心方法需要执行 command 对象的executenonquery方法。该方法对数据库连接执行 transact-sql 语句并返回受影响的行数。

生成数据集对象需要利用 ado.net 中的数据提供者对象包括idbconnection、idbcommand、idbdataparameter等，如何使用这些对象请参考这篇文章：c#实现idbconnection/idbcommand等相关通用数据接口_c#教程_代码网 (jb51.net)

本文将介绍如何通过利用idbcommand 实现通用数据库脚本执行程序。

数据库脚本程序的执行流程

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

范例运行环境

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

dal类

创建一个 dal 数据操作类，该类设计如下：

序号	成员	类型	说明
1	public string connkeystring=""	属性	访问在configurationsettings.appsettings[connkeystring]中存储的数据连接串，该关键字为优先选项，如果为空则访问 connstring 直接连接串
2	public string connstring=""	属性	idbconnection对象的连接串，该属性仅到connkeystring为空时试图访问
3	public string dbservertype=""	属性	目前支持 "oracle"、 "dm8"，其它字符串均视为 ms sql server
4	public string errormessage=""	属性	当执行脚本命令发生错误时捕捉到的错误信息
5	public int rowscount=0	属性	当执行脚本命令成功后的影响行数，默认值为0
6	public int errornum=0	属性	当执行脚本命令失败时，返回数据库提供的错误号
7	public void execdbscripts(string _sql,arraylist paras,commandtype ct)	方法	execdbscripts 方法用于执行数据库脚本

execdbscripts 方法无返回值，均通过设置 errormessage、rowscount、errornum属性实现，其参数说明见下表：

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

序号

参数名

类型

说明

_sql

string

要执行的sql语句命令行

paras

arraylist

要赋值的参数对象，逐个添加到arraylist里，请注意参数为实体数据参数对象，如 ms sql server ，请传递如下代码：

arraylist.add(new sqlparameter("参数名",参数值));

commandtype

system.data.commandtype 枚举，可包括：

storedprocedure（存储过程）
tabledirect（直接表查询）
text（文本查询）该值为默认值

有关 commandtype 的更多资料请参考如下链接：commandtype 枚举 (system.data) | microsoft learn

实现代码

dal类完整的实现代码如下：

public class codal
{
		public string connkeystring="janeconnection";
		public string connstring="";
		public string dbservertype= configurationsettings.appsettings["dbservertype"];
        public string errormessage="";
		public int rowscount=0;
		public int errornum=0;
 
		public void execdbscripts(string _sql,arraylist paras,commandtype ct)
		{
			string strconn =configurationsettings.appsettings[connkeystring];
			if(connstring!="")
			{
				strconn=connstring;
			}
			system.data.idbconnection conn=getconnection(dbservertype,strconn);
			system.data.idbcommand cmd=getcommand(dbservertype,_sql,paras,conn);
			cmd.commandtype=ct;
			cmd.commandtimeout=commandtimeout;
			try
			{
				conn.open();
				int i=cmd.executenonquery();
				rowscount=i;
			}
			catch (exception e)
			{
				if (e.gettype() ==typeof(system.data.sqlclient.sqlexception))
				{
					int errnumber = ((system.data.sqlclient.sqlexception)e).number;
					errornum = errnumber;
				}else if (e.gettype() == typeof(system.data.oracleclient.oracleexception))
                {
                    int errnumber = ((system.data.oracleclient.oracleexception)e).code;
                    errornum = errnumber;
                }
                else if (e.gettype() == typeof(dmexception))
                {
                    int errnumber = ((dmexception)e).number;
                    errornum = errnumber;
                }
				errormessage=rv[1];
				cmd.parameters.clear();
			}
			finally
			{
				if(conn.state==connectionstate.open)
				{
					conn.close();
				}
			}
		}
		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;
 
		}
		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;
		}
        public system.data.idbdataparameter getparameter(string dbservertype,object paras)
		{
			idbdataparameter para = null;
			switch (dbservertype.tolower())
			{
 
				case "oracle": para =(oracleparameter)paras; 
					break;
                case "dm8":
                    para =  (dmparameter)paras;
                    break;
                default: para =(sqlparameter)paras; break;
			}
			return para;
		}
 
}