.net - 如何通过 SqlProvider 中的反射从数据库上下文中恢复表？

Question

我正在尝试拥有一个强大的客户端查询 API，客户端可以在其中指定要在哪个表中运行查询以及查询的条件。当然，这并不能替代成熟的 LINQ 或 SQL，只是为了让 JS 客户端可以在没有连接的情况下对表进行复杂的查询。

现在，大部分已经完成了，如下图。客户端向我发送一个 JSON 序列化的 Predicate(我使用 JSON.NET 对其进行反序列化)，我可以轻松地将其组合成一个查询。

module Query =
    open System.Linq
    open FSharp.Data.Sql.Common
    open FSharpComposableQuery

    type Predicate =
    | All
    | Greater of string * System.IComparable
    | GreaterEq of string * System.IComparable
    | Lesser of string * System.IComparable
    | LesserEq of string * System.IComparable
    | Equal of string * obj
    | Diff of string * obj
    | And of Predicate * Predicate
    | Or of Predicate * Predicate
    | Not of Predicate

    let satisfies (table : IQueryable<SqlEntity>) =
        <@ fun p -> query {
           for c in table do
           if p c
           then yield c
          } @>

    let rec eval t =
        match t with
            | All                   -> <@ fun _ -> true @>
            | Greater (column, n)   -> <@ fun (c : SqlEntity) -> c.GetColumn column > n @>
            | GreaterEq (column, n) -> <@ fun c -> c.GetColumn column >= n @>
            | Lesser (column, n)    -> <@ fun c -> c.GetColumn column < n @>
            | LesserEq (column, n)  -> <@ fun c -> c.GetColumn column <= n @>
            | Equal (column, n)     -> <@ fun c -> c.GetColumn column = n @>
            | Diff (column, n)      -> <@ fun c -> c.GetColumn column <> n @>
            | And (p1, p2)          -> <@ fun c -> (%eval p1) c && (%eval p2) c @>
            | Or (p1, p2)           -> <@ fun c -> (%eval p1) c || (%eval p2) c @>
            | Not p                 -> <@ fun c -> not((%eval p) c) @>

    let predicate = Or (Equal ("myColumn", "myValue"), Equal ("myColumn", "myOtherValue"))
    let t = query {
        for c in <someDataProvidedTable> do
        select (c :> SqlEntity)
    }
    let result = query { yield! (%satisfies t) (%eval predicate) } |> Seq.toArray

module DataLayer =
    open FSharp.Data.Sql
    open FSharp.Data.Sql.Common
    let [<Literal>] ConnectionString = "Data Source=" + __SOURCE_DIRECTORY__ + @"/db.sqlite3;Version=3"
    type Sql = SqlDataProvider<
                ConnectionString = ConnectionString,
                DatabaseVendor = Common.DatabaseProviderTypes.SQLITE,
                IndividualsAmount = 1000,
                UseOptionTypes = true >
    let ctx = Sql.GetDataContext()
    let db = ctx.Maint

剩下要参数化的就是……表格。 DataLayer.db 具有与我的表等效的表对象，我的函数接受这些表对象。但我希望客户端能够将表格作为字符串发送给我，然后我检查 DataLayer.db 以从中检索表格。

现在，我知道我可以通过从字符串到表对象的字典来解决这个问题。但这会使整个结构的可用性降低(我们从外部 DSL 生成架构和客户端)。当然，我已经尝试过 DataLayer.db.GetType().InvokeMethod，但无论参数是什么，我都会得到以下异常。

System.MissingMethodException: Method 'FSharp.Data.Sql.Runtime.SqlDataContext.FsmIssue' not found.
  at System.RuntimeType.InvokeMember (System.String name, System.Reflection.BindingFlags bindingFlags, System.Reflection.Binder binder, System.Object target, System.Object[] providedArgs, System.Reflection.ParameterModifier[] modifiers, System.Globalization.CultureInfo culture, System.String[] namedParams) [0x008a0] in <dca3b561b8ad4f9fb10141d81b39ff45>:0 
  at System.Type.InvokeMember (System.String name, System.Reflection.BindingFlags invokeAttr, System.Reflection.Binder binder, System.Object target, System.Object[] args) [0x00000] in <dca3b561b8ad4f9fb10141d81b39ff45>:0 
  at <StartupCode$FSI_0062>.$FSI_0062.main@ () [0x0001a] in <906a7cff96cb466bbad0babb35abf8de>:0 
  at (wrapper managed-to-native) System.Reflection.MonoMethod:InternalInvoke (System.Reflection.MonoMethod,object,object[],System.Exception&)
  at System.Reflection.MonoMethod.Invoke (System.Object obj, System.Reflection.BindingFlags invokeAttr, System.Reflection.Binder binder, System.Object[] parameters, System.Globalization.CultureInfo culture) [0x00038] in <dca3b561b8ad4f9fb10141d81b39ff45>:0 
Stopped due to error

那么，有人能帮帮我吗？

Answer 1

您可以使用下面的 getTable 之类的定义函数，它将针对给定的上下文和表全名返回 IQueryable:

open FSharp.Data.Sql
open System.Reflection
open FSharp.Data.Sql.Common
open System.Linq

type DB = SqlDataProvider< 
              ConnectionString = "Data Source=/Path/to/db",
              DatabaseVendor = Common.DatabaseProviderTypes.SQLITE,
              IndividualsAmount = 1000,
              UseOptionTypes = true>

let getTable ctx (tableFullName: string) =
  let m = 
    ctx.GetType().GetMethod("FSharp-Data-Sql-Common-ISqlDataContext-CreateEntities", BindingFlags.NonPublic ||| BindingFlags.Public ||| BindingFlags.Instance)

  m.Invoke(ctx,[| tableFullName |]) :?> IQueryable<SqlEntity> 

[<EntryPoint>]
let main _ = 
  let ctx = DB.GetDataContext()

  getTable ctx "Main.Test" |> Seq.iter ( fun x-> printfn "%A" x.ColumnValues)

  0 

请注意，tableFullName 是特定于数据库的，如果您查看:FSharp.Data.Sql.Schema.Table source code您注意到它基于 Schema 和 TableName，其中记录成员在特定提供程序中设置:

• MS Access
• MS SQL
• MySQL
• ODBC
• Oracle
• PostgeSQL
• SQLite

编辑:调试/查找实际完整表名的更简单方法

如果对表全名有疑问/问题，您可以依赖 DB.dataContext，它使用各种数据库对象的全名。

更新:关于访问 Create 的评论中的问题

类似于访问所有记录，create 可以通过反射访问为:

let create ctx (tableFullName: string) (data: (string * obj) seq) =
  let m = 
    ctx.GetType().GetMethod("FSharp-Data-Sql-Common-ISqlDataContext-CreateEntity", BindingFlags.NonPublic ||| BindingFlags.Public ||| BindingFlags.Instance)

  let e = m.Invoke(ctx,[| tableFullName |]) :?> SqlEntity
  e._State <- Created
  e.SetData data
  e.DataContext.SubmitChangedEntity e
  e


[<EntryPoint>]
let main _ = 
  let ctx = DB2.GetDataContext()

  seq { yield "test",232L:>obj } |> create ctx "Main.Test" |> ignore

  ctx.SubmitUpdates()
  0 

这个特殊的例子利用(string * obj) seq 作为参数，如FSharp.Data.Sql.SqlDesignTime 中所示在 create3 中。它可以根据 create1 或 create2 或任何其他需要的方式进行调整。