DataBase/DataConSql.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using System;
using System.Collections.Generic;
using System.Text;
using System.Configuration;
using System.Data;
using System.Data.SqlClient;

namespace DataBase
{
    public abstract class DataConSql
    {
        protected static string strCon = ConfigurationSettings.AppSettings["ConStr"];
       
        public static DataSet RunProcedure(SqlConnection oleCon, SqlTransaction tx, string storedProcName, IDataParameter[] parameters, string tablename)
        {
            DataSet dataSet = new DataSet();
            SqlDataAdapter SqlDA = new SqlDataAdapter();
            SqlCommand cmd = BuildQueryCommand(oleCon, tx, storedProcName, parameters);
            parameters[0].Direction = ParameterDirection.Output;
            SqlDA.SelectCommand = cmd;
            SqlDA.Fill(dataSet, tablename);
            cmd.Dispose();
            SqlDA.Dispose();
            return dataSet;
        }
       
        public static DataSet RunProcedure_notParam(SqlConnection oleCon, SqlTransaction tx, string storedProcName, string tablename)
        {
            DataSet dataSet = new DataSet();
            SqlDataAdapter SqlDA = new SqlDataAdapter();
            SqlCommand cmd = BuildQueryCommand(oleCon, tx, storedProcName);
            SqlDA.SelectCommand = cmd;
            SqlDA.Fill(dataSet, tablename);
            cmd.Dispose();
            SqlDA.Dispose();
            return dataSet;
        }
       
        public static int RunProcedure_Row(SqlConnection oleCon, SqlTransaction tx, string storedProcName, IDataParameter[] parameters)
        {
            int influenceRow = 0;
            try
            {
                SqlCommand cmd = BuildQueryCommand(oleCon, tx, storedProcName, parameters);
                influenceRow = cmd.ExecuteNonQuery();
                cmd.Dispose();
            }
            catch (SqlException ex)
            {
                influenceRow = -1;
                throw new Exception(ex.Message);
            }
            return influenceRow; 
        }
        private static SqlCommand BuildQueryCommand(SqlConnection oleCon, SqlTransaction tx, string storedProcName, IDataParameter[] parameters)
        {
            SqlCommand command = new SqlCommand(storedProcName, oleCon);
            if (tx != null)
            {
                command.Transaction = tx;