pass multiple query in query() function in nodejs

Question

In this only first query will run how I pass 2 query simultaneously .

I want to run insert or update query simultaneously.
db.js

require('dotenv').config()
const mysql = require('mysql');


const db_config = {
    connectionLimit: 10,
    host: "localhost",
    user: "root",
    password: "",
    database: "vechain"
};

const pool = mysql.createPool(db_config);
exports.pool = pool;
exports.query = function(query) {
    try {
        return new Promise((resolve, reject) => {
            pool.query(query, function(err, result, fields) {
                if (err) reject(err);
                resolve(result);
            });
        })
    } catch (err) {
        console.log('in db_sql function error');
        console.log(err);
        res.status(500).send({ success: false, msg: 'Error', data: '', errors: err });
    }
}

**app.js**

const db = require('./db'); //here I inclue database details

//this is my query var check = await db.query('insert into test ( name) Select "kk" where not exists(select * from test where name="kmkm" )';'update test set name = "88" where id = "463"');

How do you initiate the db object then? Can you please show us? — ikhvjs
– ikhvjs, Commented Jul 28, 2021 at 5:43
var db= mysql.createConnection({ host: "localhost", user: "root_new", password: "pas", database: "database" }); — Tarannum
– Tarannum, Commented Jul 28, 2021 at 6:17
Sorry, Please also show us What is the query1 and query2 as well. I don't fully understand what are you trying to do in the SQL? — ikhvjs
– ikhvjs, Commented Jul 28, 2021 at 7:21

ikhvjs · Accepted Answer · 2021-07-29 07:53:16Z

0

From the doc, you can pass two queries.

I add a option multipleStatements: true, in the config.

Also, I use ...args to pass multiple queries to the query function.

From the doc, Please note that the interface for streaming multiple statement queries is experimental

Example:

require("dotenv").config();
const mysql = require("mysql");

const db_config = {
  connectionLimit: 10,
  host: "localhost",
  user: "root",
  password: "",
  database: "vechain",
  multipleStatements: true,
};

const pool = mysql.createPool(db_config);
exports.pool = pool;
exports.query = function (...args) {
  try {
    const query = args.join(";");
    console.log({ query });
    return new Promise((resolve, reject) => {
      pool.query(query, function (err, result, fields) {
        if (err) reject(err);
        resolve(result);
      });
    });
  } catch (err) {
    console.log("in db_sql function error");
    console.log(err);
    res
      .status(500)
      .send({ success: false, msg: "Error", data: "", errors: err });
  }
};

You app.js

const db = require("./db"); //here I include database details

const query1 = "SELECT 1";
const query2 = "SELECT 2";

db.query(query1, query2).then(res => {
  console.log(res);
});

edited Jul 29, 2021 at 7:53

answered Jul 28, 2021 at 10:44

ikhvjs

6,0874 gold badges24 silver badges53 bronze badges

Sign up to request clarification or add additional context in comments.

19 Comments

Tarannum Over a year ago

var check = await db.query('insert into test ( name) Select "kk" where not exists(select * from test where name="kmkm" ) ; update test set name = "88" where id = "463"'); When I use this Then getting sql syntax error

ikhvjs Over a year ago

@Tarannum, I updated my answer. Please check if you have any errors from it. If so, please provide the error.

Tarannum Over a year ago

this is my error UnhandledPromiseRejectionWarning: Error: ER_PARSE_ERROR: You have an error in your SQL syntax; check the manual that corresponds to your MariaDB server version for the right syntax to use near 'update test set name = "88" where id = "463"' at line 1 @ikhvjs

Tarannum Over a year ago

var check = await db.query(

${'insert into test ( name) Select "kk"  where not exists(select * from test where name="kmkm" )'} ;${ 'update test set name = "88" where  id = "463"'}

);

ikhvjs Over a year ago

@Tarannum, can you please just copy the whole script from my answer to run? including the const query1= .....

|

Jesse · Accepted Answer · 2021-07-27 11:55:01Z

0

Try it;

var check = db.query(query1,query2);

answered Jul 27, 2021 at 11:55

Jesse

3511 gold badge2 silver badges9 bronze badges

1 Comment

skomisa Over a year ago

To improve your answer and help the OP, please add an explanation for why this will work. As it stands, the brevity of your answer makes it liable for deletion.

Collectives™ on Stack Overflow

pass multiple query in query() function in nodejs

2 Answers 2

19 Comments

1 Comment

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

19 Comments

1 Comment

Your Answer

Sign up or log in

Post as a guest

Linked

Related