centeremployee.cs

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

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


namespace RemotingClass
{
	/// <summary>
	/// CenterEmployee 的摘要说明。
	/// </summary>
	public class CenterEmployee
	{
		public CenterEmployee()
		{
		{
			string connectString="workstation id=7B1EE60547FB453;packet size=4096;integrated security=SSPI;initial catalog=Center;persist security info=False";
			mySqlConnection=new SqlConnection(connectString);

		}
		}
		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 SqlConnection SetSQL(string sqlid,string tableid)
		{
			string connectString="workstation id="+sqlid+";packet size=4096;integrated security=SSPI;initial catalog="+tableid+";persist security info=False";
			return mySqlConnection=new SqlConnection(connectString);
			
		}
		
		public void NewEmpolyee(int id,string branchid,string staffname,string gender,string staffkind,string salary,string staffphone)
		{
//			mySqlConnection.Open();
			
			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();
			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);

//			mySqlConnection.Close();

			
			//增加SystemUser表中员工信息
			//			SqlDataAdapter sqlDataAdapter_SysUser=new SqlDataAdapter("select * from SystemUser",mySqlConnection);
			//			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(string id)
		{
			SqlDataAdapter sqlDataAdapter_Staff=new SqlDataAdapter("select * from Staff ",mySqlConnection);
			DataSet dataSet_Delete=new DataSet();
//			mySqlConnection.Open();
			
			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))
				{
					t.Rows[i].Delete();

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

					sqlDataAdapter_Staff.Update(t);
					return;
				}
			}

//			mySqlConnection.Close();

		}

		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);

			//mySqlConnection.Close();

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