diff --git a/csvkit/utilities/sql2csv.py b/csvkit/utilities/sql2csv.py index 87187c966..9c9a899bb 100644 --- a/csvkit/utilities/sql2csv.py +++ b/csvkit/utilities/sql2csv.py @@ -69,7 +69,7 @@ def main(self): self.input_file.close() - rows = connection.execution_options(no_parameters=True).execute(query) + rows = connection.execution_options(no_parameters=True).exec_driver_sql(query) output = agate.csv.writer(self.output_file, **self.writer_kwargs) if rows.returns_rows: