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

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

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
赞(80) 打赏



未经允许不得转载:搜云库技术团队 » 二十五、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