码云 node.js教程 2020-10-26

Node.js 连接 MySQL

AI 概述

安装驱动连接数据库数据库连接参数说明：数据库操作( CURD )查询数据插入数据更新数据删除数据本章节我们将为大家介绍如何使用 Node.js 来连接 MySQL，并对数据库进行操作。本教程使用到的 Websites 表 SQL 文件：websites.sql 提取码：2fc4。安装驱动本教程使用了淘宝定制的 cnpm 命令进行安装...

文章目录隐藏

安装驱动

连接数据库
数据库连接参数说明：

数据库操作( CURD )

查询数据
插入数据
更新数据
删除数据

本章节我们将为大家介绍如何使用 Node.js 来连接 MySQL，并对数据库进行操作。

本教程使用到的 Websites 表 SQL 文件：websites.sql 提取码：2fc4。

安装驱动

本教程使用了淘宝定制的 cnpm 命令进行安装：

$ cnpm install mysql

连接数据库

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

test.js 文件代码：

var mysql      = require('mysql');
var connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '123456',
  database : 'test'
});
 
connection.connect();
 
connection.query('SELECT 1 + 1 AS solution', function (error, results, fields) {
  if (error) throw error;
  console.log('The solution is: ', results[0].solution);
});

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

$ node test.js
The solution is: 2

数据库连接参数说明：

参数	描述
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 )

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

本教程测试的 MySQL 用户名为 root，密码为 123456，数据库为 test，你需要根据自己配置情况修改。

查询数据

将上面我们提供的 SQL 文件导入数据库后，执行以下代码即可查询出数据：

var mysql  = require('mysql');  
 
var connection = mysql.createConnection({     
  host     : 'localhost',       
  user     : 'root',              
  password : '123456',       
  port: '3306',                   
  database: 'test' 
}); 
 
connection.connect();
 
var  sql = 'SELECT * FROM websites';
//查
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: 'node.js 教程',
    url: 'https://mybj123.com/qdkfnote/jsnote/nodejs/',
    alexa: 1,
    country: 'USA' },
  RowDataPacket {
    id: 2,
    name: '前端',
    url: 'https://mybj123.com/qdkfnote/',
    alexa: 13,
    country: 'CN' },
  RowDataPacket {
    id: 3,
    name: '码云笔记',
    url: 'https://mybj123.com/',
    alexa: 4689,
    country: 'CN' },
  RowDataPacket {
    id: 4,
    name: '源码',
    url: 'https://mybj123.com/yuancode/',
    alexa: 20,
    country: 'CN' },
  RowDataPacket {
    id: 5,
    name: '面试题',
    url: 'https://mybj123.com/question/',
    alexa: 3,
    country: 'USA' } ]
------------------------------------------------------------

插入数据

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

var mysql  = require('mysql');  
 
var connection = mysql.createConnection({     
  host     : 'localhost',       
  user     : 'root',              
  password : '123456',       
  port: '3306',                   
  database: 'test' 
}); 
 
connection.connect();
 
var  addSql = 'INSERT INTO websites(Id,name,url,alexa,country) VALUES(0,?,?,?,?)';
var  addSqlParams = ['typescript', 'https://mybj123.com/qdkfnote/typescript/','23453', 'CN'];
//增
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();

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

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

执行成功后，查看数据表，即可以看到添加的数据。

更新数据

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

var mysql  = require('mysql');  
 
var connection = mysql.createConnection({     
  host     : 'localhost',       
  user     : 'root',              
  password : '123456',       
  port: '3306',                   
  database: 'test' 
}); 
 
connection.connect();
 
var modSql = 'UPDATE websites SET name = ?,url = ? WHERE Id = ?';
var modSqlParams = ['前端问答', 'https://mybj123.com/qa/',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 : '123456',       
  port: '3306',                   
  database: 'test' 
}); 
 
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
-----------------------------------------------------------------

执行成功后，查看数据表，即可以看到 id=6 的数据已被删除。

以上关于Node.js 连接 MySQL的文章就介绍到这了，更多相关内容请搜索码云笔记以前的文章或继续浏览下面的相关文章，希望大家以后多多支持码云笔记。

「点点赞赏，手留余香」

赞 0 赏

给作者打赏，鼓励TA抓紧创作！

微信

支付宝

还没有人赞赏，快来当第一个赞赏的人吧！

声明：本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如若内容造成侵权/违法违规/事实不符，请将相关资料发送至 admin@mybj123.com 进行投诉反馈，一经查实，立即处理！
重要：如软件存在付费、会员、充值等，均属软件开发者或所属公司行为，与本站无关，网友需自行判断
码云笔记 » Node.js 连接 MySQL