Node.js MySQLのクエリでプレースホルダーを使う

前置き

Lambdaなどでmysqlを実行するにあたっての簡易メモ
仕様は公式から参照

.query(sqlString, values, callback)でプレースホルダー値を利用する
（connection作成は省略します。）

• 第一引数のSQLに?を指定する。
• 第二引数に配列を渡す。

SELECT

const sql = "SELECT * FROM sample WHERE id = ?";
const data = [1];
const query = connection.query(sql, data, (err, results, fields) => {
  if (error) throw error;
  // ...
});
console.log(query.sql); // SELECT * FROM testdb.sample WHERE id = 1

フィールド名に使う場合は??を指定する。

const sql = "SELECT ?? FROM ?? WHERE id = ?";
const columns = ['id', 'name', 'email'];
const data = [columns, 'users', 1]
const query = connection.query(sql, data, (err, results, fields) => {
  if (error) throw error;
  // ...
});
console.log(query.sql); // SELECT id, name, email FROM users WHERE id = 1

INSERT

複数カラムを１つの?で対応できます。

const sql = "INSERT INTO posts SET ?"
const post  = {id: 1, title: 'Hello MySQL'};
const query = connection.query(sql, post, (error, results, fields) => {
  if (error) throw error;
  // ...
});
console.log(query.sql); // INSERT INTO posts SET id = 1, title = 'Hello MySQL'

複数行のinsertを行う場合は(?)を使用する
※insertするレコード数分必要。

const sql = "INSERT INTO users(name, age, sex) VALUES(?),(?),(?)"
const data = [['boy', 23, 'man'], ['girl', 14, 'woman'], ['guy', 42, 'man']];
const query = connection.query(sql, data, (error,results,fields) => {
  if (error) throw error;
  // ...
});
console.log(query.sql); 
/*
INSERT INTO
 users(name, age, sex) 
VALUES 
 ('boy', 23, 'man'),
 ('girl', 14, 'woman'),
 ('guy', 42, 'man')'
*/

UPDATE

const sql = "INSERT INTO users SET name = ? WHERE id = ?"
const data  = ['佐藤', 1];
const query = connection.query(sql, data, (error, results, fields) => {
  if (error) throw error;
  // ...
});
console.log(query.sql); // INSERT INTO users SET name = '佐藤' WHERE id = 1

複数行もinsertと同じ。
onduplicate key updateのサンプル

const sql = "INSERT INTO users(name, age, sex) VALUES(?),(?) ON DUPLICATE KEY UPDATE age = VALUES(age) "
const data = [['boy', 25, 'man'], ['girl', 16, 'woman']];
const query = connection.query(sql, data, (error,results,fields) => {
  if (error) throw error;
  // ...
});
console.log(query.sql); 
/*
INSERT INTO
 users(name, age, sex) 
VALUES 
 ('boy', 25'man'),
 ('girl', 16, 'woman')
ON DUPLICATE KEY UPDATE age = VALUES(age)
*/