node鏈接mysql並執行增刪改查實例

// 使用命令npm install mysql下載mysql模塊

//調用MySQL模塊
var mysql = require('mysql');

//建立一個connection
var connection = mysql.createConnection({
    //主機名
    host: 'localhost',
    // 數據庫的端口號，若是不設置，默認是3306
    port: 3306,
    user: 'root',
    password: 'root',
    //建立的數據庫
    database: 'test1',
});

//鏈接數據庫
connection.connect(function(err) {
    if (err) {
        //輸出錯誤的信息
        console.log('[query] - :' + err);
    } else {
        console.log('鏈接成功！');
    }
});

//mysql建表語句
let t1 = `create table if not exists t(
    id int primary key auto_increment,
    title varchar(255)not null
)`;

//執行sql語句
connection.query(t1, function(err, results, fields) {
    if (err) {
        console.log(err.message);
    } else {
        console.log('建表成功！');
    }
});

//關閉查詢
connection.end(function(err) {
    if (err) {
        return console.log(err.message);
    }
});


//增
// 添加的字段
let add = 'INSERT INTO t(id,title) VALUES(?,?)';
//添加的值
let addParams = ['1', 'aaa'];
//執行sql語句
connection.query(add, addParams, function(err, result) {
    if (err) {
        console.log('[INSERT ERROR] - ', err.message);
        return;
    } else {
        console.log('存儲成功！');
    }
});

//查
var sql = 'SELECT * FROM t';
connection.query(sql, function(err, result) {
    if (err) {
        console.log('[SELECT ERROR] - ', err.message);
        return;
    }
    console.log('--------------------------start----------------------------');
    console.log(result);
    console.log('--------------------------end----------------------------\n\n');
});

//改
// 更新title字段，經過id值定位，t是表名
var updata = 'UPDATE t SET title = ? WHERE Id = ?';
var updataParams = ['two', 2];
//執行sql語句
connection.query(updata, updataParams, function(err, result) {
    if (err) {
        console.log('[INSERT ERROR] - ', err.message);
        return;
    } else {
        console.log('更新成功！');
    }
});


//刪
let del = 'DELETE FROM t where id=3';
connection.query(del, (err, result) => {
    if (err) {
        console.log('[刪除失敗] - ', err.message);
        return;
    }
    console.log('刪除成功');
});

都是經過mysql語法操做數據庫。