Я использую SqlBulkCopy для копирования нескольких таблиц в базу данных. Однако большинство таблиц успешно скопированы в базу данных, кроме одной таблицы с 6000 ++ строками данных. Когда я запускаю функцию, она просто висит там и не отвечает.
Ниже мой код:
using (SqlConnection destinationConnection = Login.GetConnection())
{
destinationConnection.Open();
using (SqlTransaction transaction = destinationConnection.BeginTransaction(IsolationLevel.ReadCommited))
{
using (SqlBulkCopy bulkCopy = new SqlBulkCopy(destinationConnection, SqlBulkCopyOptions.KeepIdentity, transaction))
{
bulkCopy.DestinationTableName = "dbo." + tableName;
try
{
bulkCopy.WriteToServer(dt);
transaction.Commit();
bulkCopySuccess = true;
}
catch (Exception ex)
{
transaction.Rollback();
MessageBox.Show(ex.Message, ex.GetType().ToString());
bulkCopySuccess = false;
}
}
}
}
Какова возможная проблема? Что-то не так с моим кодом?
Проблема: если вы используете код BulkCopy
из основного потока, он будет ждать / не отвечать до тех пор, пока не будет освобожден от завершения всей операции.
поэтому, если пользователь хочет выполнить некоторые операции с UI
он будет полностью не отвечать на запросы и зависает.
Решение. Вы можете использовать компонент BackgroundWorker
для выполнения операций на фоне без виджета UI
.
Попробуй это:
private void button1_Click(object sender, EventArgs e)
{
BackgroundWorker backgroundWorker = new BackgroundWorker();
backgroundWorker.DoWork += new DoWorkEventHandler(backgroundWorker_DoWork);
backgroundWorker.RunWorkerAsync();
}
private void backgroundWorker_DoWork(object sender, DoWorkEventArgs e)
{
DoBulkCopy();
}
private void DoBulkCopy()
{
using (SqlConnection destinationConnection = Login.GetConnection())
{
destinationConnection.Open();
using (SqlTransaction transaction = destinationConnection.BeginTransaction(IsolationLevel.ReadCommited))
{
using (SqlBulkCopy bulkCopy = new SqlBulkCopy(destinationConnection, SqlBulkCopyOptions.KeepIdentity, transaction))
{
bulkCopy.DestinationTableName = "dbo." + tableName;
try
{
bulkCopy.WriteToServer(dt);
transaction.Commit();
bulkCopySuccess = true;
}
catch (Exception ex)
{
transaction.Rollback();
MessageBox.Show(ex.Message, ex.GetType().ToString());
bulkCopySuccess = false;
}
}
}
}
}