import connection from "./base.js";

export async function author_insert({ name = "", author_id = "" }) {
  return new Promise(async (resolve, reject) => {
    try {
      const sql = `
          INSERT INTO author (name, author_id)
VALUES (?, ?)
ON DUPLICATE KEY UPDATE author_id = author_id;
        `;
      const values = [name, author_id];
      // 直接接收 execute 返回的内容
      const result = await connection.execute(sql, values);
      return resolve(result);
    } catch (err) {
      return resolve(false);
    }
  });
}

export async function get_author_info(name = "") {
  return new Promise(async (resolve, reject) => {
    try {
      const sql = `
          SELECT * FROM author WHERE name = ?
        `;
      const values = [name];
      // 直接接收 execute 返回的内容
      connection.execute(sql, values, (error, row) => {
        if (error) {
          return resolve("");
        }
        return resolve(row.length > 0 ? row[0] : "");
      });
    } catch (err) {
      return resolve(false);
    }
  });
}

export async function clear_all_data(name = "") {
  /* 
    DELETE FROM epub_manage.book;
    DELETE FROM epub_manage.author;
    DELETE FROM epub_manage.category;
    DELETE FROM epub_manage.style;
    DELETE FROM epub_manage.style_link_book;
    DELETE FROM epub_manage.chapter;
    DELETE FROM epub_manage.files;
    DELETE FROM epub_manage.book_link_file;
 */
  return new Promise(async (resolve, reject) => {
    try {
      // 直接接收 execute 返回的内容
      await connection.execute("DELETE FROM epub_manage.book;");
      await connection.execute("DELETE FROM epub_manage.author;");
      await connection.execute("DELETE FROM epub_manage.category;");
      await connection.execute("DELETE FROM epub_manage.style;");
      await connection.execute("DELETE FROM epub_manage.style_link_book;");
      await connection.execute("DELETE FROM epub_manage.chapter;");
      await connection.execute("DELETE FROM epub_manage.files;");
      await connection.execute("DELETE FROM epub_manage.book_link_file;");
      return resolve("ok");
    } catch (err) {
      return resolve(false);
    }
  });
}