store-serve/app/models/dao/collectDao.js

/*
 * @Description: 我的收藏模块数据持久层
 * @Author: hai-27
 * @Date: 2020-03-04 22:33:56
 * @LastEditors: hai-27
 * @LastEditTime: 2020-03-10 17:50:37
 */
const db = require('./db.js');

module.exports = {
  // 连接数据库,把收藏商品信息插入数据库
  AddCollect: async (user_id, product_id, timeTemp) => {
    const sql = 'insert into collect values(null,?,?,?)';
    return await db.query(sql, [user_id, product_id, timeTemp]);
  },
  // 连接数据库,获取用户的所有收藏商品信息
  GetCollect: async (user_id) => {
    const sql = 'select * from collect where user_id=?';
    return await db.query(sql, user_id);
  },
  // 连接数据库,获取用户的某个收藏商品信息
  FindCollect: async (user_id, product_id) => {
    const sql = 'select * from collect where user_id=? and product_id=?';
    return await db.query(sql, [user_id, product_id]);
  },
  // 连接数据库,删除用户的某个收藏商品信息
  DeleteCollect: async (user_id, product_id) => {
    const sql = 'delete from collect where user_id=? and product_id=?';
    return await db.query(sql, [user_id, product_id]);
  }
}