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

using System.Data;
using System.Data.SqlClient;
using System.Data.OracleClient;
using Dm;
using System.Collections;

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;
		}
 
}