[Node-DuckDB API](./node-duckdb.md) > [Connection](./node-duckdb.connection.md) > [execute](./node-duckdb.connection.execute.md)
## Connection.execute() method
Asynchronously executes the query and returns a [Readable stream](https://nodejs.org/api/stream.html#stream_class_stream_readable) that wraps the result set.
Signature:
```typescript
execute(command: string, options?: IExecuteOptions): Promise;
```
## Parameters
| Parameter | Type | Description |
| --------- | --------------------------------------------------- | ----------------------------------------------------------------------------------- |
| command | string | SQL command to execute |
| options | [IExecuteOptions](./node-duckdb.iexecuteoptions.md) | optional options object of type [IExecuteOptions](./node-duckdb.iexecuteoptions.md) |
Returns:
Promise<Readable>
## Example
Streaming results of a DuckDB query into a CSV file:
```ts
import { Connection, DuckDB, RowResultFormat } from "node-duckdb";
import { createWriteStream } from "fs";
import { Transform } from "stream";
class ArrayToCsvTransform extends Transform {
constructor() {
super({ objectMode: true });
}
_transform(chunk: any[], _encoding: string, callback: any) {
this.push(chunk.join(",") + "\n");
callback();
}
}
async function outputToFileAsCsv() {
const db = new DuckDB();
const connection = new Connection(db);
await connection.execute("CREATE TABLE people(id INTEGER, name VARCHAR);");
await connection.execute("INSERT INTO people VALUES (1, 'Mark'), (2, 'Hannes'), (3, 'Bob');");
const resultStream = await connection.execute("SELECT * FROM people;", { rowResultFormat: RowResultFormat.Array });
const transformToCsvStream = new ArrayToCsvTransform();
const writeStream = createWriteStream("my-people-output");
resultStream.pipe(transformToCsvStream).pipe(writeStream);
}
outputToFileAsCsv();
```