0

次の問題があります: vb.net の 1 つの sqltransaction 内で、複数のテーブルにデータを挿入します。
それは次のようなものです： 

...
sqltransaction = connection.begintransaction
INSERT into table1
...
for i=1 to x
    ...
    INSERT into table2
    ...
    SELECT FROM table3
    ...
    INSERT into table3
    ...
next i
sqltransaction.commit
...

Private Sub salveazaCerereaDeOferta()
    If checkCompletion() = 1 Then
        Dim conn As New SqlConnection(My.Settings.GestiuneService2012_beSQLConnectionString)
        conn.Open()
        Dim sqlTrans As SqlTransaction = conn.BeginTransaction()
        Try
            Dim cmdInsertCerereOferta As SqlCommand = conn.CreateCommand
            cmdInsertCerereOferta.Transaction = sqlTrans
            cmdInsertCerereOferta.CommandText = "INSERT INTO ListaCereriOferte (IDFurnizor,NrCerereOferta,DataCerereOferta,IDModTransCerereOferta,ObservatiiCerereOferta)" + _
                                                " VALUES (@IDFurnizor,@NrCerereOferta,@DataCerereOferta,@IDModTransCerereOferta,@ObservatiiCerereOferta);" + _
                                                " SELECT SCOPE_IDENTITY();"
            cmdInsertCerereOferta.Parameters.Add("@IDFurnizor", SqlDbType.Int).Value = CInt(Me.t_IDFurnizor.Text)
            cmdInsertCerereOferta.Parameters.Add("@NrCerereOferta", SqlDbType.Int).Value = CInt(Me.t_NumarCerereOferta.Text)
            cmdInsertCerereOferta.Parameters.Add("@DataCerereOferta", SqlDbType.Date).Value = CDate(Me.t_DataCerereOferta.Text)
            cmdInsertCerereOferta.Parameters.Add("@IDModTransCerereOferta", SqlDbType.Int).Value = 1
            cmdInsertCerereOferta.Parameters.Add("@ObservatiiCerereOferta", SqlDbType.NVarChar).Value = Me.t_ObservatiiCerereOferta.Text
            Dim IDCerereOferta As Integer = cmdInsertCerereOferta.ExecuteScalar
            Dim ListaPieseCerereOferta = Me.CerereOfertaDataSet.ListaPieseCerereOferta.AsEnumerable
            Dim ListaNecesarePePiesa = Me.CerereOfertaDataSet.NecesarePeOferta.AsEnumerable
            Dim PieseOferta = From q In ListaPieseCerereOferta _
                                 Select q
            Dim cantTotalaPiese = Aggregate q In ListaPieseCerereOferta _
                                   Into Sum(q.Cantitate)
            Dim salvat As Integer = 0
            Dim curIDPiesaDeSchimb As Integer
            For Each piesa In PieseOferta
                curIDPiesaDeSchimb = piesa.IDPiesaDeSchimb
                Dim NecesarePePiesa = From p In ListaNecesarePePiesa _
                                      Select p _
                                      Order By p.IDNecesar Descending
                Dim curIDNecesar As Integer
                For Each necesar In NecesarePePiesa
                    curIDNecesar = necesar.IDNecesar
                    Dim cmdInsertPiesaCerereOferta As SqlCommand = conn.CreateCommand
                    cmdInsertPiesaCerereOferta.Transaction = sqlTrans
                    cmdInsertPiesaCerereOferta.CommandText = "INSERT INTO CereriOferte (IDCerereOferta,IDPiesaDeSchimb,Cantitate,UM,Observatii)" + _
                                                                " VALUES (@IDCerereOferta,@IDPiesaDeSchimb,@Cantitate,@UM,@Observatii);" + _
                                                                " SELECT SCOPE_IDENTITY();"
                    cmdInsertPiesaCerereOferta.Parameters.Add("@IDCerereOferta", SqlDbType.Int)
                    cmdInsertPiesaCerereOferta.Parameters.Add("@IDPiesaDeSchimb", SqlDbType.Int)
                    cmdInsertPiesaCerereOferta.Parameters.Add("@Cantitate", SqlDbType.Float)
                    cmdInsertPiesaCerereOferta.Parameters.Add("@UM", SqlDbType.NVarChar)
                    cmdInsertPiesaCerereOferta.Parameters.Add("@Observatii", SqlDbType.NVarChar)
                    Dim cmdInsertNecesarCerereOferta As SqlCommand = conn.CreateCommand
                    cmdInsertNecesarCerereOferta.Transaction = sqlTrans
                    cmdInsertNecesarCerereOferta.CommandText = "INSERT INTO NecesareCereriOferte (IDPiesaNecesar,IDPiesaCerereOferta)" + _
                                                               " VALUES (@IDPiesaNecesar,@IDPiesaCerereOferta)"
                    cmdInsertNecesarCerereOferta.Parameters.Add("@IDPiesaNecesar", SqlDbType.Int)
                    cmdInsertNecesarCerereOferta.Parameters.Add("@IDPiesaCerereOferta", SqlDbType.Int)
                    Select Case curIDNecesar
                        Case 0
                            cmdInsertPiesaCerereOferta.Parameters("@IDCerereOferta").Value = IDCerereOferta
                            cmdInsertPiesaCerereOferta.Parameters("@IDPiesaDeSchimb").Value = curIDPiesaDeSchimb
                            cmdInsertPiesaCerereOferta.Parameters("@Cantitate").Value = 1
                            cmdInsertPiesaCerereOferta.Parameters("@UM").Value = piesa.UM
                            cmdInsertPiesaCerereOferta.Parameters("@Observatii").Value = ""
                            For i = 1 To necesar.Cantitate
                                cmdInsertPiesaCerereOferta.ExecuteNonQuery()
                                salvat += 1
                                Me.tsspb_SalvareCerereOferta.Value = CInt(100 * salvat / cantTotalaPiese)
                            Next
                        Case Is > 0
                            Me.PieseNecesarePeOfertaTableAdapter.Fill(Me.CerereOfertaDataSet.PieseNecesarePeOferta, curIDNecesar, curIDPiesaDeSchimb, CInt(necesar.Cantitate))
                            Dim ListaPieseNecesarePeOferta = Me.CerereOfertaDataSet.PieseNecesarePeOferta.AsEnumerable
                            Dim PieseNecesareOferta = From q In ListaPieseNecesarePeOferta _
                                                 Select q
                            For i = 1 To necesar.Cantitate
                                cmdInsertPiesaCerereOferta.Parameters("@IDCerereOferta").Value = IDCerereOferta
                                cmdInsertPiesaCerereOferta.Parameters("@IDPiesaDeSchimb").Value = curIDPiesaDeSchimb
                                cmdInsertPiesaCerereOferta.Parameters("@Cantitate").Value = 1
                                cmdInsertPiesaCerereOferta.Parameters("@UM").Value = piesa.UM
                                cmdInsertPiesaCerereOferta.Parameters("@Observatii").Value = ""
                                Dim insertedIDPiesaCerereOferta As Integer = cmdInsertPiesaCerereOferta.ExecuteScalar
                                cmdInsertNecesarCerereOferta.Parameters("@IDPiesaNecesar").Value = PieseNecesareOferta(i - 1).IDPiesaNecesar
                                cmdInsertNecesarCerereOferta.Parameters("@IDPiesaCerereOferta").Value = insertedIDPiesaCerereOferta
                                cmdInsertNecesarCerereOferta.ExecuteNonQuery()
                                salvat += 1
                                Me.tsspb_SalvareCerereOferta.Value = CInt(100 * salvat / cantTotalaPiese)
                            Next
                    End Select
                Next
            Next
            sqlTrans.Commit()
            MsgBox("Cererea de oferta a fost salvata.")
        Catch ex As Exception
            Try
                sqlTrans.Rollback()
                MsgBox("A aparut o eroare." + vbNewLine + ex.ToString + vbNewLine + "RollBack success. Cererea nu a fost salvata.")
            Catch ex2 As SqlException
                If Not sqlTrans.Connection Is Nothing Then
                    MsgBox("An exception of type " & ex2.GetType().ToString() & _
                                      " was encountered while attempting to roll back the transaction.")
                End If
            End Try
        Finally
            If conn.State = ConnectionState.Open Then conn.Close()
        End Try
    Else
        MsgBox("Nu ai completat integral cererea de oferta!")
    End If
