files.js 1.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. import connection from "./base.js";
  2. /*
  3. `file_id` VARCHAR(100) NOT NULL, -- file_id 长度为 100
  4. `md5` VARCHAR(32) NOT NULL, -- MD5 长度为 32
  5. `mimetype` VARCHAR(255) NOT NULL, -- mimetype 长度为 255
  6. `size` INT NOT NULL,
  7. `name` VARCHAR(255) DEFAULT NULL,
  8. `path` VARCHAR(255) DEFAULT NULL,
  9. */
  10. export async function files_insert({
  11. file_id = "",
  12. md5 = "",
  13. mimetype = "",
  14. size = "",
  15. name = "",
  16. path = "",
  17. }) {
  18. console.log(20, file_id, md5, mimetype, size, name, path)
  19. return new Promise(async (resolve, reject) => {
  20. try {
  21. const sql = `
  22. INSERT INTO files (file_id, md5, mimetype, size, name, path)
  23. VALUES (?, ?, ?, ?, ?, ?)
  24. `;
  25. const values = [file_id, md5, mimetype, size, name, path];
  26. // 直接接收 execute 返回的内容
  27. const result = await connection.execute(sql, values);
  28. return resolve(result);
  29. } catch (err) {
  30. return resolve(false);
  31. }
  32. });
  33. }
  34. // 查询图片信息
  35. export function getFileBymd5(md5Str) {
  36. return new Promise((resolve, reject) => {
  37. connection.query(`SELECT * FROM files WHERE md5 = ?`, [md5Str], (err, rows) => {
  38. if (err) {
  39. resolve(false); // 如果存在记录,则返回 true,否则返回 false
  40. } else {
  41. resolve(rows[0]); // 如果存在记录,则返回 true,否则返回 false
  42. }
  43. });
  44. });
  45. }