这部分示例将示范SQLite3、MongoDB这两种不同类型的数据库在 Node.js 中的使用方法。首先，我们要在code目录下执行mkdir 06_database命令来创建用于存放这一组示例的目录。

1. SQLite

SQLite3是一个轻量级的关系型数据库，我们在这里用它来示范 Node.js 对关系型数据库的处理。首先，在code/06_database目录下执行mkdir sqlite命令，并执行以下步骤：

1. 在code/06_database/sqlite目录下执行npm install sqlite3命令，将sqlite3安装到当前示例项目中。
2. 为控制程序按串行方式执行，需在code/06_database/sqlite目录下执行npm install async命令，将async包安装到当前示例项目中。
3. 在code/06_database/sqlite目录下执行touch Sqlite.js，创建一个脚本文件，具体如下：

const fs = require('fs')const sqlite3 = require('sqlite3').verbose()class SqliteDB {constructor(file) {this.db = new sqlite3.Database(file)const db_exist = fs.existsSync(file)if ( !db_exist ) {console.error('数据库文件创建成功！')fs.openSync(file, 'w')}}createTable(sql) {this.db.serialize(function() {this.run(sql, function(err) {if( err !== null ) {return console.error('错误信息：' + err.message)}})})}insertData(sql, objects) {this.db.serialize(function() {const stmt = this.prepare(sql)for ( let i = 0; i < objects.length; ++i ) {stmt.run(objects[i])}stmt.finalize()})}queryData(sql, callback, message) {this.db.all(sql, function(err, rows) {if( err !== null ) {return console.error('错误信息：' + err.message)}if( callback ) {callback(rows, message)}})}executeSql(sql) {this.db.run(sql, function(err) {if( err !== null ) {return console.error('错误信息：' + err.message)}})}close() {this.db.close()}}module.exports = SqliteDB

4、在code/06_database/sqlite目录下执行touch useSqlite.js，创建一个脚本文件，具体如下：