End Sub

ロックするクエリ:

SELECT     TOP (100) PERCENT dbo.qry_NecesareNerezolvate.IDPiesaNecesar, COUNT(dbo.NecesareCereriOferte.IDPiesaCerereOferta) AS CereriOferte, 
                      dbo.qry_NecesareNerezolvate.IDNecesar, dbo.qry_NecesareNerezolvate.IDPiesaDeSchimb, dbo.qry_NecesareNerezolvate.Cantitate
FROM         dbo.qry_NecesareNerezolvate LEFT OUTER JOIN
                      dbo.NecesareCereriOferte ON dbo.qry_NecesareNerezolvate.IDPiesaNecesar = dbo.NecesareCereriOferte.IDPiesaNecesar
GROUP BY dbo.qry_NecesareNerezolvate.IDPiesaNecesar, dbo.qry_NecesareNerezolvate.IDNecesar, dbo.qry_NecesareNerezolvate.IDPiesaDeSchimb, 
                      dbo.qry_NecesareNerezolvate.Cantitate

qry_NecesareNerezolvate: 

SELECT     TOP (100) PERCENT dbo.Necesare.IDPiesaNecesar, dbo.Necesare.IDNecesar, dbo.Necesare.IDPiesaDeSchimb, dbo.Necesare.Cantitate, dbo.Necesare.UM, 
                  dbo.Necesare.Observatii
