Node.js 连接 MongoDB

安装驱动

$ cnpm install mongodb

数据库操作( CURD )

与 MySQL 不同的是 MongoDB 会自动创建数据库和集合,所以使用前我们不需要手动去创建。

插入数据

以下实例我们连接数据库 hello 的 site 表,并插入两条数据:

var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://localhost:27017/hello';//数据库为 hello

var insertData = function (db, callback) {
    //连接到表 site
    var collection = db.collection('site');
    //插入数据
    var data = [{
        "name": "hello",
        "url": "www.hello.com"
    }, {
        "name": "hi",
        "url": "c.hello.com"
    }];
    collection.insert(data, function (err, result) {
        if (err) {
            console.log('Error:' + err);
            return;
        }
        callback(result);
    });
}

MongoClient.connect(DB_CONN_STR, function (err, db) {
    console.log("连接成功!");
    insertData(db, function (result) {
        console.log(result);
        db.close();
    });
});

执行以下命令输出就结果为:

$ node test.js
连接成功!
{ result: { ok: 1, n: 2 },
  ops: 
   [ { name: 'hello',
       url: 'www.hello.com',
       _id: 58c25e13a08de70d3b9d4116 },
     { name: 'hi',
       url: 'c.hello.com',
       _id: 58c25e13a08de70d3b9d4117 } ],
  insertedCount: 2,
  insertedIds: [ 58c25e13a08de70d3b9d4116, 58c25e13a08de70d3b9d4117 ] }

从输出结果来看,数据已插入成功。
我们也可以打开 MongoDB 的客户端查看数据,如:

> show dbs
admin   0.000GB
local   0.000GB
hello  0.000GB          # 自动创建了 hello 数据库
> show tables
site                     # 自动创建了 site 集合(数据表)
> db.site.find()         # 查看集合中的数据
{ "_id" : ObjectId("58c25f300cd56e0d7ddfc0c8"), "name" : "hello", "url" : "www.hello.com" }
{ "_id" : ObjectId("58c25f300cd56e0d7ddfc0c9"), "name" : "hi", "url" : "c.hello.com" }
> 

查询数据

以下实例检索 name 为 “hello” 的实例:

var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://localhost:27017/hello';    
 
var selectData = function(db, callback) {  
  //连接到表  
  var collection = db.collection('site');
  //查询数据
  var whereStr = {"name":'hello'};
  collection.find(whereStr).toArray(function(err, result) {
    if(err)
    {
      console.log('Error:'+ err);
      return;
    }     
    callback(result);
  });
}
 
MongoClient.connect(DB_CONN_STR, function(err, db) {
  console.log("连接成功!");
  selectData(db, function(result) {
    console.log(result);
    db.close();
  });
});

执行以下命令输出就结果为:

连接成功!
[ { _id: 58c25f300cd56e0d7ddfc0c8,
    name: 'hello',
    url: 'www.hello.com' } ]

更新数据

我们也可以对数据库的数据进行修改,以下实例将 name 为 “hello” 的 url 改为https://www.hello.com:

var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://localhost:27017/hello';

var updateData = function (db, callback) {
    //连接到表  
    var collection = db.collection('site');
    //更新数据
    var whereStr = {
        "name": 'hello'
    };
    var updateStr = {
        $set: {
            "url": "https://www.hello.com"
        }
    };
    collection.update(whereStr, updateStr, function (err, result) {
        if (err) {
            console.log('Error:' + err);
            return;
        }
        callback(result);
    });
}

MongoClient.connect(DB_CONN_STR, function (err, db) {
    console.log("连接成功!");
    updateData(db, function (result) {
        console.log(result);
        db.close();
    });
});

执行成功后,进入 mongo 管理工具查看数据已修改:

> db.site.find()
{ "_id" : ObjectId("58c25f300cd56e0d7ddfc0c8"), "name" : "hello", "url" : "https://www.hello.com" }
{ "_id" : ObjectId("58c25f300cd56e0d7ddfc0c9"), "name" : "hi", "url" : "c.hello.com" }

