add function call support

Author: Marcos Magueta

src/SQLProvider.Runtime/Providers.MsSqlServer.Ssdt.fs

@@ -112,7 +112,6 @@ module MSSqlServerSsdt =
                 sb.AppendLine(s.FullName) |> ignore
             failwith (sb.ToString())
 
-
     /// Tries to parse a schema model from the given .dacpac file path.
     let parseDacpac = findDacPacFile >> extractModelXml >> parseXml
 
@@ -367,38 +366,43 @@ type internal MSSqlServerProviderSsdt(tableNames: string, ssdtPath: string) =
             )
 
         member __.GetSprocs(con) =
-            ssdtSchema.Value.StoredProcs
-            |> List.map (fun sp ->
-                let inParams =
-                    sp.Parameters
-                    |> List.mapi (fun idx p ->
-                        { Name = p.Name
-                          TypeMapping = MSSqlServerSsdt.tryFindMappingOrVariant (ssdtSchema.Value.UserDefinedDataTypes) p.DataType
-                          Direction = if p.IsOutput then ParameterDirection.InputOutput else ParameterDirection.Input
-                          Length = p.Length
-                          Ordinal = idx }
-                    )
-                let outParams =
-                    sp.Parameters
-                    |> List.filter (fun p -> p.IsOutput)
-                    |> List.mapi (fun idx p ->
-                        { Name = p.Name
-                          TypeMapping = MSSqlServerSsdt.tryFindMappingOrVariant (ssdtSchema.Value.UserDefinedDataTypes) p.DataType
-                          Direction = ParameterDirection.InputOutput
-                          Length = p.Length
-                          Ordinal = idx }
-                    )
-
-                // If no outParams, add a "ResultSet" property (see issue #706)
-                let outParams =
-                    match outParams with
-                    | [] -> [ sprocReturnParam 0 ]
-                    | _ -> outParams
-
-                let spName = { ProcName = sp.Name; Owner = sp.Schema; PackageName = sp.Schema; }
-
-                Root("Procedures", Sproc({ Name = spName; Params = (fun con -> inParams); ReturnColumns = (fun con sparams -> outParams) }))
-            )
+            let convertExecutable type' elems =
+                elems
+                |> List.map (fun sp ->
+                    let inParams =
+                        sp.Parameters
+                        |> List.mapi (fun idx p ->
+                            { Name = p.Name
+                              TypeMapping = MSSqlServerSsdt.tryFindMappingOrVariant (ssdtSchema.Value.UserDefinedDataTypes) p.DataType
+                              Direction = if p.IsOutput then ParameterDirection.InputOutput else ParameterDirection.Input
+                              Length = p.Length
+                              Ordinal = idx }
+                        )
+                    let outParams =
+                        sp.Parameters
+                        |> List.filter (fun p -> p.IsOutput)
+                        |> List.mapi (fun idx p ->
+                            { Name = p.Name
+                              TypeMapping = MSSqlServerSsdt.tryFindMappingOrVariant (ssdtSchema.Value.UserDefinedDataTypes) p.DataType
+                              Direction = ParameterDirection.InputOutput
+                              Length = p.Length
+                              Ordinal = idx }
+                        )
+    
+                    // If no outParams, add a "ResultSet" property (see issue #706)
+                    let outParams =
+                        match outParams with
+                        | [] -> [ sprocReturnParam 0 ]
+                        | _ -> outParams
+    
+                    let spName = { ProcName = sp.Name; Owner = sp.Schema; PackageName = sp.Schema; }
+    
+                    Root(type', Sproc({ Name = spName; Params = (fun con -> inParams); ReturnColumns = (fun con sparams -> outParams) }))
+                )
+            let sprocs = convertExecutable "Procedures" ssdtSchema.Value.StoredProcs
+            let funcs = convertExecutable "Functions" ssdtSchema.Value.Functions
+            List.append sprocs funcs
+            
         member __.GetIndividualsQueryText(table,amount) = String.Empty // Not implemented for SSDT
         member __.GetIndividualQueryText(table,column) = String.Empty // Not implemented for SSDT
 

src/SQLProvider.Runtime/Ssdt.DacpacParser.fs

@@ -11,6 +11,7 @@ type SsdtSchema = {
     Relationships: SsdtRelationship list
     Descriptions: SsdtDescriptionItem list
     UserDefinedDataTypes: SsdtUserDefinedDataType
+    Functions: SsdtStoredProc list
 }
 and SsdtTable = {
     FullName: string
@@ -377,6 +378,38 @@ let parseXml(xml: string) =
           Name = parts.[1]
           Parameters = parameters |> Seq.toList }
 
+    let parseFunctions (funElement: XmlNode) =
+        let fullName = funElement |> att "Name" |> RegexParsers.splitFullName |> fun n -> String.Join(".", n) |> fun n -> n.ToUpper()
+        let parameters =
+            let paramsNode = funElement |> nodes "x:Relationship" |> Seq.tryFind (fun r -> r |> att "Name" = "Parameters")
+            match paramsNode with
+            | Some e ->
+                e
+                |> nodes "x:Entry"
+                |> Seq.map (fun entry ->
+                    let el = entry |> node "x:Element"
+                    let parameterName = el |> att "Name"
+                    let isOutput =
+                        match el |> nodes "x:Property" |> Seq.tryFind (fun p -> p |> att "Name" = "IsOutput") with
+                        | Some p when p |> att "Value" = "True" -> true
+                        | _ -> false
+                    let dataType =
+                        el
+                        |> node "x:Relationship/x:Entry/x:Element/x:Relationship/x:Entry/x:References"
+                        |> att "Name"
+                    { FullName = parameterName
+                      Name = parameterName |> RegexParsers.splitFullName |> Array.last
+                      DataType = dataType |> removeBrackets
+                      Length = ValueNone
+                      IsOutput = isOutput })
+            | None -> Seq.empty
+        
+        let parts = fullName |> RegexParsers.splitFullName
+        { FullName = fullName
+          Schema = parts.[0]
+          Name = parts.[1]
+          Parameters = parameters |> Seq.toList }
+
     let parseDescription (extElement: XmlNode) =
         let fullName = extElement |> att "Name"
         let parts = fullName |> RegexParsers.splitFullName
@@ -412,6 +445,16 @@ let parseXml(xml: string) =
         |> Seq.map parseUserDefinedDataType
         |> Map.ofSeq
 
+    let functions =
+        let filterPredicate elem =
+            (att "Type" elem) = "SqlScalarFunction"
+            || (att "Type" elem) = "SqlInlineTableValuedFunction"
+        model
+        |> nodes "x:Element"
+        |> Seq.filter filterPredicate
+        |> Seq.map parseFunctions
+        |> Seq.toList
+
     let storedProcs =
         model
         |> nodes "x:Element"
@@ -492,4 +535,5 @@ let parseXml(xml: string) =
       TryGetTableByName = fun nm -> tablesAndViews |> (List.tryFind (fun t -> t.Name = nm) >> function Some x -> ValueSome x | None -> ValueNone)
       Relationships = relationships
       Descriptions = descriptions
-      UserDefinedDataTypes = userDefinedDataTypes } : SsdtSchema
+      UserDefinedDataTypes = userDefinedDataTypes
+      Functions = functions } : SsdtSchema