DAL/Query.cs

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

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

// ******************************************************************
// 文件名: Query.cs
// 主要内容： IQuery的实现。
// ******************************************************************

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Logistics.IDal;
using System.Data.SqlClient;
using System.Data;
namespace Logistics.DAL
{
   public class Query:IQuery
    {
        #region IQuery 成员

        public System.Data.SqlClient.SqlConnection connection{get;set;}
        public SqlTransaction transaction { get; set; }

        public System.Data.DataSet execute(string procname, System.Data.SqlClient.SqlParameter[] pars)
        {
            SqlCommand comm = connection.CreateCommand();
            comm.CommandText = procname;
            comm.CommandType = CommandType.StoredProcedure;
            comm.Transaction = transaction;
            if (pars != null)
            {
                foreach (var v in pars)
                {
                    comm.Parameters.Add(v);
                }
            }
            DataSet ds = new DataSet();
            SqlDataAdapter sda = new SqlDataAdapter(comm);
            sda.Fill(ds);
            return ds;
        }

        public System.Data.DataSet execute(string sql)
        {
            SqlCommand comm= connection.CreateCommand();
            comm.CommandText = sql;
            comm.Transaction = transaction;
            DataSet ds = new DataSet();
            SqlDataAdapter sda = new SqlDataAdapter(comm);
            sda.Fill(ds);
            return ds;

        }

        int IQuery.executeInt(string sql)
        {
            SqlCommand comm = connection.CreateCommand();
            comm.CommandText = sql;
            comm.Transaction = transaction;
            return comm.ExecuteNonQuery();
        }