驱动安装

npm install mysql

连接数据库

在以下实例中根据你的实际配置修改数据库用户名、及密码及数据库名：

var mysql = require('mysql');var connection = mysql.createConnection({    host: 'localhost',    user: 'root',    password: 'root',    database: 'gov'});connection.connect(); // 连接数据库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() // 关闭连接

数据库连接参数说明

参数描述
host主机地址 （默认：localhost）
user用户名
password密码
port端口号 （默认：3306）
database数据库名
charset连接字符集（默认：’UTF8_GENERAL_CI’，注意字符集的字母都要大写）
localAddress此IP用于TCP连接（可选）
socketPath连接到unix域路径，当使用 host 和 port 时会被忽略
timezone时区（默认：’local’）
connectTimeout连接超时（默认：不限制；单位：毫秒）
stringifyObjects是否序列化对象
typeCast是否将列值转化为本地JavaScript类型值 （默认：true）
queryFormat自定义query语句格式化方法
supportBigNumbers数据库支持bigint或decimal类型列时，需要设此option为true （默认：false）
bigNumberStringssupportBigNumbers和bigNumberStrings启用 强制bigint或decimal列以JavaScript字符串类型返回（默认：false）
dateStrings强制timestamp,datetime,data类型以字符串类型返回，而不是JavaScript Date类型（默认：false）
debug开启调试（默认：false）
multipleStatements是否许一个query中有多个MySQL语句 （默认：false）
flags用于修改连接标志
ssl使用ssl参数（与crypto.createCredenitals参数格式一至）或一个包含ssl配置文件名称的字符串，目前只捆绑Amazon RDS的配置文件

数据库操作( CURD )

在进行数据库操作前，你可以对现有的数据进行操作，也可以新建数据来进行操作，也可以使用NodeJS的Faker模块产生批量的假数据来操作。本教程测试的 MySQL 用户名为 root，密码为 root，数据库为 gov，你需要根据自己配置情况修改。

查询数据

执行以下代码即可查询出数据：

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();

执行以上命令输出就结果为：

$ 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' } ]------------------------------------------------------------

插入数据

我们可以向数据表中插入数据：

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();

更新数据

我们也可以对数据库的数据进行修改：

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();

输出的结果为：

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

删除数据

我们可以使用以下代码来删除 id 为 6 的数据:

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();

执行以下命令输出就结果为：

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

流式读取数据

当数据有几千万条的时候，上面普通的查询操作会导致内存占用过高，也就是数据会先缓存下来，然后再返回给我们，如果数据庞大就需要采用流式读取的方式，占用内存少：

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();})

参考

以上就是NodeJS连接MySQL数据库并进行增删改查操作详解的详细内容，更多关于NodeJS连接MySQL数据库并进行增删改查操作详解的资料请关注脚本之家其它相关文章！