sqlprovider.cs

来自「此项目是用asp.net开发的航班查询系统」· CS 代码 · 共 57 行

using System;
using System.Collections;
using System.Data;
using System.Data.SqlClient;

namespace OceanSoft.Data
{
	/// <summary>
	/// 通用数据访问接口的 Sql Server 实现类
	/// </summary>
	internal class SqlProvider:DefaultProvider
	{
        /// <summary>
        /// Sql实现的构造函数
        /// </summary>
        /// <param name="ConnString">连接字符串</param>
		public SqlProvider(string ConnString)
		{
			this.Conn=new SqlConnection(ConnString);
		}

        /// <summary>
        /// 得到空数据适配对象
        /// </summary>
        /// <returns>基于Sql的适配器对象</returns>
        public override IDbDataAdapter GetNullDataAdapter()
		{
			return new SqlDataAdapter();
		}

        protected override void FillTable(IDbDataAdapter da, DataTable mDataTable)
        {
            ((SqlDataAdapter)da).Fill(mDataTable);
        }

        protected override int GetReturnValue()
        {
            return (int)((SqlCommand)this.Cmd).Parameters["returnValue"].Value;
        }

		protected override void SetParams()
		{
            //先清空上次预设的参数
            this.Cmd.Parameters.Clear();
			IDictionaryEnumerator pParams=this.CommandParams.GetEnumerator();

			while(pParams.MoveNext())
				((SqlCommand)this.Cmd).Parameters.Add(pParams.Key.ToString(),pParams.Value);

            SqlParameter par = new SqlParameter();
            par.ParameterName = "returnValue";
            par.Direction = ParameterDirection.ReturnValue;
            ((SqlCommand)this.Cmd).Parameters.Add(par);
		}
	}
}