node/ninja-store/routes/db_helper.js

var mysql = require('mysql');
var MYSQL_USERNAME = 'root';
var MYSQL_PASSWORD = 'condoms';

// init;
var client = mysql.createClient({
  user: MYSQL_USERNAME,
  password: MYSQL_PASSWORD,
});

// destroy old db
//client.query('DROP DATABASE IF EXISTS mynode_db', function(err) {
//  if (err) { throw err; }
//});

// create database
//client.query('CREATE DATABASE mynode_db', function(err) {
//  if (err) { throw err; }
//});
//console.log('database mynode_db is created.');
client.query('USE mynode_db');

// create table
//var sql = ""+
//"create table employees("+
//" id int unsigned not null auto_increment,"+
//" name varchar(50) not null default 'unknown',"+
//" salary dec(10,2) not null default 100000.00,"+
//" primary key (id)"+
//");";
//client.query(sql, function(err) {
//  if (err) { throw err; }
//});
//console.log('table employees is created.');


// function to create employee
exports.add_employee = function(data, callback) {
console.log('Employee '+data.name+' has salary '+data.salary); 
 client.query("insert into employees (name, salary) values (?,?)", [data.name, data.salary], function(err, info) {
    // callback function returns last insert id
    callback(info.insertId);
    console.log('Employee '+data.name+' has salary '+data.salary); 
  });
}

// function to get list of employees
 exports.get_employees = function(callback) {
 client.query("select * from employees", function(err, results, fields) {
//callback function returns employees array
 callback(results);
   });
 }

// function to get data from database
exports.get_all = function(data, callback) {
console.log('Table '+data);
  client.query("select * from " + data, function(err, results, fields) {
    // callback function returns employees array
      // Uncomment these if you want lots of feedback
      // console.log('Results:');
      // console.log(results);
      // console.log('Field metadata:');
      // console.log(fields);
	callback(err,results,fields);
  });
}