node.js连接mysql

var http = require(‘http‘);
　　http.createServer(function (req, res) {
　　  res.writeHead(200, {‘Content-Type‘: ‘text/plain‘});
 　　 res.end(‘Hello World node.js \n‘);

　　}).listen(1337, "127.0.0.1");
　　console.log(‘Server running at http://127.0.0.1:1337/‘);

打开命令行 切换到脚本的路径
node hello.js

浏览器访问地址 ：

http://127.0.0.1:1337  

如果看到这个页面，恭喜你进入node.js 世界

1 $ cd /usr/local/lib         
2 $ sudo npm install mysql 

 /*
 Navicat Premium Data Transfer

 Source Server         : 127.0.0.1
 Source Server Type    : MySQL
 Source Server Version : 50617
 Source Host           : 127.0.0.1
 Source Database       : test

 Target Server Type    : MySQL
 Target Server Version : 50617
 File Encoding         : utf-8

 Date: 08/20/2014 23:55:29 PM
*/

SET NAMES utf8;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
--  Table structure for `user`
-- ----------------------------
DROP TABLE IF EXISTS `user`;
CREATE TABLE `user` (
  `userid` int(3) NOT NULL,
  `username` varchar(50) DEFAULT NULL,
  `userage` int(3) DEFAULT NULL,
  PRIMARY KEY (`userid`)
) ENGINE=InnoDB DEFAULT CHARSET=latin1;

-- ----------------------------
--  Records of `user`
-- ----------------------------
BEGIN;
INSERT INTO `user` VALUES (‘1‘, ‘admin‘, ‘100‘), (‘2‘, ‘xainzhi‘, ‘101‘);
COMMIT;

SET FOREIGN_KEY_CHECKS = 1;

与数据库连接获取数据， 新建文件 sql.js

var mysql      = require(‘mysql‘);
var clinet = mysql.createConnection({
  host     : ‘localhost‘,
  user     : ‘root‘,
  database : ‘test‘,
  password : ‘root‘,
  port:3306
});
 
clinet.connect();

 
 
    clinet.query(‘SELECT *  from user ‘, function(err, rows, fields) {
      if (err) throw err;
     
      var data = ‘‘;
        for(var i = 0; i ){
             console.log(‘
‘ + ‘用户id：‘ + rows[i].userid + ‘
‘);
             console.log(‘
‘ + ‘用户姓名：‘ + rows[i].username+‘
‘);
             console.log(‘
‘ + ‘用户年龄：‘ + rows[i].userage + ‘
‘);
                 
        }
         
    });
 
 
clinet.end();

打开命令行 切换到脚本的路径
node   sql.js

运行的结果是这样的

sudo npm install -g express
sudo npm install -d　　　

var express = require(‘express‘);
var mysql = require(‘mysql‘);
var app = express();
 
app.use(function(req, res, next){
  console.log(‘%s %s‘, req.method, req.url);
  next();
});
 
var conn = mysql.createConnection({
    host:‘localhost‘,
    user:‘root‘,
    database:‘test‘,
    password:‘root‘,
    port:3306
});
 
conn.connect();
app.get(‘/‘, function(req, res){
 
    conn.query(‘SELECT * from user‘, function(err, rows, fields) {
        if (err) throw err;
        var data = ‘‘;
        for(var i = 0; i ){
            data += ‘
‘ + ‘用户id：‘ + rows[i].userid + ‘‘;
            data += ‘
‘ + ‘用户名：‘ + rows[i].username + ‘‘;
            data += ‘
‘ + ‘年龄：‘ + rows[i].userage + ‘‘;
            data += ‘
‘;
        }
        res.send(data);
 
    });
});
 
app.listen(3000);
 
console.log(‘service URL：http://127.0.0.1:3000 ‘);

export NODE_PATH="/usr/local/lib/node_modules"