{
  "app-plus": {
    "modules": {
      "SQLite": {}
    }
  }
}

// 數(shù)據(jù)庫名稱和路徑配置
const sqlName = "mydatabase"
const sqlPath = "_doc/mydatabase.db"
// 打開數(shù)據(jù)庫
function openDb(name, path) {
  return new Promise((resolve, reject) => {
    plus.sqlite.openDatabase({
      name: name,
      path: path,
      success: function(e) {
        console.log('數(shù)據(jù)庫打開成功')
        resolve(e)
      },
      fail: function(e) {
        console.log('數(shù)據(jù)庫打開失敗:' + JSON.stringify(e))
        reject(e)
      }
    })
  })
}
// 判斷數(shù)據(jù)庫是否打開
function isOpened(name, path) {
  return plus.sqlite.isOpenDatabase({
    name: name,
    path: path
  })
}
// 關(guān)閉數(shù)據(jù)庫
function closeDb(name) {
  return new Promise((resolve, reject) => {
    plus.sqlite.closeDatabase({
      name: name,
      success: function(e) {
        console.log('數(shù)據(jù)庫關(guān)閉成功')
        resolve(e)
      },
      fail: function(e) {
        console.log('數(shù)據(jù)庫關(guān)閉失敗')
        reject(e)
      }
    })
  })
}
// 查詢SQL（所有查詢都用該方法）
function selectSql(name, sqlText) {
  return new Promise((resolve, reject) => {
    plus.sqlite.selectSql({
      name: name,
      sql: sqlText,
      success: function(e) {
        resolve(e)
      },
      fail: function(e) {
        console.log('查詢失敗:' + sqlText + "-異常信息:" + JSON.stringify(e))
        reject(e)
      }
    })
  })
}
// 執(zhí)行增刪改查都使用該方法
function executeSql(name, sqlText) {
  return new Promise((resolve, reject) => {
    plus.sqlite.executeSql({
      name: name,
      sql: sqlText,
      success: function(e) {
        console.log('操作成功')
        resolve(e)
      },
      fail: function(e) {
        console.log('執(zhí)行失敗:' + sqlText + '-異常信息:' + JSON.stringify(e))
        reject(e)
      }
    })
  })
}
export { sqlName, sqlPath, openDb, isOpened, closeDb, selectSql, executeSql }

import { sqlName, executeSql } from "./sqllite.js"
export function userTable() {
  let createSql = {
    name: "user",
    sql: "id INTEGER PRIMARY KEY AUTOINCREMENT, userId VARCHAR(255) NOT NULL, userName VARCHAR(255) NOT NULL, email VARCHAR(255), createdTime DATETIME DEFAULT CURRENT_TIMESTAMP"
  }
  executeSql(sqlName, `create table if not exists ${createSql.name} (${createSql.sql})`)
}
export function productTable() {
  let createSql = {
    name: "product",
    sql: "id INTEGER PRIMARY KEY AUTOINCREMENT, name VARCHAR(255) NOT NULL, price REAL NOT NULL, stock INTEGER DEFAULT 0, category VARCHAR(100)"
  }
  executeSql(sqlName, `create table if not exists ${createSql.name} (${createSql.sql})`)
}

import { sqlName, sqlPath, openDb, isOpened } from "./static/sql/sqllite.js"
import { userTable, productTable } from "./static/sql/tables.js"
export default {
  onLaunch() {
    this.initDatabase()
  },
  methods: {
    async initDatabase() {
      try {
        // 判斷數(shù)據(jù)庫是否已打開
        let type = isOpened(sqlName, sqlPath)
        if (!type) {
          // 打開數(shù)據(jù)庫
          await openDb(sqlName, sqlPath)
          // 創(chuàng)建表結(jié)構(gòu)
          userTable()
          productTable()
          console.log('數(shù)據(jù)庫初始化完成')
        }
      } catch (error) {
        console.error('數(shù)據(jù)庫初始化失敗:', error)
      }
    }
  }
}

