Node连接MongDB,MySQL

作者: majun00 | 来源:发表于2018-03-20 16:00 被阅读0次

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('------------------------------------------------------------\n\n');  
});
 
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('-----------------------------------------------------------------\n\n');
});

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('-----------------------------------------------------------------\n\n');
});

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('-----------------------------------------------------------------\n\n');
});

connection.end();

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

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

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

Node连接MongDB,MySQL

Node.js 连接 MongoDB

安装驱动

数据库操作( CURD )

插入数据

查询数据

更新数据

删除数据

Node.js 连接 MySQL

安装驱动

连接数据库

数据库连接参数说明：

数据库操作( CURD )

查询数据

插入数据

更新数据

删除数据

相关文章

网友评论

延伸阅读

深度阅读

栏目导航

热点阅读

我爱编程