Show / Hide Table of Contents

Class MySQLCRUDTransaction

Represents MySQL CRUD transaction

Inheritance
System.Object
DisposableObject
CRUDTransaction
MySQLCRUDTransaction
Implements
System.IDisposable
ICRUDOperations
Inherited Members
CRUDTransaction.m_Store
CRUDTransaction.DataStore
CRUDTransaction.Status
CRUDTransaction.DisposeBehavior
CRUDTransaction.SupportsTrueAsynchrony
CRUDTransaction.GetSchema(Query)
CRUDTransaction.GetSchemaAsync(Query)
CRUDTransaction.Load(Query[])
CRUDTransaction.LoadAsync(Query[])
CRUDTransaction.ExecuteWithoutFetch(Query[])
CRUDTransaction.ExecuteWithoutFetchAsync(Query[])
CRUDTransaction.LoadOneRowset(Query)
CRUDTransaction.LoadOneRowsetAsync(Query)
CRUDTransaction.LoadOneRow(Query)
CRUDTransaction.LoadOneRowAsync(Query)
CRUDTransaction.OpenCursor(Query)
CRUDTransaction.OpenCursorAsync(Query)
CRUDTransaction.Save(RowsetBase[])
CRUDTransaction.SaveAsync(RowsetBase[])
CRUDTransaction.Insert(Row, FieldFilterFunc)
CRUDTransaction.InsertAsync(Row, FieldFilterFunc)
CRUDTransaction.Upsert(Row, FieldFilterFunc)
CRUDTransaction.UpsertAsync(Row, FieldFilterFunc)
CRUDTransaction.Update(Row, IDataStoreKey, FieldFilterFunc)
CRUDTransaction.UpdateAsync(Row, IDataStoreKey, FieldFilterFunc)
CRUDTransaction.Delete(Row, IDataStoreKey)
CRUDTransaction.DeleteAsync(Row, IDataStoreKey)
CRUDTransaction.Commit()
CRUDTransaction.Rollback()
CRUDTransaction.CheckOpenStatus(String)
DisposableObject.DisposeAndNull<T>(T)
DisposableObject.DisposeStarted
DisposableObject.Disposed
DisposableObject.EnsureObjectNotDisposed()
DisposableObject.Dispose()
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 MySQLCRUDTransaction : CRUDTransaction, IDisposable, ICRUDOperations

Properties

Connection

Returns the underlying MySQL connection that this transaction works through

Declaration
public MySqlConnection Connection { get; }
Property Value
Type Description
MySqlConnection

Transaction

Returns the underlying MySQL transaction that this instance represents. Do not call Commit/Rollback method on this property directly

Declaration
public MySqlTransaction Transaction { get; }
Property Value
Type Description
MySqlTransaction

Methods

Destructor()

Declaration
protected override void Destructor()
Overrides
CRUDTransaction.Destructor()

DoCommit()

Declaration
protected override void DoCommit()
Overrides
CRUDTransaction.DoCommit()

DoDelete(Row, IDataStoreKey)

Declaration
protected override int DoDelete(Row row, IDataStoreKey key)
Parameters
Type Name Description
Row row
IDataStoreKey key
Returns
Type Description
System.Int32
Overrides
CRUDTransaction.DoDelete(Row, IDataStoreKey)

DoDeleteAsync(Row, IDataStoreKey)

Declaration
protected override Task<int> DoDeleteAsync(Row row, IDataStoreKey key)
Parameters
Type Name Description
Row row
IDataStoreKey key
Returns
Type Description
System.Threading.Tasks.Task<System.Int32>
Overrides
CRUDTransaction.DoDeleteAsync(Row, IDataStoreKey)

DoExecuteWithoutFetch(Query[])

Declaration
protected override int DoExecuteWithoutFetch(params Query[] queries)
Parameters
Type Name Description
Query[] queries
Returns
Type Description
System.Int32
Overrides
CRUDTransaction.DoExecuteWithoutFetch(Query[])

DoExecuteWithoutFetchAsync(Query[])

Declaration
protected override Task<int> DoExecuteWithoutFetchAsync(params Query[] queries)
Parameters
Type Name Description
Query[] queries
Returns
Type Description
System.Threading.Tasks.Task<System.Int32>
Overrides
CRUDTransaction.DoExecuteWithoutFetchAsync(Query[])

DoGetSchema(Query)

Declaration
protected override Schema DoGetSchema(Query query)
Parameters
Type Name Description
Query query
Returns
Type Description
Schema
Overrides
CRUDTransaction.DoGetSchema(Query)

DoGetSchemaAsync(Query)

