import connection from "./base.js"; export async function auth_insert({ name = "", user_id = "", account = "", password = "", create_time = "", update_time = "", }) { return new Promise(async (resolve, reject) => { try { const sql = ` INSERT INTO authors (name, user_id, account, password, create_time, update_time) VALUES (?, ?, ?, ?, ?, ?) `; const values = [ name, user_id, account, password, create_time, update_time, ]; // 直接接收 execute 返回的内容 connection.execute(sql, values, (result, fields) => { return resolve(fields); }); } catch (err) { console.error("Error inserting data:", err); return resolve(false); } }); } // 是否存在重复的数据 export function isHaveUserByUserId({ user_id = "", account = ""}) { return new Promise((resolve, reject) => { connection.query( `SELECT * FROM authors WHERE user_id = ? OR account = ?`, [user_id, account], (err, rows) => { if (err) { // reject(err); resolve(false); // 如果存在记录,则返回 true,否则返回 false } else { resolve(rows.length > 0); // 如果存在记录,则返回 true,否则返回 false } }, ); }); } // 获取用户详情 export function getUserInfoByuserId(user_id) { return new Promise((resolve, reject) => { connection.query( `SELECT * FROM authors WHERE user_id = ?`, [user_id], (err, rows) => { if (err) { // reject(err); resolve(false); // 如果存在记录,则返回 true,否则返回 false } else { resolve(rows.length > 0 ? rows[0] : false); // 如果存在记录,则返回 true,否则返回 false } }, ); }); } // 用户是否已经注册 export function isLoginUserByUserId({ account = "", password = "", }) { return new Promise((resolve, reject) => { connection.query( `SELECT * FROM authors WHERE password = ? AND account = ?`, [password, account], (err, rows) => { if (err) { // reject(err); resolve(false); // 如果存在记录,则返回 true,否则返回 false } else { resolve(rows.length > 0 ? rows[0] : false); // 如果存在记录,则返回 true,否则返回 false } }, ); }); }