NodeJS中使用SQLite3

SQLite简介

sqlite是一款轻量级的数据库，sqlite的第一个版本是2000年就发布了的，经过十多年的历练，显然sqlite目前已经相当成熟。sqlite最大的特点就是没有任何数据库服务器，无论是C、java、node.js，只需要相应的驱动，就可以直接对数据库进行读写，速度是相当的快。相比之下，其他的sql数据库必须启动一个服务，而且还要安装、配置，sqlite简洁的令人感动。

Node.js安装sqlite3模块

和其他语言一样，node.js仍然只需要一个module就可以对sqlite进行操作了。

npm find sqlite

发现sqlite的模块居然有几十个，足见node.js目前的火爆程度，小小的sqlite就有这么多可用模块。
其中一个就叫做sqlite3，解释如下：

sqlite3 Asynchronous, non-blocking SQLite3 bindings 异步，非阻塞sqlite3绑定。

node.js最大的特点就是异步，这款sqlite的驱动太符合node的核心思想了，经过与其他模块的比较，最终还是选择了这款。

npm install sqlite3

就将sqlite的驱动安装进来了。

调用SQLite3的接口

1.  var sqlite3 = require('sqlite3');
2.  var db = new sqlite3.Database('/tmp/1.db',function() {
3.    db.run("create table test(name varchar(15))",function(){
4.      db.run("insert into test values('hello,world')",function(){
5.        db.all("select * from test",function(err,res){
6.          if(!err)
7.            console.log(JSON.stringify(res));
8.          else
9.            console.log(err);
10.       });
11.     })
12.   });
13. });

执行：

node test.js
[{"name":"hello,world"}]

插入的时候使用db.run()，查询的时候使用db.all()
由于是异步，必须在执行sql后注册回调函数，这样如果连续执行几十条sql，那代码就跟楼梯差不多了。但这就是node的特点，所以还是要慢慢适应。

引入SQLite3模块

1.  var fs = require('fs');
2.  var file = 'test.db';//这里写的就是数据库文件的路径
3.  var exists = fs.existsSync(file);
4.  var sqlite3 = require('sqlite3').verbose();
5.  var db = new sqlite3.Database(file);

增删改查操作

1. //增
2. var sql1 = db.prepare("insert into 表名 values (内容，跟mysql一样)");
3. sql1.run();
4. //删
5. var sql2 = db.prepare("delete from 表名 where id = 1");
6. sql2.run();
7. //改
8. var sql3 = db.prepare("update 表名 set name = winston where id = 1");
9. sql3.run();
10. //查
11. //查一个表的所有数据
12. db.all("select * from 表名",function(err,row){
13.     console.log(JSON.stringify(row));
14. })
15. //查一条数据
16. db().each("select * from 表名",function(err,row){
17.      console.log(row);
18. })

SQLite3 API介绍

在nodejs的模块安装模块下，进入sqlite3/lib目录下，打开sqlite3.js文件查看，操作数据库主要是用Database，Database相关的函数有：run、prepare、each、get、all、exec、map和close。

Database

• 用法：new sqlite3.Database(filename,[mode],[callback])。
• 功能：返回数据库对象并且自动打开和连接数据库，它没有独立打开数据库的方法。

close

• 用法：close([callback])。
• 功能：关闭和释放数据库对象。

run

• 用法：run(sql,param,...],[callback])。
• 功能：运行指定参数的SQL语句，完成之后调用回调函数，它不返回任何数据，在回调函数里面有一个参数，SQL语句执行成功，则参数的值为null,反之为一个错误的对象，它返回的是数据库的操作对象。在这个回调函数里面当中的this,里面包含有lastId(插入的ID)和change(操作影响的行数,如果执行SQL语句失败，则change的值永远为0)。

get

• 用法：get(sql,[param,...],[callback])。
• 功能：运行指定参数的SQL语句，完成过后调用回调函数。如果执行成功，则回调函数中的第一个参数为null,第二个参数为结果集中的第一行数据，反之则回调函数中只有一个参数，只参数为一个错误的对象。

all

• 用法：all(sql,[param,...],[callback])。
• 功能：运行指定参数的SQL语句，完成过后调用回调函数。如果执行成功，则回调函数中的第一个参数为null,第二个参数为查询的结果集，反之，则只有一个参数，且参数的值为一个错误的对象。

prepare

• 用法：prepare(sql,[param,...],[callback])。
• 功能：预执行绑定指定参数的SQL语句，返回一个Statement对象，如果执行成功，则回调函数的第一个参数为null,反之为一个错误的对象。

具体事例

