Show / Hide Table of Contents

Class MySQLCRUDScriptQueryHandler

Executes MySql CRUD script-based queries

Inheritance
System.Object
CRUDQueryHandler
CRUDQueryHandler<MySQLDataStore>
MySQLCRUDScriptQueryHandler
Implements
INamed
Inherited Members
CRUDQueryHandler<MySQLDataStore>.Store
CRUDQueryHandler.Source
CRUDQueryHandler.Name
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.MySQL
Assembly: NFX.MySQL.dll
Syntax
public sealed class MySQLCRUDScriptQueryHandler : CRUDQueryHandler<MySQLDataStore>, INamed

Constructors

MySQLCRUDScriptQueryHandler(MySQLDataStore, QuerySource)

Declaration
public MySQLCRUDScriptQueryHandler(MySQLDataStore store, QuerySource source)
Parameters
Type Name Description
MySQLDataStore store
QuerySource source

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
CRUDQueryHandler.Execute(ICRUDQueryExecutionContext, Query, Boolean)

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
CRUDQueryHandler.ExecuteAsync(ICRUDQueryExecutionContext, Query, Boolean)

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
CRUDQueryHandler.ExecuteWithoutFetch(ICRUDQueryExecutionContext, Query)

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
CRUDQueryHandler.ExecuteWithoutFetchAsync(ICRUDQueryExecutionContext, Query)

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
CRUDQueryHandler.GetSchema(ICRUDQueryExecutionContext, Query)

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
CRUDQueryHandler.GetSchemaAsync(ICRUDQueryExecutionContext, Query)

GetSchemaForQuery(String, Query, MySqlDataReader, QuerySource, out Schema.FieldDef[])

Gets schema from reader taking Query.ResultRowType in consideration

Declaration
public static Schema GetSchemaForQuery(string target, Query query, MySqlDataReader reader, QuerySource qSource, out Schema.FieldDef[] toLoad)
Parameters
Type Name Description
System.String target
Query query
MySqlDataReader reader
QuerySource qSource
Schema.FieldDef[] toLoad
Returns
Type Description
Schema

GetSchemaFromReader(String, QuerySource, MySqlDataReader)

Gets CRUD schema from MySqlReader per particular QuerySource. If source is null then all columns from reader are copied. Note: this code was purposely made provider specific because other providers may treat some nuances differently

Declaration
public static Schema GetSchemaFromReader(string name, QuerySource source, MySqlDataReader reader)
Parameters
Type Name Description
System.String name
QuerySource source
MySqlDataReader reader
Returns
Type Description
Schema

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
CRUDQueryHandler.OpenCursor(ICRUDQueryExecutionContext, Query)

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
CRUDQueryHandler.OpenCursorAsync(ICRUDQueryExecutionContext, Query)

PopulateParameters(MySqlCommand, Query)

Populates MySqlCommand with parameters from CRUD Query object Note: this code was purposely made provider specific because other providers may treat some nuances differently

Declaration
public void PopulateParameters(MySqlCommand cmd, Query query)
Parameters
Type Name Description
MySqlCommand cmd
Query query

PopulateRow(MySQLCRUDQueryExecutionContext, Type, Schema, Schema.FieldDef[], MySqlDataReader)

Reads data from reader into rowset. the reader is NOT disposed

Declaration
public static Row PopulateRow(MySQLCRUDQueryExecutionContext context, Type tRow, Schema schema, Schema.FieldDef[] toLoad, MySqlDataReader reader)
Parameters
Type Name Description
MySQLCRUDQueryExecutionContext context
System.Type tRow
Schema schema
Schema.FieldDef[] toLoad
MySqlDataReader reader
Returns
Type Description
Row

PopulateRowset(MySQLCRUDQueryExecutionContext, MySqlDataReader, String, Query, QuerySource, Boolean)

Reads data from reader into rowset. the reader is NOT disposed

Declaration
public static Rowset PopulateRowset(MySQLCRUDQueryExecutionContext context, MySqlDataReader reader, string target, Query query, QuerySource qSource, bool oneRow)
Parameters
Type Name Description
MySQLCRUDQueryExecutionContext context
MySqlDataReader reader
System.String target
Query query
QuerySource qSource
System.Boolean oneRow
Returns
Type Description
Rowset

Implements

INamed

Extension Methods