const async = require('async')const SqliteDB = require('./Sqlite')const file = "HRDB.db"const sqliteDB = new SqliteDB(file)function dataDeal(objects, message) {console.log(message)for ( const i = 0; i < objects.length; ++i ) {console.log(objects[i])}}async.waterfall([function (callback) {// 创建表格const createTableSql = `create table if not exists HR_TABLE (name TEXT,age TEXT,sex TEXT,items TEXT);`sqliteDB.createTable(createTableSql)callback()},function (callback) {// 插入数据const insertTileSql = `insert into HR_TABLE(name, age, sex, items)values(?, ?, ?, ?)`const arr = [['凌杰', '24', '男', '看书, 看电影, 旅游'],['蔓儿', '25', '女', '看书, 看电影, 写作'],['张语', '32', '女', '看书, 旅游, 绘画']]sqliteDB.insertData(insertTileSql, arr)callback()},function (callback) {// 查询数据const querySql = 'select * from HR_TABLE'sqliteDB.queryData(querySql, dataDeal, '初始数据')callback()},function (callback) {// 更新数据const updateSql = `update HR_TABLE set age = 37 where name = "凌杰"`sqliteDB.executeSql(updateSql)callback()},function (callback) {// 查询更新后的数据querySql = `select * from HR_TABLE`sqliteDB.queryData(querySql, dataDeal, '更新后数据')callback()},function (callback) {sqliteDB.close()callback()}])

5、保存所有文件后，在code/06_database/sqlite目录下执行node useSqlite.js命令，结果如下：

2. MongoDB

MongoDB是非关系型数据库的一个典型代表，我们在这里用它来示范 Node.js 对关系型数据库的处理。在 Node.js 中操作MongoDB数据库有两个扩展包可以选择，下面我们一一来演示。首先，在code/06_database目录下执行mkdir mongodb命令，并执行以下步骤：

使用mongodb包

1. 在code/06_database/mongodb目录下执行npm install mongodb命令，将mongodb包安装到当前示例项目中。
2. 为控制程序按串行方式执行，需在code/06_database/mongodb目录下执行npm install async命令，将async包安装到当前示例项目中。
3. 在code/06_database/mongodb目录下执行touch useMongodb.js，创建一个脚本文件，具体如下：

 const MongoClient = require('mongodb').MongoClientconst async = require('async')const server = 'mongodb://localhost:27017'const dbName = 'hrdb'const collName = 'hr_table'const dbPath = server + '/' + dbNameMongoClient.connect(dbPath, { useNewUrlParser: true },function(err, db) {if ( err !== null ) {return console.error('错误信息：' + err.message)}const dbo = db.db(dbName)console.log(dbName + '数据库创建成功')const collect = dbo.collection(collName)console.log(collName + '集合创建成功')async.series([// 控制程序串行执行function (callback) {// 插入单条数据const data = {name : '杨过',age : '42',sex : '男',items : '看书, 喝酒, 习武'}collect.insertOne(data, function(err, res) {if ( err !== null ) {return console.error('错误信息：' + err.message)}console.log('单条数据插入成功')})callback()},function (callback) {// 插入多条数据const dataArray = [{name : '小龙女',age : '24',sex : '男',items : '看书, 唱歌, 习武'},{name : '郭靖',age : '52',sex : '男',items : '看书, 喝酒, 习武'},{name : '黄蓉',age : '45',sex : '女',items : '看书, 绘画, 习武'},{name : '雅典娜',age : '24',sex : '女',items : '看书, 音乐, 被救'}]collect.insertMany(dataArray, function(err, res) {if ( err !== null ) {return console.error('错误信息：' + err.message)}console.log('数组插入成功')})callback()},function (callback) {// 列出所有数据collect. find({}).toArray(function(err, result) {if ( err !== null ) {return console.error('错误信息：' + err.message)}console.log('列出当前集合中的所有数据：')console.log(result)})callback()},function (callback) {// 更新单一数据const whereData = {'name' : '小龙女'}const updataValue = { $set: { 'sex' : '女' } }collect.updateOne(whereData, updataValue,function(err, res) {if ( err !== null ) {return console.error('错误信息：' + err.message)}console.log(whereData['name'] + "的数据更新成功")})callback()},function (callback) {// 查询指定数据const querystr = { 'name' : '小龙女' }collect. find(querystr).toArray(function(err, result) {if ( err !== null ) {return console.error('错误信息：' + err.message)}console.log('查看更新后的' + querystr['name'] + '的数据：')console.log(result)})callback()},function (callback) {// 删除指定单一数据const whereData = { 'name' : '黄蓉' }collect.deleteOne(whereData,function(err, result) {if ( err !== null ) {return console.error('错误信息：' + err.message)}console.log(whereData['name'] + '的数据已被删除')})callback()},function (callback) {// 查询所有数据，并按name降序排列const isort = { name : -1 }collect. find({}).sort(isort).toArray(function(err, result) {if ( err !== null ) {return console.error('错误信息：' + err.message)}console.log('降序排列当前集合中的所有数据：')console.log(result)})callback()},function (callback) {// 删除指定多条数据const whereData = { 'age' : '24' }collect.deleteMany(whereData,function(err, result) {if ( err !== null ) {return console.error('错误信息：' + err.message)}console.log('年龄为' + whereData['age'] + '的数据已被删除')})callback()},function (callback) {// 查询所有数据，并按name升序排列const isort = { name : 1 }collect. find({}).sort(isort).toArray(function(err, result) {if ( err !== null ) {return console.error('错误信息：' + err.message)}console.log('升序排列当前集合中的所有数据：')console.log(result)})callback()},function (callback) {// 删除指定集合dbo.dropCollection(collName, function(err, delOK) {if ( err !== null ) {return console.error('错误信息：' + err.message)}if ( delOK !== null ) {console.log(collName + "集合已删除！")}})callback()}])db.close()})

4、保存所有文件后，在code/06_database/mongodb目录下执行node useMongodb.js命令，结果如下：

使用mongoose包

1. 在code/06_database/mongodb目录下执行npm install mongoose命令，将mongoose包安装到当前示例项目中。
2. 在code/06_database/mongodb目录下执行touch useMongoose.js，创建一个脚本文件，具体如下：

const server = 'mongodb://localhost:27017'const dbName = 'hrdb'const collName = 'hr_table'const dbPath = server + '/' + dbNameconst mongoose = require('mongoose');const async = require('async')const Schema = mongoose.Schemaconst hrSchema = new Schema({name : {type : String,required: true},age : {type : String,required: true},sex : {type : String,required: true},items : {type : String,required: true}})const hrModel = new mongoose.model('Hrobj', hrSchema)mongoose.connect(dbPath, {useNewUrlParser: true});const conn = mongoose.connectionconn.on('error', console.error.bind(console, '连接错误:'))conn.on('open', console.log.bind(console, '数据库连接成功'))conn.on('disconnected', console.log.bind(console, '断开数据库连接'))conn.once('open', function(){async.series([function(callback) {// 插入单条数据const someone = new hrModel ({name : '杨过',age : '42',sex : '男',items : '看书, 喝酒, 习武'})someone.save(function(err, one){callback(err, one.name+'的数据插入成功')})},function(callback) {hrModel.find(function(err, hrTable){callback(err, '插入一条数据后的结果：' + hrTable)})},function(callback) {// 插入多条数据const dataArray = [{name : '小龙女',age : '24',sex : '男',items : '看书, 唱歌, 习武'},{name : '郭靖',age : '52',sex : '男',items : '看书, 喝酒, 习武'},{name : '黄蓉',age : '45',sex : '女',items : '看书, 绘画, 习武'},{name : '雅典娜',age : '24',sex : '女',items : '看书, 音乐, 被救'},{name : '阿波罗',age : '24',sex : '女',items : '看书, 音乐, 被救'}]hrModel.insertMany(dataArray, function(err) {callback(err, '数组中的数据插入成功')})},function(callback) {hrModel.find(function(err, hrTable){callback(err, '插入多条数据后的结果：' + hrTable)})},function(callback) {hrModel.updateMany({sex:'男'}, {sex:'女'}, function(err, one){callback(err, '将所有男人改为女人')})},function(callback) {hrModel.updateOne({name:'阿波罗'}, {sex:'男'}, function(err, one){callback(err, '将阿波罗的性别改为：男')})},function(callback) {hrModel.find({age:'24'}, function(err, hrTable){callback(err, '所有年龄为24的数据：' + hrTable)})},function(callback) {hrModel.findOne({age:'24'}, function(err, hrTable){callback(err, '第一个年龄为24的结果：' + hrTable)})},function(callback) {hrModel.deleteMany({age:'24'}, function(err, hrTable){callback(err, '所有年龄为24数据已被删除')})},function(callback) {hrModel.find({age:'24'}, function(err, hrTable){callback(err, '所有年龄为24的数据：' + hrTable)})},function(callback) {hrModel.deleteMany({}, function(err, hrTable){callback(err, '所有数据已被删除')})},function(callback) {hrModel.find(function(err, hrTable){callback(err, '删除所有数据后的结果：' + hrTable)})},function(callback) {mongoose.disconnect(function(err){callback(err, '正在断开连接……')})}], function(err, message) {if ( err !== null ) {return console.error('错误信息：' + err.message)}console.log(message)})})

3、保存所有文件后，在code/06_database/mongodb目录下执行node useMongoose.js命令，结果如下：

如果图片重复显示或者内容重复显示影响阅读，请访问：
https://www.cnblogs.com/owlman/p/13588513.html

这部分示例将示范SQLite3、MongoDB这两种不同类型的数据库在 Node.js 中的使用方法。首先，我们要在code目录下执行mkdir 06_database命令来创建用于存放这一组示例的目录。

1. SQLite

SQLite3是一个轻量级的关系型数据库，我们在这里用它来示范 Node.js 对关系型数据库的处理。首先，在code/06_database目录下执行mkdir sqlite命令，并执行以下步骤：

1. 在code/06_database/sqlite目录下执行npm install sqlite3命令，将sqlite3安装到当前示例项目中。
2. 为控制程序按串行方式执行，需在code/06_database/sqlite目录下执行npm install async命令，将async包安装到当前示例项目中。
3. 在code/06_database/sqlite目录下执行touch Sqlite.js，创建一个脚本文件，具体如下：

const fs = require('fs')const sqlite3 = require('sqlite3').verbose()class SqliteDB {constructor(file) {this.db = new sqlite3.Database(file)const db_exist = fs.existsSync(file)if ( !db_exist ) {console.error('数据库文件创建成功！')fs.openSync(file, 'w')}}createTable(sql) {this.db.serialize(function() {this.run(sql, function(err) {if( err !== null ) {return console.error('错误信息：' + err.message)}})})}insertData(sql, objects) {this.db.serialize(function() {const stmt = this.prepare(sql)for ( let i = 0; i < objects.length; ++i ) {stmt.run(objects[i])}stmt.finalize()})}queryData(sql, callback, message) {this.db.all(sql, function(err, rows) {if( err !== null ) {return console.error('错误信息：' + err.message)}if( callback ) {callback(rows, message)}})}executeSql(sql) {this.db.run(sql, function(err) {if( err !== null ) {return console.error('错误信息：' + err.message)}})}close() {this.db.close()}}module.exports = SqliteDB

4、在code/06_database/sqlite目录下执行touch useSqlite.js，创建一个脚本文件，具体如下：

const async = require('async')const SqliteDB = require('./Sqlite')const file = "HRDB.db"const sqliteDB = new SqliteDB(file)function dataDeal(objects, message) {console.log(message)for ( const i = 0; i < objects.length; ++i ) {console.log(objects[i])}}async.waterfall([function (callback) {// 创建表格const createTableSql = `create table if not exists HR_TABLE (name TEXT,age TEXT,sex TEXT,items TEXT);`sqliteDB.createTable(createTableSql)callback()},function (callback) {// 插入数据const insertTileSql = `insert into HR_TABLE(name, age, sex, items)values(?, ?, ?, ?)`const arr = [['凌杰', '24', '男', '看书, 看电影, 旅游'],['蔓儿', '25', '女', '看书, 看电影, 写作'],['张语', '32', '女', '看书, 旅游, 绘画']]sqliteDB.insertData(insertTileSql, arr)callback()},function (callback) {// 查询数据const querySql = 'select * from HR_TABLE'sqliteDB.queryData(querySql, dataDeal, '初始数据')callback()},function (callback) {// 更新数据const updateSql = `update HR_TABLE set age = 37 where name = "凌杰"`sqliteDB.executeSql(updateSql)callback()},function (callback) {// 查询更新后的数据querySql = `select * from HR_TABLE`sqliteDB.queryData(querySql, dataDeal, '更新后数据')callback()},function (callback) {sqliteDB.close()callback()}])

5、保存所有文件后，在code/06_database/sqlite目录下执行node useSqlite.js命令，结果如下：

2. MongoDB

MongoDB是非关系型数据库的一个典型代表，我们在这里用它来示范 Node.js 对关系型数据库的处理。在 Node.js 中操作MongoDB数据库有两个扩展包可以选择，下面我们一一来演示。首先，在code/06_database目录下执行mkdir mongodb命令，并执行以下步骤：

使用mongodb包

1. 在code/06_database/mongodb目录下执行npm install mongodb命令，将mongodb包安装到当前示例项目中。
2. 为控制程序按串行方式执行，需在code/06_database/mongodb目录下执行npm install async命令，将async包安装到当前示例项目中。
3. 在code/06_database/mongodb目录下执行touch useMongodb.js，创建一个脚本文件，具体如下：

 const MongoClient = require('mongodb').MongoClientconst async = require('async')const server = 'mongodb://localhost:27017'const dbName = 'hrdb'const collName = 'hr_table'const dbPath = server + '/' + dbNameMongoClient.connect(dbPath, { useNewUrlParser: true },function(err, db) {if ( err !== null ) {return console.error('错误信息：' + err.message)}const dbo = db.db(dbName)console.log(dbName + '数据库创建成功')const collect = dbo.collection(collName)console.log(collName + '集合创建成功')async.series([// 控制程序串行执行function (callback) {// 插入单条数据const data = {name : '杨过',age : '42',sex : '男',items : '看书, 喝酒, 习武'}collect.insertOne(data, function(err, res) {if ( err !== null ) {return console.error('错误信息：' + err.message)}console.log('单条数据插入成功')})callback()},function (callback) {// 插入多条数据const dataArray = [{name : '小龙女',age : '24',sex : '男',items : '看书, 唱歌, 习武'},{name : '郭靖',age : '52',sex : '男',items : '看书, 喝酒, 习武'},{name : '黄蓉',age : '45',sex : '女',items : '看书, 绘画, 习武'},{name : '雅典娜',age : '24',sex : '女',items : '看书, 音乐, 被救'}]collect.insertMany(dataArray, function(err, res) {if ( err !== null ) {return console.error('错误信息：' + err.message)}console.log('数组插入成功')})callback()},function (callback) {// 列出所有数据collect. find({}).toArray(function(err, result) {if ( err !== null ) {return console.error('错误信息：' + err.message)}console.log('列出当前集合中的所有数据：')console.log(result)})callback()},function (callback) {// 更新单一数据const whereData = {'name' : '小龙女'}const updataValue = { $set: { 'sex' : '女' } }collect.updateOne(whereData, updataValue,function(err, res) {if ( err !== null ) {return console.error('错误信息：' + err.message)}console.log(whereData['name'] + "的数据更新成功")})callback()},function (callback) {// 查询指定数据const querystr = { 'name' : '小龙女' }collect. find(querystr).toArray(function(err, result) {if ( err !== null ) {return console.error('错误信息：' + err.message)}console.log('查看更新后的' + querystr['name'] + '的数据：')console.log(result)})callback()},function (callback) {// 删除指定单一数据const whereData = { 'name' : '黄蓉' }collect.deleteOne(whereData,function(err, result) {if ( err !== null ) {return console.error('错误信息：' + err.message)}console.log(whereData['name'] + '的数据已被删除')})callback()},function (callback) {// 查询所有数据，并按name降序排列const isort = { name : -1 }collect. find({}).sort(isort).toArray(function(err, result) {if ( err !== null ) {return console.error('错误信息：' + err.message)}console.log('降序排列当前集合中的所有数据：')console.log(result)})callback()},function (callback) {// 删除指定多条数据const whereData = { 'age' : '24' }collect.deleteMany(whereData,function(err, result) {if ( err !== null ) {return console.error('错误信息：' + err.message)}console.log('年龄为' + whereData['age'] + '的数据已被删除')})callback()},function (callback) {// 查询所有数据，并按name升序排列const isort = { name : 1 }collect. find({}).sort(isort).toArray(function(err, result) {if ( err !== null ) {return console.error('错误信息：' + err.message)}console.log('升序排列当前集合中的所有数据：')console.log(result)})callback()},function (callback) {// 删除指定集合dbo.dropCollection(collName, function(err, delOK) {if ( err !== null ) {return console.error('错误信息：' + err.message)}if ( delOK !== null ) {console.log(collName + "集合已删除！")}})callback()}])db.close()})

4、保存所有文件后，在code/06_database/mongodb目录下执行node useMongodb.js命令，结果如下：

使用mongoose包

1. 在code/06_database/mongodb目录下执行npm install mongoose命令，将mongoose包安装到当前示例项目中。
2. 在code/06_database/mongodb目录下执行touch useMongoose.js，创建一个脚本文件，具体如下：

const server = 'mongodb://localhost:27017'const dbName = 'hrdb'const collName = 'hr_table'const dbPath = server + '/' + dbNameconst mongoose = require('mongoose');const async = require('async')const Schema = mongoose.Schemaconst hrSchema = new Schema({name : {type : String,required: true},age : {type : String,required: true},sex : {type : String,required: true},items : {type : String,required: true}})const hrModel = new mongoose.model('Hrobj', hrSchema)mongoose.connect(dbPath, {useNewUrlParser: true});const conn = mongoose.connectionconn.on('error', console.error.bind(console, '连接错误:'))conn.on('open', console.log.bind(console, '数据库连接成功'))conn.on('disconnected', console.log.bind(console, '断开数据库连接'))conn.once('open', function(){async.series([function(callback) {// 插入单条数据const someone = new hrModel ({name : '杨过',age : '42',sex : '男',items : '看书, 喝酒, 习武'})someone.save(function(err, one){callback(err, one.name+'的数据插入成功')})},function(callback) {hrModel.find(function(err, hrTable){callback(err, '插入一条数据后的结果：' + hrTable)})},function(callback) {// 插入多条数据const dataArray = [{name : '小龙女',age : '24',sex : '男',items : '看书, 唱歌, 习武'},{name : '郭靖',age : '52',sex : '男',items : '看书, 喝酒, 习武'},{name : '黄蓉',age : '45',sex : '女',items : '看书, 绘画, 习武'},{name : '雅典娜',age : '24',sex : '女',items : '看书, 音乐, 被救'},{name : '阿波罗',age : '24',sex : '女',items : '看书, 音乐, 被救'}]hrModel.insertMany(dataArray, function(err) {callback(err, '数组中的数据插入成功')})},function(callback) {hrModel.find(function(err, hrTable){callback(err, '插入多条数据后的结果：' + hrTable)})},function(callback) {hrModel.updateMany({sex:'男'}, {sex:'女'}, function(err, one){callback(err, '将所有男人改为女人')})},function(callback) {hrModel.updateOne({name:'阿波罗'}, {sex:'男'}, function(err, one){callback(err, '将阿波罗的性别改为：男')})},function(callback) {hrModel.find({age:'24'}, function(err, hrTable){callback(err, '所有年龄为24的数据：' + hrTable)})},function(callback) {hrModel.findOne({age:'24'}, function(err, hrTable){callback(err, '第一个年龄为24的结果：' + hrTable)})},function(callback) {hrModel.deleteMany({age:'24'}, function(err, hrTable){callback(err, '所有年龄为24数据已被删除')})},function(callback) {hrModel.find({age:'24'}, function(err, hrTable){callback(err, '所有年龄为24的数据：' + hrTable)})},function(callback) {hrModel.deleteMany({}, function(err, hrTable){callback(err, '所有数据已被删除')})},function(callback) {hrModel.find(function(err, hrTable){callback(err, '删除所有数据后的结果：' + hrTable)})},function(callback) {mongoose.disconnect(function(err){callback(err, '正在断开连接……')})}], function(err, message) {if ( err !== null ) {return console.error('错误信息：' + err.message)}console.log(message)})})

3、保存所有文件后，在code/06_database/mongodb目录下执行node useMongoose.js命令，结果如下：