删除数据

以下实例将 name 为 “hi” 的数据删除 :

var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://localhost:27017/hello';    
 
var delData = function(db, callback) {  
  //连接到表  
  var collection = db.collection('site');
  //删除数据
  var whereStr = {"name":'hi'};
  collection.remove(whereStr, function(err, result) {
    if(err)
    {
      console.log('Error:'+ err);
      return;
    }     
    callback(result);
  });
}
 
MongoClient.connect(DB_CONN_STR, function(err, db) {
  console.log("连接成功!");
  delData(db, function(result) {
    console.log(result);
    db.close();
  });
});

执行成功后,进入 mongo 管理工具查看数据已删除:

> db.site.find()
{ "_id" : ObjectId("58c25f300cd56e0d7ddfc0c8"), "name" : "hello", "url" : "https://www.hello.com" }
> 

Node.js 连接 MySQL

MySQL 教程 本教程使用到的 Websites 表 SQL 文件:websites.sql。

安装驱动

$ cnpm install mysql

连接数据库

在以下实例中修改根据你的实际配置修改数据库用户名、及密码及数据库名:
test.js 文件代码:

var mysql      = require('mysql');
var connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '123456',
  database : 'test'
});
 
connection.connect();
 
connection.query('SELECT 1 + 1 AS solution', function (error, results, fields) {
  if (error) throw error;
  console.log('The solution is: ', results[0].solution);
});

执行以下命令输出就结果为:

$ node test.js
The solution is: 2

数据库连接参数说明:

host' 主机地址 (默认:localhost)user’ 用户名
password' 密码port’ 端口号 (默认:3306)
database' 数据库名charset’ 连接字符集(默认:’UTF8_GENERAL_CI’,注意字符集的字母都要大写)
localAddress' 此IP用于TCP连接(可选)socketPath’ 连接到unix域路径,当使用 host 和 port 时会被忽略
timezone' 时区(默认:'local')connectTimeout’ 连接超时(默认:不限制;单位:毫秒)
stringifyObjects' 是否序列化对象typeCast’ 是否将列值转化为本地JavaScript类型值 (默认:true)
queryFormat' 自定义query语句格式化方法supportBigNumbers’ 数据库支持bigint或decimal类型列时,需要设此option为true (默认:false)
bigNumberStrings' supportBigNumbers和bigNumberStrings启用 强制bigint或decimal列以JavaScript字符串类型返回(默认:false)dateStrings’ 强制timestamp,datetime,data类型以字符串类型返回,而不是JavaScript Date类型(默认:false)
debug' 开启调试(默认:false)multipleStatements’ 是否许一个query中有多个MySQL语句 (默认:false)
flags' 用于修改连接标志ssl’ 使用ssl参数(与crypto.createCredenitals参数格式一至)或一个包含ssl配置文件名称的字符串,目前只捆绑Amazon RDS的配置文件

数据库操作( CURD )

在进行数据库操作前,你需要将本站提供的 Websites 表 SQL 文件websites.sql 导入到你的 MySQL 数据库中。本教程测试的 MySQL 用户名为 root,密码为 123456,数据库为 test,你需要根据自己配置情况修改。

查询数据

将上面我们提供的 SQL 文件导入数据库后,执行以下代码即可查询出数据:

var mysql  = require('mysql');  
 
var connection = mysql.createConnection({     
  host     : 'localhost',       
  user     : 'root',              
  password : '123456',       
  port: '3306',                   
  database: 'test', 
}); 
 
connection.connect();
 
var  sql = 'SELECT * FROM websites';
//查
connection.query(sql,function (err, result) {
        if(err){
          console.log('[SELECT ERROR] - ',err.message);
          return;
        }
 
       console.log('--------------------------SELECT----------------------------');
       console.log(result);
       console.log('------------------------------------------------------------nn');  
});
 
