devbox
从前慢现在也慢
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

uni-app集成使用SQLite_uniapp集成sqllite

作者：从前慢现在也慢 | 2024-02-15 19:48:25

赞

踩

uniapp集成sqllite

一、打开uni-app中SQLite

二、封装sqlite.js 

  1. module.exports = {
  2.     dbName: 'chat', // 数据库名称
  3.     dbPath: '_doc/chat.db', // 数据库地址,推荐以下划线为开头   _doc/xxx.db
  4. 	
  5. 	/**
  6. 	  * @Description: 创建数据库 或 有该数据库就打开
  7. 	  * @author: ZXL
  8. 	  * @createTime: 2023-10-12 09:23:10
  9. 	  * @Copyright by 蓝创科技有限公司
  10. 	  */
  11. 	openSqlite() {
  12. 	    return new Promise((resolve, reject) => {
  13. 			// 打开数据库
  14. 			plus.sqlite.openDatabase({
  15. 			    name: this.dbName,
  16. 			    path: this.dbPath,
  17. 			    success(e) {
  18. 				    resolve(e); 
  19. 			    },
  20. 			    fail(e) {
  21. 				    reject(e); 
  22. 			    }
  23. 			})
  24. 	    })
  25. 	},
  26. 	/**
  27. 	  * @Description: 判断数据库是否打开  数据库打开了就返回 true,否则返回 false
  28. 	  * @author: ZXL
  29. 	  * @createTime: 2023-10-12 08:43:03
  30. 	  * @Copyright by 蓝创科技有限公司
  31. 	  */
  32.     isOpen() {
  33. 		var open = plus.sqlite.isOpenDatabase({
  34. 		    name: this.dbName,  // 数据库名称
  35. 		    path: this.dbPath  // 数据库地址
  36. 		})
  37. 		return open;
  38.     },
  39. 	/**
  40. 	  * @Description: 创建表（executeSql是执行增删改等操作的SQL语句）
  41. 	  * @author: ZXL
  42. 	  * @createTime: 2023-10-12 08:43:03
  43. 	  * @Copyright by 蓝创科技有限公司
  44. 	  */
  45.     ExecuteSQL(sql) {
  46. 		return new Promise((resolve, reject) => {
  47. 		    plus.sqlite.executeSql({
  48. 				name: this.dbName,
  49. 				sql: sql,
  50. 				success(e) {
  51. 				    resolve(e);
  52. 				},
  53. 				fail(e) {
  54. 				    reject(e);
  55. 				}
  56. 		    })
  57. 		})
  58.     },
  59. 	/**
  60. 	  * @Description: 查询表数据
  61. 	  * @author: ZXL
  62. 	  * @createTime: 2023-10-12 08:52:15
  63. 	  * @Copyright by 蓝创科技有限公司
  64. 	  */
  65. 	getTable(dbTable){
  66. 	  	return new Promise((resolve, reject) => {
  67. 			plus.sqlite.selectSql({
  68. 				name: this.dbName,
  69. 				sql: `SELECT * FROM ${dbTable}`,
  70. 				success(e) {
  71. 					resolve(e);
  72. 				},
  73. 				fail(e) {
  74. 					console.log(e)
  75. 					reject(e);
  76. 				}
  77. 			})
  78. 	  	})
  79. 	},
  80. 	/**
  81. 	  * @Description: 查询数据库所有表
  82. 	  * @author: ZXL
  83. 	  * @createTime: 2023-10-12 09:01:05
  84. 	  * @Copyright by 蓝创科技有限公司
  85. 	  */
  86. 	QueryAllTables(){
  87. 		return new Promise((resolve, reject) => {
  88. 			plus.sqlite.selectSql({
  89. 				name: this.dbName,
  90. 				sql: "SELECT * FROM sqlite_master WHERE type='table'",
  91. 				success(e) {
  92. 					resolve(e);
  93. 				},
  94. 				fail(e) {
  95. 					console.log(e)
  96. 					reject(e);
  97. 				}
  98. 			})
  99. 		})
  100. 	},
  101. 	/**
  102. 	  * @Description: 查询数据库下的所有表
  103. 	  * @author: ZXL
  104. 	  * @createTime: 2023-10-12 09:20:33
  105. 	  * @Copyright by 蓝创科技有限公司
  106. 	  */
  107. 	selectTableName(){
  108. 		return new Promise((resolve, reject) => {
  109. 			plus.sqlite.selectSql({
  110. 				name: this.dbName,
  111. 				sql: "select * FROM chat where type='table'",
  112. 				success(e) {
  113. 					resolve(e);
  114. 				},
  115. 				fail(e) {
  116. 					console.log(e)
  117. 					reject(e);
  118. 				}
  119. 			})
  120. 		})
  121. 	},
  122. 	/**
  123. 	  * @Description: 新增数据
  124. 	  * @author: ZXL
  125. 	  * 向表格里添加数据 sql:'INSERT INTO dbTable VALUES('x','x','x')'   对应新增
  126. 	  * 或者 sql:'INSERT INTO dbTable ('x','x','x') VALUES('x','x','x')'   具体新增
  127. 	  * 插入 INSERT INTO  、 dbTable 是表名、根据表头列名插入列值
  128. 	  * @createTime: 2023-10-12 10:21:32
  129. 	  * @Copyright by 蓝创科技有限公司
  130. 	  */
  131. 	//使用
  132. 	// let arr = [
  133. 	//     {id:121,dept_id: '100',dept_name: '你好呀'},
  134. 	// 	   {id:332,dept_id: '200',dept_name: '你好呀'},
  135. 	// ]
  136. 	// arr.map((item) => {
  137. 	//     let condition = "'id','dept_id','dept_name'"
  138. 	//     let data = `'${item.id}','${item.dept_id}','${item.dept_name}'`
  139. 	//     DB.insertTableData('表名',数据,字段).then((res) => {})
  140. 	// 	  .catch((error) => {
  141. 	// 	    console.log('失败', error)
  142. 	// 	  })
  143. 	// })
  144. 	insertTableData(dbTable, data, condition) {
  145. 	    // 判断有没有传参
  146. 	    if (dbTable !== undefined && data !== undefined) {
  147. 			// 判断传的参是否有值
  148. 			var bol = (JSON.stringify(data) == "{}");
  149. 			if (!bol) {
  150. 				if (condition == undefined) var sql = `INSERT INTO ${dbTable} VALUES('${data}')`;
  151. 				else var sql = `INSERT INTO ${dbTable} (${condition}) VALUES(${data})`;
  152. 			    return new Promise((resolve, reject) => {
  153. 					// 表格添加数据
  154. 					plus.sqlite.executeSql({
  155. 					  name: this.dbName,
  156. 					  sql: sql,
  157. 					  success(e) {
  158. 						resolve(e);
  159. 					  },
  160. 					  fail(e) {
  161. 						reject(e);
  162. 					  }
  163. 					})
  164. 			    })
  165. 			} else {
  166. 			  return new Promise((resolve, reject) => { reject("错误添加") })
  167. 			}
  168. 		} else {
  169. 			return new Promise((resolve, reject) => { reject("错误添加") })
  170. 	    }
  171. 	},
  172. 	/**
  173. 	  * @Description: 数据库建表
  174. 	  * @author: ZXL
  175. 	  * 数据库建表 sql:'CREATE TABLE IF NOT EXISTS dbTable("id" varchar(50),"name" TEXT) 
  176. 	  * 创建 CREATE TABLE IF NOT EXISTS 、 dbTable 是表名，不能用数字开头、括号里是表格的表头
  177. 	  * @createTime: 2023-10-12 09:26:44
  178. 	  * @Copyright by 蓝创科技有限公司
  179. 	  */
  180.     // 使用
  181. 	// DB.createTable('bus_mzpy','"id" INTEGER PRIMARY KEY AUTOINCREMENT,"mzpy_name" TEXT ,"dept_id" INTEGER ,"dept_name" TEXT ,"mzpy_concent" TEXT')
  182.     createTable(dbTable, data) {
  183. 		return new Promise((resolve, reject) => {
  184. 		    // executeSql: 执行增删改等操作的SQL语句
  185. 		    plus.sqlite.executeSql({
  186. 				name: this.dbName,
  187. 				sql: `CREATE TABLE IF NOT EXISTS ${dbTable}(${data})`,
  188. 				success(e) {
  189. 				    resolve(e);
  190. 				},
  191. 				fail(e) {
  192. 				    reject(e);
  193. 				}
  194. 		    })
  195. 		})
  196.     },
  197. 	/**
  198. 	  * @Description: 数据库删表 sql:'DROP TABLE dbTable'
  199. 	  * @author: ZXL
  200. 	  * @createTime: 2023-10-12 09:28:46
  201. 	  * @Copyright by 蓝创科技有限公司
  202. 	  */
  203.     dropTable(dbTable) {
  204. 		return new Promise((resolve, reject) => {
  205. 		    plus.sqlite.executeSql({
  206. 				name: this.dbName,
  207. 				sql: `DROP TABLE ${dbTable}`,
  208. 				success(e) {
  209. 					resolve(e);
  210. 				},
  211. 				fail(e) {
  212. 					reject(e);
  213. 				}
  214. 		    })
  215. 		})
  216.     },
  217. 	/**
  218. 	  * @Description: 根据条件向表里插入数据、更新或覆盖
  219. 	  * @author: ZXL
  220. 	  *  根据条件向表格里添加数据  有数据更新、无数据插入
  221. 	  * (建表时需要设置主键) 例如 --- "roomid" varchar(50) PRIMARY KEY
  222. 	  * @createTime: 2023-10-12 09:31:19
  223. 	  * @Copyright by 蓝创科技有限公司
  224. 	  */
  225.     insertOrReplaceData(dbTable, data, condition) {
  226. 		// 判断有没有传参
  227. 		if (dbTable !== undefined && data !== undefined) {
  228. 			if (condition == undefined) var sql = `INSERT OR REPLACE INTO ${dbTable} VALUES('${data}')`;
  229. 			else var sql = `INSERT OR REPLACE INTO ${dbTable} (${condition}) VALUES(${data})`;
  230. 			return new Promise((resolve, reject) => {
  231. 			    // 表格添加数据
  232. 			    plus.sqlite.executeSql({
  233. 					name: this.dbName,
  234. 					sql: sql,
  235. 					success(e) {
  236. 						resolve(e);
  237. 					},
  238. 					fail(e) {
  239. 						reject(e);
  240. 					}
  241. 			    })
  242. 		    })
  243. 		} else {
  244. 		    return new Promise((resolve, reject) => { reject("错误添加") })
  245. 		}
  246.     },
  247. 	/**
  248. 	  * @Description: 表里查询数据
  249. 	  * @author: ZXL
  250. 	  * 查询获取数据库里的数据 sql:'SELECT * FROM dbTable WHERE lname = 'lvalue''
  251. 	  * 查询 SELECT * FROM 、 dbTable 是表名、 WHERE 查找条件 lname,lvalue 是查询条件的列名和列值
  252. 	  * @createTime: 2023-10-12 09:44:08
  253. 	  * @Copyright by 蓝创科技有限公司
  254. 	  */ 
  255.     selectTableData(dbTable, lname, lvalue, cc, dd) {
  256. 		if (dbTable !== undefined) {
  257. 			let sql;
  258. 		    // 第一个是表单名称，后两个参数是列表名，用来检索
  259. 		    // 两个检索条件
  260. 		    if (lname !== undefined && cc !== undefined) sql=`SELECT * FROM ${dbTable} WHERE ${lname} = '${lvalue}' AND ${cc} = '${dd}'`;
  261. 			// 一个检索条件
  262. 		    if (lname !== undefined && cc == undefined) sql = `SELECT * FROM ${dbTable} WHERE ${lname} = '${lvalue}'`;
  263. 		    if (lname == undefined) sql = `SELECT * FROM ${dbTable}`;
  264. 		    return new Promise((resolve, reject) => {
  265. 				// 表格查询数据  执行查询的SQL语句
  266. 				plus.sqlite.selectSql({
  267. 				    name: this.dbName,
  268. 				    sql: sql,
  269. 				    success(e) {
  270. 					    resolve(e);
  271. 				    },
  272. 				    fail(e) {
  273. 					    reject(e);
  274. 				    }
  275. 				})
  276. 		    })
  277. 		} else {
  278. 		  return new Promise((resolve, reject) => { reject("错误查询") });
  279. 		}
  280.     },
  281.     /**
  282.       * @Description: 表里删除数据
  283.       * @author: ZXL
  284.       * 删除表里的数据 sql:'DELETE FROM dbTable WHERE lname = 'lvalue''
  285.       * 删除 DELETE FROM 、 dbTable 是表名、 WHERE 查找条件 lname,lvalue 是查询条件的列名和列值
  286.       * @createTime: 2023-10-12 09:40:37
  287.       * @Copyright by 蓝创科技有限公司
  288.       */
  289.     deleteTableData(dbTable, lname, lvalue, ww, ee) {
  290. 		if(dbTable !== undefined){
  291. 			let sql;
  292. 		    if(lname == undefined){
  293. 			    sql = `DELETE FROM ${dbTable}`;
  294. 		    }else{
  295. 				if (ww !== undefined) {
  296. 				  // 两个检索条件
  297. 				  sql = `DELETE FROM ${dbTable} WHERE ${lname} = '${lvalue}' AND ${ww} = '${ee}'`;
  298. 				} else {
  299. 				  // 一个检索条件
  300. 				  sql = `DELETE FROM ${dbTable} WHERE ${lname} = '${lvalue}'`;
  301. 				}
  302. 		    }
  303. 			return new Promise((resolve, reject) => {
  304. 				// 删除表数据
  305. 				plus.sqlite.executeSql({
  306. 					name: this.dbName,
  307. 					sql: sql,
  308. 					success(e) {
  309. 						resolve(e);
  310. 					},
  311. 					fail(e) {
  312. 						reject(e);
  313. 					}
  314. 				})
  315. 			})
  316. 		} else {
  317. 		  return new Promise((resolve, reject) => { reject("错误删除") });
  318. 		}
  319.     },
  320.     /**
  321.       * @Description: 表里修改数据
  322.       * @author: ZXL
  323.       * 修改数据表里的数据 sql:"UPDATE dbTable SET 列名 = '列值',列名 = '列值' WHERE lname = 'lvalue'"
  324.       * 修改 UPDATE 、 dbTable 是表名, data: 要修改的列名=修改后列值, lname,lvalue 是查询条件的列名和列值
  325.       * @createTime: 2023-10-12 09:37:59
  326.       * @Copyright by 蓝创科技有限公司
  327.       */
  328.     updateTableData(dbTable, data, lname, lvalue) {
  329. 		let sql;
  330. 		if (lname == undefined) sql = `UPDATE ${dbTable} SET ${data}`;
  331. 		else sql = `UPDATE ${dbTable} SET ${data} WHERE ${lname} = '${lvalue}'`;
  332. 		// WHERE 前面是要修改的列名、列值，后面是条件的列名、列值
  333. 		return new Promise((resolve, reject) => {
  334. 		  // 修改表数据
  335. 		    plus.sqlite.executeSql({
  336. 				name: this.dbName,
  337. 				sql: sql,
  338. 				success(e) {
  339. 				  resolve(e);
  340. 				},
  341. 				fail(e) {
  342. 				  reject(e);
  343. 				}
  344. 		    })
  345. 		})
  346.     },
  347. 	/**
  348. 	  * @Description: 获取指定数据条数
  349. 	  * @author: ZXL
  350. 	  * 获取指定数据条数  sql:"SELECT * FROM dbTable ORDER BY 'id' DESC LIMIT 15 OFFSET 'num'"
  351. 	  * dbTable 表名, ORDER BY 代表排序默认正序, id 是排序的条件 DESC 代表倒序，从最后一条数据开始拿
  352. 	  * LIMIT 15 OFFSET '${num}',这句的意思是跳过 num 条拿 15 条数据, num 为跳过多少条数据是动态值
  353. 	  * 例 初始num设为0，就从最后的数据开始拿15条，下次不拿刚获取的数据，所以可以让num为15，这样就能一步一步的拿完所有的数据
  354. 	  * @createTime: 2023-10-12 09:33:43
  355. 	  * @Copyright by 蓝创科技有限公司
  356. 	  */
  357. 	pullSQL(dbTable, id, num) {
  358. 		return new Promise((resolve, reject) => {
  359. 		    plus.sqlite.selectSql({
  360. 				name: this.dbName,
  361. 				sql: `SELECT * FROM ${dbTable} ORDER BY '${id}' DESC LIMIT 15 OFFSET '${num}'`,
  362. 				success(e) {
  363. 				  resolve(e);
  364. 				},
  365. 				fail(e) {
  366. 				  reject(e);
  367. 				}
  368. 		    })
  369. 		})
  370.     },
  371.     /**
  372.     	* @Description: 关闭数据库
  373.     	* @author: ZXL
  374.     	* @createTime: 2023-10-12 09:23:56
  375.     	* @Copyright by 蓝创科技有限公司
  376.     	*/
  377.     closeSqlite() {
  378. 		return new Promise((resolve, reject) => {
  379. 			plus.sqlite.closeDatabase({
  380. 				name: this.dbName,
  381. 				success(e) {
  382. 					resolve(e);
  383. 				},
  384. 				fail(e) {
  385. 					reject(e);
  386. 				}
  387. 			})
  388. 		})
  389.     },
  390. }

三、使用 

  1. import DB from '@/utils/sqlite.js'
  2.  
  3.  
  4. 类似这样
  5. DB.selectTableData('','','').then((res) => {
  6. 				
  7. }).catch((error) => {
  8. 	console.log('查询失败', error)
  9. })

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/从前慢现在也慢/article/detail/86443
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号