Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- var mysql = require('mysql');
- var pool = mysql.createPool({
- host : 'localhost',
- user : 'root',
- password : 'root',
- database : 'guess'
- });
- exports.pool = pool;
- var mysql = require('../db/mysql').pool;
- var test = function(req, res) {
- mysql.getConnection(function(err, conn){
- conn.query("select * from users", function(err, rows) {
- res.json(rows);
- })
- })
- }
- var getConnection = function(callback) {
- pool.getConnection(function(err, connection) {
- callback(err, connection);
- });
- };
- module.exports = getConnection;
- connection.release();
- var pool = mysql.createPool(config.db);
- exports.connection = {
- query: function () {
- var queryArgs = Array.prototype.slice.call(arguments),
- events = [],
- eventNameIndex = {};
- pool.getConnection(function (err, conn) {
- if (err) {
- if (eventNameIndex.error) {
- eventNameIndex.error();
- }
- }
- if (conn) {
- var q = conn.query.apply(conn, queryArgs);
- q.on('end', function () {
- conn.release();
- });
- events.forEach(function (args) {
- q.on.apply(q, args);
- });
- }
- });
- return {
- on: function (eventName, callback) {
- events.push(Array.prototype.slice.call(arguments));
- eventNameIndex[eventName] = callback;
- return this;
- }
- };
- }
- };
- db.connection.query("SELECT * FROM `table` WHERE `id` = ? ", row_id)
- .on('result', function (row) {
- setData(row);
- })
- .on('error', function (err) {
- callback({error: true, err: err});
- });
- var mysql = require("mysql");
- var pool = mysql.createPool({
- connectionLimit : 10,
- host: Config.appSettings().database.host,
- user: Config.appSettings().database.username,
- password: Config.appSettings().database.password,
- database: Config.appSettings().database.database
- });
- var DB = (function () {
- function _query(query, params, callback) {
- pool.getConnection(function (err, connection) {
- if (err) {
- connection.release();
- callback(null, err);
- throw err;
- }
- connection.query(query, params, function (err, rows) {
- connection.release();
- if (!err) {
- callback(rows);
- }
- else {
- callback(null, err);
- }
- });
- connection.on('error', function (err) {
- connection.release();
- callback(null, err);
- throw err;
- });
- });
- };
- return {
- query: _query
- };
- })();
- module.exports = DB;
- var DB = require('../dal/base.js');
- DB.query("select * from tasks", null, function (data, error) {
- callback(data, error);
- });
- pool.getConnection(function (err, connection) {
- connection.release();
- if (!err)
- {
- console.log('*** Mysql Connection established with ', config.database, ' and connected as id ' + connection.threadId);
- //CHECKING USERNAME EXISTENCE
- email = receivedValues.email
- connection.query('SELECT * FROM users WHERE email = ?', [email],
- function (err, rows) {
- if (!err)
- {
- if (rows.length == 1)
- {
- if (bcrypt.compareSync(req.body.password, rows[0].password))
- {
- var alldata = rows;
- var userid = rows[0].id;
- var tokendata = (receivedValues, userid);
- var token = jwt.sign(receivedValues, config.secret, {
- expiresIn: 1440 * 60 * 30 // expires in 1440 minutes
- });
- console.log("*** Authorised User");
- res.json({
- "code": 200,
- "status": "Success",
- "token": token,
- "userData": alldata,
- "message": "Authorised User!"
- });
- logger.info('url=', URL.url, 'Responce=', 'User Signin, username', req.body.email, 'User Id=', rows[0].id);
- return;
- }
- else
- {
- console.log("*** Redirecting: Unauthorised User");
- res.json({"code": 200, "status": "Fail", "message": "Unauthorised User!"});
- logger.error('*** Redirecting: Unauthorised User');
- return;
- }
- }
- else
- {
- console.error("*** Redirecting: No User found with provided name");
- res.json({
- "code": 200,
- "status": "Error",
- "message": "No User found with provided name"
- });
- logger.error('url=', URL.url, 'No User found with provided name');
- return;
- }
- }
- else
- {
- console.log("*** Redirecting: Error for selecting user");
- res.json({"code": 200, "status": "Error", "message": "Error for selecting user"});
- logger.error('url=', URL.url, 'Error for selecting user', req.body.email);
- return;
- }
- });
- connection.on('error', function (err) {
- console.log('*** Redirecting: Error Creating User...');
- res.json({"code": 200, "status": "Error", "message": "Error Checking Username Duplicate"});
- return;
- });
- }
- else
- {
- Errors.Connection_Error(res);
- }
- });
Add Comment
Please, Sign In to add comment