Class ErlCRUDScriptQueryHandler

Executes Erlang CRUD script-based queries

Inheritance
System.Object
CRUDQueryHandler
CRUDQueryHandler<ErlDataStore>
ErlCRUDScriptQueryHandler
Implements
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: NFX.DataAccess.Erlang
Assembly: NFX.Erlang.dll
Syntax
public sealed class ErlCRUDScriptQueryHandler : CRUDQueryHandler<ErlDataStore>, INamed

Constructors

ErlCRUDScriptQueryHandler(ErlDataStore, QuerySource)

Declaration
public ErlCRUDScriptQueryHandler(ErlDataStore store, QuerySource source)
Parameters
Type Name Description
ErlDataStore store
QuerySource source

Fields

ATOM_Code

Declaration
public static readonly ErlAtom ATOM_Code
Field Value
Type Description
ErlAtom

ATOM_Msg

Declaration
public static readonly ErlAtom ATOM_Msg
Field Value
Type Description
ErlAtom

ATOM_ReqID

Declaration
public static readonly ErlAtom ATOM_ReqID
Field Value
Type Description
ErlAtom

ATOM_Rows

Declaration
public static readonly ErlAtom ATOM_Rows
Field Value
Type Description
ErlAtom

ATOM_SchemaID

Declaration
public static readonly ErlAtom ATOM_SchemaID
Field Value
Type Description
ErlAtom

ATOM_Subscriber

Declaration
public static readonly ErlAtom ATOM_Subscriber
Field Value
Type Description
ErlAtom

ATOM_Timestamp

Declaration
public static readonly ErlAtom ATOM_Timestamp
Field Value
Type Description
ErlAtom

EXECUTE_ERROR_PATTERN

Declaration
public static readonly IErlObject EXECUTE_ERROR_PATTERN
Field Value
Type Description
IErlObject

EXECUTE_OK_PATTERN

Declaration
public static readonly IErlObject EXECUTE_OK_PATTERN
Field Value
Type Description
IErlObject

EXECUTE_SUBSCRIBE_ERROR_PATTERN

Declaration
public static readonly IErlObject EXECUTE_SUBSCRIBE_ERROR_PATTERN
Field Value
Type Description
IErlObject

EXECUTE_SUBSCRIBE_OK_PATTERN

Declaration
public static readonly IErlObject EXECUTE_SUBSCRIBE_OK_PATTERN
Field Value
Type Description
IErlObject

INVALID_SUBSCRIPTION_REQUEST_EXCEPTION

Declaration
public const int INVALID_SUBSCRIPTION_REQUEST_EXCEPTION = -10
Field Value
Type Description
System.Int32

Properties

ErlStore

Declaration
public ErlDataStore ErlStore { get; }
Property Value
Type Description
ErlDataStore

Methods

Execute(ICRUDQueryExecutionContext, Query, Boolean)

Declaration
public override RowsetBase Execute(ICRUDQueryExecutionContext context, Query query, bool oneRow = false)
Parameters
Type Name Description
ICRUDQueryExecutionContext context
Query query
System.Boolean oneRow
Returns
Type Description
RowsetBase
Overrides

ExecuteAsync(ICRUDQueryExecutionContext, Query, Boolean)

Declaration
public override Task<RowsetBase> ExecuteAsync(ICRUDQueryExecutionContext context, Query query, bool oneRow = false)
Parameters
Type Name Description
ICRUDQueryExecutionContext context
Query query
System.Boolean oneRow
Returns
Type Description
System.Threading.Tasks.Task<RowsetBase>
Overrides

ExecuteWithoutFetch(ICRUDQueryExecutionContext, Query)

Declaration
public override int ExecuteWithoutFetch(ICRUDQueryExecutionContext context, Query query)
Parameters
Type Name Description
ICRUDQueryExecutionContext context
Query query
Returns
Type Description
System.Int32
Overrides

ExecuteWithoutFetchAsync(ICRUDQueryExecutionContext, Query)

Declaration
public override Task<int> ExecuteWithoutFetchAsync(ICRUDQueryExecutionContext context, Query query)
Parameters
Type Name Description
ICRUDQueryExecutionContext context
Query query
Returns
Type Description
System.Threading.Tasks.Task<System.Int32>
Overrides

GetSchema(ICRUDQueryExecutionContext, Query)

Declaration
public override Schema GetSchema(ICRUDQueryExecutionContext context, Query query)
Parameters
Type Name Description
ICRUDQueryExecutionContext context
Query query
Returns
Type Description
Schema
Overrides

GetSchemaAsync(ICRUDQueryExecutionContext, Query)

Declaration
public override Task<Schema> GetSchemaAsync(ICRUDQueryExecutionContext context, Query query)
Parameters
Type Name Description
ICRUDQueryExecutionContext context
Query query
Returns
Type Description
System.Threading.Tasks.Task<Schema>
Overrides

OpenCursor(ICRUDQueryExecutionContext, Query)

Declaration
public override Cursor OpenCursor(ICRUDQueryExecutionContext context, Query query)
Parameters
Type Name Description
ICRUDQueryExecutionContext context
Query query
Returns
Type Description
Cursor
Overrides

OpenCursorAsync(ICRUDQueryExecutionContext, Query)

Declaration
public override Task<Cursor> OpenCursorAsync(ICRUDQueryExecutionContext context, Query query)
Parameters
Type Name Description
ICRUDQueryExecutionContext context
Query query
Returns
Type Description
System.Threading.Tasks.Task<Cursor>
Overrides

Implements

Extension Methods