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); // console.log("Record inserted successfully:", result); return resolve(result); } catch (err) { // console.error("Error inserting data:", err); // throw 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 } }); }); }