NodeJS連接MySQL數(shù)據(jù)庫并進行增刪改查操作詳解

更新時間：2024年02月22日 16:09:44 作者：挖掘機小王子

本篇是使用NodeJS的模塊MySQL操作MySQL數(shù)據(jù)庫的基礎(chǔ)教程,連接MySQL數(shù)據(jù)庫并進行增刪改查操作詳解,需要的朋友可以參考下

驅(qū)動安裝

npm install mysql

連接數(shù)據(jù)庫

在以下實例中根據(jù)你的實際配置修改數(shù)據(jù)庫用戶名、及密碼及數(shù)據(jù)庫名：

var mysql = require('mysql');

var connection = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: 'root',
    database: 'gov'
});

connection.connect(); // 連接數(shù)據(jù)庫

connection.query('select * from gov_policy', function (error, results, fields) {
    if (error) throw error;
 console.log('The results is: ', results);
 console.log(fields);
});
connection.end() // 關(guān)閉連接

數(shù)據(jù)庫連接參數(shù)說明

參數(shù)	描述
host	主機地址（默認：localhost）
user	用戶名
password	密碼
port	端口號（默認：3306）
database	數(shù)據(jù)庫名
charset	連接字符集（默認：'UTF8_GENERAL_CI'，注意字符集的字母都要大寫）
localAddress	此IP用于TCP連接（可選）
socketPath	連接到unix域路徑，當使用 host 和 port 時會被忽略
timezone	時區(qū)（默認：'local'）
connectTimeout	連接超時（默認：不限制；單位：毫秒）
stringifyObjects	是否序列化對象
typeCast	是否將列值轉(zhuǎn)化為本地JavaScript類型值（默認：true）
queryFormat	自定義query語句格式化方法
supportBigNumbers	數(shù)據(jù)庫支持bigint或decimal類型列時，需要設(shè)此option為true （默認：false）
bigNumberStrings	supportBigNumbers和bigNumberStrings啟用強制bigint或decimal列以JavaScript字符串類型返回（默認：false）
dateStrings	強制timestamp,datetime,data類型以字符串類型返回，而不是JavaScript Date類型（默認：false）
debug	開啟調(diào)試（默認：false）
multipleStatements	是否許一個query中有多個MySQL語句（默認：false）
flags	用于修改連接標志
ssl	使用ssl參數(shù)（與crypto.createCredenitals參數(shù)格式一至）或一個包含ssl配置文件名稱的字符串，目前只捆綁Amazon RDS的配置文件

更多說明可參見：https://github.com/mysqljs/mysql

數(shù)據(jù)庫操作( CURD )

在進行數(shù)據(jù)庫操作前，你可以對現(xiàn)有的數(shù)據(jù)進行操作，也可以新建數(shù)據(jù)來進行操作，也可以使用NodeJS的Faker模塊產(chǎn)生批量的假數(shù)據(jù)來操作。本教程測試的 MySQL 用戶名為 root，密碼為 root，數(shù)據(jù)庫為 gov，你需要根據(jù)自己配置情況修改。

查詢數(shù)據(jù)

執(zhí)行以下代碼即可查詢出數(shù)據(jù)：

var mysql = require('mysql');

var connection = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: 'root',
    port: '3306',
    database: 'gov'
});

connection.connect();

var sql = 'select * from gov_policy';
//查
connection.query(sql, function (err, result) {
    if (err) {
        console.log('[SELECT ERROR] - ', err.message);
        return;
    }

    console.log('--------------------------SELECT----------------------------');
    console.log(result);
    console.log('------------------------------------------------------------\n\n');
});

connection.end();

執(zhí)行以上命令輸出就結(jié)果為：

$ node test.js
--------------------------SELECT----------------------------
[ RowDataPacket {
    id: 1,
    name: 'Google',
    url: 'https://www.google.cm/',
    alexa: 1,
    country: 'USA' },
  RowDataPacket {
    id: 2,
    name: '淘寶',
    url: 'https://www.taobao.com/',
    alexa: 13,
    country: 'CN' },
    ......
  RowDataPacket {
    id: 4,
    name: '微博',
    url: 'http://weibo.com/',
    alexa: 20,
    country: 'CN' },
  RowDataPacket {
    id: 5,
    name: 'Facebook',
    url: 'https://www.facebook.com/',
    alexa: 3,
    country: 'USA' } ]
------------------------------------------------------------

插入數(shù)據(jù)

我們可以向數(shù)據(jù)表中插入數(shù)據(jù)：

var mysql = require('mysql');

var connection = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: 'root',
    port: '3306',
    database: 'gov'
});

connection.connect();

var addSql = 'INSERT INTO websites(Id,name,url,alexa,country) VALUES(0,?,?,?,?)';
var addSqlParams = ['博客論壇', 'https://segmentfault.com', 'NodeJS', 'China'];
//增
connection.query(addSql, addSqlParams, function (err, result) {
    if (err) {
        console.log('[INSERT ERROR] - ', err.message);
        return;
    }

    console.log('--------------------------INSERT----------------------------');
    //console.log('INSERT ID:',result.insertId);
    console.log('INSERT ID:', result);
    console.log('-----------------------------------------------------------------\n\n');
});

connection.end();

更新數(shù)據(jù)

我們也可以對數(shù)據(jù)庫的數(shù)據(jù)進行修改：

var mysql = require('mysql');

var connection = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: 'root',
    port: '3306',
    database: 'gov'
});

connection.connect();

var modSql = 'UPDATE websites SET name = ?,url = ? WHERE Id = ?';
var modSqlParams = ['思否論壇', 'https://segmentfault.com', 6];
//改
connection.query(modSql, modSqlParams, function (err, result) {
    if (err) {
        console.log('[UPDATE ERROR] - ', err.message);
        return;
    }
    console.log('--------------------------UPDATE----------------------------');
    console.log('UPDATE affectedRows', result.affectedRows);
    console.log('-----------------------------------------------------------------\n\n');
});

connection.end();

輸出的結(jié)果為：

--------------------------UPDATE----------------------------
UPDATE affectedRows 1
-----------------------------------------------------------------

刪除數(shù)據(jù)

我們可以使用以下代碼來刪除 id 為 6 的數(shù)據(jù):

var mysql = require('mysql');

var connection = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: 'root',
    port: '3306',
    database: 'gov'
});

connection.connect();

var delSql = 'DELETE FROM websites where id=6';
//刪
connection.query(delSql, function (err, result) {
    if (err) {
        console.log('[DELETE ERROR] - ', err.message);
        return;
    }

    console.log('--------------------------DELETE----------------------------');
    console.log('DELETE affectedRows', result.affectedRows);
    console.log('-----------------------------------------------------------------\n\n');
});

connection.end();

執(zhí)行以下命令輸出就結(jié)果為：

--------------------------DELETE----------------------------
DELETE affectedRows 1
-----------------------------------------------------------------

流式讀取數(shù)據(jù)

當數(shù)據(jù)有幾千萬條的時候，上面普通的查詢操作會導(dǎo)致內(nèi)存占用過高，也就是數(shù)據(jù)會先緩存下來，然后再返回給我們，如果數(shù)據(jù)龐大就需要采用流式讀取的方式，占用內(nèi)存少：

var mysql = require('mysql');

var connection = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: 'root',
    port: '3306',
    database: 'gov'
});

connection.connect();

var sql = 'SELECT * FROM gov_policy_old';

const query = connection.query(sql);
query.on('error', function (err) {
    console.log(err);
}).on('fields', function (fields) {
    // console.log(fields);
}).on('result', function (row) {
    console.log(row['title']);
}).on('end', function () {
    connection.end();
})