@@ -5,6 +5,7 @@ const Excel = require('exceljs');
55const csv = require ( 'fast-csv' ) ;
66const fs = require ( 'fs' ) ;
77const fsp = require ( 'fs' ) . promises ;
8+ const path = require ( 'path' ) ;
89
910const Executor = require ( '@runnerty/module-core' ) . Executor ;
1011
@@ -61,6 +62,7 @@ class mysqlExecutor extends Executor {
6162 // XLSX FILE EXPORT
6263 // ****************
6364 if ( params . xlsxFileExport ) {
65+ await fsp . access ( path . dirname ( params . xlsxFileExport ) ) ;
6466 const options = {
6567 filename : params . xlsxFileExport ,
6668 useStyles : true ,
@@ -102,6 +104,7 @@ class mysqlExecutor extends Executor {
102104 // CSV FILE EXPORT
103105 // ***************
104106 else if ( params . csvFileExport ) {
107+ await fsp . access ( path . dirname ( params . csvFileExport ) ) ;
105108 const fileStreamWriter = fs . createWriteStream ( params . csvFileExport ) ;
106109 const paramsCSV = params . csvOptions || { } ;
107110 if ( ! paramsCSV . hasOwnProperty ( 'headers' ) ) paramsCSV . headers = true ;
@@ -150,6 +153,7 @@ class mysqlExecutor extends Executor {
150153 // TEXT FILE EXPORT JSON
151154 // *********************
152155 else if ( params . fileExport ) {
156+ await fsp . access ( path . dirname ( params . fileExport ) ) ;
153157 const fileStreamWriter = fs . createWriteStream ( params . fileExport ) ;
154158
155159 queryStream . on ( 'result' , row => {
0 commit comments