三好先森|Node.js 学习笔记：使用数据库这部分示例将示范SQLite3、mongodb这两

这部分示例将示范SQLite3、mongodb这两种不同类型的数据库在 Node.js 中的使用方法。首先，我们要在code目录下执行mkdir 06_database命令来创建用于存放这一组示例的目录。
1. SQLiteSQLite3是一个轻量级的关系型数据库，我们在这里用它来示范 Node.js 对关系型数据库的处理。首先，在code/06_database目录下执行mkdir sqlite命令，并执行以下步骤：

在code/06_database/sqlite目录下执行npm install sqlite3命令，将sqlite3安装到当前示例项目中。
为控制程序按串行方式执行，需在code/06_database/sqlite目录下执行npm install async命令，将async包安装到当前示例项目中。
在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命令，结果如下：