Struct CRUDOperations
Provides facade for ICrudOperations and ICRUDTransactionOperations
executed against the particular shard returned by the Mdb areas partition / routing
Inherited Members
System.ValueType.Equals(System.Object)
System.ValueType.GetHashCode()
System.ValueType.ToString()
System.Object.Equals(System.Object, System.Object)
System.Object.GetType()
System.Object.ReferenceEquals(System.Object, System.Object)
Assembly: Azos.Sky.dll
Syntax
public struct CRUDOperations : ICRUDOperations, ICRUDTransactionOperations
Fields
Shard
The shard that services this instance
Declaration
public readonly MdbArea.Partition.Shard Shard
Field Value
Properties
SupportsTransactions
Declaration
public bool SupportsTransactions { get; }
Property Value
| Type |
Description |
| System.Boolean |
|
SupportsTrueAsynchrony
Declaration
public bool SupportsTrueAsynchrony { get; }
Property Value
| Type |
Description |
| System.Boolean |
|
Methods
BeginTransaction(IsolationLevel, TransactionDisposeBehavior)
Declaration
public CRUDTransaction BeginTransaction(IsolationLevel iso = IsolationLevel.ReadCommitted, TransactionDisposeBehavior behavior = TransactionDisposeBehavior.CommitOnDispose)
Parameters
Returns
BeginTransactionAsync(IsolationLevel, TransactionDisposeBehavior)
Declaration
public Task<CRUDTransaction> BeginTransactionAsync(IsolationLevel iso = IsolationLevel.ReadCommitted, TransactionDisposeBehavior behavior = TransactionDisposeBehavior.CommitOnDispose)
Parameters
Returns
Delete(Doc, IDataStoreKey)
Declaration
public int Delete(Doc doc, IDataStoreKey key = null)
Parameters
Returns
| Type |
Description |
| System.Int32 |
|
DeleteAsync(Doc, IDataStoreKey)
Declaration
public Task<int> DeleteAsync(Doc doc, IDataStoreKey key = null)
Parameters
Returns
| Type |
Description |
| System.Threading.Tasks.Task<System.Int32> |
|
ExecuteWithoutFetch(Query[])
Declaration
public int ExecuteWithoutFetch(params Query[] queries)
Parameters
| Type |
Name |
Description |
| Query[] |
queries |
|
Returns
| Type |
Description |
| System.Int32 |
|
ExecuteWithoutFetchAsync(Query[])
Declaration
public Task<int> ExecuteWithoutFetchAsync(params Query[] queries)
Parameters
| Type |
Name |
Description |
| Query[] |
queries |
|
Returns
| Type |
Description |
| System.Threading.Tasks.Task<System.Int32> |
|
GetSchema(Query)
Declaration
public Schema GetSchema(Query query)
Parameters
| Type |
Name |
Description |
| Query |
query |
|
Returns
GetSchemaAsync(Query)
Declaration
public Task<Schema> GetSchemaAsync(Query query)
Parameters
| Type |
Name |
Description |
| Query |
query |
|
Returns
| Type |
Description |
| System.Threading.Tasks.Task<Schema> |
|
Insert(Doc, FieldFilterFunc)
Declaration
public int Insert(Doc doc, FieldFilterFunc filter = null)
Parameters
Returns
| Type |
Description |
| System.Int32 |
|
InsertAsync(Doc, FieldFilterFunc)
Declaration
public Task<int> InsertAsync(Doc doc, FieldFilterFunc filter = null)
Parameters
Returns
| Type |
Description |
| System.Threading.Tasks.Task<System.Int32> |
|
Load(Query[])
Declaration
public List<RowsetBase> Load(params Query[] queries)
Parameters
| Type |
Name |
Description |
| Query[] |
queries |
|
Returns
| Type |
Description |
| System.Collections.Generic.List<RowsetBase> |
|
LoadAsync(Query[])
Declaration
public Task<List<RowsetBase>> LoadAsync(params Query[] queries)
Parameters
| Type |
Name |
Description |
| Query[] |
queries |
|
Returns
| Type |
Description |
| System.Threading.Tasks.Task<System.Collections.Generic.List<RowsetBase>> |
|
LoadOneDoc(Query)
Declaration
public Doc LoadOneDoc(Query query)
Parameters
| Type |
Name |
Description |
| Query |
query |
|
Returns
LoadOneDocAsync(Query)
Declaration
public Task<Doc> LoadOneDocAsync(Query query)
Parameters
| Type |
Name |
Description |
| Query |
query |
|
Returns
| Type |
Description |
| System.Threading.Tasks.Task<Doc> |
|
LoadOneRowset(Query)
Declaration
public RowsetBase LoadOneRowset(Query query)
Parameters
| Type |
Name |
Description |
| Query |
query |
|
Returns
LoadOneRowsetAsync(Query)
Declaration
public Task<RowsetBase> LoadOneRowsetAsync(Query query)
Parameters
| Type |
Name |
Description |
| Query |
query |
|
Returns
| Type |
Description |
| System.Threading.Tasks.Task<RowsetBase> |
|
OpenCursor(Query)
Declaration
public Cursor OpenCursor(Query query)
Parameters
| Type |
Name |
Description |
| Query |
query |
|
Returns
OpenCursorAsync(Query)
Declaration
public Task<Cursor> OpenCursorAsync(Query query)
Parameters
| Type |
Name |
Description |
| Query |
query |
|
Returns
| Type |
Description |
| System.Threading.Tasks.Task<Cursor> |
|
Save(RowsetBase[])
Declaration
public int Save(params RowsetBase[] rowsets)
Parameters
Returns
| Type |
Description |
| System.Int32 |
|
SaveAsync(RowsetBase[])
Declaration
public Task<int> SaveAsync(params RowsetBase[] rowsets)
Parameters
Returns
| Type |
Description |
| System.Threading.Tasks.Task<System.Int32> |
|
Update(Doc, IDataStoreKey, FieldFilterFunc)
Declaration
public int Update(Doc doc, IDataStoreKey key = null, FieldFilterFunc filter = null)
Parameters
Returns
| Type |
Description |
| System.Int32 |
|
UpdateAsync(Doc, IDataStoreKey, FieldFilterFunc)
Declaration
public Task<int> UpdateAsync(Doc doc, IDataStoreKey key = null, FieldFilterFunc filter = null)
Parameters
Returns
| Type |
Description |
| System.Threading.Tasks.Task<System.Int32> |
|
Upsert(Doc, FieldFilterFunc)
Declaration
public int Upsert(Doc doc, FieldFilterFunc filter = null)
Parameters
Returns
| Type |
Description |
| System.Int32 |
|
UpsertAsync(Doc, FieldFilterFunc)
Declaration
public Task<int> UpsertAsync(Doc doc, FieldFilterFunc filter = null)
Parameters
Returns
| Type |
Description |
| System.Threading.Tasks.Task<System.Int32> |
|
Implements
Extension Methods