namespace BitBadger.Documents.Postgres
open Npgsql
open Npgsql.FSharp
open WithProps
/// F# Extensions for the NpgsqlConnection type
[]
module Extensions =
type NpgsqlConnection with
/// Execute a query that returns a list of results
/// The query to retrieve the results
/// Parameters to use for the query
/// The mapping function between the document and the domain item
/// A list of results for the given query
member conn.customList<'TDoc> query parameters (mapFunc: RowReader -> 'TDoc) =
Custom.list<'TDoc> query parameters mapFunc (Sql.existingConnection conn)
/// Execute a query that returns a JSON array of results
/// The query to retrieve the results
/// Parameters to use for the query
/// The mapping function to extract the document
/// A JSON array of results for the given query
member conn.customJsonArray query parameters mapFunc =
Custom.jsonArray query parameters mapFunc (Sql.existingConnection conn)
/// Execute a query, writing its results to the given PipeWriter
/// The query to retrieve the results
/// Parameters to use for the query
/// The PipeWriter to which the results should be written
/// The mapping function to extract the document
member conn.writeCustomJsonArray query parameters writer mapFunc =
Custom.writeJsonArray query parameters writer mapFunc (Sql.existingConnection conn)
/// Execute a query that returns one or no results
/// The query to retrieve the results
/// Parameters to use for the query
/// The mapping function between the document and the domain item
/// Some with the first matching result, or None if not found
member conn.customSingle<'TDoc> query parameters (mapFunc: RowReader -> 'TDoc) =
Custom.single<'TDoc> query parameters mapFunc (Sql.existingConnection conn)
/// Execute a query that returns one or no JSON documents
/// The query to retrieve the results
/// Parameters to use for the query
/// The mapping function to extract the document
/// The JSON document with the first matching result, or an empty document if not found
member conn.customJsonSingle query parameters mapFunc =
Custom.jsonSingle query parameters mapFunc (Sql.existingConnection conn)
/// Execute a query that returns no results
/// The query to retrieve the results
/// Parameters to use for the query
member conn.customNonQuery query parameters =
Custom.nonQuery query parameters (Sql.existingConnection conn)
/// Execute a query that returns a scalar value
/// The query to retrieve the value
/// Parameters to use for the query
/// The mapping function to obtain the value
/// The scalar value for the query
member conn.customScalar<'T when 'T: struct> query parameters (mapFunc: RowReader -> 'T) =
Custom.scalar query parameters mapFunc (Sql.existingConnection conn)
/// Create a document table
/// The table whose existence should be ensured (may include schema)
member conn.ensureTable name =
Definition.ensureTable name (Sql.existingConnection conn)
/// Create an index on documents in the specified table
/// The table to be indexed (may include schema)
/// The type of document index to create
member conn.ensureDocumentIndex name idxType =
Definition.ensureDocumentIndex name idxType (Sql.existingConnection conn)
/// Create an index on field(s) within documents in the specified table
/// The table to be indexed (may include schema)
/// The name of the index to create
/// One or more fields to be indexed
member conn.ensureFieldIndex tableName indexName fields =
Definition.ensureFieldIndex tableName indexName fields (Sql.existingConnection conn)
/// Insert a new document
/// The table into which the document should be inserted (may include schema)
/// The document to be inserted
member conn.insert<'TDoc> tableName (document: 'TDoc) =
insert<'TDoc> tableName document (Sql.existingConnection conn)
///
/// Save a document, inserting it if it does not exist and updating it if it does (AKA "upsert")
///
/// The table into which the document should be saved (may include schema)
/// The document to be saved
member conn.save<'TDoc> tableName (document: 'TDoc) =
save<'TDoc> tableName document (Sql.existingConnection conn)
/// Count all documents in a table
/// The table in which documents should be counted (may include schema)
/// The count of the documents in the table
member conn.countAll tableName =
Count.all tableName (Sql.existingConnection conn)
/// Count matching documents using JSON field comparisons (->> =, etc.)
/// The table in which documents should be counted (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// The count of matching documents in the table
member conn.countByFields tableName howMatched fields =
Count.byFields tableName howMatched fields (Sql.existingConnection conn)
/// Count matching documents using a JSON containment query (@>)
/// The table in which documents should be counted (may include schema)
/// The document to match with the containment query
/// The count of the documents in the table
member conn.countByContains tableName criteria =
Count.byContains tableName criteria (Sql.existingConnection conn)
/// Count matching documents using a JSON Path match query (@?)
/// The table in which documents should be counted (may include schema)
/// The JSON Path expression to be matched
/// The count of the documents in the table
member conn.countByJsonPath tableName jsonPath =
Count.byJsonPath tableName jsonPath (Sql.existingConnection conn)
/// Determine if a document exists for the given ID
/// The table in which existence should be checked (may include schema)
/// The ID of the document whose existence should be checked
/// True if a document exists, false if not
member conn.existsById tableName docId =
Exists.byId tableName docId (Sql.existingConnection conn)
/// Determine if a document exists using JSON field comparisons (->> =, etc.)
/// The table in which existence should be checked (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// True if any matching documents exist, false if not
member conn.existsByFields tableName howMatched fields =
Exists.byFields tableName howMatched fields (Sql.existingConnection conn)
/// Determine if a document exists using a JSON containment query (@>)
/// The table in which existence should be checked (may include schema)
/// The document to match with the containment query
/// True if any matching documents exist, false if not
member conn.existsByContains tableName criteria =
Exists.byContains tableName criteria (Sql.existingConnection conn)
/// Determine if a document exists using a JSON Path match query (@?)
/// The table in which existence should be checked (may include schema)
/// The JSON Path expression to be matched
/// True if any matching documents exist, false if not
member conn.existsByJsonPath tableName jsonPath =
Exists.byJsonPath tableName jsonPath (Sql.existingConnection conn)
/// Retrieve all documents in the given table
/// The table from which documents should be retrieved (may include schema)
/// All documents from the given table
member conn.findAll<'TDoc> tableName =
Find.all<'TDoc> tableName (Sql.existingConnection conn)
/// Retrieve all documents in the given table ordered by the given fields in the document
/// The table from which documents should be retrieved (may include schema)
/// Fields by which the results should be ordered
/// All documents from the given table, ordered by the given fields
member conn.findAllOrdered<'TDoc> tableName orderFields =
Find.allOrdered<'TDoc> tableName orderFields (Sql.existingConnection conn)
/// Retrieve a document by its ID
/// The table from which a document should be retrieved (may include schema)
/// The ID of the document to retrieve
/// Some with the document if found, None otherwise
member conn.findById<'TKey, 'TDoc> tableName docId =
Find.byId<'TKey, 'TDoc> tableName docId (Sql.existingConnection conn)
/// Retrieve documents matching JSON field comparisons (->> =, etc.)
/// The table from which documents should be retrieved (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// All documents matching the given fields
member conn.findByFields<'TDoc> tableName howMatched fields =
Find.byFields<'TDoc> tableName howMatched fields (Sql.existingConnection conn)
///
/// Retrieve documents matching JSON field comparisons (->> =, etc.) ordered by the given fields in
/// the document
///
/// The table from which documents should be retrieved (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// Fields by which the results should be ordered
/// All documents matching the given fields, ordered by the other given fields
member conn.findByFieldsOrdered<'TDoc> tableName howMatched queryFields orderFields =
Find.byFieldsOrdered<'TDoc>
tableName howMatched queryFields orderFields (Sql.existingConnection conn)
/// Retrieve documents matching a JSON containment query (@>)
/// The table from which documents should be retrieved (may include schema)
/// The document to match with the containment query
/// All documents matching the given containment query
member conn.findByContains<'TDoc> tableName (criteria: obj) =
Find.byContains<'TDoc> tableName criteria (Sql.existingConnection conn)
///
/// Retrieve documents matching a JSON containment query (@>) ordered by the given fields in the
/// document
///
/// The table from which documents should be retrieved (may include schema)
/// The document to match with the containment query
/// Fields by which the results should be ordered
/// All documents matching the given containment query, ordered by the given fields
member conn.findByContainsOrdered<'TDoc> tableName (criteria: obj) orderFields =
Find.byContainsOrdered<'TDoc> tableName criteria orderFields (Sql.existingConnection conn)
/// Retrieve documents matching a JSON Path match query (@?)
/// The table from which documents should be retrieved (may include schema)
/// The JSON Path expression to match
/// All documents matching the given JSON Path expression
member conn.findByJsonPath<'TDoc> tableName jsonPath =
Find.byJsonPath<'TDoc> tableName jsonPath (Sql.existingConnection conn)
///
/// Retrieve documents matching a JSON Path match query (@?) ordered by the given fields in the document
///
/// The table from which documents should be retrieved (may include schema)
/// The JSON Path expression to match
/// Fields by which the results should be ordered
/// All documents matching the given JSON Path expression, ordered by the given fields
member conn.findByJsonPathOrdered<'TDoc> tableName jsonPath orderFields =
Find.byJsonPathOrdered<'TDoc> tableName jsonPath orderFields (Sql.existingConnection conn)
/// Retrieve the first document matching JSON field comparisons (->> =, etc.)
/// The table from which a document should be retrieved (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// Some with the first document, or None if not found
member conn.findFirstByFields<'TDoc> tableName howMatched fields =
Find.firstByFields<'TDoc> tableName howMatched fields (Sql.existingConnection conn)
///
/// Retrieve the first document matching JSON field comparisons (->> =, etc.) ordered by the given
/// fields in the document
///
/// The table from which a document should be retrieved (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// Fields by which the results should be ordered
///
/// Some with the first document ordered by the given fields, or None if not found
///
member conn.findFirstByFieldsOrdered<'TDoc> tableName howMatched queryFields orderFields =
Find.firstByFieldsOrdered<'TDoc>
tableName howMatched queryFields orderFields (Sql.existingConnection conn)
/// Retrieve the first document matching a JSON containment query (@>)
/// The table from which a document should be retrieved (may include schema)
/// The document to match with the containment query
/// Some with the first document, or None if not found
member conn.findFirstByContains<'TDoc> tableName (criteria: obj) =
Find.firstByContains<'TDoc> tableName criteria (Sql.existingConnection conn)
///
/// Retrieve the first document matching a JSON containment query (@>) ordered by the given fields in
/// the document
///
/// The table from which a document should be retrieved (may include schema)
/// The document to match with the containment query
/// Fields by which the results should be ordered
///
/// Some with the first document ordered by the given fields, or None if not found
///
member conn.findFirstByContainsOrdered<'TDoc> tableName (criteria: obj) orderFields =
Find.firstByContainsOrdered<'TDoc> tableName criteria orderFields (Sql.existingConnection conn)
/// Retrieve the first document matching a JSON Path match query (@?)
/// The table from which a document should be retrieved (may include schema)
/// The JSON Path expression to match
/// Some with the first document, or None if not found
member conn.findFirstByJsonPath<'TDoc> tableName jsonPath =
Find.firstByJsonPath<'TDoc> tableName jsonPath (Sql.existingConnection conn)
///
/// Retrieve the first document matching a JSON Path match query (@?) ordered by the given fields in the
/// document
///
/// The table from which a document should be retrieved (may include schema)
/// The JSON Path expression to match
/// Fields by which the results should be ordered
///
/// Some with the first document ordered by the given fields, or None if not found
///
member conn.findFirstByJsonPathOrdered<'TDoc> tableName jsonPath orderFields =
Find.firstByJsonPathOrdered<'TDoc> tableName jsonPath orderFields (Sql.existingConnection conn)
/// Retrieve all documents in the given table as a JSON array
/// The table from which documents should be retrieved (may include schema)
/// All documents from the given table as a JSON array
member conn.jsonAll tableName =
Json.all tableName (Sql.existingConnection conn)
/// Write all documents in the given table to the given PipeWriter
/// The table from which documents should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
member conn.writeJsonAll tableName writer =
Json.writeAll tableName writer (Sql.existingConnection conn)
///
/// Retrieve all documents in the given table as a JSON array, ordered by the given fields in the document
///
/// The table from which documents should be retrieved (may include schema)
/// Fields by which the results should be ordered
/// All documents from the given table as a JSON array, ordered by the given fields
member conn.jsonAllOrdered tableName orderFields =
Json.allOrdered tableName orderFields (Sql.existingConnection conn)
///
/// Write all documents in the given table to the given PipeWriter, ordered by the given fields in the
/// document
///
/// The table from which documents should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// Fields by which the results should be ordered
member conn.writeJsonAllOrdered tableName writer orderFields =
Json.writeAllOrdered tableName writer orderFields (Sql.existingConnection conn)
/// Retrieve a JSON document by its ID
/// The table from which a document should be retrieved (may include schema)
/// The ID of the document to retrieve
/// The JSON document if found, an empty JSON document otherwise
member conn.jsonById<'TKey> tableName (docId: 'TKey) =
Json.byId tableName docId (Sql.existingConnection conn)
/// Write a JSON document to the given PipeWriter by its ID
/// The table from which a document should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// The ID of the document to retrieve
member conn.writeJsonById<'TKey> tableName writer (docId: 'TKey) =
Json.writeById tableName writer docId (Sql.existingConnection conn)
/// Retrieve JSON documents matching JSON field comparisons (->> =, etc.)
/// The table from which documents should be retrieved (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// All JSON documents matching the given fields
member conn.jsonByFields tableName howMatched fields =
Json.byFields tableName howMatched fields (Sql.existingConnection conn)
///
/// Write JSON documents to the given PipeWriter matching JSON field comparisons (->> =,
/// etc.)
///
/// The table from which documents should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// Whether to match any or all of the field conditions
/// The field conditions to match
member conn.writeJsonByFields tableName writer howMatched fields =
Json.writeByFields tableName writer howMatched fields (Sql.existingConnection conn)
///
/// Retrieve JSON documents matching JSON field comparisons (->> =, etc.) ordered by the given
/// fields in the document
///
/// The table from which documents should be retrieved (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// Fields by which the results should be ordered
/// All JSON documents matching the given fields, ordered by the other given fields
member conn.jsonByFieldsOrdered tableName howMatched queryFields orderFields =
Json.byFieldsOrdered tableName howMatched queryFields orderFields (Sql.existingConnection conn)
///
/// Write JSON documents to the given PipeWriter matching JSON field comparisons (->> =,
/// etc.) ordered by the given fields in the document
///
/// The table from which documents should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// Fields by which the results should be ordered
member conn.writeJsonByFieldsOrdered tableName writer howMatched queryFields orderFields =
Json.writeByFieldsOrdered tableName writer howMatched queryFields orderFields (Sql.existingConnection conn)
/// Retrieve JSON documents matching a JSON containment query (@>)
/// The table from which documents should be retrieved (may include schema)
/// The document to match with the containment query
/// All JSON documents matching the given containment query
member conn.jsonByContains tableName (criteria: obj) =
Json.byContains tableName criteria (Sql.existingConnection conn)
///
/// Write JSON documents to the given PipeWriter matching a JSON containment query (@>)
///
/// The table from which documents should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// The document to match with the containment query
member conn.writeJsonByContains tableName writer (criteria: obj) =
Json.writeByContains tableName writer criteria (Sql.existingConnection conn)
///
/// Retrieve JSON documents matching a JSON containment query (@>) ordered by the given fields in the
/// document
///
/// The table from which documents should be retrieved (may include schema)
/// The document to match with the containment query
/// Fields by which the results should be ordered
/// All documents matching the given containment query, ordered by the given fields
member conn.jsonByContainsOrdered tableName (criteria: obj) orderFields =
Json.byContainsOrdered tableName criteria orderFields (Sql.existingConnection conn)
///
/// Write JSON documents to the given PipeWriter matching a JSON containment query (@>) ordered
/// by the given fields in the document
///
/// The table from which documents should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// The document to match with the containment query
/// Fields by which the results should be ordered
member conn.writeJsonByContainsOrdered tableName writer (criteria: obj) orderFields =
Json.writeByContainsOrdered tableName writer criteria orderFields (Sql.existingConnection conn)
/// Retrieve JSON documents matching a JSON Path match query (@?)
/// The table from which documents should be retrieved (may include schema)
/// The JSON Path expression to match
/// All JSON documents matching the given JSON Path expression
member conn.jsonByJsonPath tableName jsonPath =
Json.byJsonPath tableName jsonPath (Sql.existingConnection conn)
///
/// Write JSON documents to the given PipeWriter matching a JSON Path match query (@?)
///
/// The table from which documents should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// The JSON Path expression to match
member conn.writeJsonByJsonPath tableName writer jsonPath =
Json.writeByJsonPath tableName writer jsonPath (Sql.existingConnection conn)
///
/// Retrieve JSON documents matching a JSON Path match query (@?) ordered by the given fields in the
/// document
///
/// The table from which documents should be retrieved (may include schema)
/// The JSON Path expression to match
/// Fields by which the results should be ordered
/// All JSON documents matching the given JSON Path expression, ordered by the given fields
member conn.jsonByJsonPathOrdered tableName jsonPath orderFields =
Json.byJsonPathOrdered tableName jsonPath orderFields (Sql.existingConnection conn)
///
/// Write JSON documents to the given PipeWriter matching a JSON Path match query (@?) ordered by
/// the given fields in the document
///
/// The table from which documents should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// The JSON Path expression to match
/// Fields by which the results should be ordered
member conn.writeJsonByJsonPathOrdered tableName writer jsonPath orderFields =
Json.writeByJsonPathOrdered tableName writer jsonPath orderFields (Sql.existingConnection conn)
///
/// Retrieve the first JSON document matching JSON field comparisons (->> =, etc.)
///
/// The table from which a document should be retrieved (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// The first matching JSON document if found, an empty JSON document otherwise
member conn.jsonFirstByFields tableName howMatched fields =
Json.firstByFields tableName howMatched fields (Sql.existingConnection conn)
///
/// Write the first JSON document to the given PipeWriter matching JSON field comparisons
/// (->> =, etc.)
///
/// The table from which a document should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// Whether to match any or all of the field conditions
/// The field conditions to match
member conn.writeJsonFirstByFields tableName writer howMatched fields =
Json.writeFirstByFields tableName writer howMatched fields (Sql.existingConnection conn)
///
/// Retrieve the first JSON document matching JSON field comparisons (->> =, etc.) ordered by the
/// given fields in the document
///
/// The table from which a document should be retrieved (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// Fields by which the results should be ordered
/// The first matching JSON document if found, an empty JSON document otherwise
member conn.jsonFirstByFieldsOrdered tableName howMatched queryFields orderFields =
Json.firstByFieldsOrdered tableName howMatched queryFields orderFields (Sql.existingConnection conn)
///
/// Write the first JSON document to the given PipeWriter matching JSON field comparisons
/// (->> =, etc.) ordered by the given fields in the document
///
/// The table from which a document should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// Fields by which the results should be ordered
member conn.writeJsonFirstByFieldsOrdered tableName writer howMatched queryFields orderFields =
Json.writeFirstByFieldsOrdered
tableName writer howMatched queryFields orderFields (Sql.existingConnection conn)
/// Retrieve the first JSON document matching a JSON containment query (@>)
/// The table from which a document should be retrieved (may include schema)
/// The document to match with the containment query
/// The first matching JSON document if found, an empty JSON document otherwise
member conn.jsonFirstByContains tableName (criteria: obj) =
Json.firstByContains tableName criteria (Sql.existingConnection conn)
///
/// Write the first JSON document to the given PipeWriter matching a JSON containment query
/// (@>)
///
/// The table from which a document should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// The document to match with the containment query
member conn.writeJsonFirstByContains tableName writer (criteria: obj) =
Json.writeFirstByContains tableName writer criteria (Sql.existingConnection conn)
///
/// Retrieve the first JSON document matching a JSON containment query (@>) ordered by the given
/// fields in the document
///
/// The table from which a document should be retrieved (may include schema)
/// The document to match with the containment query
/// Fields by which the results should be ordered
/// The first matching JSON document if found, an empty JSON document otherwise
member conn.jsonFirstByContainsOrdered tableName (criteria: obj) orderFields =
Json.firstByContainsOrdered tableName criteria orderFields (Sql.existingConnection conn)
///
/// Write the first JSON document to the given PipeWriter matching a JSON containment query
/// (@>) ordered by the given fields in the document
///
/// The table from which a document should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// The document to match with the containment query
/// Fields by which the results should be ordered
member conn.writeJsonFirstByContainsOrdered tableName writer (criteria: obj) orderFields =
Json.writeFirstByContainsOrdered tableName writer criteria orderFields (Sql.existingConnection conn)
/// Retrieve the first JSON document matching a JSON Path match query (@?)
/// The table from which a document should be retrieved (may include schema)
/// The JSON Path expression to match
/// The first matching JSON document if found, an empty JSON document otherwise
member conn.jsonFirstByJsonPath tableName jsonPath =
Json.firstByJsonPath tableName jsonPath (Sql.existingConnection conn)
///
/// Write the first JSON document to the given PipeWriter matching a JSON Path match query (@?)
///
/// The table from which a document should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// The JSON Path expression to match
member conn.writeJsonFirstByJsonPath tableName writer jsonPath =
Json.writeFirstByJsonPath tableName writer jsonPath (Sql.existingConnection conn)
///
/// Retrieve the first JSON document matching a JSON Path match query (@?) ordered by the given fields
/// in the document
///
/// The table from which a document should be retrieved (may include schema)
/// The JSON Path expression to match
/// Fields by which the results should be ordered
/// The first matching JSON document if found, an empty JSON document otherwise
member conn.jsonFirstByJsonPathOrdered tableName jsonPath orderFields =
Json.firstByJsonPathOrdered tableName jsonPath orderFields (Sql.existingConnection conn)
///
/// Write the first JSON document to the given PipeWriter matching a JSON Path match query (@?)
/// ordered by the given fields in the document
///
/// The table from which a document should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// The JSON Path expression to match
/// Fields by which the results should be ordered
member conn.writeJsonFirstByJsonPathOrdered tableName writer jsonPath orderFields =
Json.writeFirstByJsonPathOrdered tableName writer jsonPath orderFields (Sql.existingConnection conn)
/// Update (replace) an entire document by its ID
/// The table in which a document should be updated (may include schema)
/// The ID of the document to be updated (replaced)
/// The new document
member conn.updateById tableName (docId: 'TKey) (document: 'TDoc) =
Update.byId tableName docId document (Sql.existingConnection conn)
///
/// Update (replace) an entire document by its ID, using the provided function to obtain the ID from the
/// document
///
/// The table in which a document should be updated (may include schema)
/// The function to obtain the ID of the document
/// The new document
member conn.updateByFunc tableName (idFunc: 'TDoc -> 'TKey) (document: 'TDoc) =
Update.byFunc tableName idFunc document (Sql.existingConnection conn)
/// Patch a document by its ID
/// The table in which a document should be patched (may include schema)
/// The ID of the document to patch
/// The partial document to patch the existing document
member conn.patchById tableName (docId: 'TKey) (patch: 'TPatch) =
Patch.byId tableName docId patch (Sql.existingConnection conn)
///
/// Patch documents using a JSON field comparison query in the WHERE clause (->> =,
/// etc.)
///
/// The table in which documents should be patched (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// The partial document to patch the existing document
member conn.patchByFields tableName howMatched fields (patch: 'TPatch) =
Patch.byFields tableName howMatched fields patch (Sql.existingConnection conn)
///
/// Patch documents using a JSON containment query in the WHERE clause (@>)
///
/// The table in which documents should be patched (may include schema)
/// The document to match the containment query
/// The partial document to patch the existing document
member conn.patchByContains tableName (criteria: 'TCriteria) (patch: 'TPatch) =
Patch.byContains tableName criteria patch (Sql.existingConnection conn)
/// Patch documents using a JSON Path match query in the WHERE clause (@?)
/// The table in which documents should be patched (may include schema)
/// The JSON Path expression to match
/// The partial document to patch the existing document
member conn.patchByJsonPath tableName jsonPath (patch: 'TPatch) =
Patch.byJsonPath tableName jsonPath patch (Sql.existingConnection conn)
/// Remove fields from a document by the document's ID
/// The table in which a document should be modified (may include schema)
/// The ID of the document to modify
/// One or more field names to remove from the document
member conn.removeFieldsById tableName (docId: 'TKey) fieldNames =
RemoveFields.byId tableName docId fieldNames (Sql.existingConnection conn)
/// Remove fields from documents via a comparison on JSON fields in the document
/// The table in which documents should be modified (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// One or more field names to remove from the matching documents
member conn.removeFieldsByFields tableName howMatched fields fieldNames =
RemoveFields.byFields tableName howMatched fields fieldNames (Sql.existingConnection conn)
/// Remove fields from documents via a JSON containment query (@>)
/// The table in which documents should be modified (may include schema)
/// The document to match the containment query
/// One or more field names to remove from the matching documents
member conn.removeFieldsByContains tableName (criteria: 'TContains) fieldNames =
RemoveFields.byContains tableName criteria fieldNames (Sql.existingConnection conn)
/// Remove fields from documents via a JSON Path match query (@?)
/// The table in which documents should be modified (may include schema)
/// The JSON Path expression to match
/// One or more field names to remove from the matching documents
member conn.removeFieldsByJsonPath tableName jsonPath fieldNames =
RemoveFields.byJsonPath tableName jsonPath fieldNames (Sql.existingConnection conn)
/// Delete a document by its ID
/// The table in which a document should be deleted (may include schema)
/// The ID of the document to delete
member conn.deleteById tableName (docId: 'TKey) =
Delete.byId tableName docId (Sql.existingConnection conn)
/// Delete documents by matching a JSON field comparison query (->> =, etc.)
/// The table in which documents should be deleted (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
member conn.deleteByFields tableName howMatched fields =
Delete.byFields tableName howMatched fields (Sql.existingConnection conn)
/// Delete documents by matching a JSON contains query (@>)
/// The table in which documents should be deleted (may include schema)
/// The document to match the containment query
member conn.deleteByContains tableName (criteria: 'TContains) =
Delete.byContains tableName criteria (Sql.existingConnection conn)
/// Delete documents by matching a JSON Path match query (@?)
/// The table in which documents should be deleted (may include schema)
/// The JSON Path expression to match
member conn.deleteByJsonPath tableName jsonPath =
Delete.byJsonPath tableName jsonPath (Sql.existingConnection conn)
open System.Runtime.CompilerServices
/// C# extensions on the NpgsqlConnection type
type NpgsqlConnectionCSharpExtensions =
/// Execute a query that returns a list of results
/// The NpgsqlConnection on which to run the query
/// The query to retrieve the results
/// Parameters to use for the query
/// The mapping function between the document and the domain item
/// A list of results for the given query
[]
static member inline CustomList<'TDoc>(conn, query, parameters, mapFunc: System.Func) =
Custom.List<'TDoc>(query, parameters, mapFunc, Sql.existingConnection conn)
/// Execute a query that returns a JSON array of results
/// The NpgsqlConnection on which to run the query
/// The query to retrieve the results
/// Parameters to use for the query
/// The mapping function to extract the document
/// A JSON array of results for the given query
[]
static member inline CustomJsonArray(conn, query, parameters, mapFunc) =
Custom.JsonArray(query, parameters, mapFunc, Sql.existingConnection conn)
/// Execute a query, writing its results to the given PipeWriter
/// The NpgsqlConnection on which to run the query
/// The query to retrieve the results
/// Parameters to use for the query
/// The PipeWriter to which the results should be written
/// The mapping function to extract the document
[]
static member inline WriteCustomJsonArray(conn, query, parameters, writer, mapFunc) =
Custom.WriteJsonArray(query, parameters, writer, mapFunc, Sql.existingConnection conn)
/// Execute a query that returns one or no results
/// The NpgsqlConnection on which to run the query
/// The query to retrieve the results
/// Parameters to use for the query
/// The mapping function between the document and the domain item
/// The first matching result, or null if not found
[]
static member inline CustomSingle<'TDoc when 'TDoc: null and 'TDoc: not struct>(
conn, query, parameters, mapFunc: System.Func) =
Custom.Single<'TDoc>(query, parameters, mapFunc, Sql.existingConnection conn)
/// Execute a query that returns one or no JSON documents
/// The NpgsqlConnection on which to run the query
/// The query to retrieve the results
/// Parameters to use for the query
/// The mapping function to extract the document
/// The JSON document with the first matching result, or an empty document if not found
[]
static member inline CustomJsonSingle(conn, query, parameters, mapFunc) =
Custom.JsonSingle(query, parameters, mapFunc, Sql.existingConnection conn)
/// Execute a query that returns no results
/// The NpgsqlConnection on which to run the query
/// The query to retrieve the results
/// Parameters to use for the query
[]
static member inline CustomNonQuery(conn, query, parameters) =
Custom.nonQuery query parameters (Sql.existingConnection conn)
/// Execute a query that returns a scalar value
/// The NpgsqlConnection on which to run the query
/// The query to retrieve the value
/// Parameters to use for the query
/// The mapping function to obtain the value
/// The scalar value for the query
[]
static member inline CustomScalar<'T when 'T: struct>(
conn, query, parameters, mapFunc: System.Func) =
Custom.Scalar(query, parameters, mapFunc, Sql.existingConnection conn)
/// Create a document table
/// The NpgsqlConnection on which to run the query
/// The table whose existence should be ensured (may include schema)
[]
static member inline EnsureTable(conn, name) =
Definition.ensureTable name (Sql.existingConnection conn)
/// Create an index on documents in the specified table
/// The NpgsqlConnection on which to run the query
/// The table to be indexed (may include schema)
/// The type of document index to create
[]
static member inline EnsureDocumentIndex(conn, name, idxType) =
Definition.ensureDocumentIndex name idxType (Sql.existingConnection conn)
/// Create an index on field(s) within documents in the specified table
/// The NpgsqlConnection on which to run the query
/// The table to be indexed (may include schema)
/// The name of the index to create
/// One or more fields to be indexed
[]
static member inline EnsureFieldIndex(conn, tableName, indexName, fields) =
Definition.ensureFieldIndex tableName indexName fields (Sql.existingConnection conn)
/// Insert a new document
/// The NpgsqlConnection on which to run the query
/// The table into which the document should be inserted (may include schema)
/// The document to be inserted
[]
static member inline Insert<'TDoc>(conn, tableName, document: 'TDoc) =
insert<'TDoc> tableName document (Sql.existingConnection conn)
/// Save a document, inserting it if it does not exist and updating it if it does (AKA "upsert")
/// The NpgsqlConnection on which to run the query
/// The table into which the document should be saved (may include schema)
/// The document to be saved
[]
static member inline Save<'TDoc>(conn, tableName, document: 'TDoc) =
save<'TDoc> tableName document (Sql.existingConnection conn)
/// Count all documents in a table
/// The NpgsqlConnection on which to run the query
/// The table in which documents should be counted (may include schema)
/// The count of the documents in the table
[]
static member inline CountAll(conn, tableName) =
Count.all tableName (Sql.existingConnection conn)
/// Count matching documents using JSON field comparisons (->> =, etc.)
/// The NpgsqlConnection on which to run the query
/// The table in which documents should be counted (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// The count of matching documents in the table
[]
static member inline CountByFields(conn, tableName, howMatched, fields) =
Count.byFields tableName howMatched fields (Sql.existingConnection conn)
/// Count matching documents using a JSON containment query (@>)
/// The NpgsqlConnection on which to run the query
/// The table in which documents should be counted (may include schema)
/// The document to match with the containment query
/// The count of the documents in the table
[]
static member inline CountByContains(conn, tableName, criteria: 'TCriteria) =
Count.byContains tableName criteria (Sql.existingConnection conn)
/// Count matching documents using a JSON Path match query (@?)
/// The NpgsqlConnection on which to run the query
/// The table in which documents should be counted (may include schema)
/// The JSON Path expression to be matched
/// The count of the documents in the table
[]
static member inline CountByJsonPath(conn, tableName, jsonPath) =
Count.byJsonPath tableName jsonPath (Sql.existingConnection conn)
/// Determine if a document exists for the given ID
/// The NpgsqlConnection on which to run the query
/// The table in which existence should be checked (may include schema)
/// The ID of the document whose existence should be checked
/// True if a document exists, false if not
[]
static member inline ExistsById(conn, tableName, docId) =
Exists.byId tableName docId (Sql.existingConnection conn)
/// Determine if a document exists using JSON field comparisons (->> =, etc.)
/// The NpgsqlConnection on which to run the query
/// The table in which existence should be checked (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// True if any matching documents exist, false if not
[]
static member inline ExistsByFields(conn, tableName, howMatched, fields) =
Exists.byFields tableName howMatched fields (Sql.existingConnection conn)
/// Determine if a document exists using a JSON containment query (@>)
/// The NpgsqlConnection on which to run the query
/// The table in which existence should be checked (may include schema)
/// The document to match with the containment query
/// True if any matching documents exist, false if not
[]
static member inline ExistsByContains(conn, tableName, criteria: 'TCriteria) =
Exists.byContains tableName criteria (Sql.existingConnection conn)
/// Determine if a document exists using a JSON Path match query (@?)
/// The NpgsqlConnection on which to run the query
/// The table in which existence should be checked (may include schema)
/// The JSON Path expression to be matched
/// True if any matching documents exist, false if not
[]
static member inline ExistsByJsonPath(conn, tableName, jsonPath) =
Exists.byJsonPath tableName jsonPath (Sql.existingConnection conn)
/// Retrieve all documents in the given table
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// All documents from the given table
[]
static member inline FindAll<'TDoc>(conn, tableName) =
Find.All<'TDoc>(tableName, Sql.existingConnection conn)
/// Retrieve all documents in the given table ordered by the given fields in the document
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// Fields by which the results should be ordered
/// All documents from the given table, ordered by the given fields
[]
static member inline FindAllOrdered<'TDoc>(conn, tableName, orderFields) =
Find.AllOrdered<'TDoc>(tableName, orderFields, Sql.existingConnection conn)
/// Retrieve a document by its ID
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// The ID of the document to retrieve
/// The document if found, null otherwise
[]
static member inline FindById<'TKey, 'TDoc when 'TDoc: null and 'TDoc: not struct>(conn, tableName, docId: 'TKey) =
Find.ById<'TKey, 'TDoc>(tableName, docId, Sql.existingConnection conn)
/// Retrieve documents matching JSON field comparisons (->> =, etc.)
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// All documents matching the given fields
[]
static member inline FindByFields<'TDoc>(conn, tableName, howMatched, fields) =
Find.ByFields<'TDoc>(tableName, howMatched, fields, Sql.existingConnection conn)
///
/// Retrieve documents matching JSON field comparisons (->> =, etc.) ordered by the given fields in the
/// document
///
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// Fields by which the results should be ordered
/// All documents matching the given fields, ordered by the other given fields
[]
static member inline FindByFieldsOrdered<'TDoc>(conn, tableName, howMatched, queryFields, orderFields) =
Find.ByFieldsOrdered<'TDoc>(
tableName, howMatched, queryFields, orderFields, Sql.existingConnection conn)
/// Retrieve documents matching a JSON containment query (@>)
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// The document to match with the containment query
/// All documents matching the given containment query
[]
static member inline FindByContains<'TDoc>(conn, tableName, criteria: obj) =
Find.ByContains<'TDoc>(tableName, criteria, Sql.existingConnection conn)
///
/// Retrieve documents matching a JSON containment query (@>) ordered by the given fields in the document
///
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// The document to match with the containment query
/// Fields by which the results should be ordered
/// All documents matching the given containment query, ordered by the given fields
[]
static member inline FindByContainsOrdered<'TDoc>(conn, tableName, criteria: obj, orderFields) =
Find.ByContainsOrdered<'TDoc>(tableName, criteria, orderFields, Sql.existingConnection conn)
/// Retrieve documents matching a JSON Path match query (@?)
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// The JSON Path expression to match
/// All documents matching the given JSON Path expression
[]
static member inline FindByJsonPath<'TDoc>(conn, tableName, jsonPath) =
Find.ByJsonPath<'TDoc>(tableName, jsonPath, Sql.existingConnection conn)
///
/// Retrieve documents matching a JSON Path match query (@?) ordered by the given fields in the document
///
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// The JSON Path expression to match
/// Fields by which the results should be ordered
/// All documents matching the given JSON Path expression, ordered by the given fields
[]
static member inline FindByJsonPathOrdered<'TDoc>(conn, tableName, jsonPath, orderFields) =
Find.ByJsonPathOrdered<'TDoc>(tableName, jsonPath, orderFields, Sql.existingConnection conn)
/// Retrieve the first document matching JSON field comparisons (->> =, etc.)
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// The first document, or null if not found
[]
static member inline FindFirstByFields<'TDoc when 'TDoc: null and 'TDoc: not struct>(
conn, tableName, howMatched, fields) =
Find.FirstByFields<'TDoc>(tableName, howMatched, fields, Sql.existingConnection conn)
///
/// Retrieve the first document matching JSON field comparisons (->> =, etc.) ordered by the given
/// fields in the document
///
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// Fields by which the results should be ordered
/// The first document ordered by the given fields, or null if not found
[]
static member inline FindFirstByFieldsOrdered<'TDoc when 'TDoc: null and 'TDoc: not struct>(
conn, tableName, howMatched, queryFields, orderFields) =
Find.FirstByFieldsOrdered<'TDoc>(
tableName, howMatched, queryFields, orderFields, Sql.existingConnection conn)
/// Retrieve the first document matching a JSON containment query (@>)
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// The document to match with the containment query
/// The first document, or null if not found
[]
static member inline FindFirstByContains<'TDoc when 'TDoc: null and 'TDoc: not struct>(
conn, tableName, criteria: obj) =
Find.FirstByContains<'TDoc>(tableName, criteria, Sql.existingConnection conn)
///
/// Retrieve the first document matching a JSON containment query (@>) ordered by the given fields in the
/// document
///
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// The document to match with the containment query
/// Fields by which the results should be ordered
/// The first document ordered by the given fields, or null if not found
[]
static member inline FindFirstByContainsOrdered<'TDoc when 'TDoc: null and 'TDoc: not struct>(
conn, tableName, criteria: obj, orderFields) =
Find.FirstByContainsOrdered<'TDoc>(tableName, criteria, orderFields, Sql.existingConnection conn)
/// Retrieve the first document matching a JSON Path match query (@?)
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// The JSON Path expression to match
/// The first document, or null if not found
[]
static member inline FindFirstByJsonPath<'TDoc when 'TDoc: null and 'TDoc: not struct>(conn, tableName, jsonPath) =
Find.FirstByJsonPath<'TDoc>(tableName, jsonPath, Sql.existingConnection conn)
///
/// Retrieve the first document matching a JSON Path match query (@?) ordered by the given fields in the
/// document
///
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// The JSON Path expression to match
/// Fields by which the results should be ordered
/// The first document ordered by the given fields, or null if not found
[]
static member inline FindFirstByJsonPathOrdered<'TDoc when 'TDoc: null and 'TDoc: not struct>(
conn, tableName, jsonPath, orderFields) =
Find.FirstByJsonPathOrdered<'TDoc>(tableName, jsonPath, orderFields, Sql.existingConnection conn)
/// Retrieve all documents in the given table as a JSON array
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// All documents from the given table as a JSON array
[]
static member inline JsonAll(conn, tableName) =
Json.all tableName (Sql.existingConnection conn)
/// Write all documents in the given table to the given PipeWriter
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
[]
static member inline WriteJsonAll(conn, tableName, writer) =
Json.writeAll tableName writer (Sql.existingConnection conn)
///
/// Retrieve all documents in the given table as a JSON array, ordered by the given fields in the document
///
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// Fields by which the results should be ordered
/// All documents from the given table as a JSON array, ordered by the given fields
[]
static member inline JsonAllOrdered(conn, tableName, orderFields) =
Json.allOrdered tableName orderFields (Sql.existingConnection conn)
///
/// Write all documents in the given table to the given PipeWriter, ordered by the given fields in the
/// document
///
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// Fields by which the results should be ordered
[]
static member inline WriteJsonAllOrdered(conn, tableName, writer, orderFields) =
Json.writeAllOrdered tableName writer orderFields (Sql.existingConnection conn)
/// Retrieve a JSON document by its ID
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// The ID of the document to retrieve
/// The JSON document if found, an empty JSON document otherwise
[]
static member inline JsonById<'TKey>(conn, tableName, docId: 'TKey) =
Json.byId tableName docId (Sql.existingConnection conn)
/// Write a JSON document to the given PipeWriter by its ID
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// The ID of the document to retrieve
[]
static member inline WriteJsonById<'TKey>(conn, tableName, writer, docId) =
Json.writeById tableName writer docId (Sql.existingConnection conn)
/// Retrieve JSON documents matching JSON field comparisons (->> =, etc.)
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// All JSON documents matching the given fields
[]
static member inline JsonByFields(conn, tableName, howMatched, fields) =
Json.byFields tableName howMatched fields (Sql.existingConnection conn)
///
/// Write JSON documents to the given PipeWriter matching JSON field comparisons (->> =, etc.)
///
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// Whether to match any or all of the field conditions
/// The field conditions to match
[]
static member inline WriteJsonByFields(conn, tableName, writer, howMatched, fields) =
Json.writeByFields tableName writer howMatched fields (Sql.existingConnection conn)
///
/// Retrieve JSON documents matching JSON field comparisons (->> =, etc.) ordered by the given fields
/// in the document
///
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// Fields by which the results should be ordered
/// All JSON documents matching the given fields, ordered by the other given fields
[]
static member inline JsonByFieldsOrdered(conn, tableName, howMatched, queryFields, orderFields) =
Json.byFieldsOrdered tableName howMatched queryFields orderFields (Sql.existingConnection conn)
///
/// Write JSON documents to the given PipeWriter matching JSON field comparisons (->> =, etc.)
/// ordered by the given fields in the document
///
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// Fields by which the results should be ordered
[]
static member inline WriteJsonByFieldsOrdered(conn, tableName, writer, howMatched, queryFields, orderFields) =
Json.writeByFieldsOrdered tableName writer howMatched queryFields orderFields (Sql.existingConnection conn)
/// Retrieve JSON documents matching a JSON containment query (@>)
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// The document to match with the containment query
/// All JSON documents matching the given containment query
[]
static member inline JsonByContains(conn, tableName, criteria: obj) =
Json.byContains tableName criteria (Sql.existingConnection conn)
///
/// Write JSON documents to the given PipeWriter matching a JSON containment query (@>)
///
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// The document to match with the containment query
[]
static member inline WriteJsonByContains(conn, tableName, writer, criteria: obj) =
Json.writeByContains tableName writer criteria (Sql.existingConnection conn)
///
/// Retrieve JSON documents matching a JSON containment query (@>) ordered by the given fields in the
/// document
///
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// The document to match with the containment query
/// Fields by which the results should be ordered
/// All documents matching the given containment query, ordered by the given fields
[]
static member inline JsonByContainsOrdered(conn, tableName, criteria: obj, orderFields) =
Json.byContainsOrdered tableName criteria orderFields (Sql.existingConnection conn)
///
/// Write JSON documents to the given PipeWriter matching a JSON containment query (@>) ordered by
/// the given fields in the document
///
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// The document to match with the containment query
/// Fields by which the results should be ordered
[]
static member inline WriteJsonByContainsOrdered(conn, tableName, writer, criteria: obj, orderFields) =
Json.writeByContainsOrdered tableName writer criteria orderFields (Sql.existingConnection conn)
/// Retrieve JSON documents matching a JSON Path match query (@?)
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// The JSON Path expression to match
/// All JSON documents matching the given JSON Path expression
[]
static member inline JsonByJsonPath(conn, tableName, jsonPath) =
Json.byJsonPath tableName jsonPath (Sql.existingConnection conn)
///
/// Write JSON documents to the given PipeWriter matching a JSON Path match query (@?)
///
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// The JSON Path expression to match
[]
static member inline WriteJsonByJsonPath(conn, tableName, writer, jsonPath) =
Json.writeByJsonPath tableName writer jsonPath (Sql.existingConnection conn)
///
/// Retrieve JSON documents matching a JSON Path match query (@?) ordered by the given fields in the document
///
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// The JSON Path expression to match
/// Fields by which the results should be ordered
/// All JSON documents matching the given JSON Path expression, ordered by the given fields
[]
static member inline JsonByJsonPathOrdered(conn, tableName, jsonPath, orderFields) =
Json.byJsonPathOrdered tableName jsonPath orderFields (Sql.existingConnection conn)
///
/// Write JSON documents to the given PipeWriter matching a JSON Path match query (@?) ordered by the
/// given fields in the document
///
/// The NpgsqlConnection on which to run the query
/// The table from which documents should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// The JSON Path expression to match
/// Fields by which the results should be ordered
[]
static member inline WriteJsonByJsonPathOrdered(conn, tableName, writer, jsonPath, orderFields) =
Json.writeByJsonPathOrdered tableName writer jsonPath orderFields (Sql.existingConnection conn)
/// Retrieve the first JSON document matching JSON field comparisons (->> =, etc.)
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// The first matching JSON document if found, an empty JSON document otherwise
[]
static member inline JsonFirstByFields(conn, tableName, howMatched, fields) =
Json.firstByFields tableName howMatched fields (Sql.existingConnection conn)
///
/// Write the first JSON document to the given PipeWriter matching JSON field comparisons
/// (->> =, etc.)
///
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// Whether to match any or all of the field conditions
/// The field conditions to match
[]
static member inline WriteJsonFirstByFields(conn, tableName, writer, howMatched, fields) =
Json.writeFirstByFields tableName writer howMatched fields (Sql.existingConnection conn)
///
/// Retrieve the first JSON document matching JSON field comparisons (->> =, etc.) ordered by the
/// given fields in the document
///
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// Fields by which the results should be ordered
/// The first matching JSON document if found, an empty JSON document otherwise
[]
static member inline JsonFirstByFieldsOrdered(conn, tableName, howMatched, queryFields, orderFields) =
Json.firstByFieldsOrdered tableName howMatched queryFields orderFields (Sql.existingConnection conn)
///
/// Write the first JSON document to the given PipeWriter matching JSON field comparisons
/// (->> =, etc.) ordered by the given fields in the document
///
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// Fields by which the results should be ordered
[]
static member inline WriteJsonFirstByFieldsOrdered(conn, tableName, writer, howMatched, queryFields, orderFields) =
Json.writeFirstByFieldsOrdered
tableName writer howMatched queryFields orderFields (Sql.existingConnection conn)
/// Retrieve the first JSON document matching a JSON containment query (@>)
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// The document to match with the containment query
/// The first matching JSON document if found, an empty JSON document otherwise
[]
static member inline JsonFirstByContains(conn, tableName, criteria: obj) =
Json.firstByContains tableName criteria (Sql.existingConnection conn)
///
/// Write the first JSON document to the given PipeWriter matching a JSON containment query (@>)
///
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// The document to match with the containment query
[]
static member inline WriteJsonFirstByContains(conn, tableName, writer, criteria: obj) =
Json.writeFirstByContains tableName writer criteria (Sql.existingConnection conn)
///
/// Retrieve the first JSON document matching a JSON containment query (@>) ordered by the given fields in
/// the document
///
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// The document to match with the containment query
/// Fields by which the results should be ordered
/// The first matching JSON document if found, an empty JSON document otherwise
[]
static member inline JsonFirstByContainsOrdered(conn, tableName, criteria: obj, orderFields) =
Json.firstByContainsOrdered tableName criteria orderFields (Sql.existingConnection conn)
///
/// Write the first JSON document to the given PipeWriter matching a JSON containment query (@>)
/// ordered by the given fields in the document
///
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// The document to match with the containment query
/// Fields by which the results should be ordered
[]
static member inline WriteJsonFirstByContainsOrdered(conn, tableName, writer, criteria: obj, orderFields) =
Json.writeFirstByContainsOrdered tableName writer criteria orderFields (Sql.existingConnection conn)
/// Retrieve the first JSON document matching a JSON Path match query (@?)
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// The JSON Path expression to match
/// The first matching JSON document if found, an empty JSON document otherwise
[]
static member inline JsonFirstByJsonPath(conn, tableName, jsonPath) =
Json.firstByJsonPath tableName jsonPath (Sql.existingConnection conn)
///
/// Write the first JSON document to the given PipeWriter matching a JSON Path match query (@?)
///
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// The JSON Path expression to match
[]
static member inline WriteJsonFirstByJsonPath(conn, tableName, writer, jsonPath) =
Json.writeFirstByJsonPath tableName writer jsonPath (Sql.existingConnection conn)
///
/// Retrieve the first JSON document matching a JSON Path match query (@?) ordered by the given fields in the
/// document
///
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// The JSON Path expression to match
/// Fields by which the results should be ordered
/// The first matching JSON document if found, an empty JSON document otherwise
[]
static member inline JsonFirstByJsonPathOrdered(conn, tableName, jsonPath, orderFields) =
Json.firstByJsonPathOrdered tableName jsonPath orderFields (Sql.existingConnection conn)
///
/// Write the first JSON document to the given PipeWriter matching a JSON Path match query (@?)
/// ordered by the given fields in the document
///
/// The NpgsqlConnection on which to run the query
/// The table from which a document should be retrieved (may include schema)
/// The PipeWriter to which the results should be written
/// The JSON Path expression to match
/// Fields by which the results should be ordered
[]
static member inline WriteJsonFirstByJsonPathOrdered(conn, tableName, writer, jsonPath, orderFields) =
Json.writeFirstByJsonPathOrdered tableName writer jsonPath orderFields (Sql.existingConnection conn)
/// Update (replace) an entire document by its ID
/// The NpgsqlConnection on which to run the query
/// The table in which a document should be updated (may include schema)
/// The ID of the document to be updated (replaced)
/// The new document
[]
static member inline UpdateById(conn, tableName, docId: 'TKey, document: 'TDoc) =
Update.byId tableName docId document (Sql.existingConnection conn)
///
/// Update (replace) an entire document by its ID, using the provided function to obtain the ID from the document
///
/// The NpgsqlConnection on which to run the query
/// The table in which a document should be updated (may include schema)
/// The function to obtain the ID of the document
/// The new document
[]
static member inline UpdateByFunc(conn, tableName, idFunc: System.Func<'TDoc, 'TKey>, document: 'TDoc) =
Update.ByFunc(tableName, idFunc, document, Sql.existingConnection conn)
/// Patch a document by its ID
/// The NpgsqlConnection on which to run the query
/// The table in which a document should be patched (may include schema)
/// The ID of the document to patch
/// The partial document to patch the existing document
[]
static member inline PatchById(conn, tableName, docId: 'TKey, patch: 'TPatch) =
Patch.byId tableName docId patch (Sql.existingConnection conn)
///
/// Patch documents using a JSON field comparison query in the WHERE clause (->> =, etc.)
///
/// The NpgsqlConnection on which to run the query
/// The table in which documents should be patched (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// The partial document to patch the existing document
[]
static member inline PatchByFields(conn, tableName, howMatched, fields, patch: 'TPatch) =
Patch.byFields tableName howMatched fields patch (Sql.existingConnection conn)
/// Patch documents using a JSON containment query in the WHERE clause (@>)
/// The NpgsqlConnection on which to run the query
/// The table in which documents should be patched (may include schema)
/// The document to match the containment query
/// The partial document to patch the existing document
[]
static member inline PatchByContains(conn, tableName, criteria: 'TCriteria, patch: 'TPatch) =
Patch.byContains tableName criteria patch (Sql.existingConnection conn)
/// Patch documents using a JSON Path match query in the WHERE clause (@?)
/// The NpgsqlConnection on which to run the query
/// The table in which documents should be patched (may include schema)
/// The JSON Path expression to match
/// The partial document to patch the existing document
[]
static member inline PatchByJsonPath(conn, tableName, jsonPath, patch: 'TPatch) =
Patch.byJsonPath tableName jsonPath patch (Sql.existingConnection conn)
/// Remove fields from a document by the document's ID
/// The NpgsqlConnection on which to run the query
/// The table in which a document should be modified (may include schema)
/// The ID of the document to modify
/// One or more field names to remove from the document
[]
static member inline RemoveFieldsById(conn, tableName, docId: 'TKey, fieldNames) =
RemoveFields.byId tableName docId fieldNames (Sql.existingConnection conn)
/// Remove fields from documents via a comparison on JSON fields in the document
/// The NpgsqlConnection on which to run the query
/// The table in which documents should be modified (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
/// One or more field names to remove from the matching documents
[]
static member inline RemoveFieldsByFields(conn, tableName, howMatched, fields, fieldNames) =
RemoveFields.byFields tableName howMatched fields fieldNames (Sql.existingConnection conn)
/// Remove fields from documents via a JSON containment query (@>)
/// The NpgsqlConnection on which to run the query
/// The table in which documents should be modified (may include schema)
/// The document to match the containment query
/// One or more field names to remove from the matching documents
[]
static member inline RemoveFieldsByContains(conn, tableName, criteria: 'TContains, fieldNames) =
RemoveFields.byContains tableName criteria fieldNames (Sql.existingConnection conn)
/// Remove fields from documents via a JSON Path match query (@?)
/// The NpgsqlConnection on which to run the query
/// The table in which documents should be modified (may include schema)
/// The JSON Path expression to match
/// One or more field names to remove from the matching documents
[]
static member inline RemoveFieldsByJsonPath(conn, tableName, jsonPath, fieldNames) =
RemoveFields.byJsonPath tableName jsonPath fieldNames (Sql.existingConnection conn)
/// Delete a document by its ID
/// The NpgsqlConnection on which to run the query
/// The table in which a document should be deleted (may include schema)
/// The ID of the document to delete
[]
static member inline DeleteById(conn, tableName, docId: 'TKey) =
Delete.byId tableName docId (Sql.existingConnection conn)
/// Delete documents by matching a JSON field comparison query (->> =, etc.)
/// The NpgsqlConnection on which to run the query
/// The table in which documents should be deleted (may include schema)
/// Whether to match any or all of the field conditions
/// The field conditions to match
[]
static member inline DeleteByFields(conn, tableName, howMatched, fields) =
Delete.byFields tableName howMatched fields (Sql.existingConnection conn)
/// Delete documents by matching a JSON contains query (@>)
/// The NpgsqlConnection on which to run the query
/// The table in which documents should be deleted (may include schema)
/// The document to match the containment query
[]
static member inline DeleteByContains(conn, tableName, criteria: 'TContains) =
Delete.byContains tableName criteria (Sql.existingConnection conn)
/// Delete documents by matching a JSON Path match query (@?)
/// The NpgsqlConnection on which to run the query
/// The table in which documents should be deleted (may include schema)
/// The JSON Path expression to match
[]
static member inline DeleteByJsonPath(conn, tableName, jsonPath) =
Delete.byJsonPath tableName jsonPath (Sql.existingConnection conn)