Verwenden von SqlBulkCopy in einer Transaktion für mehrere, verknüpfte Tabellen

Question

Ich bin hier ein bisschen fest hier versuchen viele Daten (eine Million Datensätze insgesamt) aus drei verwandten Tabellen zu anderen drei verwandten Tabellen in der gleichen Datenbank zu kopieren.

Mein Tischdesign ist wie folgt:

Was ich brauche, ist in der Lage sein, Daten aus dem Entwurf Tabellen kopieren über die nicht-Entwurf Tabellen in einer Transaktion, die ich in der Lage bin zu Rollback, wenn etwas schief geht. Dies wird benötigt, da wir keine Billing und BillingPriceLine Datensätze in der Datenbank haben wollen, wenn die Bulk-Einfügung von BillingPriceLineSpecificationDraft Kopie fehlgeschlagen ist.

Da ich jedoch SqlBulkCopy zum Kopieren der Datensätze verwende, kann ich die neuen IDs nicht erfassen, um die richtigen Beziehungen zwischen den drei neuen Tabellen herzustellen. Wenn ich einen Lesevorgang, d. H. Die Billing Tabelle in der Transaktion, um die richtige Billing ID zu erhalten, bekomme ich eine Auszeit, die erwartet wird, da die Tabellen innerhalb der Transaktion gesperrt sind.

Ich habe versucht, die IsolationLevel Enum auf die Transaktion (in der Tat, ich ging verrückt und versuchte sie alle ;-)), aber sie taten nichts, was es scheint.

Gibt es einen guten Weg, dies zu tun, dass ich vermisse?

Vielen Dank im Voraus.

Answer 1

Sie können das nicht wirklich mit Bulk-Kopie tun.

Sie müssen auch nicht - es ist eine sehr schlechte Praxis, echte Tabellen mit SqlBulkCopy zu berühren, denn wer auch immer dieses Ding geschrieben hat, hat kein Verständnis für SQL Server-Sperrmechanismen.

• Erstellen Sie 3 temporäre Tabellen mit der gleichen Tabellenstruktur wie das Ziel.
• SqlBulkCopy in diese Tabellen (wodurch vermieden SqlBulkCopy Sperren Verschrauben Sie und Vermeidung der Transaktion Problem).
• Geben Sie dann in einer Transaktion 3 INSERT INTO-Anweisungen mit den Daten aus den temporären Tabellen als Quelle aus.

Ergebnis ist das Beste aus beiden Welten. Sobald Sie die Daten in den temporären Tabellen (mit möglicherweise gefälschten IDs) haben, können Sie einige wirklich interessante SQL ziehen, um die Quellentabelle in einer Transaktion mit den relevanten internen IDs für die nächste Tabelle zu aktualisieren. Das SQL wird komplex, aber das ist das Beste, was Sie tun können.

---

Erklärung, warum SqlBulkCopy schlecht ist:

SqlBulkCopy wirklich sehr problematisch ist - es Schraubverriegelung der Fall ist. Es erfordert eine exklusive Tabellensperre (was "sort of ok" ist). Es fragt danach - aber es wartet nie (d. H. Wenn es eine Sperre für den Tisch gibt, schlägt dies fehl), dann versucht es erneut .... nach einiger Zeit .... bis ein Timeout abläuft. Das Ergebnis ist, dass es auf einer Tabelle mit Aktivität wirklich schwierig ist, SqlBulkCopy zu erhalten, um eine Sperre zu erhalten. Der richtige Code wäre, auf die exklusive Sperre zu warten ... nun.