copyTo method

Future<int> copyTo(
  1. String sql,
  2. void onData(
    1. Uint8List data
    ), {
  3. dynamic substitutionValues,
  4. PlaceholderIdentifier placeholderIdentifier = PlaceholderIdentifier.atSign,
  5. int? timeoutInSeconds,
})
inherited

Executa um COPY ... TO STDOUT, entregando a onData o conteúdo de cada mensagem de dados (no formato texto, uma linha por chamada; veja PgCopy.decodeTextRow), e devolve o número de linhas copiadas.

Se onData lançar uma exceção, os dados restantes são descartados e a exceção é lançada ao final do COPY; a conexão continua utilizável.

Implementation

Future<int> copyTo(String sql, void Function(Uint8List data) onData,
    {dynamic substitutionValues,
    PlaceholderIdentifier placeholderIdentifier =
        PlaceholderIdentifier.atSign,
    int? timeoutInSeconds}) async {
  final query = _copyQuery(sql, substitutionValues, placeholderIdentifier)
    ..copyOutHandler = onData;
  final result = await _enqueue(query,
      timeoutInSeconds: timeoutInSeconds ?? _connection.queryTimeoutInSeconds);
  return result.affectedRowCount;
}