DatabaseExporter

StockSharp.Algo.Export

导出到数据库中。

构造函数

public DatabaseExporter(IDatabaseProvider dbProvider, DataType dataType, DatabaseConnectionPair connection, decimal? priceStep, decimal? volumeStep)

databaseExporter = DatabaseExporter(dbProvider, dataType, connection, priceStep, volumeStep)

导出到数据库中。

dbProvider: IDatabaseProvider
dataType: 数据类型信息.
connection: 连接到 DB 。
priceStep: 最低价阶.
volumeStep: 最小量步数.

属性

BatchSize

public int BatchSize { get; set; }

value = databaseExporter.BatchSize
databaseExporter.BatchSize = value

传输数据包的大小。默认为 50 个元素。

CheckUnique

public bool CheckUnique { get; set; }

value = databaseExporter.CheckUnique
databaseExporter.CheckUnique = value

检查数据库中数据的独特性。它影响性能。默认启用。

DropExisting

public bool DropExisting { get; set; }

value = databaseExporter.DropExisting
databaseExporter.DropExisting = value

导出前放下已有的表格。默认值已禁用。

PriceStep

public decimal? PriceStep { get; }

value = databaseExporter.PriceStep

最低价阶.

TableNamePrefix

public string TableNamePrefix { get; set; }

value = databaseExporter.TableNamePrefix
databaseExporter.TableNamePrefix = value

表格名称的可选前缀(e.g. " SS_ ")。

VolumeStep

public decimal? VolumeStep { get; }

value = databaseExporter.VolumeStep

最小量步数.

方法

Export

protected override Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<IndicatorValue> values, CancellationToken cancellationToken)

result = databaseExporter.Export(values, cancellationToken)

To export IndicatorValue asynchronously.

values: 价值.
cancellationToken: 取消的代币。

返回值: 数并上回.

Export

protected override Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<PositionChangeMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.Export(messages, cancellationToken)

To export PositionChangeMessage asynchronously.

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

Export

protected override Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<SecurityMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.Export(messages, cancellationToken)

To export SecurityMessage asynchronously.

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

Export

protected override Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<NewsMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.Export(messages, cancellationToken)

To export NewsMessage asynchronously.

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

Export

protected override Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<CandleMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.Export(messages, cancellationToken)

To export CandleMessage asynchronously.

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

Export

protected override Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<Level1ChangeMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.Export(messages, cancellationToken)

To export Level1ChangeMessage asynchronously.

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

Export

protected override Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<BoardMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.Export(messages, cancellationToken)

To export BoardMessage asynchronously.

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

Export

protected override Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<BoardStateMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.Export(messages, cancellationToken)

To export BoardStateMessage asynchronously.

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

Export

protected override Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<QuoteChangeMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.Export(messages, cancellationToken)

To export QuoteChangeMessage asynchronously.

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

ExportOrderLogAsync

protected override Task<ValueTuple<int, DateTime?>> ExportOrderLogAsync(IAsyncEnumerable<ExecutionMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.ExportOrderLogAsync(messages, cancellationToken)

To export OrderLog asynchronously.

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

ExportTicksAsync

protected override Task<ValueTuple<int, DateTime?>> ExportTicksAsync(IAsyncEnumerable<ExecutionMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.ExportTicksAsync(messages, cancellationToken)

要同步导出 Ticks 。

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

ExportTransactionsAsync

protected override Task<ValueTuple<int, DateTime?>> ExportTransactionsAsync(IAsyncEnumerable<ExecutionMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.ExportTransactionsAsync(messages, cancellationToken)

同步导出交易。

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.