14 node.js使用mysql模块,创建连接,创建连接池,并处理mysql数据库

node.js使用mysql模块,连接并处理mysql数据库

一、使用 createConnection 获取连接：   

const mysql = require('mysql');
const conn = mysql.createConnection({
    host: 'localhost',
    port: 3306,
    user: 'test',
    password: '1',
    database: 'study'
});

/** 查询数据 */
conn.query('select * from banji', function (err, rows, fields) {
    if (err) {
        console.log(err);
    } else {
        console.log(`查询出 ${rows.length} 条数据，第一条数据为 ${JSON.stringify(rows[0])}`);
    }
});

/** 添加数据 */
let banjiData = [4, '特长班'];
conn.query("INSERT INTO banji(banji_id,name) VALUES(?,?)", banjiData, function (err, results) {
    if (err) {
        console.log(err);
    } else {
        console.log(results);
    }
});

/** 删除数据 */
conn.query("DELETE FROM banji WHERE banji_id=?", [4], function (err, results) {
    if (err) {
        console.log(err);
    } else {
        console.log(results);
    }
});

/** 修改数据 */
conn.query("UPDATE banji SET name=? WHERE banji_id=?", ['特长贪睡班', 4], function (err, results) {
    if (err) {
        console.log(err);
    } else {
        console.log(results);
    }
});

conn.end();

二、使用 createPool 创建连接池：   

const mysql = require('mysql');
const pool = mysql.createPool({
    host: 'localhost',
    port: 3306,
    user: 'test',
    password: '1',
    database: 'study'
});

pool.getConnection((err, conn) => {
    /** 查询数据 */
    conn.query('select * from banji', function (err, rows, fields) {
        if (err) {
            console.log(err);
        } else {
            console.log(`查询出 ${rows.length} 条数据，第一条数据为 ${JSON.stringify(rows[0])}`);
        }
    });
    conn.release();//用完连接后，释放
});