sqldboperhandler.cs

x2webcontrols

using System;

namespace X2Design.Data
{
	/// <summary>
	/// 本对象用与提供对SqlServer数据库的常用访问操作。
	/// </summary>
	public class SqlDbOperHandler:DbOperHandler
	{
		/// <summary>
		/// 构造函数，接收一个SqlServer数据库连接对象SqlConnection
		/// </summary>
		public SqlDbOperHandler(System.Data.SqlClient.SqlConnection _conn)
		{
			
			conn=_conn;
			dbType=DatabaseType.SqlServer;
			
			conn.Open();
			cmd=conn.CreateCommand();
			da=new System.Data.SqlClient.SqlDataAdapter();
			
		}
		/// <summary>
		/// 产生SqlCommand对象所需的查询参数。
		/// </summary>
		protected override void GenParameters()
		{
			System.Data.SqlClient.SqlCommand sqlCmd=(System.Data.SqlClient.SqlCommand)cmd;
			if(this.alFieldItems.Count>0)
			{
				for(int i=0;i<alFieldItems.Count;i++)
				{
					//if(((DbKeyItem)alFieldItems[i]).fieldValue.ToString().Length>
					sqlCmd.Parameters.Add("@para"+i.ToString(),((DbKeyItem)alFieldItems[i]).fieldValue.ToString());
				}
			}
			
			if(this.alSqlCmdParameters.Count>0)
			{
				for(int i=0;i<this.alSqlCmdParameters.Count;i++)
				{
					//sqlCmd.Parameters.Add("@spara"+i.ToString(),((DbKeyItem)alSqlCmdParameters[i]).fieldValue.ToString());
					sqlCmd.Parameters.Add(((DbKeyItem)alSqlCmdParameters[i]).fieldName.ToString(),((DbKeyItem)alSqlCmdParameters[i]).fieldValue.ToString());
				}
			}
			if(this.alConditionParameters.Count>0)
			{
				for(int i=0;i<this.alConditionParameters.Count;i++)
				{
					//sqlCmd.Parameters.Add("@cpara"+i.ToString(),((DbKeyItem)alConditionParameters[i]).fieldValue.ToString());
					sqlCmd.Parameters.Add(((DbKeyItem)alConditionParameters[i]).fieldName.ToString(),((DbKeyItem)alConditionParameters[i]).fieldValue.ToString());
				}
			}
		}
		
	}
}