ALTERTSBLE students // 找到对应表
ADD CONSTRAINT fk_class_id // 添加约束，fk_class_id 约束名称任意，
FOREIGN KEY (class_id) // 指定class_id为外键	
REFERENCES classes (id)  // 将外键关联到classes 表的id列

ALTERTABLE students
DROPFOREIGNKEY fk_class_id

ALTER TABLE students
ADD INDEX idx_score (score) // 创建了名称为idx_score,使用score列的索引，索引可以有多列，即多个搜索关键字，倘若二人分数一致，第二个索引会加以区分。

ALTER TABLE students
ADD UNIQUE uni_name (name)

ALTER TABLE students
ADD CONSTRAINT uni_name UNIQUE (name)

LIMIT:pageSize
OFFSET: pageSize * (pageIndex - 1)

let mysql = require("mysql");
let connection = mysql.createConnection({
    host: "localhost",
    user: "root",
    password: "***",
    database: "cainiao"
});

connection.connect();

function selectDate(search) {
    // 数据库的查询是一个异步读取的过程，用promise包裹，search是查询条件
    return new Promise((resolve, reject) => {
        let sql = search != "undefined" ? `SELECT * FROM websites WHERE ${search}` : `SELECT * FROM websites`;
        connection.query(sql, function(err, result) {
            if (err) {
                reject(err.message);
                return;
            }
            resolve(result);
        });
    });
}

// 增加数据
function insertSql(pres = []) {
    return new Promise(async (resolve, reject) => {
        // 先判断是否存在
        const result = await selectDate(`name='${pres.name}'`).then(res => {
            return res;
        });
        if (result.length != 0) {
            reject({
                success: false,
                err: `新增失败,已存在name为${pres.name}的数据。`
            });
            return;
        }
        var addsql = `INSERT INTO websites (Id,name,url,alexa,country) VALUES (0,?,?,?,?)`;
        connection.query(addsql, [pres.name, pres.url, pres.alexa, pres.country], function(err, ret) {
            if (err) {
                reject(err.message);
            }
            resolve(ret);
        });
    });
}

const querystring = require("querystring");
// 针对post传参的解析
const paramBody = req => {
    return new Promise((resolve, reject) => {
        /**服务端接收post请求参数的流程
         * （1）给req请求注册接收数据data事件（该方法会执行多次，需要我们手动累加二进制数据）
         *      * 如果表单数据量越多，则发送的次数越多，如果比较少，可能一次就发过来了
         *      * 所以接收表单数据的时候，需要通过监听 req 对象的 data 事件来取数据
         *      * 也就是说，每当收到一段表单提交过来的数据，req 的 data 事件就会被触发一次，同时通过回调函数可以拿到该 段 的数据
         * （2）给req请求注册完成接收数据end事件（所有数据接收完成会执行一次该方法）
         */
        //创建空字符叠加数据片段
        var data = "";

        //2.注册data事件接收数据（每当收到一段表单提交的数据，该方法会执行一次）
        req.on("data", function(chunk) {
            // chunk 默认是一个二进制数据，和 data 拼接会自动 toString
            data += chunk;
        });

        // 3.当接收表单提交的数据完毕之后，就可以进一步处理了
        //注册end事件，所有数据接收完成会执行一次该方法
        req.on("end", function() {
            //（1）.对url进行解码（url会对中文进行编码）
            data = decodeURI(data);
            /**post请求参数不能使用url模块解析，因为他不是一个url，而是一个请求体对象 */
            //（2）.使用querystring对url进行反序列化（解析url将&和=拆分成键值对），得到一个对象
            //querystring是nodejs内置的一个专用于处理url的模块，API只有四个，详情见nodejs官方文档
            resolve(querystring.parse(data));
        });
        req.on("err", function() {
            reject(err);
        });
    });
};

module.exports = {
    paramBody
};