SqlBulkCopy类 基本使用方法

private void button1_Click(object sender, EventArgs e)
{
try
{
string DatabaseOne = "Data Source = DATABASE-VPC\\SQL2005; User ID = sa; password = admin; Initial Catalog = AdventureWorks; Pooling=true";
string DatabaseTwo = "Data Source = DATABASE-VPC\\SQL2005; User ID = sa; password = admin; Initial Catalog = Jiang; Pooling=true";
SqlConnection Conn = new SqlConnection(DatabaseOne);
SqlCommand cmd = new SqlCommand();
cmd.Connection = Conn;
cmd.CommandType = CommandType.Text;
cmd.CommandText = "select * from TableCopyTest";
Conn.Open();
DataSet ds = new DataSet();
SqlDataAdapter per = new SqlDataAdapter(cmd);
per.Fill(ds, "One");
cmd.ExecuteNonQuery();
SqlBulkCopy copytable = new SqlBulkCopy(DatabaseTwo, SqlBulkCopyOptions.UseInternalTransaction);
copytable.BulkCopyTimeout = 500000;
copytable.SqlRowsCopied += new SqlRowsCopiedEventHandler(copytable_SqlRowsCopied);
copytable.NotifyAfter = ds.Tables[0].Rows.Count;

copytable.DestinationTableName = "TableCopyTwo";
copytable.ColumnMappings.Add("uid", "pass");///互换对应列
copytable.WriteToServer(ds.Tables[0]);
}
catch (Exception ex) { MessageBox.Show(ex.Message); }
}

void copytable_SqlRowsCopied(object sender, SqlRowsCopiedEventArgs e)
{
this.label1.Text = "完成！ 共：" + e.RowsCopied.ToString();
}