Aeon.Database

namespace Aeon.Database

Classes

CreateConnection

class Aeon.Database.CreateConnection : Source

Inheritance diagram for Aeon::Database::CreateConnection:

Collaboration diagram for Aeon::Database::CreateConnection:

Public Functions

override IObservable<MySqlConnection> Generate ()

Properties

string ConnectionString { get; set; }

DataReaderExtensions

class Aeon.Database.DataReaderExtensions

Public Static Functions

IEnumerable<TRecord> GetRecords<TRecord> (this MySqlDataReader reader)

IEnumerable<TRecord> GetRecords<TRecord> (this MySqlDataReader reader, Func<MySqlDataReader, TRecord> selector)

IEnumerable<TRecord> GetRecords<TRecord> (this MySqlDataReader reader, Action<MySqlDataReader> validator, Func<MySqlDataReader, TRecord> selector)

? bool GetNullableBoolean (this MySqlDataReader reader, int ordinal)

? bool GetNullableBoolean (this MySqlDataReader reader, string name)

? char GetNullableChar (this MySqlDataReader reader, int ordinal)

? char GetNullableChar (this MySqlDataReader reader, string name)

? sbyte GetNullableSByte (this MySqlDataReader reader, int ordinal)

? sbyte GetNullableSByte (this MySqlDataReader reader, string name)

? byte GetNullableByte (this MySqlDataReader reader, int ordinal)

? byte GetNullableByte (this MySqlDataReader reader, string name)

? short GetNullableInt16 (this MySqlDataReader reader, int ordinal)

? short GetNullableInt16 (this MySqlDataReader reader, string name)

? ushort GetNullableUInt16 (this MySqlDataReader reader, int ordinal)

? ushort GetNullableUInt16 (this MySqlDataReader reader, string name)

? int GetNullableInt32 (this MySqlDataReader reader, int ordinal)

? int GetNullableInt32 (this MySqlDataReader reader, string name)

? uint GetNullableUInt32 (this MySqlDataReader reader, int ordinal)

? uint GetNullableUInt32 (this MySqlDataReader reader, string name)

? long GetNullableInt64 (this MySqlDataReader reader, int ordinal)

? long GetNullableInt64 (this MySqlDataReader reader, string name)

? ulong GetNullableUInt64 (this MySqlDataReader reader, int ordinal)

? ulong GetNullableUInt64 (this MySqlDataReader reader, string name)

? float GetNullableFloat (this MySqlDataReader reader, int ordinal)

? float GetNullableFloat (this MySqlDataReader reader, string name)

? double GetNullableDouble (this MySqlDataReader reader, int ordinal)

? double GetNullableDouble (this MySqlDataReader reader, string name)

? decimal GetNullableDecimal (this MySqlDataReader reader, int ordinal)

? decimal GetNullableDecimal (this MySqlDataReader reader, string name)

? DateTime GetNullableDateTime (this MySqlDataReader reader, int ordinal)

? DateTime GetNullableDateTime (this MySqlDataReader reader, string name)

string GetNullableString (this MySqlDataReader reader, int ordinal)

string GetNullableString (this MySqlDataReader reader, string name)

ExecuteQuery

class Aeon.Database.ExecuteQuery : Combinator

Inheritance diagram for Aeon::Database::ExecuteQuery:

Collaboration diagram for Aeon::Database::ExecuteQuery:

Public Functions

override IObservable<MySqlDataReader> Process (IObservable<MySqlConnection> source)

Properties

string QueryString { get; set; }

ObservableDatabase

class Aeon.Database.ObservableDatabase

Public Static Functions

IObservable<MySqlDataReader> Query (string queryString, MySqlConnection connection)

IObservable<TRecord> Query<TRecord> (string queryString, MySqlConnection connection)

IObservable<TRecord> Query<TRecord> (string queryString, MySqlConnection connection, Func<MySqlDataReader, TRecord> selector)

IObservable<TRecord> Query<TRecord> (string queryString, MySqlConnection connection, Action<MySqlDataReader> validator, Func<MySqlDataReader, TRecord> selector)

RecordReader-1-g

class Aeon.Database.RecordReader-1-g<T>

Collaboration diagram for Aeon::Database::RecordReader-1-g:

Properties

MySqlDataReader > Validate { get; set; }

T > Select { get; set; }

Public Static Attributes

readonly RecordReader<T> Instance = new()