deleteemployee.cs

分布试数据库系统的管理员程序

			this.sqlInsertCommand2.Parameters.Add(new System.Data.SqlClient.SqlParameter("@branchid", System.Data.SqlDbType.VarChar, 10, "branchid"));
			this.sqlInsertCommand2.Parameters.Add(new System.Data.SqlClient.SqlParameter("@sever", System.Data.SqlDbType.VarChar, 50, "sever"));
			this.sqlInsertCommand2.Parameters.Add(new System.Data.SqlClient.SqlParameter("@db", System.Data.SqlDbType.VarChar, 50, "db"));
			this.sqlInsertCommand2.Parameters.Add(new System.Data.SqlClient.SqlParameter("@ip", System.Data.SqlDbType.VarChar, 10, "ip"));
			// 
			// sqlSelectCommand2
			// 
			this.sqlSelectCommand2.CommandText = "SELECT branchid, sever, db, ip FROM Branch";
			this.sqlSelectCommand2.Connection = this.sqlConnection_Staff;
			// 
			// sqlUpdateCommand2
			// 
			this.sqlUpdateCommand2.CommandText = @"UPDATE Branch SET branchid = @branchid, sever = @sever, db = @db, ip = @ip WHERE (branchid = @Original_branchid) AND (db = @Original_db OR @Original_db IS NULL AND db IS NULL) AND (ip = @Original_ip OR @Original_ip IS NULL AND ip IS NULL) AND (sever = @Original_sever OR @Original_sever IS NULL AND sever IS NULL); SELECT branchid, sever, db, ip FROM Branch WHERE (branchid = @branchid)";
			this.sqlUpdateCommand2.Connection = this.sqlConnection_Staff;
			this.sqlUpdateCommand2.Parameters.Add(new System.Data.SqlClient.SqlParameter("@branchid", System.Data.SqlDbType.VarChar, 10, "branchid"));
			this.sqlUpdateCommand2.Parameters.Add(new System.Data.SqlClient.SqlParameter("@sever", System.Data.SqlDbType.VarChar, 50, "sever"));
			this.sqlUpdateCommand2.Parameters.Add(new System.Data.SqlClient.SqlParameter("@db", System.Data.SqlDbType.VarChar, 50, "db"));
			this.sqlUpdateCommand2.Parameters.Add(new System.Data.SqlClient.SqlParameter("@ip", System.Data.SqlDbType.VarChar, 10, "ip"));
			this.sqlUpdateCommand2.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_branchid", System.Data.SqlDbType.VarChar, 10, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "branchid", System.Data.DataRowVersion.Original, null));
			this.sqlUpdateCommand2.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_db", System.Data.SqlDbType.VarChar, 50, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "db", System.Data.DataRowVersion.Original, null));
			this.sqlUpdateCommand2.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_ip", System.Data.SqlDbType.VarChar, 10, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "ip", System.Data.DataRowVersion.Original, null));
			this.sqlUpdateCommand2.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_sever", System.Data.SqlDbType.VarChar, 50, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "sever", System.Data.DataRowVersion.Original, null));
			// 
			// sqlSelectCommand1
			// 
			this.sqlSelectCommand1.CommandText = "SELECT staffid, branch, branchid, staffname, gender, staffkind, salary, staffphon" +
				"e FROM Staff";
			this.sqlSelectCommand1.Connection = this.sqlConnection_Staff;
			// 
			// sqlInsertCommand1
			// 
			this.sqlInsertCommand1.CommandText = @"INSERT INTO Staff(staffid, branch, branchid, staffname, gender, staffkind, salary, staffphone) VALUES (@staffid, @branch, @branchid, @staffname, @gender, @staffkind, @salary, @staffphone); SELECT staffid, branch, branchid, staffname, gender, staffkind, salary, staffphone FROM Staff WHERE (staffid = @staffid)";
			this.sqlInsertCommand1.Connection = this.sqlConnection_Staff;
			this.sqlInsertCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@staffid", System.Data.SqlDbType.Int, 4, "staffid"));
			this.sqlInsertCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@branch", System.Data.SqlDbType.VarChar, 10, "branch"));
			this.sqlInsertCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@branchid", System.Data.SqlDbType.Int, 4, "branchid"));
			this.sqlInsertCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@staffname", System.Data.SqlDbType.VarChar, 50, "staffname"));
			this.sqlInsertCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@gender", System.Data.SqlDbType.VarChar, 2, "gender"));
			this.sqlInsertCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@staffkind", System.Data.SqlDbType.VarChar, 50, "staffkind"));
			this.sqlInsertCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@salary", System.Data.SqlDbType.VarChar, 10, "salary"));
			this.sqlInsertCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@staffphone", System.Data.SqlDbType.VarChar, 50, "staffphone"));
			// 
			// sqlUpdateCommand1
			// 
			this.sqlUpdateCommand1.CommandText = @"UPDATE Staff SET staffid = @staffid, branch = @branch, branchid = @branchid, staffname = @staffname, gender = @gender, staffkind = @staffkind, salary = @salary, staffphone = @staffphone WHERE (staffid = @Original_staffid) AND (branch = @Original_branch) AND (branchid = @Original_branchid) AND (gender = @Original_gender) AND (salary = @Original_salary OR @Original_salary IS NULL AND salary IS NULL) AND (staffkind = @Original_staffkind) AND (staffname = @Original_staffname OR @Original_staffname IS NULL AND staffname IS NULL) AND (staffphone = @Original_staffphone OR @Original_staffphone IS NULL AND staffphone IS NULL); SELECT staffid, branch, branchid, staffname, gender, staffkind, salary, staffphone FROM Staff WHERE (staffid = @staffid)";
			this.sqlUpdateCommand1.Connection = this.sqlConnection_Staff;
			this.sqlUpdateCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@staffid", System.Data.SqlDbType.Int, 4, "staffid"));
			this.sqlUpdateCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@branch", System.Data.SqlDbType.VarChar, 10, "branch"));
			this.sqlUpdateCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@branchid", System.Data.SqlDbType.Int, 4, "branchid"));
			this.sqlUpdateCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@staffname", System.Data.SqlDbType.VarChar, 50, "staffname"));
			this.sqlUpdateCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@gender", System.Data.SqlDbType.VarChar, 2, "gender"));
			this.sqlUpdateCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@staffkind", System.Data.SqlDbType.VarChar, 50, "staffkind"));
			this.sqlUpdateCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@salary", System.Data.SqlDbType.VarChar, 10, "salary"));
			this.sqlUpdateCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@staffphone", System.Data.SqlDbType.VarChar, 50, "staffphone"));
			this.sqlUpdateCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_staffid", System.Data.SqlDbType.Int, 4, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "staffid", System.Data.DataRowVersion.Original, null));
			this.sqlUpdateCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_branch", System.Data.SqlDbType.VarChar, 10, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "branch", System.Data.DataRowVersion.Original, null));
			this.sqlUpdateCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_branchid", System.Data.SqlDbType.Int, 4, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "branchid", System.Data.DataRowVersion.Original, null));
			this.sqlUpdateCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_gender", System.Data.SqlDbType.VarChar, 2, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "gender", System.Data.DataRowVersion.Original, null));
			this.sqlUpdateCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_salary", System.Data.SqlDbType.VarChar, 10, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "salary", System.Data.DataRowVersion.Original, null));
			this.sqlUpdateCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_staffkind", System.Data.SqlDbType.VarChar, 50, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "staffkind", System.Data.DataRowVersion.Original, null));
			this.sqlUpdateCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_staffname", System.Data.SqlDbType.VarChar, 50, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "staffname", System.Data.DataRowVersion.Original, null));
			this.sqlUpdateCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_staffphone", System.Data.SqlDbType.VarChar, 50, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "staffphone", System.Data.DataRowVersion.Original, null));
			// 
			// sqlDeleteCommand1
			// 
			this.sqlDeleteCommand1.CommandText = @"DELETE FROM Staff WHERE (staffid = @Original_staffid) AND (branch = @Original_branch) AND (branchid = @Original_branchid) AND (gender = @Original_gender) AND (salary = @Original_salary OR @Original_salary IS NULL AND salary IS NULL) AND (staffkind = @Original_staffkind) AND (staffname = @Original_staffname OR @Original_staffname IS NULL AND staffname IS NULL) AND (staffphone = @Original_staffphone OR @Original_staffphone IS NULL AND staffphone IS NULL)";
			this.sqlDeleteCommand1.Connection = this.sqlConnection_Staff;
			this.sqlDeleteCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_staffid", System.Data.SqlDbType.Int, 4, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "staffid", System.Data.DataRowVersion.Original, null));
			this.sqlDeleteCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_branch", System.Data.SqlDbType.VarChar, 10, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "branch", System.Data.DataRowVersion.Original, null));
			this.sqlDeleteCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_branchid", System.Data.SqlDbType.Int, 4, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "branchid", System.Data.DataRowVersion.Original, null));
			this.sqlDeleteCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_gender", System.Data.SqlDbType.VarChar, 2, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "gender", System.Data.DataRowVersion.Original, null));
			this.sqlDeleteCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_salary", System.Data.SqlDbType.VarChar, 10, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "salary", System.Data.DataRowVersion.Original, null));
			this.sqlDeleteCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_staffkind", System.Data.SqlDbType.VarChar, 50, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "staffkind", System.Data.DataRowVersion.Original, null));
			this.sqlDeleteCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_staffname", System.Data.SqlDbType.VarChar, 50, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "staffname", System.Data.DataRowVersion.Original, null));
			this.sqlDeleteCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Original_staffphone", System.Data.SqlDbType.VarChar, 50, System.Data.ParameterDirection.Input, false, ((System.Byte)(0)), ((System.Byte)(0)), "staffphone", System.Data.DataRowVersion.Original, null));
			// 
			// DeleteEmployee
			// 
			this.AutoScaleBaseSize = new System.Drawing.Size(6, 14);
			this.BackgroundImage = ((System.Drawing.Image)(resources.GetObject("$this.BackgroundImage")));
			this.ClientSize = new System.Drawing.Size(336, 270);
			this.Controls.Add(this.btExit);
			this.Controls.Add(this.btDelete);
			this.Controls.Add(this.tbID);
			this.Controls.Add(this.label1);
			this.ForeColor = System.Drawing.Color.Magenta;
			this.Icon = ((System.Drawing.Icon)(resources.GetObject("$this.Icon")));
			this.Name = "DeleteEmployee";
			this.Text = "删除员工_总部";
			this.Load += new System.EventHandler(this.DeleteEmployee_Load);
			((System.ComponentModel.ISupportInitialize)(this.dataSet_Staff)).EndInit();
			this.ResumeLayout(false);

		}
		#endregion

		private void btExit_Click(object sender, System.EventArgs e)
		{
			this.Close();
		}

		private void btDelete_Click(object sender, System.EventArgs e)
		{
			String id=tbID.Text.ToString().Trim();
			if(id.Length==0)
			{
				MessageBox.Show("员工ID不能为空!");
				return;
			}
			sqlDataAdapter_Staff.SelectCommand.CommandText=
				"select * from Staff ";
			sqlDataAdapter_Staff.Fill(dataSet_Staff);
			DataTable Staff=dataSet_Staff.Tables[0];
			DataRow item;
			int i;
			for(i=0;i<Staff.Rows.Count;i++)
			{
				item=Staff.Rows[i];
				string branchid=(string)item["branch"];
				if(item["staffid"].ToString().Trim().Equals(id))
				{
					
					sqlDataAdapter_Branch.SelectCommand.CommandText="select * from Branch where branchid= '"+branchid+"'";
					DataSet dataset_branch=new DataSet();
					sqlDataAdapter_Branch.Fill(dataset_branch);
					DataRow row=dataset_branch.Tables[0].Rows[0];
					string ip=(string)row["ip"];

					//本地删除
					item.Delete();
					sqlDataAdapter_Staff.Update(Staff);
					if(branchid.Trim().Equals("0"))
						return;
					//远程调用	
					try
					{
						int k=int.Parse(branchid);
						k += 8084;				

						Change obj = (Change)Activator.GetObject(typeof(Change), "tcp://"+ ip.Trim() +":"+ k.ToString() +"/remotingChange");
						if(branchid.Trim().Equals("1"))
							obj.SetSQL("7B1EE60547FB453","branchlww");
						else
							obj.SetSQL("7B1EE60547FB453","branchyf");
						obj.DeleteEmployee((int)item["branchid"]);
					}
					catch(Exception ex)
					{
						MessageBox.Show(ex.ToString());
					}

					MessageBox.Show("删除成功");
					return;					//MessageBox.Show(ip+branchid);
				}
			}
			if(i==Staff.Rows.Count)
				MessageBox.Show("该员工不存在");
			tbID.Text="";
			
		}

		private void DeleteEmployee_Load(object sender, System.EventArgs e)
		{
//			//注册通道
//			IDictionary properties = new Hashtable();
//			properties["name"] = "centerDeleteEmployee";
//			//properties["name"] = "tcp1";
//			properties["port"] = "8002";
//			properties["priority"] = "20";
//			//MessageBox.Show("tcp"+branch.Trim());
//
//			BinaryClientFormatterSinkProvider provider = new BinaryClientFormatterSinkProvider();
//								
//			TcpClientChannel chan = new TcpClientChannel(properties,provider);
//			ChannelServices.RegisterChannel(chan);
		}

	}
}