Skip to content

[WIP] Stop loading table members if static schema is provided. #120

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
isaacabraham merged 1 commit into from
Feb 5, 2019
Merged

[WIP] Stop loading table members if static schema is provided. #120

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
59 changes: 30 additions & 29 deletions src/FSharp.Azure.StorageTypeProvider/Table/TableMemberFactory.fs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -20,30 +20,31 @@ let (|BlobOnlyAccount|FullAccount|) = function
/// Builds up the Table Storage member
let getTableStorageMembers optionalStaticSchema schemaInferenceRowCount humanize (connectionString, domainType : ProvidedTypeDefinition) =
async {
match! (getTableClient connectionString).GetTableReference("1").ExistsAsync() |> Async.AwaitTask |> Async.toAsyncResult with
| BlobOnlyAccount -> return None
| FullAccount ->
let tableListingType = ProvidedTypeDefinition("Tables", Some typeof<obj>, hideObjectMethods = true)
domainType.AddMember tableListingType
let tableListingType = ProvidedTypeDefinition("Tables", Some typeof<obj>, hideObjectMethods = true)
domainType.AddMember tableListingType

/// Creates an individual Table member
let createTableType columnDefinitions connectionString tableName propertyName =
let tableEntityType = ProvidedTypeDefinition(tableName + "Entity", Some typeof<LightweightTableEntity>, hideObjectMethods = true)
let tableType = ProvidedTypeDefinition(tableName + "Table", Some typeof<AzureTable>, hideObjectMethods = true)
domainType.AddMembers [ tableEntityType; tableType ]
/// Creates an individual Table member
let createTableType columnDefinitions connectionString tableName propertyName =
let tableEntityType = ProvidedTypeDefinition(tableName + "Entity", Some typeof<LightweightTableEntity>, hideObjectMethods = true)
let tableType = ProvidedTypeDefinition(tableName + "Table", Some typeof<AzureTable>, hideObjectMethods = true)
domainType.AddMembers [ tableEntityType; tableType ]

TableEntityMemberFactory.buildTableEntityMembers columnDefinitions humanize (tableType, tableEntityType, domainType, connectionString, tableName)
let tableProp = ProvidedProperty(propertyName, tableType, getterCode = (fun _ -> <@@ TableBuilder.createAzureTable connectionString tableName @@>))
tableProp.AddXmlDoc <| sprintf "Provides access to the '%s' table." tableName
tableProp

match optionalStaticSchema with
| Some (optionalStaticSchema:StaticSchema.Parsed.TableSchema) ->
optionalStaticSchema.Tables
|> Array.map(fun table -> createTableType table.Columns connectionString table.Table table.Table)
|> Array.toList
|> tableListingType.AddMembers
| None ->
TableEntityMemberFactory.buildTableEntityMembers columnDefinitions humanize (tableType, tableEntityType, domainType, connectionString, tableName)
let tableProp = ProvidedProperty(propertyName, tableType, getterCode = (fun _ -> <@@ TableBuilder.createAzureTable connectionString tableName @@>))
tableProp.AddXmlDoc <| sprintf "Provides access to the '%s' table." tableName
tableProp

match optionalStaticSchema with
| Some (optionalStaticSchema:StaticSchema.Parsed.TableSchema) ->
optionalStaticSchema.Tables
|> Array.map(fun table -> createTableType table.Columns connectionString table.Table table.Table)
|> Array.toList
|> tableListingType.AddMembers
| None ->
match! (getTableClient connectionString).GetTableReference("1").ExistsAsync() |> Async.AwaitTask |> Async.toAsyncResult with
| BlobOnlyAccount ->
()
| FullAccount ->
tableListingType.AddMembersDelayed(fun _ ->
async {
let! tables = getTables connectionString
Expand Down Expand Up @@ -73,11 +74,11 @@ let getTableStorageMembers optionalStaticSchema schemaInferenceRowCount humanize
metricsTablesProp.AddXmlDoc "Provides access to metrics tables populated by Azure that are available on this storage account."
[ metricsTablesProp ])

let ctcProp = ProvidedProperty("CloudTableClient", typeof<CloudTableClient>, getterCode = (fun _ -> <@@ TableBuilder.createAzureTableRoot connectionString @@>))
ctcProp.AddXmlDoc "Gets a handle to the Table Azure SDK client for this storage account."
tableListingType.AddMember ctcProp
let tableListingProp = ProvidedProperty("Tables", tableListingType, isStatic = true, getterCode = (fun _ -> <@@ () @@>))
tableListingProp.AddXmlDoc "Gets the list of all tables in this storage account."
return Some tableListingProp }
let ctcProp = ProvidedProperty("CloudTableClient", typeof<CloudTableClient>, getterCode = (fun _ -> <@@ TableBuilder.createAzureTableRoot connectionString @@>))
ctcProp.AddXmlDoc "Gets a handle to the Table Azure SDK client for this storage account."
tableListingType.AddMember ctcProp

let tableListingProp = ProvidedProperty("Tables", tableListingType, isStatic = true, getterCode = (fun _ -> <@@ () @@>))
tableListingProp.AddXmlDoc "Gets the list of all tables in this storage account."
return Some tableListingProp }
|> Async.RunSynchronously