dataform1.cs

从数据库导入文件到EXCEL 从EXCEL导入到数据库表 速度快

				a1.Fill (dataset,"t1");
				dataGrid1.DataSource =dataset.Tables ["t1"];
				a1.Dispose ();
			}
			catch(Exception ex)
			{
				MessageBox.Show(ex.Message,"错误");
			}

		}



		private void oleDbConnection1_InfoMessage(object sender, System.Data.OleDb.OleDbInfoMessageEventArgs e)
		{
		
		}

		private void button1_Click(object sender, System.EventArgs e)
		{
			try
			{
				Form2 frm=new Form2();
				frm.Show();

	
			}
			catch(Exception ex)
			{
				MessageBox.Show(ex.Message);
			}
		}
		private void button2_Click(object sender, System.EventArgs e)
		{
			try
			{

		               
					if(MessageBox.Show("导入之前请确认你需要导入的服务器设置，并确认你需要导入的数据同你选择的表有相同的数据结构！","安全警报",MessageBoxButtons.OKCancel,MessageBoxIcon.Question)==DialogResult.OK)
						if (openFileDialog1.ShowDialog()==DialogResult.OK)
						{
							string fileName=openFileDialog1.FileName;
							inputbox input=new inputbox();
							input.Show();
	
					
								SqlConnection conn=new SqlConnection();
							conn.ConnectionString="data source="+textBox1.Text+";initial catalog="+comboBox2.Text+";password="+textBox3.Text+" ;user id="+textBox2.Text+"";
							SqlDataReader reader=null;
							//conn=GetConnection();
							conn.Open();
							string str1="EXEC master..xp_cmdshell 'bcp "+comboBox2.Text+".."+comboBox1.Text+" in "+fileName+" -c -Usa -P'";
							MessageBox.Show(input.ss);
							if (comboBox1.Text=="")
							{
								MessageBox.Show("对不起！数据表名不能为空，请选择需要导入的数据表名");
					

							}
					
							else 
							{
								SqlCommand comm=new SqlCommand();
								comm.Connection=conn;
								comm.CommandText=str1;
								reader=comm.ExecuteReader();
								MessageBox.Show("导入成功！");
								conn.Close();
								label1.Text="你导入的数据库表名为"+comboBox1.Text+"！";
							}

						}
			
			}
			catch(Exception ex)
			{
				MessageBox.Show(ex.Message);
			}
		
		}

		private void button3_Click(object sender, System.EventArgs e)
		{
			
			try
			{
				if (saveFileDialog2.ShowDialog()==DialogResult.OK)
				{
					string fileName=saveFileDialog2.FileName;
					Stream stream=File.OpenWrite(fileName);
					//FileStream  fs=new FileStream(fileName,FileMode.Open,FileAccess.Read);
					//StreamReader read=new StreamReader(fs);
					//  textBox1.Text=read;
					stream.Close();
					
					SqlConnection conn=new SqlConnection();
					conn.ConnectionString="data source="+textBox1.Text+";initial catalog="+comboBox2.Text+";password="+textBox3.Text+" ;user id="+textBox2.Text+"";
					SqlDataReader reader=null;
					//conn=GetConnection();
					conn.Open();
					string str1="select *  from "+comboBox2.Text+".."+comboBox1.Text+"";
					string str="EXEC master..xp_cmdshell 'bcp \""+str1+"\" queryout "+fileName+" -c -U"+textBox2.Text+" -P"+textBox3.Text+"'";
					SqlCommand comm=new SqlCommand();
					comm.Connection=conn;
					comm.CommandText=str;
					//dataGrid1.DataSource=Dataset.
					reader=comm.ExecuteReader();
					MessageBox.Show("数据库表"+comboBox1.Text+"已经成功导入到"+fileName+"中！");
					label1.Text="数据已经保存到"+fileName+"中！";
					conn.Close();
			stream.Close();
	
				}
					

			}
			catch(Exception ex)
			{
				MessageBox.Show(ex.Message);
			}
		}

		private void grdzSYSSequence_Navigate(object sender, System.Windows.Forms.NavigateEventArgs ne)
		{
		
		}

		private void DataForm1_Load(object sender, System.EventArgs e)
		{ 
			
			try{
				//"data source='.';initial catalog=tianwei;password='';user id=sa ;";

				//string connstr1;

				//string connstr1="data source="+frm.str1+";initial catalog="+frm.str2+";password='';user id=sa ;";
			
				SqlConnection conn=new SqlConnection();
				conn.ConnectionString="data source=192.168.19.60;initial catalog=master;password='';user id=sa";
				SqlDataReader reader=null;
				conn.Open ();
				string str2="select * from master..sysdatabases";
				//select * from [master].dbo.[sysservers]
				//[master].dbo.
				SqlCommand comm=new SqlCommand(str2,conn);			
				comm.Connection=conn;
				comm.CommandText=str2;
				reader=comm.ExecuteReader();
			
				while(reader.Read())
				{
					this.comboBox2.Items.Add(reader.GetString(0));
				}

				reader.Close();
				conn.Close();
			
		//catch(Exception ex)
			//	{
			//	MessageBox.Show(ex.Message);
			//}
	

	//SqlConnection conn=new SqlConnection();
			
		//string connstr1="data source="+frm.str1+";initial catalog="+frm.str2+";password='';user id=sa ;";
		//SqlConnection conn=new SqlConnection();
		conn.ConnectionString="data source=192.168.19.60;initial catalog=master;password='';user id=sa; ";
	

		//	label1.Text=connstr1;
		//	SqlDataReader reader=null;
		conn.Open();
		label1.Text=connstr1;
		string str3="select * from sysobjects  where xtype='u' order by name ";
	//	SqlCommand comm=new SqlCommand(str3,conn);	
	//SqlDataReader reader=null;	
		comm.Connection=conn;
		comm.CommandText=str3;
		reader=comm.ExecuteReader();
		
	
			while(reader.Read())
	{
		this.comboBox1.Items.Add(reader.GetString(0));
		
	}
	reader.Close();
	conn.Close();
}
catch(Exception ex)
{
MessageBox.Show(ex.Message);
}
			
}

	
		private void dataGrid1_Navigate(object sender, System.Windows.Forms.NavigateEventArgs ne)
		{
		
		}

		private void button4_Click(object sender, System.EventArgs e)
		{
			LoadDataSet();
		}

		private void comboBox1_SelectedIndexChanged(object sender, System.EventArgs e)
		{
		
		}

		private void richTextBox1_TextChanged(object sender, System.EventArgs e)
		{
			
	}

		private void button2_Click_1(object sender, System.EventArgs e)
		{
			try
			{
				//dataconn dc=new dataconn(); 
				string connstr1="data source="+textBox1.Text+";initial catalog="+comboBox2.Text+";password="+textBox3.Text+" ;user id="+textBox2.Text+"";
				SqlConnection conn=new SqlConnection(connstr1);
			
				conn.Open ();
				string str2=richTextBox1.Text;
				SqlCommand comm=new SqlCommand(str2,conn);			
				comm.Connection=conn;
				comm.CommandText=str2;
				DataSet dataset=new DataSet ();
				//string sql1="select * from tabtfd where 姓名='"+this.tb .Text +"'";
				SqlDataAdapter a1=new SqlDataAdapter (str2,conn);
		
				a1.Fill (dataset,"t1");
				dataGrid1.DataSource =dataset.Tables ["t1"];
					MessageBox.Show("操作执行成功！");
				a1.Dispose ();
			
			
				conn.Close();
			
			}
			catch(Exception ex)
			{
				MessageBox.Show(ex.Message,"错误");
			}
			
		}

		private void button3_Click_1(object sender, System.EventArgs e)
		{
			if(MessageBox.Show("真的要退出吗？","注意",MessageBoxButtons.OKCancel,MessageBoxIcon.Question)==DialogResult.OK)
			this.Close ();
		}

		private void label1_Click(object sender, System.EventArgs e)
		{
		
		}

		private void comboBox2_SelectedIndexChanged(object sender, System.EventArgs e)
		{
		
		}

		private void button4_Click_1(object sender, System.EventArgs e)

		{
			try

			{
			
				//"data source='.';initial catalog=tianwei;password='';user id=sa ;";

				//string connstr1;

				//string connstr1="data source="+frm.str1+";initial catalog="+frm.str2+";password='';user id=sa ;";
				SqlConnection conn=new SqlConnection();
				conn.ConnectionString="data source="+textBox1.Text+";initial catalog="+comboBox2.Text+";password="+textBox3.Text+" ;user id="+textBox2.Text+"";
				label1.Text=connstr1;
				SqlDataReader reader=null;
				conn.Open ();
				label1.Text=connstr1;
				label1.Text="如果不输入数据！则默认连接为[.].[master]数据库账号SA，密码为空！";
				string str2;
				str2="select * from sysobjects  where xtype='u' order by name";
				SqlCommand comm=new SqlCommand(str2,conn);			
				//comm.Connection=conn;
				//comm.CommandText=str2;
				reader=comm.ExecuteReader();
			    comboBox1.Items.Clear();
				while(reader.Read())
				{
					this.comboBox1.Items.Add(reader.GetString(0));
		
				

				}
				MessageBox.Show("连接成功！");
				reader.Close();
				conn.Close();
			}
			catch(Exception ex)
			{
				MessageBox.Show(ex.Message,"连接失败");
			}

		}

		private void comboBox2_DataSourceChanged(object sender, System.EventArgs e)
		{
			try

			{
			
				//"data source='.';initial catalog=tianwei;password='';user id=sa ;";

				//string connstr1;

				//string connstr1="data source="+frm.str1+";initial catalog="+frm.str2+";password='';user id=sa ;";
				SqlConnection conn=new SqlConnection();
				conn.ConnectionString="data source="+textBox1.Text+";initial catalog="+comboBox2.Text+";password="+textBox3.Text+" ;user id="+textBox2.Text+"";
				label1.Text=connstr1;
				SqlDataReader reader=null;
				conn.Open ();
				label1.Text=connstr1;
				label1.Text="如果不输入数据！则默认连接为[.].[master]数据库账号SA，密码为空！";
				string str2;
				str2="select * from sysobjects  where xtype='u' order by name";
				SqlCommand comm=new SqlCommand(str2,conn);			
				//comm.Connection=conn;
				//comm.CommandText=str2;
				reader=comm.ExecuteReader();
				comboBox1.Items.Clear();
				while(reader.Read())
				{
					this.comboBox1.Items.Add(reader.GetString(0));
		
				

				}
				MessageBox.Show("连接成功！");
				reader.Close();
				conn.Close();
			}
			catch(Exception ex)
			{
				MessageBox.Show(ex.Message,"连接失败");
			}

		}

		private void comboBox2_TextChanged(object sender, System.EventArgs e)
		{
			try

			{
			
				//"data source='.';initial catalog=tianwei;password='';user id=sa ;";

				//string connstr1;

				//string connstr1="data source="+frm.str1+";initial catalog="+frm.str2+";password='';user id=sa ;";
				SqlConnection conn=new SqlConnection();
				conn.ConnectionString="data source="+textBox1.Text+";initial catalog="+comboBox2.Text+";password="+textBox3.Text+" ;user id="+textBox2.Text+"";
				label1.Text=connstr1;
				SqlDataReader reader=null;
				conn.Open ();
				label1.Text=connstr1;
				label1.Text="如果不输入数据！则默认连接为[.].[master]数据库账号SA，密码为空！";
				string str2;
				str2="select * from sysobjects  where xtype='u' order by name";
				SqlCommand comm=new SqlCommand(str2,conn);			
				//comm.Connection=conn;
				//comm.CommandText=str2;
				reader=comm.ExecuteReader();
				comboBox1.Items.Clear();
				while(reader.Read())
				{
					this.comboBox1.Items.Add(reader.GetString(0));
		
				

				}
				MessageBox.Show("连接成功！");
				reader.Close();
				conn.Close();
			}
			catch(Exception ex)
			{
				MessageBox.Show(ex.Message,"连接失败");
			}

		}
		}
}