Class ObservableDatabase#
Namespace: Aeon.Database
Assembly: Aeon.Database.dll
public static class ObservableDatabase
Inheritance#
Inherited Members#
object.ToString(), object.Equals(object), object.Equals(object, object), object.ReferenceEquals(object, object), object.GetHashCode(), object.GetType(), object.MemberwiseClone()
Methods#
Query(string, MySqlConnection)#
public static IObservable<MySqlDataReader> Query(string queryString, MySqlConnection connection)
Parameters#
queryString string
connection MySqlConnection
Returns#
IObservable<MySqlDataReader>
Query<TRecord>(string, MySqlConnection)#
public static IObservable<TRecord> Query<TRecord>(string queryString, MySqlConnection connection)
Parameters#
queryString string
connection MySqlConnection
Returns#
IObservable<TRecord>
Type Parameters#
TRecord
Query<TRecord>(string, MySqlConnection, Func<MySqlDataReader, TRecord>)#
public static IObservable<TRecord> Query<TRecord>(string queryString, MySqlConnection connection, Func<MySqlDataReader, TRecord> selector)
Parameters#
queryString string
connection MySqlConnection
selector Func<MySqlDataReader, TRecord>
Returns#
IObservable<TRecord>
Type Parameters#
TRecord
Query<TRecord>(string, MySqlConnection, Action<MySqlDataReader>, Func<MySqlDataReader, TRecord>)#
public static IObservable<TRecord> Query<TRecord>(string queryString, MySqlConnection connection, Action<MySqlDataReader> validator, Func<MySqlDataReader, TRecord> selector)
Parameters#
queryString string
connection MySqlConnection
validator Action<MySqlDataReader>
selector Func<MySqlDataReader, TRecord>
Returns#
IObservable<TRecord>
Type Parameters#
TRecord