@@ -38,58 +38,55 @@ function runQuery(query, connection) {
3838 }
3939
4040 return new Promise ( ( resolve , reject ) => {
41- const client = vertica . connect (
42- params ,
43- function ( err ) {
44- if ( err ) {
45- client . disconnect ( )
46- return reject ( err )
47- }
41+ const client = vertica . connect ( params , function ( err ) {
42+ if ( err ) {
43+ client . disconnect ( )
44+ return reject ( err )
45+ }
4846
49- let incomplete = false
50- const rows = [ ]
51- let finished = false
52- let columnNames = [ ]
47+ let incomplete = false
48+ const rows = [ ]
49+ let finished = false
50+ let columnNames = [ ]
5351
54- const verticaQuery = client . query ( query )
52+ const verticaQuery = client . query ( query )
5553
56- verticaQuery . on ( 'fields' , fields => {
57- columnNames = fields . map ( field => field . name )
58- } )
54+ verticaQuery . on ( 'fields' , fields => {
55+ columnNames = fields . map ( field => field . name )
56+ } )
5957
60- verticaQuery . on ( 'row' , function ( row ) {
61- if ( rows . length < connection . maxRows ) {
62- const resultRow = { }
63- row . forEach ( ( value , index ) => {
64- resultRow [ columnNames [ index ] ] = value
65- } )
66- return rows . push ( resultRow )
67- }
68- if ( ! finished ) {
69- finished = true
70- client . disconnect ( )
71- incomplete = true
72- return resolve ( { rows, incomplete } )
73- }
74- } )
58+ verticaQuery . on ( 'row' , function ( row ) {
59+ if ( rows . length < connection . maxRows ) {
60+ const resultRow = { }
61+ row . forEach ( ( value , index ) => {
62+ resultRow [ columnNames [ index ] ] = value
63+ } )
64+ return rows . push ( resultRow )
65+ }
66+ if ( ! finished ) {
67+ finished = true
68+ client . disconnect ( )
69+ incomplete = true
70+ return resolve ( { rows, incomplete } )
71+ }
72+ } )
7573
76- verticaQuery . on ( 'end' , function ( ) {
77- if ( ! finished ) {
78- finished = true
79- client . disconnect ( )
80- return resolve ( { rows, incomplete } )
81- }
82- } )
74+ verticaQuery . on ( 'end' , function ( ) {
75+ if ( ! finished ) {
76+ finished = true
77+ client . disconnect ( )
78+ return resolve ( { rows, incomplete } )
79+ }
80+ } )
8381
84- verticaQuery . on ( 'error' , function ( err ) {
85- if ( ! finished ) {
86- finished = true
87- client . disconnect ( )
88- return reject ( err )
89- }
90- } )
91- }
92- )
82+ verticaQuery . on ( 'error' , function ( err ) {
83+ if ( ! finished ) {
84+ finished = true
85+ client . disconnect ( )
86+ return reject ( err )
87+ }
88+ } )
89+ } )
9390 } )
9491}
9592
0 commit comments