224 lines
7.7 KiB
JavaScript
224 lines
7.7 KiB
JavaScript
module.exports = {
|
||
dbName: 'databaseName', // 数据库名称
|
||
dbPath: '_downloads/databaseName.db', // 数据库地址,推荐以下划线为开头 _doc/xxx.db
|
||
|
||
// 判断数据库是否打开
|
||
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 是表名，不能用数字开头、括号里是表格的表头
|
||
// data 是字段设置字符串，逗号分隔，如"id varchar(32),name varchar(32),age int ..."
|
||
createTable(dbTable, data) {
|
||
return new Promise((resolve, reject) => {
|
||
// executeSql: 执行增删改等操作的SQL语句
|
||
plus.sqlite.executeSql({
|
||
name: this.dbName,
|
||
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) {
|
||
// 判断传的参是否有值
|
||
console.log(data,condition);
|
||
var bol = (data == "");
|
||
if (!bol) {
|
||
if (condition == undefined) {
|
||
var sql = `INSERT INTO ${dbTable} VALUES(${data})`;
|
||
console.log(sql);
|
||
} else {
|
||
var sql = `INSERT INTO ${dbTable} (${condition}) VALUES(${data})`;
|
||
}
|
||
// console.log(sql);
|
||
return new Promise((resolve, reject) => { resolve(sql) })
|
||
} else {
|
||
return new Promise((resolve, reject) => { reject("错误添加") })
|
||
}
|
||
} else {
|
||
return new Promise((resolve, reject) => { reject("错误添加") })
|
||
}
|
||
},
|
||
|
||
|
||
// 查询获取数据库里的数据 sql:'SELECT * FROM dbTable WHERE lname = 'lvalue''
|
||
// 查询 SELECT * FROM 、 dbTable 是表名、 WHERE 查找条件 lname,lvalue 是查询条件的列名和列值
|
||
selectTableData(dbTable, fieldName1, fieldValue1, fieldName2, fieldValue2,fieldName3,fieldValue3) {
|
||
if (dbTable !== undefined) {
|
||
// 第一个是表单名称，后两个参数是列表名，用来检索
|
||
if (fieldName1 !== undefined && fieldName2 !== undefined && fieldName3!==undefined) {
|
||
// 三个检索条件
|
||
var sql = `SELECT * FROM ${dbTable} WHERE ${fieldName1} = '${fieldValue1}' AND ${fieldName2} = '${fieldValue2}' AND ${fieldName3}='${fieldValue3}'`;
|
||
}
|
||
if (fieldName1 !== undefined && fieldName2 !== undefined &&fieldName3==undefined) {
|
||
// 两个检索条件
|
||
var sql = `SELECT * FROM ${dbTable} WHERE ${fieldName1} = '${fieldValue1}' AND ${fieldName2} = '${fieldValue2}'`;
|
||
}
|
||
if (fieldName1 !== undefined && fieldName2 == undefined && fieldName3==undefined ) {
|
||
// 一个检索条件
|
||
var sql = `SELECT * FROM ${dbTable} WHERE ${fieldName1} = '${fieldValue1}'`;
|
||
// console.log(sql);
|
||
}
|
||
if (fieldName1 == 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, fieldName1, fieldValue1, fieldName2, fieldValue2) {
|
||
if (dbTable !== undefined) {
|
||
if (lname == undefined) {
|
||
var sql = `DELETE FROM ${dbTable}`;
|
||
} else {
|
||
if (ww !== undefined) {
|
||
// 两个检索条件
|
||
var sql = `DELETE FROM ${dbTable} WHERE ${fieldName1} = '${fieldValue1}' AND ${ww} = '${fieldValue2}'`;
|
||
} else {
|
||
// 一个检索条件
|
||
var sql = `DELETE FROM ${dbTable} WHERE ${fieldName1} = '${fieldValue1}'`;
|
||
}
|
||
}
|
||
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: 是由要"列名1=值1,列名2=值2..."拼接的字符串， lname,lvalue 是查询条件的列名和列值
|
||
updateTableData(dbTable, data, fieldName, fieldValue) {
|
||
if (lname == undefined) {
|
||
var sql = `UPDATE ${dbTable} SET ${data}`;
|
||
} else {
|
||
var sql = `UPDATE ${dbTable} SET ${data} WHERE ${fieldName} = '${fieldValue}'`;
|
||
}
|
||
// 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);
|
||
}
|
||
})
|
||
})
|
||
}
|
||
}
|