MiscUtils.NonNull<T>(T, Func<Exception>, String)
ObjectValueConversion.AsString(Object, String, ConvertErrorHandling)
ObjectValueConversion.AsNonNullOrEmptyString(Object)
ObjectValueConversion.AsLaconicConfig(Object, ConfigSectionNode, String, ConvertErrorHandling)
ObjectValueConversion.AsJSONConfig(Object, ConfigSectionNode, String, ConvertErrorHandling)
ObjectValueConversion.AsXMLConfig(Object, ConfigSectionNode, ConvertErrorHandling)
ObjectValueConversion.AsChar(Object, Char, ConvertErrorHandling)
ObjectValueConversion.AsNullableChar(Object, Nullable<Char>, ConvertErrorHandling)
ObjectValueConversion.AsByte(Object, Byte, ConvertErrorHandling)
ObjectValueConversion.AsNullableByte(Object, Nullable<Byte>, ConvertErrorHandling)
ObjectValueConversion.AsSByte(Object, SByte, ConvertErrorHandling)
ObjectValueConversion.AsNullableSByte(Object, Nullable<SByte>, ConvertErrorHandling)
ObjectValueConversion.AsShort(Object, Int16, ConvertErrorHandling)
ObjectValueConversion.AsNullableShort(Object, Nullable<Int16>, ConvertErrorHandling)
ObjectValueConversion.AsUShort(Object, UInt16, ConvertErrorHandling)
ObjectValueConversion.AsNullableUShort(Object, Nullable<UInt16>, ConvertErrorHandling)
ObjectValueConversion.AsInt(Object, Int32, ConvertErrorHandling)
ObjectValueConversion.AsNullableInt(Object, Nullable<Int32>, ConvertErrorHandling)
ObjectValueConversion.AsUInt(Object, UInt32, ConvertErrorHandling)
ObjectValueConversion.AsNullableUInt(Object, Nullable<UInt32>, ConvertErrorHandling)
ObjectValueConversion.AsLong(Object, Int64, ConvertErrorHandling)
ObjectValueConversion.AsNullableLong(Object, Nullable<Int64>, ConvertErrorHandling)
ObjectValueConversion.AsULong(Object, UInt64, ConvertErrorHandling)
ObjectValueConversion.AsNullableULong(Object, Nullable<UInt64>, ConvertErrorHandling)
ObjectValueConversion.AsDouble(Object, Double, ConvertErrorHandling)
ObjectValueConversion.AsNullableDouble(Object, Nullable<Double>, ConvertErrorHandling)
ObjectValueConversion.AsFloat(Object, Single, ConvertErrorHandling)
ObjectValueConversion.AsNullableFloat(Object, Nullable<Single>, ConvertErrorHandling)
ObjectValueConversion.AsDecimal(Object, Decimal, ConvertErrorHandling)
ObjectValueConversion.AsNullableDecimal(Object, Nullable<Decimal>, ConvertErrorHandling)
ObjectValueConversion.AsBool(Object, Boolean, ConvertErrorHandling)
ObjectValueConversion.AsNullableBool(Object, Nullable<Boolean>, ConvertErrorHandling)
ObjectValueConversion.AsGUID(Object, Guid, ConvertErrorHandling)
ObjectValueConversion.AsNullableGUID(Object, Nullable<Guid>, ConvertErrorHandling)
ObjectValueConversion.AsDateTime(Object)
ObjectValueConversion.AsDateTime(Object, DateTime, ConvertErrorHandling)
ObjectValueConversion.AsNullableDateTime(Object, Nullable<DateTime>, ConvertErrorHandling)
ObjectValueConversion.AsGDID(Object)
ObjectValueConversion.AsGDID(Object, GDID, ConvertErrorHandling)
ObjectValueConversion.AsNullableGDID(Object, Nullable<GDID>, ConvertErrorHandling)
ObjectValueConversion.AsGDIDSymbol(Object)
ObjectValueConversion.AsGDIDSymbol(Object, GDIDSymbol, ConvertErrorHandling)
ObjectValueConversion.AsNullableGDIDSymbol(Object, Nullable<GDIDSymbol>, ConvertErrorHandling)
ObjectValueConversion.AsTimeSpan(Object)
ObjectValueConversion.AsTimeSpan(Object, TimeSpan, ConvertErrorHandling)
ObjectValueConversion.AsNullableTimeSpan(Object, Nullable<TimeSpan>, ConvertErrorHandling)
ObjectValueConversion.AsEnum<TEnum>(Object, TEnum, ConvertErrorHandling)
ObjectValueConversion.AsNullableEnum<TEnum>(Object, Nullable<TEnum>, ConvertErrorHandling)
ObjectValueConversion.AsUri(Object, Uri, ConvertErrorHandling)
JSONExtensions.ToJSON(Object, JSONWritingOptions)
JSONExtensions.ToJSON(Object, TextWriter, JSONWritingOptions)
JSONExtensions.ToJSON(Object, Stream, JSONWritingOptions, Encoding)
ErlObject.ToErlObject(Object)
ErlObject.ToErlObject(Object, ErlTypeOrder, Boolean)
Back to top Copyright © 2006-2018 Agnicore Inc
Generated by DocFX