newCashBook/expores_node/db/files.js

import connection from './base.js';
export async function files_insert({
  name = '',
  mimetype = '',
  size = '',
  md5 = '',
  create_time = '',
  update_time = '',
}) {
  return new Promise(async (resolve, reject) => {
    try {
      const sql = `
        INSERT INTO files (name, mimetype, size, md5, create_time, update_time)
        VALUES (?, ?, ?, ?, ?, ?)
      `;
      const values = [name, mimetype, size, md5, create_time, update_time];
      // 直接接收 execute 返回的内容
      const result = await connection.execute(sql, values);
      return resolve(result);
    } catch (err) {
      return resolve(false);
    }
  })
}

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

// 查询图片信息
export function getFileBymd5(md5Str) {
  return new Promise((resolve, reject) => {
    connection.query(`SELECT * FROM files WHERE md5 = ?`, [md5Str], (err, rows) => {
      if (err) {
        resolve(false); // 如果存在记录，则返回 true，否则返回 false
      } else {
        resolve(rows[0]); // 如果存在记录，则返回 true，否则返回 false
      }
    });
  });
}

// 删除图片
export function delFileBymd5(md5Str) {
  return new Promise((resolve, reject) => {
    connection.query(`update files SET is_del = 1 WHERE md5=?`, [md5Str], (err, rows) => {
      if (err) {
        resolve(false); // 如果存在记录，则返回 true，否则返回 false
      } else {
        resolve(true); // 如果存在记录，则返回 true，否则返回 false
      }
    });
  });
}

// 映射数据与文件数据
export function addFileByRecordId({
  file_id = '',
  record_id = '',
  book_id = '',
  author_id = '',
  create_time = '',
  update_time = '',
}) {
  return new Promise(async (resolve, reject) => {
    try {
      const sql = `
        INSERT INTO record_files (file_id, record_id, book_id, author_id, create_time, update_time)
        VALUES (?, ?, ?, ?, ?, ?)
      `;
      const values = [file_id, record_id, book_id, author_id, create_time, update_time];
      // 直接接收 execute 返回的内容
      const result = await connection.execute(sql, values);
      return resolve(result);
    } catch (err) {
      return resolve(false);
    }
  })
}

// 根据id获取files
export function getFileByRecordId(record_id) {
  return new Promise((resolve, reject) => {
    connection.query(`SELECT * FROM record_files WHERE record_id = ?`, [record_id], (err, rows) => {
      if (err) {
        resolve(false); // 如果存在记录，则返回 true，否则返回 false
      } else {
        resolve(rows); // 如果存在记录，则返回 true，否则返回 false
      }
    });
  });
}

// 根据id删除映射数据
export function delFileByRecordId(record_id, file_id) {
  return new Promise((resolve, reject) => {
    try {
      const sql = `DELETE FROM record_files WHERE record_id = ? AND file_id = ?`;
      connection.query(sql, [record_id, file_id], (err, result) => {
        if (err) {
          // 如果执行过程中出现错误，返回 false
          return resolve(false);
        }
        // 删除成功后返回结果
        return resolve(result);
      });
    } catch (err) {
      // 捕获异常并返回 false
      return resolve(false);
    }
  });
}