testda.cs

三层框架结构

using System;
using System.Data;
using System.Text;

namespace DataAccess
{
	/// <summary>
	/// TestDA 的摘要说明。
	/// </summary>
	public class TestDA:BaseDA
	{
		private System.Data.SqlClient.SqlCommand sqlSelectCommand1;
		private System.Data.SqlClient.SqlCommand sqlInsertCommand1;
		private System.Data.SqlClient.SqlCommand sqlUpdateCommand1;
		private System.Data.SqlClient.SqlCommand sqlDeleteCommand1;
		private System.Data.SqlClient.SqlConnection sqlConnection1;
		private System.Data.SqlClient.SqlDataAdapter sqlDataAdapter1;

		public TestDA()
		{
			//
			// TODO: 在此处添加构造函数逻辑
			//
			this.InitializeComponent();
		}


		public void Select(string sql,DataSet ds)
		{
			StringBuilder sb = new StringBuilder();
			sb.Append("SELECT likename A,likeid id  FROM likename ");
			if( sql != null && sql != "")
			{
				sb.Append(" Where "+sql);
			}
			this.Query(sb.ToString(),ds);
		}


		// 得到应该插入自增列ID
		public int GetPrimaryKey()
		{
			DataSet ds = new DataSet();
			ds.Tables.Add(new DataTable());
			StringBuilder sb = new StringBuilder();
			sb.Append("select max(likeId) from likename ");

			this.Query(sb.ToString(),ds);

			return Convert.ToInt32(ds.Tables[0].Rows[0][0])+1;
		}

		public void SelectForUpdate(string sql,DataSet ds)
		{
			StringBuilder sb = new StringBuilder();
			sb.Append(this.sqlSelectCommand1.CommandText);
			if( sql != null && sql != "")
			{
				sb.Append(" Where "+sql);
			}
			this.Query(sb.ToString(),ds);
		}


		// Update DataBase 
		public void Update( DataSet ds )
		{
			this.sqlDataAdapter1.Update(ds,ds.Tables[0].TableName);
		}

		#region 组件设计器生成的代码
		/// <summary>
		/// 设计器支持所需的方法 - 不要使用代码编辑器修改
		/// 此方法的内容。
		/// </summary>
		private void InitializeComponent()
		{
			this.sqlSelectCommand1 = new System.Data.SqlClient.SqlCommand();
			this.sqlInsertCommand1 = new System.Data.SqlClient.SqlCommand();
			this.sqlUpdateCommand1 = new System.Data.SqlClient.SqlCommand();
			this.sqlDeleteCommand1 = new System.Data.SqlClient.SqlCommand();
			this.sqlConnection1 = new System.Data.SqlClient.SqlConnection();
			this.sqlDataAdapter1 = new System.Data.SqlClient.SqlDataAdapter();
			// 
			// sqlSelectCommand1
			// 
			this.sqlSelectCommand1.CommandText = "SELECT likeid, likename FROM likename";
			this.sqlSelectCommand1.Connection = this.sqlConnection1;
			// 
			// sqlInsertCommand1
			// 
			this.sqlInsertCommand1.CommandText = "INSERT INTO likename(likeid, likename) VALUES (@likeid, @likename); SELECT likeid" +
				", likename FROM likename WHERE (likeid = @likeid)";
			this.sqlInsertCommand1.Connection = this.sqlConnection1;
			this.sqlInsertCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@likeid", System.Data.SqlDbType.Int, 4, "likeid"));
			this.sqlInsertCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@likename", System.Data.SqlDbType.VarChar, 50, "likename"));
			// 
			// sqlUpdateCommand1
			// 
			this.sqlUpdateCommand1.CommandText = "UPDATE likename SET likeid = @likeid, likename = @likename WHERE (likeid = @Origi" +
				"nal_likeid) AND (likename = @Original_likename OR @Original_likename IS NULL AND" +
				" likename IS NULL); SELECT likeid, likename FROM likename WHERE (likeid = @likei" +
				"d)";
			this.sqlUpdateCommand1.Connection = this.sqlConnection1;
			this.sqlUpdateCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@likeid", System.Data.SqlDbType.Int, 4, "likeid"));
			this.sqlUpdateCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@likename", System.Data.SqlDbType.VarChar, 50, "likename"));
			this.sqlUpdateCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_likeid", System.Data.SqlDbType.Int, 4, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "likeid", System.Data.DataRowVersion.Original, null));
			this.sqlUpdateCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_likename", System.Data.SqlDbType.VarChar, 50, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "likename", System.Data.DataRowVersion.Original, null));
			// 
			// sqlDeleteCommand1
			// 
			this.sqlDeleteCommand1.CommandText = "DELETE FROM likename WHERE (likeid = @Original_likeid) AND (likename = @Original_" +
				"likename OR @Original_likename IS NULL AND likename IS NULL)";
			this.sqlDeleteCommand1.Connection = this.sqlConnection1;
			this.sqlDeleteCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_likeid", System.Data.SqlDbType.Int, 4, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "likeid", System.Data.DataRowVersion.Original, null));
			this.sqlDeleteCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_likename", System.Data.SqlDbType.VarChar, 50, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "likename", System.Data.DataRowVersion.Original, null));
			// 
			// sqlConnection1
			// 
			this.sqlConnection1.ConnectionString = this.GetConnectString;
			// 
			// sqlDataAdapter1
			// 
			this.sqlDataAdapter1.DeleteCommand = this.sqlDeleteCommand1;
			this.sqlDataAdapter1.InsertCommand = this.sqlInsertCommand1;
			this.sqlDataAdapter1.SelectCommand = this.sqlSelectCommand1;
			this.sqlDataAdapter1.TableMappings.AddRange(new System.Data.Common.DataTableMapping[] {
																									  new System.Data.Common.DataTableMapping("Table", "likename", new System.Data.Common.DataColumnMapping[] {
																																																				  new System.Data.Common.DataColumnMapping("likeid", "likeid"),
																																																				  new System.Data.Common.DataColumnMapping("likename", "likename")})});
			this.sqlDataAdapter1.UpdateCommand = this.sqlUpdateCommand1;

		}
		#endregion
	}
}