feat(mysql): update MySQL wrapper to propagate fields. (#1412)

michaelsafyan · sofisl · web-flow · commit 1b92362d9a9b · 2022-08-10T12:19:44.000-07:00
Co-authored-by: sofisl &lt;55454395+sofisl@users.noreply.github.com&gt;
diff --git a/src/plugins/plugin-mysql.ts b/src/plugins/plugin-mysql.ts
@@ -48,7 +48,7 @@ function createCreateQueryWrap(api) {
 }
 
 function wrapCallback(api, span, done) {
-  const fn = function (err, res) {
+  const fn = function (err, res, fields) {
     if (api.enhancedDatabaseReportingEnabled()) {
       if (err) {
         span.addLabel('error', err);
@@ -59,7 +59,7 @@ function wrapCallback(api, span, done) {
     }
     span.endSpan();
     if (done) {
-      done(err, res);
+      done(err, res, fields);
     }
   };
   return api.wrap(fn);

Original file line number	Diff line number	Diff line change
`@@ -48,7 +48,7 @@ function createCreateQueryWrap(api) {`
`48`	`48`	`}`
`49`	`49`
`50`	`50`	`function wrapCallback(api, span, done) {`
`51`		`- const fn = function (err, res) {`
	`51`	`+ const fn = function (err, res, fields) {`
`52`	`52`	`if (api.enhancedDatabaseReportingEnabled()) {`
`53`	`53`	`if (err) {`
`54`	`54`	`span.addLabel('error', err);`
`@@ -59,7 +59,7 @@ function wrapCallback(api, span, done) {`
`59`	`59`	`}`
`60`	`60`	`span.endSpan();`
`61`	`61`	`if (done) {`
`62`		`- done(err, res);`
	`62`	`+ done(err, res, fields);`
`63`	`63`	`}`
`64`	`64`	`};`
`65`	`65`	`return api.wrap(fn);`