@@ -2785,19 +2785,33 @@ connection.execute(
2785
2785
2786
2786
var lob = result .outBinds .lobbv [0 ];
2787
2787
lob .on (' error' , function (err ) { console .error (err); });
2788
+ lob .on (' finish' ,
2789
+ function ()
2790
+ {
2791
+ connection .commit (
2792
+ function (err )
2793
+ {
2794
+ if (err)
2795
+ console .error (err .message );
2796
+ else
2797
+ console .log (" Text inserted successfully." );
2798
+ connection .release (function (err ) {
2799
+ if (err) console .error (err .message );
2800
+ });
2801
+ });
2802
+ });
2788
2803
2789
2804
console .log (' Reading from ' + inFileName);
2790
2805
var inStream = fs .createReadStream (inFileName);
2791
- inStream .on (' end' , function () {
2792
- connection .commit (
2793
- function (err ) {
2794
- if (err)
2795
- console .error (err .message );
2796
- else
2797
- console .log (" Text inserted successfully." );
2798
- });
2799
- });
2800
- inStream .on (' error' , function (err ) { console .error (err); });
2806
+ inStream .on (' error' ,
2807
+ function (err )
2808
+ {
2809
+ console .error (err);
2810
+ connection .release (function (err ) {
2811
+ if (err) console .error (err .message );
2812
+ });
2813
+ });
2814
+
2801
2815
inStream .pipe (lob); // copies the text to the CLOB
2802
2816
});
2803
2817
` ` `
@@ -2835,6 +2849,9 @@ connection.execute(
2835
2849
2836
2850
lob .setEncoding (' utf8' ); // we want text, not binary output
2837
2851
lob .on (' error' , function (err ) { console .error (err); });
2852
+ lob .on (' close' , function () {
2853
+ connection .release (function (err ) { if (err) console .error (err .message ); });
2854
+ });
2838
2855
2839
2856
console .log (' Writing to ' + outFileName);
2840
2857
var outStream = fs .createWriteStream (outFileName);
0 commit comments