IT俱乐部 JavaScript NodeJS连接MySQL数据库并进行增删改查操作详解

NodeJS连接MySQL数据库并进行增删改查操作详解

发布: 2024年 2月 24日 495阅读

驱动安装

1
npm install mysql

连接数据库

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
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）
bigNumberStrings supportBigNumbers和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，你需要根据自己配置情况修改。

查询数据

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
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('------------------------------------------------------------nn');
});
 
connection.end();

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
$ 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' } ]
------------------------------------------------------------

插入数据

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
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('-----------------------------------------------------------------nn');
});
 
connection.end();

更新数据

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
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('-----------------------------------------------------------------nn');
});
 
connection.end();

输出的结果为：

1
2
3
--------------------------UPDATE----------------------------
UPDATE affectedRows 1
-----------------------------------------------------------------

删除数据

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
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('-----------------------------------------------------------------nn');
});
 
connection.end();

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

1
2
3
--------------------------DELETE----------------------------
DELETE affectedRows 1
-----------------------------------------------------------------

流式读取数据

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
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数据库并进行增删改查操作详解的资料请关注IT俱乐部其它相关文章！

本文收集自网络，不代表IT俱乐部立场，转载请注明出处。https://www.2it.club/navsub/js/9427.html
37赞
标签:
上一篇
下一篇

相关推荐

联系我们

联系我们

在线咨询: QQ交谈

邮箱: 1120393934@qq.com

工作时间：周一至周五，9:00-17:30，节假日休息

关注微信
微信扫一扫关注我们

微信扫一扫关注我们

返回顶部