This module custom from module "mysql".

Install

npm i vn-define vn-mysql --save

Examples

var mysql = require("vn-mysql");
var db = new mysql("database");
var callback = function(e){ console.log(e) };

// fetch or fetchAll
db.table("user")
  .column("id,fname,lname");
  .where({id: 1})
  .fetch(callback)
  .catch(callback);

// join
db.table("post as p")
  .column([
    "p.id as post_id, p.user as post_user, p.title, p.content, p.created",
    "a.id as album_id, a.name as album_name",
    "u.fname as user_fname, u.lname as user_lname"
  ])
  .leftJoin({
    "album as a": "a.aid = p.aid",
    "user as u": "u.id = p.user"
  })
  .where("id", ">", 10)
  .limit(20)
  .fetchAll(callback);

// select in
db.table("post").column("id, title").in("name", ["Thuan", "Chi"]).fetchAll(callback);

db.table("post").column("id, title").in("name", function(){
  return this.table("user").column("lname").where({fname: "Nguyen"});
})
.fetchAll(callback)
.catch(callback);

// insert
db.table("user").insert({fname: "Nguyen", lname: "Thuan"}, callback);

db.table("post").column("name").insert(function(){
  return this.table("user").where({id: 1}).column("concat(fname, ' ', lname)");
});

db.table("user").insertArray([
  {fname: "Fname1", lname: "Lname1"},
  {fname: "Fname2", lname: "Lname2"}
]);

// update
db.table("user").where({id: 1}).update({fname: "New Fname"});

// delete
db.table("user").where({id: 1}).remove();

db.table("post").remove(function(){
  this.table("user").where({username: 'nguyenthuan'});
  return this;
});