//import plus from '@dcloudio/uni-app-plus'

// 数据库名称
const dbName = 'qt_app_800'

// 数据库地址,推荐以下划线为开头   _doc/xxx.db
// 如果路径不为_downloads/xxx.db,在手机中会找不到文件夹(强烈建议：不要修改路径)
const dbPath = '/db/qt_app_800.db'

const sqlite = uni.createSQLiteContext({
  name: dbPath,
});

/**
 * 数据库地址
 * @type {String} 推荐以下划线为开头   _doc/xxx.db
 * @description 开发环境中数据库所在地址：文件管理/Android/data/io.dcloud.HBuilder/downloads/salary.db
 * @description 打包安装后数据库所在地址：文件管理/Android/data/uni.UNI4312312(以UNI开头接数字)/downloads/salary.db
 */



// 判断数据库是否打开(箭头函数)
const isOpen = () => {
  // 数据库打开了就返回 true,否则返回 false  
  var open = sqlite.isOpenDatabase({
    name: dbName, // 数据库名称
    path: dbPath, // 数据库地址
  })
  return open
}

// 创建数据库 或 有该数据库就打开(普通函数)
const openSqlite = () => {
  return new Promise((resolve, reject) => {
    // 打开数据库
    sqlite.openDatabase({
      name: dbName,
      path: dbPath,
      success(e) {
        resolve(e) // 成功回调
      },
      fail(e) {
        reject(e) // 失败回调
      },
    })
  })
}

// 关闭数据库(箭头函数)
const closeSqlite = () => {
  return new Promise((resolve, reject) => {
    sqlite.closeDatabase({
      name: 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 是表名，不能用数字开头、括号里是表格的表头
// @param {Object} dbTable:表名
// @param {Object} data : 表结构
const createTable = function (dbTable: string, data: string) {
  return new Promise((resolve, reject) => {
    // executeSql: 执行增删改等操作的SQL语句
    sqlite.executeSql({
      name: dbName,
      sql: `CREATE TABLE IF NOT EXISTS ${dbTable}(${data})`,
      success(e) {
        resolve(e)
      },
      fail(e) {
        reject(e)
      },
    })
  })
}

// 数据库删表 sql:'DROP TABLE dbTable'(箭头函数)
// @param {Object} dbTable:表名
const dropTable = (dbTable: string) => {
  return new Promise((resolve, reject) => {
    sqlite.executeSql({
      name: 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 是表名、根据表头列名插入列值
// @param {Object} dbTable:表名
// @param {Object} data : 插入表中的值结构
// @param {Object} condition : 插入表中对应的列的属性名称结构
const insertTableData = function (dbTable: string, data: string, condition?: string) {
  // 判断有没有传参
  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})`
      }
      console.log(sql)
      // console.log(sql);
      return new Promise((resolve, reject) => {
        // 表格添加数据
        sqlite.executeSql({
          name: 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
// @param {Object} dbTable:表名
// @param {Object} data : 插入表中的值结构
// @param {Object} condition : 插入表中对应的列的属性名称结构
const insertOrReplaceData = (dbTable: string, data: string, condition?: string) => {
  // 判断有没有传参
  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) => {
      // 表格添加数据
      sqlite.executeSql({
        name: 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 是查询条件的列名和列值
// @param {Object} dbTable:表名
// @param {Object} lname:列名
// @param {Object} lvalue:列中的属性值
const selectTableData = function (
  dbTable: string,
  lname?: string,
  lvalue?: string,
  cc?: string,
  dd?: string,
) {
  if (dbTable !== undefined) {
    // 第一个是表单名称，后两个参数是列表名，用来检索
    if (lname !== undefined && cc !== undefined) {
      // 两个检索条件
      var sql = `SELECT * FROM ${dbTable} WHERE ${lname} = '${lvalue}' AND ${cc} = '${dd}'`
    }
    if (lname !== undefined && cc == undefined) {
      // 一个检索条件
      var sql = `SELECT * FROM ${dbTable} WHERE ${lname} = '${lvalue}'`
      // console.log(sql);
    }
    if (lname == undefined) {
      var sql = `SELECT * FROM ${dbTable}`
    }
    return new Promise((resolve, reject) => {
      // 表格查询数据  执行查询的SQL语句
      sqlite.selectSql({
        name: 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 是查询条件的列名和列值
// @param {Object} dbTable:表名
// @param {Object} lname:列名
// @param {Object} lvalue:列中的属性值
const deleteTableData = (
  dbTable: string,
  lname?: string,
  lvalue?: string,
  ww?: string,
  ee?: string,
) => {
  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) => {
      // 删除表数据
      sqlite.executeSql({
        name: 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 是查询条件的列名和列值
// @param {Object} dbTable:表名
// @param {Object} data : 修改表中的值结构
// @param {Object} lname:列名
// @param {Object} lvalue:列中的属性值
const updateTableData = function (dbTable: string, data: string, lname?: string, lvalue?: string) {
  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) => {
    // 修改表数据
    sqlite.executeSql({
      name: 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，这样就能一步一步的拿完所有的数据
// @param {Object} dbTable:表名
// @param {Object} id:数据id
/**
 * @param {Object} num 例子如下：
 * select * from boot limit 10 offset 0;
 * select * from boot limit 10 offset 10;
 * select * from boot limit 10 offset 20;
 * select * from boot limit 10 offset 30;
 * 比如说每页数量为 10 条，然后我们分别获区第1、2、3、4页的数据
 *
 */
const pullSQL = (dbTable: string, id: string, num: number) => {
  return new Promise((resolve, reject) => {
    sqlite.selectSql({
      name: dbName,
      sql: `SELECT * FROM ${dbTable} ORDER BY '${id}' DESC LIMIT 15 OFFSET '${num}'`,

      success(e) {
        resolve(e)
      },

      fail(e) {
        reject(e)
      },
    })
  })
}

// 导出方法
export default {
  // 查询数据库是否打开
  isOpen,
  // 创建/开启数据库
  openSqlite,
  // 关闭数据库
  closeSqlite,
  // 数据库建表
  createTable,
  // 数据库删表
  dropTable,
  // 表里新增/插入数据
  insertTableData,
  // 根据条件向表里插入数据、更新或覆盖
  insertOrReplaceData,
  // 表里查询数据
  selectTableData,
  // 表里删除数据
  deleteTableData,
  // 表里修改数据
  updateTableData,
  // 倒叙查询数据
  pullSQL,
}