import { sqlName, selectSql, executeSql } from "./sqllite.js"
const name = sqlName
// 查詢所有用戶
export function getAllUsers() {
  let sql = "SELECT * FROM user ORDER BY createdTime DESC"
  return selectSql(name, sql)
}
// 根據(jù)ID查詢用戶
export function getUserById(id) {
  let sql = `SELECT * FROM user WHERE id = ${id}`
  return selectSql(name, sql)
}
// 添加用戶
export function addUser(userData) {
  let sql = `INSERT INTO user (userId, userName, email) VALUES ('${userData.userId}', '${userData.userName}', '${userData.email}')`
  return executeSql(name, sql)
}
// 更新用戶
export function updateUser(id, userData) {
  let sql = `UPDATE user SET userName = '${userData.userName}', email = '${userData.email}' WHERE id = ${id}`
  return executeSql(name, sql)
}
// 刪除用戶
export function deleteUser(id) {
  let sql = `DELETE FROM user WHERE id = ${id}`
  return executeSql(name, sql)
}

import { getAllUsers, addUser, updateUser, deleteUser } from "@/static/sql/user.js"
export default {
  data() {
    return {
      users: [],
      newUser: {
        userId: '',
        userName: '',
        email: ''
      }
    }
  },
  async onLoad() {
    await this.loadUsers()
  },
  methods: {
    async loadUsers() {
      try {
        const result = await getAllUsers()
        this.users = result
      } catch (error) {
        console.error('加載用戶失敗:', error)
        uni.showToast({
          title: '加載失敗',
          icon: 'none'
        })
      }
    },
    async handleAddUser() {
      if (!this.newUser.userName || !this.newUser.userId) {
        uni.showToast({
          title: '請(qǐng)?zhí)顚懲暾畔?,
          icon: 'none'
        })
        return
      }
      try {
        await addUser(this.newUser)
        uni.showToast({
          title: '添加成功',
          icon: 'success'
        })
        this.newUser = { userId: '', userName: '', email: '' }
        await this.loadUsers()
      } catch (error) {
        console.error('添加用戶失敗:', error)
        uni.showToast({
          title: '添加失敗',
          icon: 'none'
        })
      }
    },
    async handleDeleteUser(id) {
      try {
        await deleteUser(id)
        uni.showToast({
          title: '刪除成功',
          icon: 'success'
        })
        await this.loadUsers()
      } catch (error) {
        console.error('刪除用戶失敗:', error)
        uni.showToast({
          title: '刪除失敗',
          icon: 'none'
        })
      }
    }
  }
}

export const batchInsert = (table, dataArray) => {
  plus.sqlite.transaction({
    name: dbName,
    operation: async () => {
      for (const data of dataArray) {
        await insertData(table, data)
      }
    }
  })
}

plus.sqlite.executeSql({
  name: dbName,
  sql: "CREATE INDEX IF NOT EXISTS idx_user_name ON user(userName)"
})

export const selectWithConditions = (table, conditions = {}) => {
  let sql = `SELECT * FROM ${table}`
  const keys = Object.keys(conditions)
  if (keys.length > 0) {
    sql += ' WHERE '
    sql += keys.map(key => `${key} = '${conditions[key]}'`).join(' AND ')
  }
  return selectSql(dbName, sql)
}

// #ifdef APP-PLUS
import { openDb } from './db/sqlite'
// #endif
// #ifdef H5
const openDb = () => Promise.resolve(mockDb)
// #endif

const mockDb = {
  users: [],
  executeSql: (sql) => {
    if (sql.includes("INSERT")) {
      const name = sql.match(/VALUES\s*\('(.*?)'\)/)[1]
      mockDb.users.push({ name })
    }
    return Promise.resolve()
  }
}

async function safeDatabaseOperation(operation) {
  try {
    return await operation()
  } catch (error) {
    console.error('數(shù)據(jù)庫操作失敗:', error)
    // 記錄錯(cuò)誤日志
    // 根據(jù)錯(cuò)誤類型進(jìn)行相應(yīng)處理
    throw error
  }
}