connection.end();

执行以下命令输出就结果为:

$ node test.js
--------------------------SELECT----------------------------
[ RowDataPacket {
    id: 1,
    name: 'Google',
    url: 'https://www.google.cm/',
    alexa: 1,
    country: 'USA' },
  RowDataPacket {
    id: 2,
    name: '淘宝',
    url: 'https://www.taobao.com/',
    alexa: 13,
    country: 'CN' },
  RowDataPacket {
    id: 3,
    name: 'hello',
    url: 'http://www.hello.com/',
    alexa: 4689,
    country: 'CN' },
  RowDataPacket {
    id: 4,
    name: '微博',
    url: 'http://weibo.com/',
    alexa: 20,
    country: 'CN' },
  RowDataPacket {
    id: 5,
    name: 'Facebook',
    url: 'https://www.facebook.com/',
    alexa: 3,
    country: 'USA' } ]
------------------------------------------------------------

插入数据

var mysql = require('mysql');

var connection = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: '123456',
    port: '3306',
    database: 'test',
});

connection.connect();

var addSql = 'INSERT INTO websites(Id,name,url,alexa,country) VALUES(0,?,?,?,?)';
var addSqlParams = ['hi', 'https://c.hello.com', '23453', 'CN'];
//增
connection.query(addSql, addSqlParams, function (err, result) {
    if (err) {
        console.log('[INSERT ERROR] - ', err.message);
        return;
    }

    console.log('--------------------------INSERT----------------------------');
    //console.log('INSERT ID:',result.insertId);        
    console.log('INSERT ID:', result);
    console.log('-----------------------------------------------------------------nn');
});

connection.end();

执行以下命令输出就结果为:

$ node test.js
--------------------------INSERT----------------------------
INSERT ID: OkPacket {
  fieldCount: 0,
  affectedRows: 1,
  insertId: 6,
  serverStatus: 2,
  warningCount: 0,
  message: '',
  protocol41: true,
  changedRows: 0 }
-----------------------------------------------------------------

执行成功后,查看数据表,即可以看到添加的数据

更新数据

我们也可以对数据库的数据进行修改:

var mysql = require('mysql');

var connection = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: '123456',
    port: '3306',
    database: 'test',
});

connection.connect();

var modSql = 'UPDATE websites SET name = ?,url = ? WHERE Id = ?';
var modSqlParams = ['菜鸟移动站', 'https://m.hello.com', 6];
//改
connection.query(modSql, modSqlParams, function (err, result) {
    if (err) {
        console.log('[UPDATE ERROR] - ', err.message);
        return;
    }
    console.log('--------------------------UPDATE----------------------------');
    console.log('UPDATE affectedRows', result.affectedRows);
    console.log('-----------------------------------------------------------------nn');
});

connection.end();

执行以下命令输出就结果为:

--------------------------UPDATE----------------------------
UPDATE affectedRows 1
-----------------------------------------------------------------

执行成功后,查看数据表,即可以看到更新的数据

删除数据

我们可以使用以下代码来删除 id 为 6 的数据:

var mysql = require('mysql');

var connection = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: '123456',
    port: '3306',
    database: 'test',
});

connection.connect();

var delSql = 'DELETE FROM websites where id=6';
//删
connection.query(delSql, function (err, result) {
    if (err) {
        console.log('[DELETE ERROR] - ', err.message);
        return;
    }

    console.log('--------------------------DELETE----------------------------');
    console.log('DELETE affectedRows', result.affectedRows);
    console.log('-----------------------------------------------------------------nn');
});

connection.end();

执行以下命令输出就结果为:

--------------------------DELETE----------------------------
DELETE affectedRows 1
-----------------------------------------------------------------

参考自:http://www.runoob.com/

文章来源于互联网:Node连接MongDB,MySQL

发表评论