nodejs同步操作sqlite3类

野生程序猿-杂烧6年前随意分享2404

electron是基于nodejs的,为了方便electron存储,想到了sqlite这种轻便数据库。作为桌面应用,不像nodejs写服务端,为了简化开发,所以写了个同步的操作sqlite的类库,需要用deasync。

var deasync=require('deasync');
const path = require('path')
const sqlite3 = require('sqlite3')



// 定义类
class db_sqlite {
	db;
	db_path;
    //构造函数
    constructor(db_path) {
        this.db_path=db_path;
		this.connect();
	
    }
	
	connect() {
	    
		var me=this;
		var temp_connect=deasync((cb) => {
	
			me.db=new sqlite3.Database(me.db_path, err => 
			{
				if (err !== null){
					console.error('db connect err',me.db_path);
					cb(err, err);
				} else{
					console.error('db connect ok',me.db_path);
					cb(null, true);
				}
			});
		
		})
		return temp_connect();
	}

	close()
	{

		this.db.close(function(err){
			if (err !== null){
				console.error('db close err',me.db_path);
				
			} else{
				console.error('db close ok',me.db_path);
			}
		});
	}
	
    strtosql(value){
        try{
            if(typeof(value)=='undefined' )
            {
                var result='';
            }else{
                var result=value;
            }
        }catch(e){
            var result='';
        }
        result=result.replace(/\'/g,"''");
        result=result.replace(/\\/g,"\\\\");
        return result;
    }
    
	select_all(sql)
	{
		
	    var me=this;
	    var temp_select_all=deasync((sql,cb) =>
		{
			
			me.db.all(sql, (err, result) =>
			{
				if(err){
				var result=[];
				}
				cb(null, result);
			});
	    })
	    return temp_select_all(sql);
	
	}
	
	select_one(sql)
	{
	    var sql=sql+' limit 0,1';
	    var this_result=this.select_all(sql);
	    try{
	        var result=this_result[0];
	        if(!result)
	        {
	            var result={};
	        }
	    }catch(e){
	        var result={};
	    }
	    return result;
	
	}
	
	dosql(sql)
	{
	    var me=this;
		//sql=me.strtosql(sql);

	    var temp_dosql=deasync((sql,cb) => {
			me.db.run(sql, (err, result) =>
			{

				if(err){
					var result=false;
				}else{
					var result=true;
				}
				cb(null, result);
			});

	
	    })
	
	    return temp_dosql(sql);
	
	}
}

module.exports = db_sqlite;


相关文章

按键精灵+大漠插件 打boss(脚本demo3)

前面介绍了大漠插件,这里再来个复杂点的,这个是 4个号多开刷任务Sub 初始巡检() //判断是否出于英雄之门界面 Delay 10000 MoveTo 40...

python RabbitMq的订阅

【test_RabbitMq1.py】import pika import json credentials = pika.PlainCredentia...

打造支付中心

随着公司业务的开展,发现多个环节需要用到支付。我们在购买聚合支付的时候,每年年费不同,享受到的服务也有很大的差距。当资金有限的时候,我们选择了较便宜的服务,这个时候我们能创建的支付应用数量较少,因此我...

按键精灵+大漠插件 打boss(脚本demo4)

前面介绍了大漠插件,这里再来个复杂点的,这个是4开刷副本//初始化数据 //地图信息 //副本坐标 ditux = -230 dituy = -19...

编译新的js库用在传统模式直接使用

面向dom的jquery被淘汰了,但是jquery拥有多年的生态,很多时候还是可以用在一些项目上的。没有最好的开发语言,也没有最好的框架;只有最适用的开发语言、最适用的框架。很多时候我们敏捷开发者都会...

扫描仪的驱动安装(一体机网络版)

扫描仪的驱动安装(一体机网络版)

上次介绍了常规硬件的驱动正确安装方法,今天来聊一下打印机一体机的扫描功能的安装。 如果是usb连接,直接驱动管理工具就可以安装上。如果网络连接,一般可以把打印驱动安装上,...