newCashBook/expores_node/db/book.js

import connection from "./base.js";

export async function books_insert({
  book_name = '',
  author_id = '',
  create_time = '',
  update_time = '',
}) {
  return new Promise(async (resolve, reject) => {
    try {
      const sql = `
        INSERT INTO book (book_name, author_id, create_time, update_time)
        VALUES (?, ?, ?, ?)
      `;
      const values = [book_name, author_id, create_time, update_time];
      // 直接接收 execute 返回的内容
      connection.execute(sql, values, (result, fields) => {
        return resolve(fields.insertId);
      });
    } catch (err) {
      return resolve(false);
    }
  })
}

// 获取所有账本
export function getAllBook(author_id) {
  return new Promise((resolve, reject) => {
    connection.query(`SELECT * FROM book WHERE author_id = ? AND is_del=0`, [author_id], (err, rows) => {
      if (err) {
        resolve(false); // 如果存在记录，则返回 true，否则返回 false
      } else {
        resolve(rows); // 如果存在记录，则返回 true，否则返回 false
      }
    });
  });
}

// 查询账本信息
export function getBookById(book_id) {
  return new Promise((resolve, reject) => {
    connection.query(`SELECT * FROM book WHERE id = ? AND is_del=0`, [book_id], (err, rows) => {
      if (err) {
        resolve(false); // 如果存在记录，则返回 true，否则返回 false
      } else {
        resolve(rows.length > 0 ?  rows[0]: false); // 如果存在记录，则返回 true，否则返回 false
      }
    });
  });
}

// 删除账本
export function delBookById(book_id) {
  return new Promise((resolve, reject) => {
    connection.query(`update book SET is_del = 1 WHERE id = ?`, [book_id], (err, rows) => {
      if (err) {
        resolve(false); // 如果存在记录，则返回 true，否则返回 false
      } else {
        resolve(true); // 如果存在记录，则返回 true，否则返回 false
      }
    });
  });
}



// 是否存在重复的账本数据
export function ishaveBookById({
  book_name = '',
  author_id = '',
}) {
  return new Promise((resolve, reject) => {
    connection.query(`SELECT * FROM book WHERE book_name = ? AND author_id = ? AND is_del=0`, [book_name, author_id], (err, rows) => {
      if (err) {
        // reject(err);
        resolve(false); // 如果存在记录，则返回 true，否则返回 false
      } else {
        resolve(rows.length > 0); // 如果存在记录，则返回 true，否则返回 false
      }
    });
  });
}

// 更新账本名称
export function updateBookName({
  book_name = '',
  book_id = '',
  update_time = '',
}) {
  return new Promise((resolve, reject) => {
    connection.query(`UPDATE book SET book_name = ? , update_time = ? WHERE id = ?`, [book_name, update_time, book_id], (err, rows) => {
      if (err) {
        // reject(err);
        resolve(false); // 如果存在记录，则返回 true，否则返回 false
      } else {
        resolve(rows.length > 0); // 如果存在记录，则返回 true，否则返回 false
      }
    });
  });
}