IDEA2023.1.3破解,IDEA破解,IDEA 2023.1破解,最新IDEA激活码
当前位置：搜云库技术团队 > Node.js 教程 > 正文

二十五、Node.js 访问 MySQL 数据库

2019-08-04 分类：Node.js 教程 阅读(994) 评论(0)
IDEA2023.1.3破解,IDEA破解,IDEA 2023.1破解,最新IDEA激活码

文章永久连接：https://tech.souyunku.com/?p=5466

本章节我们将学习如何使用 Node.js 访问和操作 MySQL 数据库

如果你未了解过 MySQL，可以学习我们的 MySQL 基础教程

本章节我们使用到的 SQL 表文件 node_site.sql

安装驱动

我们使用 mysql 访问 MySQL 数据库

$ npm install mysql

引入 mysql 模块

var driver  = require('mysql');

导入数据

在进行数据库操作前，需要将本站提供的 node_site.sql 表 SQL 文件 node_site.sql 导入到 MySQL 数据库 node_site 中

你可以使用以下命令把 node_site.sql 导入到 node_site 数据库中

$ wget https://tech.souyunku.com/static/media/node_site.sql
$ mysql -uroot -p -e "CREATE DATABASE node_site;"
$ mysql -uroot -p --default-character-set=utf8mb4 node_site < node_site.sql

连接 MySQL 数据库

使用 createConnection 方法可以创建连接
使用 connect() 方法可以连接到 MySQL 数据库

你可以根据你的实际配置修改数据库用户名、及密码及数据库名

main.js

/*
 * filename: main.js
 * author: 搜云库技术团队(tech.souyunku.com)
 * Copyright © 2015-2065 tech.souyunku.com. All rights reserved.
*/

var driver      = require('mysql');
var conn        = driver.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '',
  database : 'node_site'
});

conn.connect();

conn.query('SELECT 3 + 7 AS sumof', function (error, results, fields) {
  if (error) throw error;
  console.log('The sum of 3 + 7 is: ', results[0].sumof);
});

运行以上 Node.js 脚本，输出结果如下

$ node main.js
The sum of 3 + 7 is:  10

createConnection 参数说明

参数 描述
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的配置文件

更多参数可以参考 ： https://github.com/mysqljs/mysql

数据库操作( CURD )

查询数据

connnection.query() 方法可以查询数据

main.js

/*
 * filename: main.js
 * author: 搜云库技术团队(tech.souyunku.com)
 * Copyright © 2015-2065 tech.souyunku.com. All rights reserved.
*/

var driver      = require('mysql');
var conn        = driver.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '',
  database : 'node_site'
});

conn.connect();

var  sql = 'SELECT * FROM node_site';

conn.query(sql,function (err, result) {
        if(err){
          console.log('[SELECT ERROR] - ',err.message);
          return;
        }

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

conn.end();

运行以上 Node.js 脚本，输出结果如下

$ node main.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: 3,
    name: '腾讯网',
    url: 'http://www.qq.com',
    alexa: 9,
    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' } ]
------------------------------------------------------------

插入数据

connnection.query() 方法可以运行 SQL 语句

main.js

/*
 * filename: main.js
 * author: 搜云库技术团队(tech.souyunku.com)
 * Copyright © 2015-2065 tech.souyunku.com. All rights reserved.
*/

var driver      = require('mysql');
var conn        = driver.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '',
  database : 'node_site'
});

conn.connect();


var  sql = 'INSERT INTO node_site(id,name,url,alexa,country) VALUES(0,?,?,?,?)';
var  addSqlParams = ['网易', 'https://www.163.com','11', 'CN'];

