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
      }
    });
  });
}