From 9d5c8d701ba0a2cea780253686764b98bac3b512 Mon Sep 17 00:00:00 2001
From: wangchen <wangcen@wsmis.com>
Date: Fri, 28 Jul 2023 09:42:53 +0800
Subject: [PATCH] init

---
 pages/index/index.vue | 102 ++++++++++++++++++++++++++++++++++++++++++
 pages/test/ceshi.vue  |  23 +++++-----
 2 files changed, 114 insertions(+), 11 deletions(-)

diff --git a/pages/index/index.vue b/pages/index/index.vue
index 2e6b7cc..531a665 100644
--- a/pages/index/index.vue
+++ b/pages/index/index.vue
@@ -14,6 +14,12 @@
 							@select="shipSelect"></superwei-combox>
 						</uni-easyinput>
 						<button class="btn" @click="onSearch">搜索</button>
+						<button class="btn" @click="open">打开</button>
+						<button class="btn" @click="isOpenDatabase">判断</button>
+						<button class="btn" @click="createTable">创建表</button>
+						<button class="btn" @click="dropTable">删除表</button>
+						<button class="btn" @click="insertChatRow">增</button>
+						<button class="btn" @click="executeSql1">查</button>
 					</view>
 				</view>
 				<view class="itemList">
@@ -56,6 +62,7 @@
 <script>
 	import SideBar from '@/components/sider-bar/slider-bar';
 	import HeadInfo from '@/components/head-info/head-info';
+	import sqlite from "../../common/sqlite.js"
 	import {
 		mapActions
 	} from 'vuex'
@@ -84,6 +91,101 @@
 				'majax',
 				'najax'
 			]),
+			open() {
+				plus.sqlite.openDatabase({
+					name: 'dianji_chat',
+					path: '_doc/dianji_chat.db',
+					success: function(e) {
+						console.log('打开数据库成功')
+					},
+					fail: function(e) {
+						console.log(e, '打开数据库失败')
+					}
+				});
+			},
+			isOpenDatabase() {
+				let res = plus.sqlite.isOpenDatabase({
+					name: 'dianji_chat',
+					path: '_doc/dianji_chat.db',
+				});
+				if (res) {
+					uni.showToast({
+						icon: 'none',
+						title: '数据库已打开'
+					});
+					return;
+				} else {
+					uni.showToast({
+						icon: 'none',
+						title: '数据库未打开'
+					});
+					return;
+				}
+			},
+			createTable() {
+				console.log('创建表');
+				let sql =
+					'CREATE TABLE if not exists cesTable ( "id" varchar(32) NOT NULL,"content" varchar(1024),"fromId" varchar(32), "toId" varchar(32), "flag" varchar(2), PRIMARY KEY ("id"));'
+				sqlite.executeSqlCeshi(sql).then((value) => {
+					// 在resolve时执行的回调函数
+					console.log(value); // 输出：Hello, World!
+				}).catch((error) => {
+					// 在reject时执行的回调函数
+					console.error(error);
+				});
+			},
+			dropTable() {
+				console.log('删除表');
+				let sql = 'DROP TABLE cesTable;'
+				plus.sqlite.executeSql({
+					name: 'dianji_chat',
+					sql: sql,
+					success: function(e) {
+						console.log("删除数据表成功");
+					},
+					fail: function(e) {
+						console.log('executeSql failed: ' + JSON.stringify(e));
+					}
+				})
+			},
+			insertChatRow() {
+				let data = {
+					id: 1,
+					fromId: '123',
+					toId: '321',
+					content: 'bihao1',
+					flag: 1
+				}
+				data.id = Math.floor(Math.random() * 100);
+				let dbTable = 'cesTable'
+				// let sql = "insert into " + this.dbTable + " values('" + data.id + "','" + data.content +
+				// 	"','" + data.fromId + "','" + data.toId + "'," + data.flag + ")";
+				let sql = "insert into " + dbTable + " values('" + data.id + "','" +
+					data.content + "','" + data.fromId + "','" + data.toId + "','" + data.flag + "')";
+				this.executeSql(sql)
+			},
+			// 查
+			executeSql(sql) {
+				sqlite.executeSqlCeshi(sql).then((value) => {
+					// 在resolve时执行的回调函数
+					// this.sqlData = value
+					console.log(value); // 输出：Hello, World!
+				}).catch((error) => {
+					// 在reject时执行的回调函数
+					console.error(error);
+				});
+			},
+			executeSql1() {
+				let sql = 'select * from cesTable'
+				sqlite.executeSqlCeshi(sql).then((value) => {
+					// 在resolve时执行的回调函数
+					// this.sqlData = value
+					console.log(value); // 输出：Hello, World!
+				}).catch((error) => {
+					// 在reject时执行的回调函数
+					console.error(error);
+				});
+			},
 			portInput(e) {
 				clearTimeout(timers)
 				timers = setTimeout(() => {
diff --git a/pages/test/ceshi.vue b/pages/test/ceshi.vue
index c1ffab4..c1d502e 100644
--- a/pages/test/ceshi.vue
+++ b/pages/test/ceshi.vue
@@ -21,8 +21,7 @@
 </template>
 
 <script>
-	import Sqlite from "../../common/sqlite.js"
-
+	import sqlite from "../../common/sqlite.js"
 	export default {
 		data() {
 			return {
@@ -35,7 +34,7 @@
 					id: 1,
 					fromId: '123',
 					toId: '321',
-					content: '你好!',
+					content: 'bihao1',
 					flag: 1
 				},
 				chatText1: [{
@@ -71,7 +70,7 @@
 				this.executeSql(sql)
 			},
 			openDatabase() {
-				Sqlite.openDatabaseCeshi().then((value) => {
+				sqlite.openDatabaseCeshi().then((value) => {
 					// 在resolve时执行的回调函数
 					console.log(value); // 输出：Hello, World!
 				}).catch((error) => {
@@ -112,8 +111,10 @@
 			insertChatRow() {
 				let data = this.chatText
 				data.id++
-				let sql = "insert into " + this.dbTable + " values('" + data.id + "','" + data.content +
-					"','" + data.fromId + "','" + data.toId + "'," + data.flag + ")";
+				// let sql = "insert into " + this.dbTable + " values('" + data.id + "','" + data.content +
+				// 	"','" + data.fromId + "','" + data.toId + "'," + data.flag + ")";
+				let sql = "insert into " + this.dbTable + "(id, content, fromId, toId, flag) values('" + data.id + "','" + data.content + 
+				"','" + data.fromId + "','" + data.toId + "'," +  data.flag + ")";
 				this.executeSql(sql)
 			},
 			insertListChatRow() {
@@ -133,8 +134,8 @@
 				let curPage = 1
 				let pageSize = 20
 				let fromId = '123'
-				let sql = 'select * from ' + this.dbTable + ' where fromId=' + fromId +
-					' limit ' + pageSize + ' offset ' + (curPage - 1) * pageSize;
+				let sql = 'select * from dianji_chat'
+				console.log(111);
 				this.executeSql(sql)
 			},
 			dropTable() {
@@ -162,10 +163,10 @@
 					}
 				});
 			},
-			executeSql(sql) {		
-				Sqlite.executeSqlCeshi(sql).then((value) => {
+			executeSql(sql) {
+				sqlite.executeSqlCeshi(sql).then((value) => {
 					// 在resolve时执行的回调函数
-					this.sqlData= value
+					this.sqlData = value
 					console.log(value); // 输出：Hello, World!
 				}).catch((error) => {
 					// 在reject时执行的回调函数