网页端处理

pages.json

 {
 	"pages": [ //pages数组中第一项表示应用启动页，参考：https://uniapp.dcloud.io/collocation/pages
-		// {
-		// 	"path": "pages/index/index",
-		// 	"style": {
-		// 		"navigationBarTitleText": "uSQLite"
-		// 	}
-		// },
+		{
+			"path": "pages/index/index",
+			"style": {
+				"navigationBarTitleText": "uSQLite"
+			}
+		},
 		{
 			"path": "uni_modules/onemue-usqlite-console/components/onemue-usqlite-console/onemue-usqlite-console",
 			"style": {
 				"navigationBarTitleText": "uSQLite-console"
 			}
-		},
-		{
-			"path": "pages/index/index",
-			"style": {
-				"navigationBarTitleText": "uSQLite"
-			}
 		}
+		// {
+		// 	"path": "pages/index/index",
+		// 	"style": {
+		// 		"navigationBarTitleText": "uSQLite"
+		// 	}
+		// }
 	],
 	"globalStyle": {
 		"navigationBarTextStyle": "black",

uni_modules/onemue-USQLite/js_sdk/usqlite-h5.js

+// 选择 
+
+/**
+ * 处理SQLite SQLite 是 APP 才有的内容 所以 需要同一套API 满足 setStorage 的API
+ * 方便多平台开发
+ * time：2021-12-16 16:30:00
+ * version：1.0.0
+ * by: onemue
+ */
+
+// 我们考虑在数据中存放一些例如：社区APP 存放一些帖子信息等等内容，实现断网信息保留等功能。
+// 参考 mysql-ithm
+// URL: https://github.com/kxzkane/mysql-ithm/blob/master/index.js
+// CREATE TABLE <表名> ([表定义选项])[表选项][分区选项];
+//数据库配置
+let options = {};
+let tableSQL = '';
+let databaseName = '';
+let isConnect = false;
+
+class Model {
+	constructor(name, option, db) {
+		this.name = name;
+		this.option = option;
+		this.db = db;
+		let self = this;
+
+		self.isExist(function(e, r){
+			if (!r) {
+				self.create();
+			}
+		})
+	}
+	/**
+	 * @description: 查询数据
+	 * @param {} options：可选参数
+	 * @param {Function} callback :（err,results）=>{}
+	 */
+	find(options, callback) {
+		var sql = '';
+		let self = this;
+
+		if (!callback) {
+			sql = `SELECT * FROM '${this.name}'`;
+			callback = options;
+		} else if (options.constructor == Array) {
+			sql = `SELECT ${options.join()} FROM '${this.name}'`;
+		} else {
+			sql = `SELECT * FROM '${this.name}' WHERE ${options}`;
+		};
+		plus.sqlite.selectSql({
+			name: self.db,
+			sql: sql,
+			success(e) {
+				callback(null, e);
+			},
+			fail(e) {
+				callback(e);
+			}
+		})
+		return this;
+	}
+	/**
+	 * @description: 分页查询
+	 * @param {Object} options :   { where:查询条件, number: 当前页数 , count : 每页数量 }
+	 * @return: 
+	 */
+	limit(options, callback) {
+		var sql = '';
+		let self = this;
+		if (!options.where) {
+			sql = `SELECT * FROM '${this.name}' LIMIT ${options.count} OFFSET ${(options.number - 1) * options.count}`
+		} else {
+			sql =
+				`SELECT * FROM '${this.name}' WHERE ${options.where} LIMIT ${options.count} OFFSET ${(options.number - 1) * options.count}`;
+		};
+		plus.sqlite.selectSql({
+			name: self.db,
+			sql: sql,
+			success(e) {
+				callback(null, e);
+			},
+			fail(e) {
+				callback(e);
+			}
+		})
+		return this;
+	}
+	/**
+	 * @description: 插入数据
+	 * @param {Object} obj:对象或者数组
+	 * @param {Function} callback :（err,results）=>{}
+	 */
+	insert(obj, callback) {
+		let self = this;
+		if (!true) {
+			// todo
+		} else {
+			if (Array.isArray(obj)) {
+				for (var i = 0; i < obj.length; i++) {
+					this.insertObj(obj[i], callback)
+				}
+			} else {
+				this.insertObj(obj, callback)
+			}
+		}
+		return this;
+	}
+
+	insertObj(obj, callback) {
+		let keys = [];
+		let values = '';
+		let self = this;
+		for (var key in obj) {
+			keys.push(key);
+			values += `'${obj[key]}',`;
+		};
+		values = values.replace(/,$/, '');
+		let sql = `INSERT INTO '${this.name}' (${keys.join()}) VALUES (${values})`;
+		console.log(sql);
+		plus.sqlite.executeSql({
+			name: self.db,
+			sql: sql,
+			success(e) {
+				callback(null, e);
+			},
+			fail(e) {
+				callback(e);
+			}
+		})
+		return this;
+	}
+	/**
+	 * @description: 更新数据
+	 * @param {Object} option：可选参数 更新条件 // TODO 更新条件
+	 * @param {Object} obj： 修改后的数据 
+	 * @param {Function} callback :（err,results）=>{}
+	 */
+	update(option, obj, callback) {
+		let sql = '';
+		let self = this;
+		if (arguments.length == 2) {
+			callback = obj;
+			obj = option;
+			sql = `UPDATE '${this.name}' SET `;
+			for (var key in obj) {
+				sql += `${key}='${obj[key]}', `;
+			};
+			sql = sql.replace(/(, )$/, '');
+		} else {
+			sql = `UPDATE ${this.name} SET `;
+			for (var key in obj) {
+				sql += `${key}='${obj[key]}', `;
+			};
+			sql = sql.replace(/(, )$/, '');
+			sql += ` WHERE ${option}`;
+		};
+		plus.sqlite.executeSql({
+			name: self.db,
+			sql: sql,
+			success(e) {
+				callback(null, e);
+			},
+			fail(e) {
+				callback(e);
+			}
+		})
+		return this;
+	}
+	/**
+	 * @description: 删除数据
+	 * @param {Object} option：可选参数 删除条件
+	 * @param {Function} callback :（err,results）=>{}
+	 */
+	delete(option, callback) {
+		var sql = '';
+		let self = this;
+		if (!callback) {
+			sql = `DELETE FROM '${this.name}'`;
+			callback = option;
+		} else {
+			sql = `DELETE FROM '${this.name}' WHERE ${option}`;
+		};
+		plus.sqlite.executeSql({
+			name: self.db,
+			sql: sql,
+			success(e) {
+				callback(null, e);
+			},
+			fail(e) {
+				callback(e);
+			}
+		})
+		return this;
+	}
+	/**
+	 * @description: 执行sql语句
+	 * @param {String} sql : sql语句
+	 * @param {Function} callback :（err,results）=>{}
+	 */
+	sql(sql, callback) {
+		let self = this;
+		plus.sqlite.selectSql({
+			name: self.db,
+			sql: sql,
+			success(e) {
+				callback(null, e);
+			},
+			fail(e) {
+				callback(e);
+			}
+		});
+		return this;
+	}
+	/**
+	 * @description: 删除model表格 （慎用！）
+	 * @param {type} 
+	 * @return: 
+	 */
+	drop(callback) {
+		var sql = `DROP TABLE '${this.name}'`;
+		let self = this;
+		plus.sqlite.selectSql({
+			name: self.db,
+			sql: sql,
+			success(e) {
+				callback(null, e);
+			},
+			fail(e) {
+				callback(e);
+			}
+		});
+		return this;
+	}
+	connect(callback) {
+		let sql = `SELETE count(*) AS isTable FROM sqlite_master WHERE type='table' AND name='${this.name}'`;
+		let self = this;
+		plus.sqlite.selectSql({
+			name: self.db,
+			sql: sql,
+			success(e) {
+				callback(null, e);
+			},
+			fail(e) {
+				callback(e);
+			}
+		});
+		return this;
+	}
+	isExist(callback) {
+		let self = this;
+		// return new Promise((resolve, reject) => {
+			plus.sqlite.selectSql({
+				name: self.db,
+				sql: `select count(*) as isExist FROM sqlite_master where type='table' and name='${this.name}'`,
+				success(e) {
+					callback(null, e[0].isExist ? true : false)
+				},
+				fail(e) {
+					console.log(e)
+					callback(e)
+					// reject(e);
+				}
+			})
+		return this;
+	}
+
+	create(callback) {
+		let self = this;
+		this.tableSQL = usqlite.modelSql(self.name, self.option);
+		plus.sqlite.executeSql({
+			name: self.db,
+			sql: self.tableSQL,
+			success(e) {
+				callback(null, e);
+			},
+			fail(e) {
+				callback(e)
+			}
+		})
+		return this;
+	}
+}
+
+
+usqlite = {
+	/**
+	 * @description:连接数据库
+	 * @param {String} name: 数据库名称*
+	 * @param {String} path: 数据库路径*
+	 * @param {Function} callback :（err,results）=>{}
+	 * @return: 
+	 */
+	connect({
+		name = '',
+		path = ''
+	}, callback) {
+		options = {
+			name, // 数据库名称*
+			path, // 数据库路径*
+		};
+		plus.sqlite.openDatabase({
+			name: options.name, //数据库名称
+			path: options.path, //数据库地址
+			success(e) {
+				isConnect = true;
+				callback(null, e);
+			},
+			fail(e) {
+				callback(e);
+			}
+		})
+	},
+	/**
+	 * @description:关闭数据库
+	 * @param {Function} callback :（err,results）=>{}
+	 * @return: 
+	 */
+	close(callback) {
+		plus.sqlite.closeDatabase({
+			name: options.name, //数据库名称
+			path: options.path, //数据库地址
+			success(e) {
+				isConnect = false;
+				callback(null, e);
+			},
+			fail(e) {
+				callback(e);
+			}
+		});
+	},
+	/**
+	 * @description:创建model (表格模型对象)
+	 * @param {String} name:表格名称
+	 * @param {Object} options:表格数据结构 
+	 * @return: Model对象：负责数据库增删改查
+	 */
+	model(name, option) {
+		return new Model(name, option, options.name);
+	},
+	/**
+	 * @description 生成创建model的modelSql
+	 * @param {Object} name
+	 * @param {Object} option
+	 */
+	modelSql(name, option) {
+		let str = '`usql_id` integer PRIMARY KEY,'; // usql_id 为自增主键
+		for (var key in option) {
+			if (option[key] == Number) {
+				str += `'${key}' numeric,`;
+			} else if (option[key] == Date) {
+				str += `'${key}' timestamp,`;
+			} else {
+				str += `'${key}' varchar,`;
+			}
+		};
+		str = str.replace(/,$/, '');
+		return `CREATE TABLE '${name}' (${str})`;
+	}
+}
+
+
+export var usqlite;

uni_modules/onemue-USQLite/js_sdk/usqlite.js

@@ -15,19 +15,23 @@ let options = {};
 let tableSQL = '';
 let databaseName = '';
 let isConnect = false;
-
+let IDBDatabase  = null;
 class Model {
 	constructor(name, option, db) {
 		this.name = name;
 		this.option = option;
-		this.db = db;
-		let self = this;
-
-		self.isExist(function(e, r){
-			if (!r) {
-				self.create();
-			}
-		})
+		// option['usql_id']=
+		if (!IDBDatabase.objectStoreNames.contains(name)) {
+		try{
+			let objectStore = IDBDatabase.createObjectStore(name, {keyPath: 'usql_id'});
+			for (let key in option) {
+				objectStore.createIndex(key, key, { unique: false });
+			}
+		}catch(e){
+			//TODO handle the exception
+			console.warn(e);
+		}
+		}
 	}
 	/**
 	 * @description: 查询数据
@@ -106,26 +110,17 @@ class Model {
 	}
 
 	insertObj(obj, callback) {
-		let keys = [];
-		let values = '';
-		let self = this;
-		for (var key in obj) {
-			keys.push(key);
-			values += `'${obj[key]}',`;
-		};
-		values = values.replace(/,$/, '');
-		let sql = `INSERT INTO '${this.name}' (${keys.join()}) VALUES (${values})`;
-		console.log(sql);
-		plus.sqlite.executeSql({
-			name: self.db,
-			sql: sql,
-			success(e) {
-				callback(null, e);
-			},
-			fail(e) {
-				callback(e);
-			}
-		})
+		var request = IDBDatabase.transaction([this.name], 'readwrite')
+			.objectStore([this.name])
+			.add(obj);
+
+		  request.onsuccess = function (r) {
+			callback(null, r)
+		  };
+
+		  request.onerror = function (e) {
+			callback(e);
+		  }
 		return this;
 	}
 	/**
@@ -297,17 +292,20 @@ usqlite = {
 			name, // 数据库名称*
 			path, // 数据库路径*
 		};
-		plus.sqlite.openDatabase({
-			name: options.name, //数据库名称
-			path: options.path, //数据库地址
-			success(e) {
-				isConnect = true;
-				callback(null, e);
-			},
-			fail(e) {
-				callback(e);
-			}
-		})
+		if(!window.indexedDB){
+			console.log('当前环境不支持indexedDB(uSQLite)')
+		}
+		IDBDatabase = window.indexedDB.open(options.name, 1);
+		IDBDatabase.onerror = function (e) {
+		  callback(e);
+		};
+		IDBDatabase.onsuccess = function (event) {
+		  let db = IDBDatabase.result;
+		  console.log(db);
+		  callback(null, {});
+		};
+		
+		// upgradeneeded 数据库升级操作
 	},
 	/**
 	 * @description:关闭数据库