FROM         dbo.Necesare LEFT OUTER JOIN
                  dbo.qry_NecesareComandateRezolvate ON dbo.Necesare.IDPiesaNecesar =     dbo.qry_NecesareComandateRezolvate.IDPiesaNecesar
WHERE     (dbo.qry_NecesareComandateRezolvate.IDPiesaNecesar IS NULL)

qry_NecesareComandateRezovate: 

SELECT     dbo.Necesare.IDPiesaNecesar, dbo.NecesareComenzi.IDPiesaComanda, dbo.NecesareRezolvate.IDBonTransfer
FROM         dbo.Necesare LEFT OUTER JOIN
                  dbo.NecesareComenzi ON dbo.Necesare.IDPiesaNecesar = dbo.NecesareComenzi.IDPiesaNecesar LEFT OUTER JOIN
                  dbo.NecesareRezolvate ON dbo.Necesare.IDPiesaNecesar = dbo.NecesareRezolvate.IDPiesaNecesar
WHERE     (dbo.NecesareComenzi.IDPiesaComanda IS NOT NULL) OR
                  (dbo.NecesareRezolvate.IDBonTransfer IS NOT NULL)

i=1の場合: insert、選択してから挿入が機能し
、次にi=2および: INSERT into table2...は機能していますが、SELECT FROM table1 および table3...はタイムアウトを取得します...

理由がわかりません！
PS: SELECT FROM table3を 2 回実行する前にコードを壊すと、SSMSに移動して選択クエリを実行すると、タイムアウトも発生します...

4

1 に答える 1

0

以下のコード サンプルでは、​​For ループの最後までトランザクションを開いています。i =1 の場合、トランザクションが開かれ、挿入が行われるように思えます。i=2 のとき、i=1 のときに挿入される行はコミットされていない状態にあり、select が table1 に結合している場合、ロック レベルはテーブル レベルにエスカレートされ、すべてがロックされます。コミットを for ループ内に移動し、その様子を確認します。

for i=1 to x
    ...
    INSERT into table2
    ...
    SELECT FROM table3
    ...
    INSERT into table3
    ...
next i
sqltransaction.commit
于 2013-08-02T05:42:28.793 に答える