Merge pull request #4395 from activepieces/fix/mysql

fix(mysql): fix delete/find/insert/update row queries
activepieces · Apr 9, 2024 · f81afc2 · f81afc2
2 parents 98bcdd6 + 6076f3f
commit f81afc2
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 5 deletions.
diff --git a/packages/pieces/community/mysql/package.json b/packages/pieces/community/mysql/package.json
@@ -1,4 +1,4 @@
 {
   "name": "@activepieces/piece-mysql",
-  "version": "0.1.5"
+  "version": "0.1.6"
 }
diff --git a/packages/pieces/community/mysql/src/lib/actions/delete-row.ts b/packages/pieces/community/mysql/src/lib/actions/delete-row.ts
@@ -26,7 +26,7 @@ export default createAction({
     const searchColumn = sanitizeColumnName(context.propsValue.search_column);
     const searchValue = context.propsValue.search_value;
 
-    const queryString = `DELETE FROM \`${tableName}\` WHERE ${searchColumn}=?;`;
+    const queryString = `DELETE FROM ${tableName} WHERE ${searchColumn}=?;`;
 
     const connection = await mysqlConnect(context.auth, context.propsValue);
     try {

diff --git a/packages/pieces/community/mysql/src/lib/actions/find-rows.ts b/packages/pieces/community/mysql/src/lib/actions/find-rows.ts
@@ -33,7 +33,7 @@ export default createAction({
       .map((c) => sanitizeColumnName(c))
       .join(',');
 
-    const qs = `SELECT ${qsColumns} FROM \`${sanitizeColumnName(context.propsValue.table)}\` WHERE ${context.propsValue.condition};`;
+    const qs = `SELECT ${qsColumns} FROM ${sanitizeColumnName(context.propsValue.table)} WHERE ${context.propsValue.condition};`;
 
     const conn = await mysqlConnect(context.auth, context.propsValue);
 

diff --git a/packages/pieces/community/mysql/src/lib/actions/insert-row.ts b/packages/pieces/community/mysql/src/lib/actions/insert-row.ts
@@ -20,7 +20,7 @@ export default createAction({
     const fields = Object.keys(context.propsValue.values);
     const qsFields = fields.map((f) => sanitizeColumnName(f)).join(',');
     const qsValues = fields.map(() => '?').join(',');
-    const qs = `INSERT INTO \`${sanitizeColumnName(context.propsValue.table)}\` (${qsFields}) VALUES (${qsValues});`;
+    const qs = `INSERT INTO ${sanitizeColumnName(context.propsValue.table)} (${qsFields}) VALUES (${qsValues});`;
     const conn = await mysqlConnect(context.auth, context.propsValue);
     try {
       const values = fields.map((f) => context.propsValue.values[f]);

diff --git a/packages/pieces/community/mysql/src/lib/actions/update-row.ts b/packages/pieces/community/mysql/src/lib/actions/update-row.ts
@@ -27,7 +27,7 @@ export default createAction({
   async run(context) {
     const fields = Object.keys(context.propsValue.values);
     const qsValues = fields.map((f) => sanitizeColumnName(f) + '=?').join(',');
-    const qs = `UPDATE \`${sanitizeColumnName(context.propsValue.table)}\` SET ${qsValues} WHERE ${sqlstring.escape(context.propsValue.search_column)}=?;`;
+    const qs = `UPDATE ${sanitizeColumnName(context.propsValue.table)} SET ${qsValues} WHERE ${sqlstring.escape(context.propsValue.search_column)}=?;`;
     const conn = await mysqlConnect(context.auth, context.propsValue);
     try {
     const values = fields.map((f) => context.propsValue.values[f]);