1- /* Copyright (c) 2015, 2016 , Oracle and/or its affiliates. All rights reserved. */
1+ /* Copyright (c) 2015, 2017 , Oracle and/or its affiliates. All rights reserved. */
22
33/******************************************************************************
44 *
@@ -68,7 +68,8 @@ var doit = function(pool) {
6868 enableDbmsOutput ,
6969 createDbmsOutput ,
7070 fetchDbmsOutput ,
71- printDbmsOutput
71+ printDbmsOutput ,
72+ closeRS
7273 ] ,
7374 function ( err , conn ) {
7475 if ( err ) { console . error ( "In waterfall error cb: ==>" , err , "<==" ) ; }
@@ -84,10 +85,10 @@ var enableDbmsOutput = function (conn, cb) {
8485
8586var createDbmsOutput = function ( conn , cb ) {
8687 conn . execute (
87- " BEGIN " +
88- " DBMS_OUTPUT.PUT_LINE('Hello, Oracle!');" +
89- " DBMS_OUTPUT.PUT_LINE('Hello, Node!');" +
90- " END;" ,
88+ ` BEGIN
89+ DBMS_OUTPUT.PUT_LINE('Hello, Oracle!');
90+ DBMS_OUTPUT.PUT_LINE('Hello, Node!');
91+ END;` ,
9192 function ( err ) { return cb ( err , conn ) ; } ) ;
9293} ;
9394
@@ -118,12 +119,18 @@ var fetchRowsFromRS = function(conn, resultSet, numRows, cb) {
118119 numRows ,
119120 function ( err , rows ) {
120121 if ( err ) {
121- return cb ( err , conn ) ;
122+ return cb ( err , conn , resultSet ) ;
122123 } else if ( rows . length > 0 ) {
123124 console . log ( rows ) ;
124125 return fetchRowsFromRS ( conn , resultSet , numRows , cb ) ;
125126 } else {
126- return cb ( null , conn ) ;
127+ return cb ( null , conn , resultSet ) ;
127128 }
128129 } ) ;
129130} ;
131+
132+ var closeRS = function ( conn , resultSet , cb ) {
133+ resultSet . close ( function ( err ) {
134+ return cb ( err , conn ) ;
135+ } ) ;
136+ } ;
0 commit comments