[聚合文章] node.js连接数据库(mysql)

在我们的myapp项目中 新建 db.js文件 创建我们的数据库连接

var mysql = require('mysql');var db ={};db.query = function sqlback(sqllan,fn){    var connetion = mysql.createConnection({        host:"localhost",       //   host表示mysql安装的地址，因为我是本地的数据库，所以直接使用localhost        user:"root",            // user表示mysql的用户名        password:"111111",      // password表示mysql的密码        database:'mysql',       // database表示你要选择操作的具体的库的名字        port:3306               // port表示端口，可不填，默认就是3306    });    connetion.connect(function(err){  //调用connection的connect方法判断连接是否成功，如果失败，则把错误信息打印出来，并且停止运行。        if(err){            console.log(err);            return;        }    });    var sql = sqllan;    if(!sql)return;    //调用connection的query方法来直接向数据库发送sql语句，    //并且把用回调函数返回结果，其中回调函数中有三个参数，    //第一参数是错误对象，如果操作失败，则会停止并打印错误信息，    //第二参数是具体的返回的结果，正常情况下是一个数组，里面包含很多json,    //第三个参数也是一个数组，里面包含着最每个数据的解释，比如当前数据属于哪个库，那张表等等。我们使用最多的自然是第二个参数了    connetion.query(sql,function(err,rows,filds){ //给他赋值一个叫query的方法，这个方法接受两个参数，第一个参数是你查询数据时候的sql语句，第二个参数是获取查询结果的回调函数。        if(err){            console.log(err);               return        }        fn(rows);    });       connetion.end(function(err){        if(err){            return;        }else{            console.log('连接关闭');        }    });}module.exports= db;

拦截路由 拿取数据
(express 从入门到放弃)http://www.expressjs.com.cn/4x/api.html

var express = require('express');var path = require('path');var favicon = require('serve-favicon');var logger = require('morgan');var cookieParser = require('cookie-parser');var bodyParser = require('body-parser');var mysql = require('./db.js')var index = require('./routes/index');var users = require('./routes/users');var app = express();//加载hbs模板var hbs = require('hbs');// view engine setupapp.set('views', path.join(__dirname, 'views'));app.set('view engine', 'jade');// uncomment after placing your favicon in /public//app.use(favicon(path.join(__dirname, 'public', 'favicon.ico')));app.use(logger('dev'));app.use(bodyParser.json());app.use(bodyParser.urlencoded({ extended: false }));app.use(cookieParser());app.use(express.static(path.join(__dirname, 'public')));//这里我们进行拦截 路由 然后 用这个app.use() 这个api  app.use('/', function(req, res, next) {  var sql="select * from userinfo";  var result = mysql.query(sql,function(result){      res.render('index', { title: JSON.stringify(result) });  });});app.use('/users', users);// catch 404 and forward to error handlerapp.use(function(req, res, next) {  var err = new Error('Not Found');  err.status = 404;  next(err);});// error handlerapp.use(function(err, req, res, next) {  // set locals, only providing error in development  res.locals.message = err.message;  res.locals.error = req.app.get('env') === 'development' ? err : {};  // render the error page  res.status(err.status || 500);  res.render('error');});module.exports = app;

好了 看下效果 一个简单的查询

注：本文内容来自互联网，旨在为开发者提供分享、交流的平台。如有涉及文章版权等事宜，请你联系站长进行处理。