change.cs

分布式数据库系统的分系统

using System;
using System.Data;
using System.Data.SqlClient;
using System.Windows.Forms;

namespace RemotingClass
{
	/// <summary>
	/// New 的摘要说明。
	/// </summary>
	public class Change: MarshalByRefObject
	{
		public SqlConnection mySqlConnection;

		public Change()
		{
//			string connectString="workstation id=7B1EE60547FB453;packet size=4096;integrated security=SSPI;initial catalog=branchyf;persist security info=False";
//			mySqlConnection=new SqlConnection(connectString);
			//
			// TODO: 在此处添加构造函数逻辑
			//
		}
		public Change(string sqlid,string tableid)
		{
//		    string connectString="workstation id="+sqlid+";packet size=4096;integrated security=SSPI;initial catalog="+tableid+";persist security info=False";
//			mySqlConnection=new SqlConnection(connectString);
		}

		public void SetSQL(string sqlid,string tableid)
		{
			string connectString="workstation id="+sqlid+";packet size=4096;integrated security=SSPI;initial catalog="+tableid+";persist security info=False";
			mySqlConnection=new SqlConnection(connectString);
			//MessageBox.Show("SetSql()!");
			return;
			
		}
		
		public void NewEmpolyee(int id,string branchid,string staffname,string gender,string staffkind,string salary,string staffphone)
		{
			DataSet dataSet_Staff=new DataSet(),dataSet_SysUser=new DataSet();	
			SqlDataAdapter sqlDataAdapter_Staff=new SqlDataAdapter("select * from Staff ",mySqlConnection);
			 SqlCommandBuilder   cb   =   new   SqlCommandBuilder(sqlDataAdapter_Staff); 
			sqlDataAdapter_Staff.Fill(dataSet_Staff);
			DataTable Staff=dataSet_Staff.Tables[0];
			//int k=int.Parse(Staff.Rows[Staff.Rows.Count-1]["staffid"].ToString());
			//k++;
			//string id=k.ToString().Trim();
			DataRow newRow=Staff.NewRow();
			newRow[0]=id;
			newRow[1]=staffname;
			newRow[2]=gender;
			newRow[3]=staffkind;
			newRow[4]=0.0;	
			newRow[5]=staffphone;
			newRow[6]=branchid;
			Staff.Rows.Add(newRow);

			//文嘉改错：command
			SqlCommandBuilder command = new SqlCommandBuilder();
			command.DataAdapter = sqlDataAdapter_Staff;
			command.GetInsertCommand();
				
			sqlDataAdapter_Staff.Update(Staff);
			
			//增加SystemUser表中员工信息
			SqlDataAdapter sqlDataAdapter_SysUser=new SqlDataAdapter("select * from SystemUser",mySqlConnection);
			 SqlCommandBuilder   nb   =   new   SqlCommandBuilder(sqlDataAdapter_SysUser);
			sqlDataAdapter_SysUser.Fill(dataSet_SysUser);
			DataTable User=dataSet_SysUser.Tables[0];
			newRow=User.NewRow();
			newRow[0]=id;
			newRow[1]="111111";
			newRow[2]=staffkind;
			User.Rows.Add(newRow);
			User.EndInit();
			sqlDataAdapter_SysUser.Update(User);	
		}

		public void NewEmpolyee_2(int id,string branchid,string staffname,string gender,string staffkind,string salary,string staffphone)
		{
			MessageBox.Show(id.ToString()+branchid+staffname+gender+staffkind+salary+staffphone);
			DataSet dataSet_Staff=new DataSet();
			DataSet dataSet_SysUser=new DataSet();	
			SqlDataAdapter sqlDataAdapter_Staff=new SqlDataAdapter("select * from Staff ",mySqlConnection);
			sqlDataAdapter_Staff.Fill(dataSet_Staff);
		    SqlCommandBuilder   cb   =   new   SqlCommandBuilder(sqlDataAdapter_Staff);  
			
			DataTable Staff=dataSet_Staff.Tables[0];
			DataRow newRow=Staff.NewRow();
			newRow[0]=(int)Staff.Rows[Staff.Rows.Count-1][0]+1;
			newRow[1]=branchid;
			newRow[2]=id;
			newRow[3]=staffname;
			newRow[4]=gender;	
			newRow[5]=staffkind;
			newRow[6]="";
			newRow[7]=staffphone;
			Staff.Rows.Add(newRow);

			//文嘉改错：command
			SqlCommandBuilder command = new SqlCommandBuilder();
			command.DataAdapter = sqlDataAdapter_Staff;
			command.GetInsertCommand();
				
			sqlDataAdapter_Staff.Update(Staff);
			
			//增加SystemUser表中员工信息
			SqlDataAdapter sqlDataAdapter_SysUser=new SqlDataAdapter("select * from SystemUser",mySqlConnection);
			 SqlCommandBuilder   nb   =   new   SqlCommandBuilder(sqlDataAdapter_SysUser);
			sqlDataAdapter_SysUser.Fill(dataSet_SysUser);
			DataTable User=dataSet_SysUser.Tables[0];
			newRow=User.NewRow();
			newRow[0]=id;
			newRow[1]="111111";
			newRow[2]=staffkind;
			User.Rows.Add(newRow);
			User.EndInit();
			sqlDataAdapter_SysUser.Update(User);	
		}

		public void DeleteEmployee(int id)
		{
			SqlDataAdapter sqlDataAdapter_Staff=new SqlDataAdapter("select * from Staff ",mySqlConnection);
			DataSet dataSet_Delete=new DataSet();
			
			sqlDataAdapter_Staff.Fill(dataSet_Delete);
			DataTable t=dataSet_Delete.Tables[0];
			DataRow item;
			int i;
			for(i=0;i<t.Rows.Count;i++)
			{
				item=t.Rows[i];
				if(item[0].ToString().Trim().Equals(id.ToString()))
				{
					t.Rows[i].Delete();

					//文嘉改错：command
					SqlCommandBuilder command = new SqlCommandBuilder();
					command.DataAdapter = sqlDataAdapter_Staff;
					command.GetDeleteCommand();

					sqlDataAdapter_Staff.Update(t);

					//雯雯：删除SystemUser表中员工信息


					return;
				}
			}
		}

		public string GetNewID()
		{
			DataSet dataSet_Staff=new DataSet(),dataSet_SysUser=new DataSet();				

			SqlDataAdapter sqlDataAdapter_Staff=new SqlDataAdapter("select * from Staff ",mySqlConnection);
			sqlDataAdapter_Staff.Fill(dataSet_Staff);

			DataTable Staff=dataSet_Staff.Tables[0];
			int k=int.Parse(Staff.Rows[Staff.Rows.Count-1]["staffid"].ToString());
			k++;

			string id=k.ToString().Trim();
			return id;
		}
	}
}