0

现在我有这个代码：

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


  }
}

正如你所看到的，这段代码让我用 OpenFileDialog 选择一个 excel 文件，清除 DataSet，用数据填充数据集和 datagridview，清除 SQL 表，然后打开一个带有进度条的表单，显示将数据从 datagridview 复制到的漫长过程sql 数据库（大约 12 列中的 150000 行。此时它工作正常。我遇到的问题是打开进度表之前的所有内容也需要时间，所以我想把它全部放在后台工作人员和进度表中显示状态报告，如“旧数据被删除”或表“加载新数据”，然后运行 ​​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;
  }
}
4

1 回答 1

1

你需要使用reportProgressbackgroundworker的事件。

将文件名保存openfiledialog在实例级别的字符串中，即在方法之外。现在在事件处理程序中移动代码以dataset完全填充backgroundworker.dowork。填充dataset呼叫后backgroundworker.ReportProgress。这将触发backgroundworker.ProgressChanged事件。在此方法中填充您的 datagridview，因为此方法将在实例化后台工作程序的线程上调用。现在在方法中发送其余的 ADO 连接代码dowork。这应该足够了。

**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
        }
    }
于 2013-06-23T10:09:10.953 回答