SQLProvider/src/SQLProvider.Common/SqlRuntime.Transactions.fs at master · fsprojects/SQLProvider · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
namespace FSharp.Data.Sql.Transactions

open System

/// Corresponds to the System.Transactions.IsolationLevel.
type IsolationLevel =
    | Serializable = 0
    | RepeatableRead = 1
    | ReadCommitted = 2
    | ReadUncommitted = 3
    | Snapshot = 4
    | Chaos = 5
    | Unspecified = 6
    | DontCreateTransaction = 99

/// Corresponds to the System.Transactions.TransactionOptions.
[<Struct>]
type TransactionOptions = {
    Timeout : TimeSpan
    IsolationLevel : IsolationLevel
}

module TransactionUtils =
    let internal toSystemTransactionsIsolationLevel isolationLevel =
        match isolationLevel with
        | IsolationLevel.Serializable -> System.Transactions.IsolationLevel.Serializable
        | IsolationLevel.RepeatableRead -> System.Transactions.IsolationLevel.RepeatableRead
        | IsolationLevel.ReadCommitted -> System.Transactions.IsolationLevel.ReadCommitted
        | IsolationLevel.ReadUncommitted -> System.Transactions.IsolationLevel.ReadUncommitted
        | IsolationLevel.Snapshot -> System.Transactions.IsolationLevel.Snapshot
        | IsolationLevel.Chaos -> System.Transactions.IsolationLevel.Chaos
        | IsolationLevel.Unspecified -> System.Transactions.IsolationLevel.Unspecified
        | _ -> failwithf "Unhandled IsolationLevel value: %A." isolationLevel

    let toSystemDataIsolationLevel isolationLevel =
        match isolationLevel with
        | IsolationLevel.Serializable -> System.Data.IsolationLevel.Serializable
        | IsolationLevel.RepeatableRead -> System.Data.IsolationLevel.RepeatableRead
        | IsolationLevel.ReadCommitted -> System.Data.IsolationLevel.ReadCommitted
        | IsolationLevel.ReadUncommitted -> System.Data.IsolationLevel.ReadUncommitted
        | IsolationLevel.Snapshot -> System.Data.IsolationLevel.Snapshot
        | IsolationLevel.Chaos -> System.Data.IsolationLevel.Chaos
        | IsolationLevel.Unspecified -> System.Data.IsolationLevel.Unspecified
        | _ -> failwithf "Unhandled IsolationLevel value: %A." isolationLevel

    let internal fromSystemTransactionsIsolationLevel isolationLevel =
        match isolationLevel with
        | System.Transactions.IsolationLevel.Serializable -> IsolationLevel.Serializable
        | System.Transactions.IsolationLevel.RepeatableRead -> IsolationLevel.RepeatableRead
        | System.Transactions.IsolationLevel.ReadCommitted -> IsolationLevel.ReadCommitted
        | System.Transactions.IsolationLevel.ReadUncommitted -> IsolationLevel.ReadUncommitted
        | System.Transactions.IsolationLevel.Snapshot -> IsolationLevel.Snapshot
        | System.Transactions.IsolationLevel.Chaos -> IsolationLevel.Chaos
        | System.Transactions.IsolationLevel.Unspecified -> IsolationLevel.Unspecified
        | _ -> failwithf "Unhandled System.Transactions.IsolationLevel value: %A." isolationLevel

    let ensureTransaction (transactionOptions : TransactionOptions) =
        if transactionOptions.IsolationLevel = IsolationLevel.DontCreateTransaction then
            Unchecked.defaultof<Transactions.TransactionScope>
        else
        let transactionOptions =
            Transactions.TransactionOptions(
                Timeout = transactionOptions.Timeout,
                IsolationLevel = toSystemTransactionsIsolationLevel transactionOptions.IsolationLevel)

        let transactionScopeOption = Transactions.TransactionScopeOption.Required // Default

        // Todo: Take TransactionScopeAsyncFlowOption into use when implemented in Mono.
        // Without it, transactions are not thread-safe over threads e.g. using async can be dangerous)
        // However, default option for TransactionScopeOption is Required, so you can create top level transaction
        // and this Mono-transaction will have its properties.
        let isMono = not (isNull(Type.GetType "Mono.Runtime"))
        match isMono with
        | true -> new Transactions.TransactionScope(transactionScopeOption, transactionOptions)
        | false ->
            // Note1: On Mono, 4.6.1 or newer is requred for compiling TransactionScopeAsyncFlowOption.
            new Transactions.TransactionScope(transactionScopeOption, transactionOptions, System.Transactions.TransactionScopeAsyncFlowOption.Enabled)

type TransactionOptions with
    static member Default =
        let sysTranOpt = System.Transactions.TransactionOptions()
        {
            Timeout = sysTranOpt.Timeout
            IsolationLevel = TransactionUtils.fromSystemTransactionsIsolationLevel sysTranOpt.IsolationLevel
        }