神刀安全网

node.js连接数据库(mysql)

node 连接数据库
这里默认你安装了Node
安装 express 依赖

npm install express --save 

安装mysql

npm install mysql --save 

创建项目

express myapp cd myapp  在myapp 目录下npm install 

安装mysql数据库
http://www.cnblogs.com/tongy0/p/6739188.html(这里是个压缩版 可以用命令行安装)
注:安装的时候记得设置密码
安装成功后 用可视化sql界面链接 这里用的是 sqlyog

node.js连接数据库(mysql)

image.png

新建张表(注意字符集选择)

node.js连接数据库(mysql)

image.png

插入数据

node.js连接数据库(mysql)

image.png

在我们的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 setup app.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 handler app.use(function(req, res, next) {   var err = new Error('Not Found');   err.status = 404;   next(err); });  // error handler app.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; 

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

node.js连接数据库(mysql)

image.png

长路漫漫,做下笔记 …

node.js连接数据库(mysql)

zixia.gif

转载本站任何文章请注明:转载至神刀安全网,谢谢神刀安全网 » node.js连接数据库(mysql)

分享到:更多 ()

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址