* 使用sqlite3持久化数据
* 需求：把一个数组中的每个对象,每个对象中的属性,存到xxx.db文件中去,像数据库一样的去操作它
* 功能：1. 创建数据库(数据库存在的话，那就直接打开)
* 2. 创建一个表(表存在的话就不用创建啦)
* 3. 有了数据库和表, 最最基础的功能就是：
* 插入数据(单个数据插入或者多个并行插入)
* 更新数据(根据不同的条件更新每列数据)
* 删除数据(根据不同的条件来删除每列数据)
* 查询数据(单个数据查询，多个数据查询)
安装:
npm install sqlite3
/**
* Created by Sorrow.X on 2017/7/12.
*/
var SQLite3 = require('sqlite3').verbose(); /**
* 使用sqlite3持久化数据
* 需求：把一个数组中的每个对象,每个对象中的属性,存到xxx.db文件中去,像数据库一样的去操作它
* 功能：1. 创建数据库(数据库存在的话，那就直接打开)
* 2. 创建一个表(表存在的话就不用创建啦)
* 3. 有了数据库和表, 最最基础的功能就是：
* 插入数据(单个数据插入或者多个并行插入)
* 更新数据(根据不同的条件更新每列数据)
* 删除数据(根据不同的条件来删除每列数据)
* 查询数据(单个数据查询，多个数据查询)
*/
class HandleDB { constructor(options) {
this.databaseFile = options && options.databaseFile || `./data/test.db`; // 数据库文件(文件路径+文件名)
this.tableName = options && options.tableName || `adsTable`; // 表名 this.db = null; // 打开的数据库对象
} // 连接数据库(不存在就创建,存在则打开)
connectDataBase() {
let _self = this;
return new Promise((resolve, reject) => {
_self.db = new SQLite3.Database(_self.databaseFile, function(err) {
if (err) reject(new Error(err));
resolve('数据库连接成功');
});
});
} /**
* 创建表
* @param sentence CREATE TABLE 语句
* @used
let sentence = `
create table if not exists ${this.tableName}(
begin_time varchar(255),
create_time varchar(255),
end_time varchar(255),
play_id varchar(255),
postion_id int(50),
status int(50),
task_id int(50)
);`;
this.createTable(sentence);
*/
createTable(sentence) {
let _self = this;
return new Promise((resolve, reject) => {
_self.db.exec(sentence, function(err) {
if (err) reject(new Error(err));
resolve(`表创建成功 / 已存在,不需要重新创建该表`);
});
});
} /**
* 执行 增 删 改 查(单个数据查询或者多个数据查询)
* @param sql sql语句
* @param param 参数(可以是数组或者数字或者字符串,根据sql语句来定)
* @param mode 执行模式, 默认run,执行sql,如果查询的话,则使用get(单个)all(多个)
* @returns {Promise}
@used
增 : this.sql(`insert into ${this.tableName} (begin_time, create_time, end_time, play_id, postion_id, status, task_id) values(?, ?, ?, ?, ?, ?, ?)`,
[obj.begin_time, obj.create_time, obj.end_time, obj.play_id, obj.postion_id, obj.status, obj.task_id]); 删 : this.sql(`delete from ${this.tableName} where id = ?`, id); 改 : this.sql(`update ${this.tableName} set begin_time = ?, status = ? where postion_id = ?`, [begin_timeValue, statusValue, postion_idValue]); 查 : this.sql(`select * from ${this.tableName} where id = ?`, id, 'get/all');
*/
sql(sql, param, mode) {
let _self = this;
mode = mode == 'all' ? 'all' : mode == 'get' ? 'get' : 'run';
return new Promise((resolve, reject) => {
_self.db[mode](sql, param,
function (err, data) { // data: Array, Object
if (err) {
reject(new Error(err));
} else {
if (data) {
resolve(data); // 返回数据查询成功的结果
} else {
resolve('success'); // 提示 增 删 改 操作成功
};
};
}
);
});
}
}; module.exports = HandleDB;
// 使用
// used:
let db = new HandleDB({
databaseFile: './data/adsbase.db',
tableName: 'ads'
}); db.connectDataBase().then((result)=>{
console.log(result);
// 创建表(如果不存在的话,则创建,存在的话, 不会创建的,但是还是会执行回调)
let sentence = `
create table if not exists ${db.tableName}(
begin_time varchar(255),
create_time varchar(255),
end_time varchar(255),
play_id varchar(255),
postion_id int(50),
status int(50),
task_id int(50),
same_day int(50)
);`;
return db.createTable(sentence);
}).then((result)=>{
console.log(result);
doLogic();
}).catch((err)=>{
console.error(err);
}); let doLogic = function() { // 增
db.sql(`insert into ${db.tableName} (begin_time, create_time, end_time, play_id, postion_id, status, task_id, same_day) values(?, ?, ?, ?, ?, ?, ?, ?)`,
['2017/7/12', '2017/7/12', '2017/7/12', 102, 3, 0, 11, '2017-7-12']).then((res)=>{
console.log(res);
}).catch((err)=>{
console.log(err);
}); // 一次性插入多个数据
var data = {
"Body": [
{
"begin_time": "1970-01-01 00:00:00",
"create_time": "2017-07-11",
"end_time": "",
"play_id": 17,
"postion_id": 1,
"status": 0,
"task_id": 24
},
{
"begin_time": "1970-01-01 00:00:00",
"create_time": "2017-07-11",
"end_time": "",
"play_id": 18,
"postion_id": 4,
"status": 0,
"task_id": 24
},
{
"begin_time": "1970-01-01 00:00:00",
"create_time": "2017-07-11",
"end_time": "",
"play_id": 19,
"postion_id": 2,
"status": 0,
"task_id": 24
},
{
"begin_time": "1970-01-01 00:00:00",
"create_time": "2017-07-11",
"end_time": "",
"play_id": 20,
"postion_id": 3,
"status": 0,
"task_id": 24
}
],
"Code": 0,
"Message": ""
};
var arr = data.Body;
var promises = arr.map(function(obj) {
return db.sql(`insert into ${db.tableName} (begin_time, create_time, end_time, play_id, postion_id, status, task_id, same_day) values(?, ?, ?, ?, ?, ?, ?, ?)`,
[obj.begin_time, obj.create_time, obj.end_time, obj.play_id, obj.postion_id, obj.status, obj.task_id, '2017-7-12']);
});
Promise.all(promises).then(function (posts) {
console.log('全部插入完毕', posts)
}).catch(function(reason){
console.error(reason);
}); // 删
db.sql(`delete from ${db.tableName} where same_day = ?`, '2017-7-12').then((res)=>{
console.log(res);
}).catch((err)=>{
console.log(err);
}); // 改
db.sql(`update ${db.tableName} set task_id = ? where same_day = ?`, [4, '2017-7-12']).then((res)=>{
console.log(res);
}).catch((err)=>{
console.log(err);
}); // 查
db.sql(`select * from ${db.tableName} where same_day = ?`, '2017-7-12', 'all').then((res)=>{
console.log(res);
}).catch((err)=>{
console.log(err);
});
};
文档: https://github.com/mapbox/node-sqlite3/wiki/API
sql工具下载： http://www.sqliteexpert.com/