У меня есть ADO.NET DataTable
приблизительно с 100 000 записей. В этой таблице существует столбец xyID
который не имеет никаких значений в нем, потому что столбец является автоматически сгенерированным IDENTITY
в моей базе данных SQL Server.
Я должен получить сгенерированные идентификаторы для других процессов. Я ищу способ выполнить массовое копирование этого DataTable
в базу данных SQL Server, и в том же "шаге" к "заливке" мой DataTable
со сгенерированными идентификаторами.
Как я могу получить значения идентификационных данных записей, вставленных в таблицу с помощью SqlBulkCopy
класс?
Сейчас я делаю что-то вроде этого:
DataTable objects = new DataTable();
DataColumn keyColumn = new DataColumn("name", typeof(string));
DataColumn versionColumn = new DataColumn("version", typeof(int));
versionColumn.DefaultValue = iVersionID;
objects.Columns.Add(keyColumn);
objects.Columns.Add(versionColumn);
foreach (KeyValuePair<string, NamedObject> kvp in Directory)
{
NamedObject o = kvp.Value;
DataRow row = objects.NewRow();
row[0] = o.Name;
objects.Rows.Add(row);
}
using (SqlBulkCopy updater = new SqlBulkCopy(conn,
SqlBulkCopyOptions.TableLock | SqlBulkCopyOptions.UseInternalTransaction, null))
{
updater.DestinationTableName = "object_table";
updater.WriteToServer(objects);
}
string sQuery = @"SELECT id, name FROM object_table WHERE version = @ver";
using (SqlCommand command = new SqlCommand(sQuery, conn))
{
SqlParameter version = new SqlParameter("@ver", SqlDbType.Int, 4);
version.Value = versionID;
command.Parameters.Add(version);
command.CommandTimeout = 600;
using (SqlDataReader reader = command.ExecuteReader())
{
while (reader.Read())
{
string key = (string)reader[1];
NamedObject item = Directory[key];
item.ID = (int)reader[0];
}
}
}
Обратите внимание, что наш дизайн данных позволяет фильтровать все наши новые объекты, используя идентификатор версии; каждая строка, которую мы добавляем, будет иметь один и тот же идентификатор версии, и мы ранее удалили все строки в базе данных, которые уже имели этот идентификатор версии.
Однако время ожидания моего запроса select в настоящее время истекает в ExecuteReader, даже с этим 10-минутным окном. Так что это не окончательное решение.