diff --git a/Sources/MySQLKit/MySQLDialect.swift b/Sources/MySQLKit/MySQLDialect.swift index 0a214f8..0753fe3 100644 --- a/Sources/MySQLKit/MySQLDialect.swift +++ b/Sources/MySQLKit/MySQLDialect.swift @@ -77,4 +77,12 @@ public struct MySQLDialect: SQLDialect { public var unionFeatures: SQLUnionFeatures { [.union, .unionAll, .explicitDistinct, .parenthesizedSubqueries] } + + public var sharedSelectLockExpression: SQLExpression? { + SQLRaw("LOCK IN SHARE MODE") + } + + public var exclusiveSelectLockExpression: SQLExpression? { + SQLRaw("FOR UPDATE") + } }