// 引入 mysql
const mysql = require('mysql');
const dbConfig = {
    // 连接的服务器
    host: 'localhost',
    // 数据库用户名
    user: 'root',
    // MySQL密码
    password: '',
    //  要连接的数据库名
    database: 'test'
};

// 连接mysql函数
function connectMysql() {
    return new Promise((resolve, reject) => {
        // 连接数据库
        const connection = mysql.createConnection(dbConfig)
        // 连接成功测试
        connection.connect((err) => {
            if (err) {
                console.error('连接失败：')
                console.error(err)
                reject(connection);
            }
            console.log('连接成功 id:')
            // console.log(connection)
            // console.log(connection.threadId)
            resolve(connection);
        })
    })
}

// 停止链接数据库
function closeMysql(connection) {
    // 必须在查询语句后，要不然一调用这个方法，就直接停止链接，数据操作就会失败
    connection.end(function (err) {
        if (err) {
            console.log('关闭数据库连接失败！');
            throw err;
        }
    });
    // 销毁同上
    // connection.destroy();
}


// 插入
function insert() {
    // 连接数据库
    connectMysql().then((connection) => {
        const sql = 'INSERT INTO test(id, username, age, school, address) VALUES (?,?,?,?,?)';
        const data = ["1", "wuwg", 37, "xj", "xj"];
        connection.query(sql, data, (error, results) => {
            // 停止链接数据库
            closeMysql(connection);
            if (error) {
                console.log('插入失败')
                console.log(error)
                return;
            }
            console.log('插入成功')
            console.log(results)
        });
    })

}

// 插入
// insert();


function deleteData() {
    // 连接数据库
    connectMysql().then((connection) => {
        const sql = 'DELETE FROM test WHERE id = "4"';
        connection.query(sql, (error, results) => {
            // 停止链接数据库
            closeMysql(connection);
            if (error) {
                console.log('删除失败')
                console.log(error)
                return;
            }
            console.log('删除成功')
            console.log(results)
        })
    })
}

// 删除
// deleteData();

// 查询
function find() {
    // 连接数据库
    connectMysql().then((connection) => {
        // 定向查找
        const sql = 'SELECT  *  FROM test  WHERE username = "wuwg" '
        //  where 关键词用于指定查询条件,
        // =、>、<、>=、<、!= 以及一些扩展运算符
        // 年龄大于21
        // select * from test where age > 21;
        // is [not] null、in、like等
        // 模糊查询
        // select * from test where username like "%王%";
        // 还可以对查询条件使用 or 和 and 进行组合查询
        // select * from test where username = "wuwg" and age>20;
        connection.query(sql, (error, results, fileds) => {
            // 停止链接数据库
            closeMysql(connection);
            if (error) {
                console.log('查询失败')
                console.log(error)
                return;
            }
            console.log('查询成功')
            console.log('results')
            // 类数组
            console.log(results)
            console.log('fileds')
            // console.log(fileds)
        })
    })
}
// find()


function update() {
    // 连接数据库
    connectMysql().then((connection) => {

        // console.log('connection')
        // console.log(connection)
        // 注意这里是把 id=3的用户名修改成了 zhangsan
        const sql = 'UPDATE test  set username="zhangsan" WHERE id = "1"';
        connection.query(sql, (error, results) => {
            // 停止链接数据库
            closeMysql(connection);
            if (error) {
                console.log('更新失败')
                console.log(error)
                return;
            }
            console.log('更新成功')
            console.log(results)
        })
    })
}

// 更新
// update();

// 以下四个方法
insert();
// deleteData();
// find();
// update();