conn.query(sql,addSqlParams,function (err, result) {
        if(err){
         console.log('[INSERT ERROR] - ',err.message);
         return;
        }        

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

conn.end();

运行以上 Node.js 脚本，输出结果如下

$ node main.js
------------------INSERT---------------------
INSERT ID: OkPacket {
  fieldCount: 0,
  affectedRows: 1,
  insertId: 6,
  serverStatus: 2,
  warningCount: 0,
  message: '',
  protocol41: true,
  changedRows: 0 }
----------------------------------------------

然后查看 MySQL node_site 数据库，可以看到我们的数据已经添加了

img_1.png

更新数据

/*
 * filename: main.js
 * author: 搜云库技术团队(tech.souyunku.com)
 * Copyright © 2015-2065 tech.souyunku.com. All rights reserved.
*/

var driver      = require('mysql');
var conn        = driver.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '',
  database : 'node_site'
});

conn.connect();


var sql = 'UPDATE node_site SET name = ? WHERE id = ?';
var modSqlParams = ['网易新闻',6];

conn.query(sql,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');
});

conn.end();

运行以上 Node.js 脚本，输出结果如下

$ node main.js
-------------UPDATE----------------------------
UPDATE affectedRows 1
-----------------------------------------------

然后查看 MySQL node_site 数据库，可以看到我们的数据已经变更了

img_2.png

删除数据

现在我们删除 id 为 6 的记录 我们可以使用以下代码来删除 id 为 6 的数据

main.js

/*
 * filename: main.js
 * author: 搜云库技术团队(tech.souyunku.com)
 * Copyright © 2015-2065 tech.souyunku.com. All rights reserved.
*/

var driver      = require('mysql');
var conn        = driver.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '',
  database : 'node_site'
});

conn.connect();


var sql = 'DELETE FROM node_site where id = 6';

conn.query(sql,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');  
});

conn.end();

运行以上 Node.js 脚本，输出结果如下

$ node main.js
-------------DELETE-----------------------
DELETE affectedRows 1
------------------------------------------

然后查看 MySQL node_site 数据库，可以看到 id=6 的记录已经删除了

img_3.png

干货推荐

本站推荐：精选优质专栏

附录：Node.js 教程：系列文章


Warning: A non-numeric value encountered in /data/wangzhan/tech.souyunku.com.wp/wp-content/themes/dux/functions-theme.php on line 1154
赞(65) 打赏



未经允许不得转载：搜云库技术团队 » 二十五、Node.js 访问 MySQL 数据库

IDEA2023.1.3破解,IDEA破解,IDEA 2023.1破解,最新IDEA激活码
IDEA2023.1.3破解,IDEA破解,IDEA 2023.1破解,最新IDEA激活码

评论 抢沙发

取消

吐血推荐

学习必备：精选优质专栏

学习必备：精选优质专栏

大前端WP主题 更专业 更方便

联系我们联系我们

觉得文章有用就打赏一下文章作者

微信扫一扫打赏

微信扫一扫打赏


Fatal error: Uncaught Exception: Cache directory not writable. Comet Cache needs this directory please: `/data/wangzhan/tech.souyunku.com.wp/wp-content/cache/comet-cache/cache/https/tech-souyunku-com/index.q`. Set permissions to `755` or higher; `777` might be needed in some cases. in /data/wangzhan/tech.souyunku.com.wp/wp-content/plugins/comet-cache/src/includes/traits/Ac/ObUtils.php:367 Stack trace: #0 [internal function]: WebSharks\CometCache\Classes\AdvancedCache->outputBufferCallbackHandler() #1 /data/wangzhan/tech.souyunku.com.wp/wp-includes/functions.php(5109): ob_end_flush() #2 /data/wangzhan/tech.souyunku.com.wp/wp-includes/class-wp-hook.php(303): wp_ob_end_flush_all() #3 /data/wangzhan/tech.souyunku.com.wp/wp-includes/class-wp-hook.php(327): WP_Hook->apply_filters() #4 /data/wangzhan/tech.souyunku.com.wp/wp-includes/plugin.php(470): WP_Hook->do_action() #5 /data/wangzhan/tech.souyunku.com.wp/wp-includes/load.php(1097): do_action() #6 [internal function]: shutdown_action_hook() #7 {main} thrown in /data/wangzhan/tech.souyunku.com.wp/wp-content/plugins/comet-cache/src/includes/traits/Ac/ObUtils.php on line 367