uni-app开发sqllite公共方法(h5使用sqllite同步异步问题)

项目基本情况

        使用uni-app开发,客户端本地数据存储选择sqllite

uni-app参考地址

uni-app官网 (dcloud.io)

sqllite参考地址

HTML5+ API Reference (html5plus.org)

解决异步的方法

        异步执行的代码一般都有回调,在外层方法中创建自己的回调函数,通过回调实现业务操作,曲折实现“同步执行”的逻辑。

开发过程

        由于业务需要,在app客户端要进行本地数据存储。本人常年开发java,面向对象理念深入人心,于是需要在合适的位置写一个dbUtils.js的工具类,提供数据库增删改查的方法,返回执行结果。但是在调试过程中发现sqllite操作数据库的方法是异步的,所以按照传统的返回值方式无法取得正确结果。

        初始思路:先定义返回结果变量,操作完成后返回结果

// 此方法行不通!
export function executeSql(sql){
	let result = false;
	// 打开数据库
    plus.sqlite.openDatabase({
    	// 数据库名称
    	name: 'xxxxx',
    	// 数据库文件路径
    	path: '_doc/xxxxx.db',
    	// 打开数据库成功
    	success: function(e){
    		result = true;
    	},
		fail:function(e){
			console.log(e);
		}
    });
	if (result) {
		// 执行sql
		plus.sqlite.executeSql({
			name:'xxxxx',
			sql: sql,
			success(){
				result = true;
			},
			fail(e) {
				console.log(e);
			}
		});
	}
	// 关闭数据库
	plus.sqlite.closeDatabase({name: 'xxxxx'});
	return result;
}

        通过调试发现方法永远返回false,在执行plus.sqllite.xxx时,js继续执行了,没有等待,导致执行是数据库已经关闭,后来我把执行sql写在打开数据库的回调中,关闭数据库写在执行sql的回调中,但只能解决数据库操作部分的执行顺序正确,返回值仍然不对。

        这时我想暴力解决这个异步问题,产生了一个天真大胆的想法,在异步执行时阻断程序执行,监听异步操作是否执行完成

	let executeFinished = false;
	......各种数据库操作,完成时赋值executeFinished = true;
	while(true) {
		if (executeFinished) {
			break;
		}
	}
	......后续操作

        然后发现程序卡在while(true)那里了,永远进不去数据库操作回调方法,executeFinished自然永远不会变。

        经过查阅资料,发现js是单线程的,那么while(true)一直循环程序就阻断了。js中的异步处理只是合适的时机去执行,底层并不是并行的。

        最后,通过给公共方法传回调事件,曲折解决了sqllite的异步问题

最终代码

工具类:dbUtils.js

/**
 * 增/删/改 sql执行
 * @param {Object} sql
 * @param {Object} callback
 */
export function executeSql(sql, callback){
	let result = {};
    // 打开数据库
    plus.sqlite.openDatabase({
    	// 数据库名称
    	name: 'xxxxx',
    	// 数据库文件路径
    	path: '_doc/xxxxx.db',
    	// 打开数据库成功
    	success: function(e){
    		plus.sqlite.executeSql({
    			name:'xxxxx',
    			sql: sql,
    			success(){
    				result.success = true;
					closeDatabase();
					callback(result);
    			},
				fail(e) {
					result.success = false;
					result.data = e;
					closeDatabase();
					callback(result);
				}
    		});
    	},
		fail:function(e){
			result.success = false;
			result.data = e;
			closeDatabase();
			callback(result);
		}
    });
}
/**
 * 数据库查询select
 * @param {Object} sql
 * @param {Object} callback
 */
export function selectSql(sql, callback){
	let result = {};
    // 打开数据库
    plus.sqlite.openDatabase({
    	// 数据库名称
    	name: 'xxxxx',
    	// 数据库文件路径
    	path: '_doc/xxxxx.db',
    	// 打开数据库成功
    	success: function(e){
    		plus.sqlite.selectSql({
    			name:'xxxxx',
    			sql: sql,
    			success(data){
    				result.success = true;
					result.data = data;
					closeDatabase();
					callback(result);
    			},
				fail(e) {
					result.success = false;
					result.data = e;
					closeDatabase();
					callback(result);
				}
    		});
    	},
		fail:function(e){
			result.success = false;
			result.data = e;
			closeDatabase();
			callback(result);
		}
    });
}
/**
 * 关闭数据库
 */
function closeDatabase() {
	plus.sqlite.closeDatabase({name: 'xxxxx'});
}

引入:

import { executeSql } from '@/common/db/dbUtils.js';

调用: 

let sql = "insert into xxxxxxxxxx";
executeSql(sql, function(result) {
	if (result.success) {
		// 业务操作
	} else {
		// 执行失败操作
	}
});

上一篇:消除游戏《消灭怪兽》源码H5+安卓+IOS三端源码


下一篇:技术周刊2020-10-12