由于sqlite3 API具体使用过程中重复代码量较多，所以进行了简单封装，在使用过程中如果第一次创建数据库和表，紧接着插入数据的话，可能导致表还未创建完成就查询出现错误（Nodejs是基于异步的且顺序不可控），所以在表创建和插入数据时使用同步方式操作来保证表已经存在。封装的代码如下：

1.  var fs = require('fs');
2.  var sqlite3 = require('sqlite3').verbose();
3.   
4.  var DB = DB || {};
5.   
6.  DB.SqliteDB = function(file){
7.      DB.db = new sqlite3.Database(file);
8.   
9.      DB.exist = fs.existsSync(file);
10.     if(!DB.exist){
11.         console.log("Creating db file!");
12.         fs.openSync(file, 'w');
13.     };
14. };
15.  
16. DB.printErrorInfo = function(err){
17.     console.log("Error Message:" + err.message + " ErrorNumber:" + errno);
18. };
19.  
20. DB.SqliteDB.prototype.createTable = function(sql){
21.     DB.db.serialize(function(){
22.         DB.db.run(sql, function(err){
23.             if(null != err){
24.                 DB.printErrorInfo(err);
25.                 return;
26.             }
27.         });
28.     });
29. };
30.  
31. /// tilesData format; [[level, column, row, content], [level, column, row, content]]
32. DB.SqliteDB.prototype.insertData = function(sql, objects){
33.     DB.db.serialize(function(){
34.         var stmt = DB.db.prepare(sql);
35.         for(var i = 0; i < objects.length; ++i){
36.             stmt.run(objects[i]);
37.         }
38.     
39.         stmt.finalize();
40.     });
41. };
42.  
43. DB.SqliteDB.prototype.queryData = function(sql, callback){
44.     DB.db.all(sql, function(err, rows){
45.         if(null != err){
46.             DB.printErrorInfo(err);
47.             return;
48.         }
49.  
50.         /// deal query data.
51.         if(callback){
52.             callback(rows);
53.         }
54.     });
55. };
56.  
57. DB.SqliteDB.prototype.executeSql = function(sql){
58.     DB.db.run(sql, function(err){
59.         if(null != err){
60.             DB.printErrorInfo(err);
61.         }
62.     });
63. };
64.  
65. DB.SqliteDB.prototype.close = function(){
66.     DB.db.close();
67. };
68.  
69. /// export SqliteDB.
70. exports.SqliteDB = DB.SqliteDB;

针对以上封装接口的调用代码如下：

1.  /// Import SqliteDB.
2.  var SqliteDB = require('./sqlite.js').SqliteDB;
3.  var file = "Gis1.db";
4.  var sqliteDB = new SqliteDB(file);
5.   
6.  /// create table.
7.  var createTileTableSql = "create table if not exists tiles(level INTEGER, column INTEGER, row INTEGER, content BLOB);";
8.  var createLabelTableSql = "create table if not exists labels(level INTEGER, longitude REAL, latitude REAL, content BLOB);";
9.  sqliteDB.createTable(createTileTableSql);
10. sqliteDB.createTable(createLabelTableSql);
11.  
12. /// insert data.
13. var tileData = [[1, 10, 10], [1, 11, 11], [1, 10, 9], [1, 11, 9]];
14. var insertTileSql = "insert into tiles(level, column, row) values(?, ?, ?)";
15. sqliteDB.insertData(insertTileSql, tileData);
16.  
17. /// query data.
18. var querySql = 'select * from tiles where level = 1 and column >= 10 and column <= 11 and row >= 10 and row <=11';
19. sqliteDB.queryData(querySql, dataDeal);
20.  
21. /// update data.
22. var updateSql = 'update tiles set level = 2 where level = 1 and column = 10 and row = 10';
23. sqliteDB.executeSql(updateSql);
24.  
25. /// query data after update.
26. querySql = "select * from tiles where level = 2";
27. sqliteDB.queryData(querySql, dataDeal);
28. sqliteDB.close();
29.  
30. function dataDeal(objects){
31.     for(var i = 0; i < objects.length; ++i){
32.         console.log(objects[i]);
33.     }
34. }
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 215,923评论 6赞 498
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 92,154评论 3赞 392
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 161,775评论 0赞 351
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 57,960评论 1赞 290
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 66,976评论 6赞 388
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 50,972评论 1赞 295
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 39,893评论 3赞 416
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 38,709评论 0赞 271
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 45,159评论 1赞 308
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,400评论 2赞 331
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,552评论 1赞 346
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 35,265评论 5赞 341
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 40,876评论 3赞 325
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,528评论 0赞 21
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,701评论 1赞 268
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 47,552评论 2赞 368
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 44,451评论 2赞 352