2013-06-23 181 views
0

所有这些代码工作现在,我有这样的代码:我怎样才能让下BackgroundWorker的

private void button1_Click(object sender, EventArgs e) 
{ 
    OpenFileDialog openFileDialog1 = new OpenFileDialog(); 

    var dialogResult = openFileDialog1.ShowDialog(); 
    string sWybranyPlik; 
    if (dialogResult == DialogResult.OK) 
    { 
     sWybranyPlik = openFileDialog1.FileName; 

     try 
     { 


     System.Data.OleDb.OleDbConnection ExcelConnection = new System.Data.OleDb.OleDbConnection("provider=Microsoft.ACE.OLEDB.12.0;Data Source='" + sWybranyPlik + "';Extended Properties=Excel 8.0;"); 

     System.Data.OleDb.OleDbDataAdapter OleDBAdapter = new System.Data.OleDb.OleDbDataAdapter("select * from [Tabelle1$]", ExcelConnection); 

     DtSet.Clear(); 


     //wypełnianie datagridview 
     OleDBAdapter.Fill(DtSet.Tables[0]); 
     dataGridView1.DataSource = DtSet.Tables[0]; 


     //kasowanie starych danych w bazie danych 
     string deletesql = @"DELETE FROM TabelaProdukty"; 
     System.Data.SqlServerCe.SqlCeCommand comDelete = new System.Data.SqlServerCe.SqlCeCommand(deletesql, sqlconnection); 
     sqlconnection.Open(); 
     comDelete.ExecuteNonQuery(); 
     sqlconnection.Close(); 


     backgroundWorker1.RunWorkerAsync(); 
     progressform.ShowDialog(); 



     ExcelConnection.Close(); 
     } 

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

而且在_DoWork:

private void backgroundWorker1_DoWork(object sender, DoWorkEventArgs e) 
{ 

    //wprowadzanie nowych danych z datagridview do bazy danych 
    string strQuery = @"INSERT INTO TabelaProdukty VALUES (@VD, @ItemCode, @Item, @Qty, @Ppcur, @StandardPrice, @CeMarked, @Description, @Description2, @Edma)"; 
    sqlconnection.Open(); 
    using (System.Data.SqlServerCe.SqlCeCommand comm = new System.Data.SqlServerCe.SqlCeCommand(strQuery, sqlconnection)) 
    { 
    comm.Parameters.Add("@VD", SqlDbType.NVarChar); 
    comm.Parameters.Add("@ItemCode", SqlDbType.NVarChar); 
    comm.Parameters.Add("@Item", SqlDbType.NVarChar); 
    comm.Parameters.Add("@Qty", SqlDbType.NVarChar); 
    comm.Parameters.Add("@Ppcur", SqlDbType.NVarChar); 
    comm.Parameters.Add("@StandardPrice", SqlDbType.NVarChar); 
    comm.Parameters.Add("@CeMarked", SqlDbType.NVarChar); 
    comm.Parameters.Add("@Description", SqlDbType.NVarChar); 
    comm.Parameters.Add("@Description2", SqlDbType.NVarChar); 
    comm.Parameters.Add("@Edma", SqlDbType.NVarChar); 

    for (int i = 0; i < dataGridView1.Rows.Count; i++) 
    { 

     comm.Parameters["@VD"].Value = dataGridView1.Rows[i].Cells["VD"].Value.ToString().Trim(); 
     comm.Parameters["@ItemCode"].Value = dataGridView1.Rows[i].Cells["ItemCode"].Value.ToString().Trim(); 
     comm.Parameters["@Item"].Value = dataGridView1.Rows[i].Cells["ITEM"].Value.ToString().Trim(); 
     comm.Parameters["@Qty"].Value = dataGridView1.Rows[i].Cells["QUANTITY"].Value.ToString().Trim(); 
     comm.Parameters["@Ppcur"].Value = dataGridView1.Rows[i].Cells["PPCUR"].Value.ToString().Trim(); 
     comm.Parameters["@StandardPrice"].Value = dataGridView1.Rows[i].Cells["STANDARD_SELL_PRICE"].Value.ToString().Trim(); 
     comm.Parameters["@CeMarked"].Value = dataGridView1.Rows[i].Cells["CE-MARKED"].Value.ToString().Trim(); 
     comm.Parameters["@Description"].Value = dataGridView1.Rows[i].Cells["ITEM_DESCRIPTION"].Value.ToString().Trim(); 
     comm.Parameters["@Description2"].Value = dataGridView1.Rows[i].Cells["ITEM_DESCRIPTION2"].Value.ToString().Trim(); 
     comm.Parameters["@Edma"].Value = dataGridView1.Rows[i].Cells["EDMA"].Value.ToString().Trim(); 


     comm.ExecuteNonQuery(); 

     backgroundWorker1.ReportProgress(i); 

     if (backgroundWorker1.CancellationPending) 
     { 
     e.Cancel = true; 
     break; 
     } 

    } 
    sqlconnection.Close(); 


    } 
} 

正如你可以看到这个代码让我挑一个excel文件使用OpenFileDialog清除DataSet,使用数据填充数据集和datagridview,清除SQL表nad,然后打开一个表单,其中进度条显示将数据从datagridview复制到sql数据库的一个长进程(12行中大约150000行。 At这点它工作正常。我遇到的问题是在打开progressform之前的所有内容都需要花费时间,所以我想把它全部放在backgroundworker下,并在progressform中显示状态报告,例如“旧数据已删除”或表“正在载入新数据”,然后运行dgv-> sql部分。不幸的是,通过在_DoWork下放置这些代码,我得到了不同的错误,具体取决于我在那里复制了多少代码(button1_Click的全部或仅“尝试”部分)。

你有什么想法应该看起来如何?

最好的问候,

编辑:

其他方法:

private void backgroundWorker1_ProgressChanged(object sender, ProgressChangedEventArgs e) 
{ 

    progressform.progressBar1.Value = e.ProgressPercentage; 
} 

private void backgroundWorker1_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e) 
{ 
    if (e.Cancelled) 
    { 
    MessageBox.Show("Operacja przerwana! Cennik nie został wprowadzony w całości", "Uwaga!", MessageBoxButtons.OK, MessageBoxIcon.Warning); 


    } 
    else 
    { 

    progressform.label1.Text = "Zakończono pomyślnie! :)"; 
    progressform.button1.Enabled = true; 
    } 
} 

回答

1

您需要使用reportProgress事件的BackgroundWorker的。

将文件名从openfiledialog保存为实例级别的字符串,即在方法外部。现在将代码填入dataset完全在backgroundworker.dowork事件处理程序中。填入后dataset致电backgroundworker.ReportProgress。这将触发backgroundworker.ProgressChanged事件。在此方法中填充datagridview,因为此方法将在实例化backgroundworker的线程上调用。现在用dowork方法发送其余的ADO连接代码。这应该够了。

**EDIT** 

class YourClass 
    { 
     string filePath; 
     DataSet dataset; 
     private static void Do_Work(object sender, DoWorkEventArgs e) 
     { 
      //populate dataset 
      //call worker.ReportProgress to trigger worker.ProgressChanged 
      //rest of time consuming ADO.Net Codes and other codes you wrote in your DoWork method 
     } 

     private static void Progress_Changed(object sender, ProgressChangedEventArgs e) 
     { 
      //this method is invoked in the thread where background worker is instantiated. 
      //do all UI stuff here like populating datagridview from dataset 
     } 
    } 
+0

谢谢,我试图得到这(这是不容易的,因为我只是用c#stariting)。无论如何,你应该把填充数据集的代码放在reportprogress下。这个事件在加载到sql期间已经被调用以使进度条工作。我应该怎么做才能知道reportchanged事件是否应该执行数据集或sql部分?一些如果方法?或者,也许我不明白你...(可能是这个;)) –

+0

你包括progresschanged方法吗? – Androidz

+0

编辑答案。看看它是否清楚。 –