newCashBook/epub_node/db/files.js

import connection from "./base.js";

/*
`file_id` VARCHAR(100) NOT NULL,  -- file_id 长度为 100
  `md5` VARCHAR(32) NOT NULL,  -- MD5 长度为 32
  `mimetype` VARCHAR(255) NOT NULL,  -- mimetype 长度为 255
  `size` INT NOT NULL,
  `name` VARCHAR(255) DEFAULT NULL,
  `path` VARCHAR(255) DEFAULT NULL,

  */
export async function files_insert({
  file_id = "",
  source_id = "",
  md5 = "",
  mimetype = "",
  size = "",
  name = "",
  path = "",
}) {
  return new Promise(async (resolve, reject) => {
    try {
      const sql = `
          INSERT INTO files (file_id, source_id, md5, mimetype, size, name, path)
VALUES (?, ?, ?, ?, ?, ?, ?)
ON DUPLICATE KEY UPDATE file_id = file_id;
        `;
      const values = [file_id, source_id, md5, mimetype, size, name, path];
      // 直接接收 execute 返回的内容
      const result = await connection.execute(sql, values);
      return resolve(result);
    } catch (err) {
      console.log(34, err);

      return resolve(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 searchFileByPath(imgPath) {
  return new Promise((resolve, reject) => {
    connection.query(
      `SELECT * FROM files WHERE path like ?;`,
      [`%${imgPath}%`],
      (err, rows) => {
        if (err) {
          console.log(62626262, err);
          resolve(false); // 如果存在记录，则返回 true，否则返回 false
        } else {
          resolve(rows.length > 0 ? rows[0] : false); // 如果存在记录，则返回 true，否则返回 false
        }
      }
    );
  });
}