diff --git a/common/sqlite.js b/common/sqlite.js new file mode 100644 index 0000000..b45e409 --- /dev/null +++ b/common/sqlite.js @@ -0,0 +1,290 @@ +module.exports = { + dbName: 'dianji_chat', + dbPath: '_doc/dianji_chat.db', + dbTable: 'dianji_chat', + dbIsOpen: false, + sqlData: [], + + executeSqlCeshi(sql) { + return new Promise((resolve, reject) => { + // 打开数据库 + plus.sqlite.selectSql({ + name: this.dbName, + sql: sql, + success: function(e) { + resolve(e); // 成功回调 + }, + fail: function(e) { + console.log('selectSql failed: ' + JSON.stringify(e)); + } + }); + }) + }, + // 判断数据库是否打开 + isOpen() { + // 数据库打开了就返回 true,否则返回 false + var open = plus.sqlite.isOpenDatabase({ + name: this.dbName, // 数据库名称 + path: this.dbPath // 数据库地址 + }) + return open; + }, + + // 创建数据库 或 有该数据库就打开 + openSqlite() { + return new Promise((resolve, reject) => { + // 打开数据库 + plus.sqlite.openDatabase({ + name: this.dbName, + path: this.dbPath, + success(e) { + resolve(e); // 成功回调 + }, + fail(e) { + reject(e); // 失败回调 + } + }) + }) + }, + // 关闭数据库 + closeSqlite() { + return new Promise((resolve, reject) => { + plus.sqlite.closeDatabase({ + name: this.dbName, + success(e) { + resolve(e); + }, + fail(e) { + reject(e); + } + }) + }) + }, + // 数据库建表 sql:'CREATE TABLE IF NOT EXISTS dbTable("id" varchar(50),"name" TEXT) + // 创建 CREATE TABLE IF NOT EXISTS 、 dbTable 是表名，不能用数字开头、括号里是表格的表头 + createTable(dbTable, data) { + return new Promise((resolve, reject) => { + // executeSql: 执行增删改等操作的SQL语句 + plus.sqlite.executeSql({ + name: this.dbName, + name: "gather", + sql: `CREATE TABLE IF NOT EXISTS ${dbTable}(${data})`, + success(e) { + resolve(e); + }, + fail(e) { + reject(e); + } + }) + }) + }, + + // 数据库删表 sql:'DROP TABLE dbTable' + dropTable(dbTable) { + return new Promise((resolve, reject) => { + plus.sqlite.executeSql({ + name: this.dbName, + sql: `DROP TABLE ${dbTable}`, + success(e) { + resolve(e); + }, + fail(e) { + reject(e); + } + }) + }) + }, + + + // 向表格里添加数据 sql:'INSERT INTO dbTable VALUES('x','x','x')' 对应新增 + // 或者 sql:'INSERT INTO dbTable ('x','x','x') VALUES('x','x','x')' 具体新增 + // 插入 INSERT INTO 、 dbTable 是表名、根据表头列名插入列值 + insertTableData(dbTable, data, condition) { + // 判断有没有传参 + if (dbTable !== undefined && data !== undefined) { + // 判断传的参是否有值 + var bol = (JSON.stringify(data) == "{}"); + if (!bol) { + if (condition == undefined) { + var sql = `INSERT INTO ${dbTable} VALUES('${data}')`; + } else { + var sql = `INSERT INTO ${dbTable} (${condition}) VALUES(${data})`; + } + return new Promise((resolve, reject) => { + // 表格添加数据 + plus.sqlite.executeSql({ + name: this.dbName, + sql: sql, + success(e) { + resolve(e); + }, + fail(e) { + reject(e); + } + }) + }) + } else { + return new Promise((resolve, reject) => { + reject("错误添加") + }) + } + } else { + return new Promise((resolve, reject) => { + reject("错误添加") + }) + } + }, + // 根据条件向表格里添加数据 有数据更新、无数据插入 + // (建表时需要设置主键) 例如 --- "roomid" varchar(50) PRIMARY KEY + insertOrReplaceData(dbTable, data, condition) { + // 判断有没有传参 + if (dbTable !== undefined && data !== undefined) { + if (condition == undefined) { + var sql = `INSERT OR REPLACE INTO ${dbTable} VALUES('${data}')`; + } else { + var sql = `INSERT OR REPLACE INTO ${dbTable} (${condition}) VALUES(${data})`; + } + // console.log(sql); + return new Promise((resolve, reject) => { + // 表格添加数据 + plus.sqlite.executeSql({ + name: this.dbName, + sql: sql, + success(e) { + resolve(e); + }, + fail(e) { + reject(e); + } + }) + }) + } else { + return new Promise((resolve, reject) => { + reject("错误添加") + }) + } + }, + + // 查询获取数据库里的数据 sql:'SELECT * FROM dbTable WHERE lname = 'lvalue'' + // 查询 SELECT * FROM 、 dbTable 是表名、 WHERE 查找条件 lname,lvalue 是查询条件的列名和列值 + // selectTableData(dbTable, uname, namevalue, upass, passvalue,urrn,rrnvalue) { + selectTableData(dbTable, uname, namevalue) { + if (dbTable !== undefined) { + // // 第一个是表单名称，后两个参数是列表名，用来检索 + // if (uname !== undefined && upass !== undefined && urrn!==undefined) { + // // 三个检索条件 + // var sql = `SELECT * FROM ${dbTable} WHERE ${uname} = '${namevalue}' AND ${upass} = '${passvalue}' AND ${urrn}='${rrnvalue}'`; + // } + // if (uname !== undefined && upass !== undefined &&urrn==undefined) { + // // 两个检索条件 + // var sql = `SELECT * FROM ${dbTable} WHERE ${uname} = '${namevalue}' AND ${upass} = '${passvalue}'`; + // } + if (uname !== undefined) { + // 一个检索条件 + var sql = `SELECT * FROM ${dbTable} WHERE ${uname} = '${namevalue}'`; + // console.log(sql); + } + if (uname == undefined) { + var sql = `SELECT * FROM ${dbTable}`; + } + return new Promise((resolve, reject) => { + // 表格查询数据 执行查询的SQL语句 + plus.sqlite.selectSql({ + name: this.dbName, + sql: sql, + success(e) { + resolve(e); + }, + fail(e) { + reject(e); + } + }) + }) + } else { + return new Promise((resolve, reject) => { + reject("错误查询") + }); + } + }, + + // 删除表里的数据 sql:'DELETE FROM dbTable WHERE lname = 'lvalue'' + // 删除 DELETE FROM 、 dbTable 是表名、 WHERE 查找条件 lname,lvalue 是查询条件的列名和列值 + // deleteTableData(dbTable, lname, lvalue, ww, ee) { + deleteTableData(dbTable, lname, lvalue) { + console.log("lname:" + lname + "," + "lvalue" + lvalue); + if (dbTable !== undefined) { + if (lname == undefined) { + var sql = `DELETE FROM ${dbTable}`; + } else { + // if (ww !== undefined) { + // // 两个检索条件 + // var sql = `DELETE FROM ${dbTable} WHERE ${lname} = '${lvalue}' AND ${ww} = '${ee}'`; + // } else { + // 一个检索条件 + var sql = `DELETE FROM ${dbTable} WHERE ${lname} = '${lvalue}'`; + // } + } + return new Promise((resolve, reject) => { + // 删除表数据 + plus.sqlite.executeSql({ + name: this.dbName, + sql: sql, + success(e) { + resolve(e); + }, + fail(e) { + reject(e); + } + }) + }) + } else { + return new Promise((resolve, reject) => { + reject("错误删除") + }); + } + }, + + // 修改数据表里的数据 sql:"UPDATE dbTable SET 列名 = '列值',列名 = '列值' WHERE lname = 'lvalue'" + // 修改 UPDATE 、 dbTable 是表名, data: 要修改的列名=修改后列值, lname,lvalue 是查询条件的列名和列值 + updateTableData(dbTable, data, lname, lvalue) { + if (lname == undefined) { + var sql = `UPDATE ${dbTable} SET ${data}`; + } else { + var sql = `UPDATE ${dbTable} SET ${data} WHERE ${lname} = '${lvalue}'`; + } + // WHERE 前面是要修改的列名、列值，后面是条件的列名、列值 + return new Promise((resolve, reject) => { + // 修改表数据 + plus.sqlite.executeSql({ + name: this.dbName, + sql: sql, + success(e) { + resolve(e); + }, + fail(e) { + reject(e); + } + }) + }) + }, + + // 获取指定数据条数 sql:"SELECT * FROM dbTable ORDER BY 'id' DESC LIMIT 15 OFFSET 'num'" + // dbTable 表名, ORDER BY 代表排序默认正序, id 是排序的条件 DESC 代表倒序，从最后一条数据开始拿 + // LIMIT 15 OFFSET '${num}',这句的意思是跳过 num 条拿 15 条数据, num 为跳过多少条数据是动态值 + // 例 初始num设为0，就从最后的数据开始拿15条，下次不拿刚获取的数据，所以可以让num为15，这样就能一步一步的拿完所有的数据 + pullSQL(dbTable, id, num) { + return new Promise((resolve, reject) => { + plus.sqlite.selectSql({ + name: this.dbName, + sql: `SELECT * FROM ${dbTable} ORDER BY '${id}' DESC LIMIT 15 OFFSET '${num}'`, + success(e) { + resolve(e); + }, + fail(e) { + reject(e); + } + }) + }) + } + +} \ No newline at end of file diff --git a/components/sider-bar/slider-bar.vue b/components/sider-bar/slider-bar.vue index 1166750..33faf73 100644 --- a/components/sider-bar/slider-bar.vue +++ b/components/sider-bar/slider-bar.vue @@ -23,6 +23,11 @@ 场位监控 + + + 测试 + + - \ No newline at end of file