# <a id="Aeon_Database_ObservableDatabase"></a> Class ObservableDatabase

Namespace: [Aeon.Database](Aeon.Database.md)  
Assembly: Aeon.Database.dll  

```csharp
public static class ObservableDatabase
```

#### Inheritance

[object](https://learn.microsoft.com/dotnet/api/system.object) ← 
[ObservableDatabase](Aeon.Database.ObservableDatabase.md)

#### Inherited Members

[object.ToString\(\)](https://learn.microsoft.com/dotnet/api/system.object.tostring), 
[object.Equals\(object\)](https://learn.microsoft.com/dotnet/api/system.object.equals\#system\-object\-equals\(system\-object\)), 
[object.Equals\(object, object\)](https://learn.microsoft.com/dotnet/api/system.object.equals\#system\-object\-equals\(system\-object\-system\-object\)), 
[object.ReferenceEquals\(object, object\)](https://learn.microsoft.com/dotnet/api/system.object.referenceequals), 
[object.GetHashCode\(\)](https://learn.microsoft.com/dotnet/api/system.object.gethashcode), 
[object.GetType\(\)](https://learn.microsoft.com/dotnet/api/system.object.gettype), 
[object.MemberwiseClone\(\)](https://learn.microsoft.com/dotnet/api/system.object.memberwiseclone)

## Methods

### <a id="Aeon_Database_ObservableDatabase_Query_System_String_MySqlConnector_MySqlConnection_"></a> Query\(string, MySqlConnection\)

```csharp
public static IObservable<MySqlDataReader> Query(string queryString, MySqlConnection connection)
```

#### Parameters

`queryString` [string](https://learn.microsoft.com/dotnet/api/system.string)

`connection` MySqlConnection

#### Returns

 [IObservable](https://learn.microsoft.com/dotnet/api/system.iobservable\-1)<MySqlDataReader\>

### <a id="Aeon_Database_ObservableDatabase_Query__1_System_String_MySqlConnector_MySqlConnection_"></a> Query<TRecord\>\(string, MySqlConnection\)

```csharp
public static IObservable<TRecord> Query<TRecord>(string queryString, MySqlConnection connection)
```

#### Parameters

`queryString` [string](https://learn.microsoft.com/dotnet/api/system.string)

`connection` MySqlConnection

#### Returns

 [IObservable](https://learn.microsoft.com/dotnet/api/system.iobservable\-1)<TRecord\>

#### Type Parameters

`TRecord` 

### <a id="Aeon_Database_ObservableDatabase_Query__1_System_String_MySqlConnector_MySqlConnection_System_Func_MySqlConnector_MySqlDataReader___0__"></a> Query<TRecord\>\(string, MySqlConnection, Func<MySqlDataReader, TRecord\>\)

```csharp
public static IObservable<TRecord> Query<TRecord>(string queryString, MySqlConnection connection, Func<MySqlDataReader, TRecord> selector)
```

#### Parameters

`queryString` [string](https://learn.microsoft.com/dotnet/api/system.string)

`connection` MySqlConnection

`selector` [Func](https://learn.microsoft.com/dotnet/api/system.func\-2)<MySqlDataReader, TRecord\>

#### Returns

 [IObservable](https://learn.microsoft.com/dotnet/api/system.iobservable\-1)<TRecord\>

#### Type Parameters

`TRecord` 

### <a id="Aeon_Database_ObservableDatabase_Query__1_System_String_MySqlConnector_MySqlConnection_System_Action_MySqlConnector_MySqlDataReader__System_Func_MySqlConnector_MySqlDataReader___0__"></a> Query<TRecord\>\(string, MySqlConnection, Action<MySqlDataReader\>, Func<MySqlDataReader, TRecord\>\)

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

#### Parameters

`queryString` [string](https://learn.microsoft.com/dotnet/api/system.string)

`connection` MySqlConnection

`validator` [Action](https://learn.microsoft.com/dotnet/api/system.action\-1)<MySqlDataReader\>

`selector` [Func](https://learn.microsoft.com/dotnet/api/system.func\-2)<MySqlDataReader, TRecord\>

#### Returns

 [IObservable](https://learn.microsoft.com/dotnet/api/system.iobservable\-1)<TRecord\>

#### Type Parameters

`TRecord`