Nodejs操作MongoDB数据库示例
2024-08-25 10:33:12
//mongodb_demo.js
/**
cnpm install mongodb
*/
var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://test:123456@127.0.0.1:27017/test'; // 数据库为 test
var insertData = function (db, callback) {
//连接到表 site
var collection = db.collection('site');
//插入数据
var data = [{ "name": "网站1", "url": "www.test1.com" }, { "name": "网站2", "url": "www.test2.com" }];
collection.insert(data, function (err, result) {
if (err) {
console.log('Error:' + err);
return;
}
callback(result);
});
}
var selectData = function (db, callback) {
//连接到表
var collection = db.collection('site');
//查询数据
var whereStr = { "name": '网站1' };
collection.find(whereStr).toArray(function (err, result) {
if (err) {
console.log('Error:' + err);
return;
}
callback(result);
});
}
var updateData = function (db, callback) {
//连接到表
var collection = db.collection('site');
//更新数据
var whereStr = { "name": '网站1' };
var updateStr = { $set: { "url": "https://www.test1.com" } };
collection.update(whereStr, updateStr, function (err, result) {
if (err) {
console.log('Error:' + err);
return;
}
callback(result);
});
}
var delData = function (db, callback) {
//连接到表
var collection = db.collection('site');
//删除数据
var whereStr = { "name": '网站1' };
collection.remove(whereStr, function (err, result) {
if (err) {
console.log('Error:' + err);
return;
}
callback(result);
});
}
MongoClient.connect(DB_CONN_STR, function (err, db) {
if (err) {
console.log(err);
return;
}
console.log("连接成功!");
//1、插入
insertData(db, function (result) {
console.log(result);
db.close();
});
//2、查询数据
selectData(db, function (result) {
console.log(result);
db.close();
});
//3、更新数据
updateData(db, function (result) {
console.log(result);
db.close();
});
//4、删除数据
delData(db, function (result) {
console.log(result);
db.close();
});
});
运行:node mongodb_demo.js
最新文章
- Basic Tutorials of Redis(7) -Publish and Subscribe
- HTTP协议请求响应过程和HTTPS工作原理
- validate插件深入学习-03validate()方法配置项
- Atitit 修改密码的功能流程设计 attilax总结
- 快速搭建Webservice接口测试环境
- JavaScript 语句 for
- Oracle 11g RAC 第二节点root.sh执行失败后再次执行root.sh
- 树形DP(简单题)(Y HDU4705)
- [UEditor]百度编辑器配置总结
- 摘录:官方文档对ROWID虚拟行的定义
- 去除input[type=number]最右边的spinners(默认加减符号)
- C#关闭显示屏,使显示屏处于待机状态
- Poj 1269 Intersecting Lines_几何模板
- bitmap--Bitmap详解与Bitmap的内存优化
- PDO查询语句结果中文乱码
- JavaScript使用浏览器内置XMLHttpRequest对象执行Ajax请求
- hashlib、logging模块
- Web开发——JavaScript基础(JSON教程)
- SHA算法:签名串SHA算法Java语言参考(SHAHelper.java)
- QPS/TPS/并发量/系统吞吐量的概念
热门文章
- 20144303 《Java程序设计》第一周学习总结
- $.getJSON()函数内的数据不能传到全局变量是怎么回事?
- mybatis映射文件_select_resultMap
- 计算java对象的内存占用
- PAT1075. PAT Judge (25)
- 05_zookeeper_原生API使用1(更新)
- Matlab 实现对码功能
- PHP数组合并:[“+”运算符]、[array_merge]、[array_merge_recursive]区别
- ctci1.4
- bootstrap 知识点