F# SQLClient typeProvider减少重复代码

open System.Data.SqlClient
open FSharp.Data.Sql

let [<Literal>] connectionString = "your_connection_string_here"

type Sql = SqlDataProvider<ConnectionString = connectionString>

let executeQuery<'a> (query: string) =
    use connection = new SqlConnection(connectionString)
    connection.Open()
    use command = new SqlCommand(query, connection)
    use reader = command.ExecuteReader()
    Sql.executeReader<'a>(reader)

let insert (entity: 'a) =
    let query = Sql.insertQuery typeof<'a> entity
    executeNonQuery query

let update (entity: 'a) =
    let query = Sql.updateQuery typeof<'a> entity
    executeNonQuery query

let delete (entity: 'a) =
    let query = Sql.deleteQuery typeof<'a> entity
    executeNonQuery query

type User = {
    Id: int
    Name: string
    Email: string
}

let usersTable = Sql.getTable "Users"

let getUserById id =
    usersTable |> Sql.filter (fun u -> u.Id = id) |> Sql.executeSingle

let getAllUsers () =
    usersTable |> Sql.executeAsList

let createUser user =
    usersTable |> Sql.insert user

let updateUser user =
    usersTable |> Sql.update user

let deleteUser id =
    usersTable |> Sql.filter (fun u -> u.Id = id) |> Sql.delete

// UserModule.fs
module UserModule =
    let [<Literal>] connectionString = "your_connection_string_here"

    type Sql = SqlDataProvider<ConnectionString = connectionString>

    let usersTable = Sql.getTable "Users"

    let getUserById id =
        usersTable |> Sql.filter (fun u -> u.Id = id) |> Sql.executeSingle

    let getAllUsers () =
        usersTable |> Sql.executeAsList

    let createUser user =
        usersTable |> Sql.insert user

    let updateUser user =
        usersTable |> Sql.update user

    let deleteUser id =
        usersTable |> Sql.filter (fun u -> u.Id = id) |> Sql.delete

type IDatabase =
    abstract member executeQuery: string -> 'a list
    abstract member insert: 'a -> unit
    abstract member update: 'a -> unit
    abstract member delete: int -> unit

type SqlDatabase(connectionString: string) =
    inherit IDatabase
    let sql = SqlDataProvider<ConnectionString = connectionString>

    member this.executeQuery query =
        use connection = new SqlConnection(connectionString)
        connection.Open()
        use command = new SqlCommand(query, connection)
        use reader = command.ExecuteReader()
        sql.executeReader<'a>(reader)

    member this.insert entity =
        let query = sql.insertQuery typeof<'a> entity
        this.executeQuery query |> ignore

    member this.update entity =
        let query = sql.updateQuery typeof<'a> entity
        this.executeQuery query |> ignore

    member this.delete id =
        let query = sql.deleteQuery typeof<'a> id
        this.executeQuery query |> ignore