nodejs同步操作sqlite3类

野生程序猿-杂烧5年前随意分享2074

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;


相关文章

bug记录-redis故障的一次处理

现象是这样的,redis启动不了,重启服务器现象依旧。与大部分企业不同的是,我们的客户主要是学校。这类客户的订制软件一般都是要提供加密狗并且需要运行在windows服务器上的。由学校机房老师管理(大部...

IPMI模块介绍,远程开机走起来

IPMI模块介绍,远程开机走起来

作为野生程序猿,生活中经常使用开发技术。这里给大家介绍一个好东西 IPMI 。 很多开发人员居然没听说过这个东西,看来做技术还是太不上心了,工作之外的积累太少了。IPMI...

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

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

GPS经纬度坐标系转换【python版】

再补充个python版的gps经纬度坐标系,在脚本处理数据的时候python,nodejs要比php性能好很多。尤其是他们更擅长多线程# -*- coding: UTF-...

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

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

vue编译成微信小程序的坑

uniapp最大的好处是方便,最大的问题就是编译后多端的异常难以排查。h5端一切正常,在其他端异常。代码不存在语法上的错误,几乎都是平台的差异性导致的,这个时候多半是经验积累不够,坑踩得不够多。很多时...