Datenbank Anwendung im Netzwerk

  • VB.NET

Es gibt 41 Antworten in diesem Thema. Der letzte Beitrag () ist von DMO.

    GerhardW schrieb:

    Oder meinst du eine Klasse (LockObject) mit den Eigenschaften des Lock Zustandes, welcher ein IDisposable beinhaltet?
    fast.
    Die Eigenschaften des LockObjektes beinhalten kein IDisposable - dassis semantisch Unfug.
    Bei Interfaces gibts nur zwei Möglichkeiten:
    • Eine Klasse implementiert ein Interface
    • Ein anderes Interface beerbt ein Interface
    Ich meine ersteres: Die LockObject-Klasse soll IDisposable implementieren.
    Die DataRow.Lock-Extension-Methode soll ein LockObject erstellen, welches IDisposable ist.
    Das LockObject enthält ausserdem Informationen über den Lock-Hole-Versuch, v.a., obs geklappt hat.
    Die Dispose-Methode des LockObject soll dann in der DB den Lock wieder freigeben.

    Dieser Beitrag wurde bereits 1 mal editiert, zuletzt von „ErfinderDesRades“ ()

    Prüfst du auch vor dem Update eines Datensatzes ob noch ein Lock besteht?

    Use Case:
    User A lockt einen Datensatz zum Schreiben, Speicher nicht hat aber den Datensatz weiter geöffnet und das Lock läuft ab.

    User B öffnet den gleichen Datensatz und beantragt ein Lock, erhält dieses weil der Lock von User A abgelaufen ist.
    User B speichert seine Änderungen.

    User A fällt auf, dass er seine Änderungen noch nicht gespeichert hat und speichert.
    Die deutsche Sprache ist Freeware, du kannst sie benutzen, ohne dafür zu bezahlen. Sie ist aber nicht Open Source, also darfst du sie nicht verändern, wie es dir gerade passt.

    MrTrebron schrieb:

    Prüfst du auch vor dem Update eines Datensatzes ob noch ein Lock besteht?

    Use Case:
    User A lockt einen Datensatz zum Schreiben, Speicher nicht hat aber den Datensatz weiter geöffnet und das Lock läuft ab.

    User B öffnet den gleichen Datensatz und beantragt ein Lock, erhält dieses weil der Lock von User A abgelaufen ist.
    User B speichert seine Änderungen.

    User A fällt auf, dass er seine Änderungen noch nicht gespeichert hat und speichert.


    Ja, das stimmt. Ich prüfen, ob ich noch innerhalb des Timeout bin. An das habe ich schon gedacht. Ich muss die Gültigkeit des Locking prüfen.

    ErfinderDesRades schrieb:

    Ich meine ersteres: Die LockObject-Klasse soll IDisposable implementieren.
    Die DataRow.Lock-Extension-Methode soll ein LockObject erstellen, welches IDisposable ist.
    Das LockObject enthält ausserdem Informationen über den Lock-Hole-Versuch, v.a., obs geklappt hat.
    Die Dispose-Methode des LockObject soll dann in der DB den Lock wieder freigeben.


    Ist jetzt keine Extension aber ist das so gemeint? Prinzipiell gemeint.

    VB.NET-Quellcode

    1. Public Class MySQLLock
    3. Shared Function Lock(dr as DataRow) As LockInfo
    4. Dim mLock As LockInfo = New LockInfo()
    5. ' Hier erfolgt das Lockingverfahren
    6. ...
    8. Return mLock
    9. End Function
    11. End Class
    13. Public Class LockInfo: Implements IDisposable
    14. Private m_Success As Boolean = False
    15. Public ReadOnly Property Success() As Boolean
    16. Get
    17. Return m_Success
    18. End Get
    19. End Property
    21. Public Sub Dispose() Implements IDisposable.Dispose
    22. ' Hier entsperre ich wieder
    24. End Sub
    26. Public Sub New()
    27. m_Success = False
    28. End Sub
    30. End Class

    Anbei mein Basiscode für das Sperren von Datensätzen in einer MySQL Umgebung. @ErfinderDesRades, ich habe die Klasse nicht wirklich in eine Extension gepackt, weil diese in unserer Anwendung nicht einsetzbar ist. Dennoch habe ich versucht meine Shared Klasse in einer Extension zu benutzen. Vielleicht würde auch das ausreichen.

    1) Die Basis der Shared Klasse ist eine LockInfo Klasse, wo die Locking Informationen ausgelesen werden können bzw. gespeichert werden.

    VB.NET-Quellcode

    1. Option Strict On
    3. ''' <summary>
    4. ''' Lock Informationen zum gesperrten Datensatz
    5. ''' </summary>
    6. Public Class LockInfo: Implements IDisposable
    7. Public Property SessionId As String
    8. Public Property LockId As Integer
    9. Public Property TableName As String
    10. Public Property RecordID as Integer
    11. Public Property UserName as String
    12. Public Property ComputerName As String
    13. Public Property Success As Boolean
    14. Public Property LockTimeout As String
    16. Public Sub New()
    17. SessionId = LockManager.SessionId
    18. LockId = 0
    19. TableName = ""
    20. RecordId = 0
    21. UserName = LockManager.UserName
    22. ComputerName = System.Environment.MachineName
    23. Success = False
    24. LockTimeout = LockManager.GetServerDateTime()
    25. End Sub
    27. ''' <summary>
    28. ''' Dispose: Freigeben des gesperrten Datensatzes
    29. ''' Wird benötigt in einer Using Anweisung
    30. ''' </summary>
    31. Public Sub Dispose() Implements IDisposable.Dispose
    32. LockManager.Unlock(Me)
    33. End Sub
    35. End Class


    2) Das gesamte Management wurde in eine Shared Klasse "LockManager" gepackt. Diese Klasse stellt Methoden zum Sperren (Lock) und Entsperren (Unlock) zur Verfügung. Des Weiteren wurde eine Methode (CheckLock) implementiert, welche vor dem Schreiben in eine Tabelle nochmals aufgerufen werden sollte. Diese Methode prüft, ob das Locking noch gültig ist. Dies ist dann der Fall, wenn der Benutzer einen Datensatz sperrt und inzwischen der Timeout abläuft. Es wird geprüft, ob der Datensatz inzwischen von jemanden anderen gesperrt wurde oder der Benutzer noch immer akutell ist. Wenn ja, dann wird neuerlicht der Datensatz gesperrt ansonsten ist das Locking ungültigt. D.h. die Propertty "Success" wird auf False gesetzt.

    Die Klasse erzeugt automatisch/prüft beim Übergeben einer gültigen MySQLConnection die Locking Tabelle (siehe Grundwerte Punkt 3)
    Damit eine eindeutige Zuordnung der Einträge in der LockingTabelle vorhanden ist, wird eine GUID erzeugt, welche ebenfalls in der LockingTabelle gespeichert wird.

    LOCK Methoden

    VB.NET-Quellcode

    1. ''' <summary>
    2. ''' Sperrt einen Datensatz und gibt eine Lock Information zurück
    3. ''' </summary>
    4. ''' <param name="row">zu sperrende Datensatz</param>
    5. ''' <returns>Lock Informationen</returns>
    6. Overloads Shared Function Lock(row As DataRow) As LockInfo
    7. m_ErrMsg = ""
    8. m_Lock = New LockInfo()
    9. ' Prüfe, ob Initialisierungsflag gesetzt ist - d.h. eine MySqlConnection und die LockManager Tabelle vorhanden sind
    10. If Not InitFlag Then Return m_Lock
    11. ' Lockinformationen zuweisen - Infos vom Datensatz holen
    12. m_Lock.TableName = row.Table.TableName
    13. Dim m_RecordIdField As String = GetPrimaryKeyFieldName(row)
    14. If m_RecordIdField = "" Then
    15. m_ErrMsg = "Kein PrimaryKey Field im DataRow mit AutoIncrement gefunden!"
    16. m_Lock.Success = False
    17. Return m_Lock
    18. End If
    19. m_Lock.RecordID = CInt(row(m_RecordIdField))
    20. ' aktuelle Server DateTime lesen
    21. m_Lock.LockTimeout = GetServerDateTime(True)
    22. If m_Lock.LockTimeout Is Nothing Then
    23. m_Lock.Success = False
    24. Return m_Lock
    25. End If
    26. ' Versuche den Datensatz zu sperren
    27. If TryLock() Then Return m_Lock
    28. m_Lock.Success = False
    29. Return m_Lock
    30. End Function
    31. ''' <summary>
    32. ''' Sperrt einen Datensatz und gibt eine Lock Information zurück
    33. ''' </summary>
    34. ''' <param name="pTableName">Tabellenname</param>
    35. ''' <param name="pRecordId">Id des zu sperrenden Datensatzes</param>
    36. ''' <returns>Lock Informationen</returns>
    37. Overloads Shared Function Lock(pTableName As String, pRecordId As Integer) As LockInfo
    38. m_ErrMsg = ""
    39. m_Lock = New LockInfo()
    40. ' Prüfe, ob Initialisierungsflag gesetzt ist - d.h. eine MySqlConnection und die LockManager Tabelle vorhanden sind
    41. If Not InitFlag Then Return m_Lock
    42. ' Lockinformationen zuweisen
    43. m_Lock.TableName = pTableName
    44. m_Lock.RecordID = pRecordId
    45. ' aktuelle Server DateTime lesen
    46. m_Lock.LockTimeout = GetServerDateTime(True)
    47. If m_Lock.LockTimeout Is Nothing Then
    48. m_Lock.Success = False
    49. Return m_Lock
    50. End If
    51. ' Versuche den Datensatz zu sperren
    52. If TryLock() Then Return m_Lock
    53. m_Lock.Success = False
    54. Return m_Lock
    55. End Function


    CHECKLOCK Methoden

    VB.NET-Quellcode

    1. ''' <summary>
    2. ''' Prüft, ob die Sperrung noch gültig ist
    3. ''' </summary>
    4. ''' <returns>True/False</returns>
    5. Overloads Shared Function CheckLock() As Boolean
    6. m_ErrMsg = ""
    7. ' Prüfe, ob Initialisierungsflag gesetzt ist - d.h. eine MySqlConnection und die LockManager Tabelle vorhanden sind
    8. If Not InitFlag Then Return False
    9. If m_Lock Is Nothing Then Return False
    10. ' Infos von m_Lock verwenden
    11. ' Prüfe, ob der RecordLock noch gültig ist
    12. If Not TryCheckLock() Then Return False
    13. Return True
    14. End Function
    15. ''' <summary>
    16. ''' Prüft, ob die Sperrung noch gültig ist
    17. ''' </summary>
    18. ''' <param name="pLockInfo">Lock Informationen eines gespeicherten Datensatzes</param>
    19. ''' <returns>True/False</returns>
    20. Overloads Shared Function CheckLock(pLockInfo As LockInfo) As Boolean
    21. m_ErrMsg = ""
    22. ' Prüfe, ob Initialisierungsflag gesetzt ist - d.h. eine MySqlConnection und die LockManager Tabelle vorhanden sind
    23. If Not InitFlag Then Return False
    24. If pLockInfo Is Nothing Then Return False
    25. ' Infos von pLockInfo zuweisen
    26. m_Lock = pLockInfo
    27. ' Prüfe, ob der RecordLock noch gültig ist
    28. If Not TryCheckLock() Then Return False
    29. Return True
    30. End Function


    UNLOCK Methoden

    VB.NET-Quellcode

    1. ''' <summary>
    2. ''' Gibt den gesperrten Datensatz wieder frei
    3. ''' </summary>
    4. ''' <returns>True/False</returns>
    5. Overloads Shared Function Unlock() As Boolean
    6. m_ErrMsg = ""
    7. ' Prüfe, ob Initialisierungsflag gesetzt ist - d.h. eine MySqlConnection und die LockManager Tabelle vorhanden sind
    8. If Not InitFlag Then Return False
    9. If m_Lock Is Nothing Then Return True
    10. ' Infos von m_Lock verwenden
    11. ' Datensatz wieder freigeben d.h. aus LockManager Tabelle löschen
    12. If Not Delete() Then Return False
    13. Return True
    14. End Function
    15. ''' <summary>
    16. ''' Gibt den gesperrten Datensatz wieder frei
    17. ''' </summary>
    18. ''' <param name="pLockInfo">Lock Informationen eines gespeicherten Datensatzes</param>
    19. ''' <returns>True/False</returns>
    20. Overloads Shared Function Unlock(pLockInfo As LockInfo) As Boolean
    21. m_ErrMsg = ""
    22. ' Prüfe, ob Initialisierungsflag gesetzt ist - d.h. eine MySqlConnection und die LockManager Tabelle vorhanden sind
    23. If Not InitFlag Then Return False
    24. If pLockInfo Is Nothing Then Return True
    25. ' Infos von pLockInfo zuweisen
    26. m_Lock = pLockInfo
    27. ' Datensatz wieder freigeben d.h. aus LockManager Tabelle löschen
    28. If Not Delete() Then Return False
    29. Return True
    30. End Function



    3) Vor der Verwendung der LockManager Klasse sind einigen Grundwerte zu setzen:

    VB.NET-Quellcode

    1. ' GW: 22.03.2021 - Startwerte für den LockManager (RecordLocking)
    2. ' Benutzername
    3. LockManager.UserName = Benutzername
    4. ' Gültige MySQL Connection
    5. LockManager.Connection = New MySqlConnection(ConnectionString)


    4) So könnten eventuell die Extensions aussehen, wenn mit DataRow gearbeitet wird

    VB.NET-Quellcode

    1. Imports System.Runtime.CompilerServices
    2. ''' <summary>
    3. ''' Extension die DataRow
    4. ''' </summary>
    5. Public Module DataRowExtensions
    7. ''' <summary>
    8. ''' Datensatz sperren
    9. ''' </summary>
    10. ''' <param name="row">Datensatz</param>
    11. ''' <returns>LockInformation</returns>
    12. <Extension()>
    13. Public Function Lock(row As DataRow) As LockInfo
    14. Dim mLockInfo As LockInfo = LockManager.Lock(row)
    15. Return mLockInfo
    16. End Function
    18. ''' <summary>
    19. ''' Datensatz prüfen, ob Sperrung noch gültig (LockTimeout abgelaufen?)
    20. ''' </summary>
    21. ''' <param name="row">Datensatz</param>
    22. ''' <returns>True/False</returns>
    23. <Extension()>
    24. Public Function CheckLock(row As DataRow) As Boolean
    25. If Not LockManager.CompareDataRowWithLockInfo(row) Then Return False
    26. Return LockManager.CheckLock()
    27. End Function
    29. ''' <summary>
    30. ''' Datensatz prüfen, ob Sperrung noch gültig (LockTimeout abgelaufen?)
    31. ''' </summary>
    32. ''' <param name="row">Datensatz</param>
    33. ''' <param name="pLockInfo">Bestimmte LockInformation</param>
    34. ''' <returns>True/False</returns>
    35. <Extension()>
    36. Public Function CheckLock(row As DataRow, pLockInfo As LockInfo) As Boolean
    37. If Not LockManager.CompareDataRowWithLockInfo(row, pLockInfo) Then Return False
    38. Return LockManager.CheckLock(pLockInfo)
    39. End Function
    41. ''' <summary>
    42. ''' Datensatz wieder freigeben
    43. ''' </summary>
    44. ''' <param name="row">Datensatz</param>
    45. ''' <returns>True/False</returns>
    46. <Extension()>
    47. Public Function UnLock(row As DataRow) As Boolean
    48. If Not LockManager.CompareDataRowWithLockInfo(row) Then Return False
    49. Return LockManager.Unlock
    50. End Function
    52. ''' <summary>
    53. ''' Datensatz wieder freigeben
    54. ''' </summary>
    55. ''' <param name="row">Datensatz</param>
    56. ''' <param name="pLockInfo">Bestimmte LockInformation</param>
    57. ''' <returns>True/False</returns>
    58. <Extension()>
    59. Public Function UnLock(row As DataRow, pLockInfo As LockInfo) As Boolean
    60. If Not LockManager.CompareDataRowWithLockInfo(row, pLockInfo) Then Return False
    61. Return LockManager.Unlock(pLockInfo)
    62. End Function
    64. End Module
    Dateien

    Dieser Beitrag wurde bereits 3 mal editiert, zuletzt von „GerhardW“ () aus folgendem Grund: Code wurde nicht richtig kopiert.

    Puh - da müsste ich MySql installieren, und der zip sieht mir auch nicht aus, als sei das eine lauffähige Solution.
    Also du wünschst dir, dass jemand
    • MySql installiert
    • eine Datenbank aufsetzt
    • eine Anwendung schreibt, mit Zugriff auf diese DB
    • deine Lock-Mechanismen da korrekt einfrickelt
    • mit mehreren Instanzen testet
    Jo - da werden sich die Leuts drum reissen. ;)

    Ich wünsche mir eigentlich nur, wenn jemand die Klassen in einem Projekt verwendet, mir eine Rückmeldung zu geben. Das Zip ist kein eingenständiges Programm (Solution). Ist auch nicht so gedacht. Es sind die Klassen als einzelne Dateien und diese sollten jederzeit in ein bestehendes Projekt importiert werden können.

    GerhardW schrieb:

    wenn jemand die Klassen in einem Projekt verwendet

    also ich hätte vor, dass in meiner 2.0-Version meines Projektes zu nutzen, anstatt der Lockinfo's an jeder einzelnen Table - wie ich es aktuell mache.

    Ich gebe dann gerne Rückmeldung ob das so funzt :thumbup:
    "Na, wie ist das Wetter bei dir?"
    "Caps Lock."
    "Hä?"
    "Shift ohne Ende!" :thumbsup:

    @GerhardW: Könntest du bitte ein Codebeispiel geben, wie du das Teil instanziierst und im Anschluss benutzt?
    Ich versuch' das grad alles zu verstehen und vor allem auch für zumindest AccessDB lauffähig zu machen.

    EDIT: wobei, ich hab' mir grad ne kleine Klasse zusammengehämmert - die scheint mir völlig auszureichen und kann ich mit jeder Datenbank nutzen:
    Spoiler anzeigen

    VB.NET-Quellcode

    1. Public Class RecordLock
    3. Private Shared UserRow As BenutzerRow
    4. Private Shared MachineName As String
    5. Private Shared TableName As String
    6. Private Shared Records As Integer()
    7. Private Shared Locked As List(Of RecordLockRow)
    9. ''' <summary>RecordLock initialisieren und Properties setzen</summary>
    10. Public Sub New(table As DataTable, ParamArray recordIDs As Integer())
    11. If recordIDs.Length = 0 Then Throw New Exception("Ohne Record-ID's kein Locking möglich!")
    12. UserRow = User.UserRow
    13. MachineName = Environment.MachineName
    14. TableName = table.TableName
    15. Records = recordIDs
    16. Locked = New List(Of RecordLockRow)
    17. End Sub
    19. ''' <summary>wenn nicht schon ein Lock eines anderen Users für die Datensätze besteht, dann Lock setzen</summary>
    20. Public Function LockRecord() As Boolean
    21. If IsAlreadyLocked() Then Return False
    22. Records.ForEach(Sub(id) Locked.Add(Dts.RecordLock.AddRecordLockRow(UserRow, MachineName, TableName, id, Date.Now)))
    23. Dts.SaveDts() 'lock persistieren
    24. Return True
    25. End Function
    27. ''' <summary>den eigenen RecordLock rausnehmen</summary>
    28. Public Sub UnlockRecord()
    29. Locked.ForEach(Sub(rw) rw.Delete())
    30. Dts.SaveDts() 'unlock persistieren
    31. End Sub
    33. ''' <summary>Refreshen der RecordLock-Tabelle und prüfen, ob bereits ein Lock eines anderen Users besteht</summary>
    34. Private Function IsAlreadyLocked() As Boolean
    35. If Not App.PersistanceModeXml Then Dts.RecordLock.CustomFill("") 'wenn DB-Betrieb, dann muss hier die Tabelle im DataSet mit den Daten aus der Datenbank aktualisiert werden
    36. Dim ToDelete As New List(Of DataRow)
    37. For Each recID In Records
    38. Dim tryLock = Dts.RecordLock.FirstOrDefault(Function(x) x.Tabelle = TableName AndAlso x.DatensatzID = recID)
    39. If tryLock IsNot Nothing Then
    40. If Not tryLock.Timestamp > Date.Now.AddHours(1) Then 'wenn der Lock seit 1 Stunde besteht, dann ist dieser verfallen.
    41. msgError($"Der Datensatz ist seit {tryLock.Timestamp} durch {tryLock.BenutzerRow.Benutzername} | {tryLock.Rechner} gesperrt.")
    42. Return True
    43. Else
    44. ToDelete.Add(tryLock) 'den abgelaufenen Lock löschen
    45. End If
    46. End If
    47. Next
    48. ToDelete.ForEach(Sub(rw) rw.Delete())
    49. Return False
    50. End Function
    52. End Class

    "Na, wie ist das Wetter bei dir?"
    "Caps Lock."
    "Hä?"
    "Shift ohne Ende!" :thumbsup:

    Dieser Beitrag wurde bereits 4 mal editiert, zuletzt von „tragl“ ()

    ne, das war nur ein Gedankengang von mir, ob man das nicht so machen kann.
    Bei Anwendungsstart werden die benötigten Daten aus der DB ins DataSet gesaugt - danach Zugriff auf DB für weitere Programmteile (jeweils immer ins DataSet).
    Und eben für jeden Lock/Unlock zusätzlich auch ein Öffnen/Schließen der Connection.
    "Na, wie ist das Wetter bei dir?"
    "Caps Lock."
    "Hä?"
    "Shift ohne Ende!" :thumbsup: