factory_web/src/utils/db.js

//初始数据库结构
const dbData = [
	{
		dbName: "masterDB",					//数据库名称
		version: 1,							//数据库版本号,当结构发生变化时
		tables: [							//表
			{
				name: "SYS_favorites",		//表名称
				keyPath: "uid",				//主键
				autoIncrement: false,		//主键是否自增
				index: [					//索引
					{
						name: "name_index",	//索引名称
						key: "name"			//索引key
					}
				]
			},
			{
				name: "SYS_keyword",
				keyPath: "id"
			}
		]
	},
	{
		dbName: "guestDB",
		version: 1,
		tables: [
			{
				name: "MY_demo",
				keyPath: "id"
			}
		]
	}
]

// 使用示例
// import DB from '@/utils/db'

// 初始化创建数据库 一般在项目启动时就执行了
// await DB.create()

// 打开某个数据库，返回数据库实例
// const database = await DB.open("dbName")

// 在打开的数据库中添加数据到tablenName表
// await database.add("tablenName", data)

// 查询
// await database.get("tablenName", key)

// 查询 根据索引
// await database.indexGet("tablenName", "indexName", indexVal)

// 修改
// await database.put("tablenName", data)

// 删除
// await database.delete("tablenName", key)

// 获取所有
// await database.getAll("tablenName")

// 清空某个表数据
// await database.clear("tablenName")

// 获取某个表信息
// database.getTable("tablenName")

// 获取所有表
// database.getTables()

// 关闭数据库连接
// database.close()


export default {
	//建立数据库，表，初始数据
	create() {
		var promiseArray = []
		const addDB = db => {
			return new Promise((resolve, reject) => {
				const request = indexedDB.open(db.dbName, db.version)
				request.onupgradeneeded = e => {
					const thisDB = e.target.result
					db.tables.forEach(item => {
						let table = null
						if (thisDB.objectStoreNames.contains(item.name)) {
							//已存在表，删除旧index
							table = e.target.transaction.objectStore(item.name)
							table.indexNames.length>0 && table.indexNames.forEach(indexName => {
								table.deleteIndex(indexName)
							})
						}else{
							//创建新的表
							table = thisDB.createObjectStore(item.name, {
							    keyPath: item.keyPath,
								autoIncrement: item.autoIncrement
							})
						}
						//建立index
						item.index && item.index.forEach(ind => {
							table.createIndex(ind.name, ind.key, { unique: false })
						})
					})
				},
				request.onsuccess = e => {
					return resolve(e.target.result)
				}
				request.onerror = e => {
					return reject(e)
				}
			})
		}
		dbData.forEach(db => {
			promiseArray.push(addDB(db))
		})
		return new Promise((resolve, reject) => {
			Promise.all(promiseArray).then((e) => {
				resolve(e)
			}).catch(e => {
				reject(e)
			})
		})
	},
	//所有数据库
	databases(){
		return indexedDB.databases()
	},
	//打开数据库
	open(dbName){
		return new Promise((resolve, reject) => {
			const request = indexedDB.open(dbName)
			request.onsuccess = e => {
				const database = new this.database(e.target.result)
				resolve(database)
			}
			request.onerror = e => {
				reject(e)
			}
		})
	},
	//删除数据库
	deleteDB(dbName){
		return indexedDB.deleteDatabase(dbName)
	},
	//数据库类
	database: function (IDBDatabase) {
		this.IDBDatabase = IDBDatabase

		/**
		 * 添加行数据
		 * @param {string} tableName 表名
		 * @param {object} data 数据
		 * @returns {promise}
		 */
		this.add = (tableName, data) => {
			return new Promise((resolve, reject) => {
				const request = IDBDatabase.transaction([tableName], 'readwrite').objectStore(tableName).add(data)
				request.onsuccess = e => {
					resolve(e)
				}
				request.onerror = e => {
					reject(e)
				}
			})
		}

		/**
		 * 修改行数据，未查询到就新增
		 * @param {string} tableName 表名
		 * @param {object} data 数据
		 * @returns {promise}
		 */
		this.put = (tableName, data) => {
			return new Promise((resolve, reject) => {
				const request = IDBDatabase.transaction([tableName], 'readwrite').objectStore(tableName).put(data)
				request.onsuccess = e => {
					resolve(e)
				}
				request.onerror = e => {
					reject(e)
				}
			})
		}

		/**
		 * 删除行
		 * @param {string} tableName 表名
		 * @param {string} key 主键
		 * @returns {promise}
		 */
		this.delete = (tableName, key) => {
			return new Promise((resolve, reject) => {
				const request = IDBDatabase.transaction([tableName], 'readwrite').objectStore(tableName).delete(key)
				request.onsuccess = e => {
					resolve(e)
				}
				request.onerror = e => {
					reject(e)
				}
			})
		}

		/**
		 * 根据主键获取行
		 * @param {string} tableName 表名
		 * @param {string} key 主键
		 * @returns {promise}
		 */
		this.get = (tableName, key) => {
			return new Promise((resolve, reject) => {
				const request = IDBDatabase.transaction([tableName], 'readwrite').objectStore(tableName).get(key)
				request.onsuccess = () => {
					resolve(request.result || null)
				}
				request.onerror = e => {
					reject(e)
				}
			})
		}

		/**
		 * 根据索引获取行
		 * @param {string} tableName 表名
		 * @param {string} indexName 索引库名称
		 * @param {string} indexVal 索引值
		 * @returns {promise}
		 */
		this.indexGet = (tableName, indexName, indexVal) => {
			return new Promise((resolve, reject) => {
				const request = IDBDatabase.transaction([tableName], 'readwrite').objectStore(tableName).index(indexName).get(indexVal)
				request.onsuccess = () => {
					resolve(request.result || null)
				}
				request.onerror = e => {
					reject(e)
				}
			})
		}

		/**
		 * 获取所有行
		 * @param {string} tableName 表名
		 * @returns {promise}
		 */
		this.getAll = (tableName) => {
			return new Promise((resolve, reject) => {
				const request = IDBDatabase.transaction([tableName], 'readwrite').objectStore(tableName).getAll()
				request.onsuccess = () => {
					resolve(request.result || null)
				}
				request.onerror = e => {
					reject(e)
				}
			})
		}

		/**
		 * 清空表
		 * @param {string} tableName 表名
		 * @returns {promise}
		 */
		this.clear = (tableName) => {
			return new Promise((resolve, reject) => {
				const request = IDBDatabase.transaction([tableName], 'readwrite').objectStore(tableName).clear()
				request.onsuccess = e => {
					resolve(e)
				}
				request.onerror = err => {
					reject(err)
				}
			})
		}

		/**
		 * 获取表信息
		 * @returns {IDBObjectStore}
		 */
		this.getTable = (tableName) => {
			const request = IDBDatabase.transaction([tableName], 'readwrite').objectStore(tableName)
			return request
		}

		/**
		 * 获取所有的表
		 * @returns {[IDBObjectStore]}
		 */
		this.getTables = () => {
			const tables = []
			for (let item of IDBDatabase.objectStoreNames) {
				tables.push(IDBDatabase.transaction([item], 'readwrite').objectStore(item))
			}
			return tables
		}

		/**
		 * 关闭数据库连接
		 * @returns {}
		 */
		this.close = () => {
			return IDBDatabase.close()
		}
	}
}