Node操作Mysql

1、引入包：

项目中 npm install mysql –save

2、测试代码

//引入数据库
var mysql=require('mysql');

var connection = mysql.createConnection({
    host: '192.168.4.62',
    user: 'dffdf',
    password: '111111',
    database: 'huajin-gf'
})
deletes();
// 查找
function select() {
    connection.connect(function (err) {
        if (err) {
            console.error('error connecting:' + err.stack)
        }
        console.log('connected as id ' + connection.threadId);
    })

    connection.query('SELECT * FROM edu_achievement_category', function (error, results, fields) {
        if (error) throw error;
        console.log('The solution is:', results);
    });
    connection.end();
}

//添加
function add() {
    let post = {
        category_id: '11111111',
        title: 'Hello'
    };
    let query = connection.query("INSERT INTO edu_achievement_category SET ?", post, function (error, results, fields) {
        if (error) throw error;
    })
    console.log(query.sql);
}

//修改
function updeate() {
    connection.connect(function (err) {
        if (err) {
            console.error('error connecting:' + err.stack);
        }
        console.log('connected as id ' + connection.threadId);
    });

    connection.query('UPDATE edu_achievement_category SET title=? where id=?', ['update', 12], function (error, results, fields) {
        if (error) throw error;
        console.log('changed:' + results.changeRows + 'rows');
    });

    connection.end();

}

//删除
function deletes() {
    connection.connect(function (err) {
        if (err) {
            console.error('error connecting:' + err.stack);
            return;
        }
        connection.query('DELETE FROM edu_achievement_category where id=?', [12], function (error, results, fields) {
            if (error) throw error;
            console.log('deleted:' + results.affectedRows + 'rows');
        });
        console.log('connected as id ' + connection.threadId);
        connection.end();

    });

}