Possible d'obtenir PrimayKey Id de retour après un SQL BulkCopy?

Dans ce scénario, je voudrais utiliser SqlBulkCopy pour l'insérer dans un mise en scène table (c'est à dire celui qui ressemble à des données que je veux importer, mais ne fait pas partie des principales tables transactionnelles), puis à la DB pour un INSERT/SELECT pour déplacer les données dans la première vraie table.

Maintenant, j'ai deux choix en fonction de la version du serveur, j'ai pu faire une deuxième INSERT/SELECT à la deuxième table réelle, ou je pouvais utiliser le INSERT/OUTPUT clause de faire la seconde insertion , à l'aide de l'identité des lignes de la table.

Par exemple:

     -- dummy schema
     CREATE TABLE TMP (data varchar(max))
     CREATE TABLE [Table1] (id int not null identity(1,1), data varchar(max))
     CREATE TABLE [Table2] (id int not null identity(1,1), id1 int not null, data varchar(max))

     -- imagine this is the SqlBulkCopy
     INSERT TMP VALUES('abc')
     INSERT TMP VALUES('def')
     INSERT TMP VALUES('ghi')

     -- now push into the real tables
     INSERT [Table1]
     OUTPUT INSERTED.id, INSERTED.data INTO [Table2](id1,data)
     SELECT data FROM TMP

OriginalL'auteur Marc Gravell

J'ai eu le même problème, où j'ai dû récupérer les id des lignes insérées avec SqlBulkCopy.
Mon ID de la colonne est une colonne d'identité.

Solution:

J'ai inséré+ de 500 lignes avec la copie en bloc, puis sélectionnés avec la requête suivante:

SELECT TOP InsertedRowCount * 
FROM   MyTable 
ORDER BY ID DESC

Cette requête renvoie les lignes, j'ai juste inséré avec leur id. Dans mon cas, j'ai eu une autre colonne unique. J'ai donc sélectionné la colonne et l'id. Ensuite mises en correspondance avec un IDictionary comme suit:

 IDictionary<string, int> mymap = new Dictionary<string, int>()
 mymap[Name] = ID

Espère que cette aide.

OriginalL'auteur Vitaly Galinsky

Je voudrais:

1. Tour sur l'identité insert sur la table

2. Saisir l'Id de la dernière ligne de la table

3. Boucle de (int i = Id; i < datable.rows.count+1; i++)

4. Dans la boucle, affectez à la propriété Id de votre datable de i+1.

5. Exécuter SQL d'insertion en bloc avec votre garder l'identité allumé.

6. Tour identité insérer back off

Je pense que c'est le moyen le plus sûr d'obtenir votre id sur un SQL d'insertion en bloc, car il permettra d'éviter incompatibles id qui pourrait causé par l'application d'être exécuté sur un autre thread.

OriginalL'auteur RiceRiceBaby

Mon approche est similaire à ce que RiceRiceBaby décrites, à l'exception d'une chose importante à ajouter, c'est que l'appel à extraire Max(Id) doit être une partie d'une opération, ainsi que l'appel à SqlBulkCopy.WriteToServer. Sinon, quelqu'un d'autre peut insérer lors de votre transaction, et ce serait faire de votre Identifiant est incorrect. Voici mon code:

public static void BulkInsert<T>(List<ColumnInfo> columnInfo, List<T> data, string 
destinationTableName, SqlConnection conn = null, string idColumn = "Id")
{
NLogger logger = new NLogger();
var closeConn = false;
if (conn == null)
{
closeConn = true;
conn = new SqlConnection(_connectionString);
conn.Open();
}
SqlTransaction tran = 
conn.BeginTransaction(System.Data.IsolationLevel.Serializable);
try
{
var options = SqlBulkCopyOptions.KeepIdentity;
var sbc = new SqlBulkCopy(conn, options, tran);
var command = new SqlCommand(
$"SELECT Max({idColumn}) from {destinationTableName};", conn, 
tran);
var id = command.ExecuteScalar();
int maxId = 0;
if (id != null && id != DBNull.Value)
{
maxId = Convert.ToInt32(id);
}
data.ForEach(d =>
{
maxId++;
d.GetType().GetProperty(idColumn).SetValue(d, maxId);
});
var dt = ConvertToDataTable(columnInfo, data);
sbc.DestinationTableName = destinationTableName;
foreach (System.Data.DataColumn dc in dt.Columns)
{
sbc.ColumnMappings.Add(dc.ColumnName, dc.ColumnName);
}
sbc.WriteToServer(dt);
tran.Commit();
if(closeConn)
{
conn.Close();
conn = null;
}
}
catch (Exception ex)
{
tran.Rollback();
logger.Write(LogLevel.Error, $@"An error occurred while performing a bulk 
insert into table {destinationTableName}. The entire
transaction has been rolled back. 
{ex.ToString()}");
throw ex;
}
}

OriginalL'auteur BeccaGirl