Declaration
protected override Task<Schema> DoGetSchemaAsync(Query query)
Parameters
Type Name Description
Query query
Returns
Type Description
System.Threading.Tasks.Task<Schema>
Overrides
CRUDTransaction.DoGetSchemaAsync(Query)

DoInsert(Row, FieldFilterFunc)

Declaration
protected override int DoInsert(Row row, FieldFilterFunc filter = null)
Parameters
Type Name Description
Row row
FieldFilterFunc filter
Returns
Type Description
System.Int32
Overrides
CRUDTransaction.DoInsert(Row, FieldFilterFunc)

DoInsertAsync(Row, FieldFilterFunc)

Declaration
protected override Task<int> DoInsertAsync(Row row, FieldFilterFunc filter = null)
Parameters
Type Name Description
Row row
FieldFilterFunc filter
Returns
Type Description
System.Threading.Tasks.Task<System.Int32>
Overrides
CRUDTransaction.DoInsertAsync(Row, FieldFilterFunc)

DoLoad(Boolean, Query[])

Declaration
protected override List<RowsetBase> DoLoad(bool oneRow, params Query[] queries)
Parameters
Type Name Description
System.Boolean oneRow
Query[] queries
Returns
Type Description
System.Collections.Generic.List<RowsetBase>
Overrides
CRUDTransaction.DoLoad(Boolean, Query[])

DoLoadAsync(Boolean, Query[])

Declaration
protected override Task<List<RowsetBase>> DoLoadAsync(bool oneRow, params Query[] queries)
Parameters
Type Name Description
System.Boolean oneRow
Query[] queries
Returns
Type Description
System.Threading.Tasks.Task<System.Collections.Generic.List<RowsetBase>>
Overrides
CRUDTransaction.DoLoadAsync(Boolean, Query[])

DoOpenCursor(Query)

Declaration
protected override Cursor DoOpenCursor(Query query)
Parameters
Type Name Description
Query query
Returns
Type Description
Cursor
Overrides
CRUDTransaction.DoOpenCursor(Query)

DoOpenCursorAsync(Query)

Declaration
protected override Task<Cursor> DoOpenCursorAsync(Query query)
Parameters
Type Name Description
Query query
Returns
Type Description
System.Threading.Tasks.Task<Cursor>
Overrides
CRUDTransaction.DoOpenCursorAsync(Query)

DoRollback()

Declaration
protected override void DoRollback()
Overrides
CRUDTransaction.DoRollback()

DoSave(RowsetBase[])

Declaration
protected override int DoSave(params RowsetBase[] rowsets)
Parameters
Type Name Description
RowsetBase[] rowsets
Returns
Type Description
System.Int32
Overrides
CRUDTransaction.DoSave(RowsetBase[])

DoSaveAsync(RowsetBase[])

Declaration
protected override Task<int> DoSaveAsync(params RowsetBase[] rowsets)
Parameters
Type Name Description
RowsetBase[] rowsets
Returns
Type Description
System.Threading.Tasks.Task<System.Int32>
Overrides
CRUDTransaction.DoSaveAsync(RowsetBase[])

DoUpdate(Row, IDataStoreKey, FieldFilterFunc)

Declaration
protected override int DoUpdate(Row row, IDataStoreKey key, FieldFilterFunc filter = null)
Parameters
Type Name Description
Row row
IDataStoreKey key
FieldFilterFunc filter
Returns
Type Description
System.Int32
Overrides
CRUDTransaction.DoUpdate(Row, IDataStoreKey, FieldFilterFunc)

DoUpdateAsync(Row, IDataStoreKey, FieldFilterFunc)

Declaration
protected override Task<int> DoUpdateAsync(Row row, IDataStoreKey key, FieldFilterFunc filter = null)
Parameters
Type Name Description
Row row
IDataStoreKey key
FieldFilterFunc filter
Returns
Type Description
System.Threading.Tasks.Task<System.Int32>
Overrides
CRUDTransaction.DoUpdateAsync(Row, IDataStoreKey, FieldFilterFunc)

DoUpsert(Row, FieldFilterFunc)

Declaration
protected override int DoUpsert(Row row, FieldFilterFunc filter = null)
Parameters
Type Name Description
Row row
FieldFilterFunc filter
Returns
Type Description
System.Int32
Overrides
CRUDTransaction.DoUpsert(Row, FieldFilterFunc)

DoUpsertAsync(Row, FieldFilterFunc)

Declaration
protected override Task<int> DoUpsertAsync(Row row, FieldFilterFunc filter = null)
Parameters
Type Name Description
Row row
FieldFilterFunc filter
Returns
Type Description
System.Threading.Tasks.Task<System.Int32>
Overrides
CRUDTransaction.DoUpsertAsync(Row, FieldFilterFunc)

Implements

System.IDisposable
ICRUDOperations

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