Node 连接mysql数据库

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: JXcore作者已经不维护了。github地址 https://github.com/jxcore/jxcore所以下面是Node.js连接MysqlNode.js 连接Mysql使用的内容作者依旧在维护 安装 PS C:\Users\mingm\Desktop\test> npm install.

JXcore作者已经不维护了。
github地址 https://github.com/jxcore/jxcore
所以下面是Node.js连接Mysql
Node.js 连接Mysql
使用的内容作者依旧在维护

安装

PS C:\Users\mingm\Desktop\test> npm install mysql --save
npm WARN saveError ENOENT: no such file or directory, open 'C:\Users\mingm\Desktop\test\package.json'
npm WARN enoent ENOENT: no such file or directory, open 'C:\Users\mingm\Desktop\test\package.json'
npm WARN test No description
npm WARN test No repository field.
npm WARN test No README data
npm WARN test No license field.

+ mysql@2.16.0
updated 1 package and audited 296 packages in 2.366s
found 0 vulnerabilities

PS C:\Users\mingm\Desktop\test>
AI 代码解读

npm地址 https://www.npmjs.com/package/mysql
github 地址 https://github.com/mysqljs/mysql
文档地址 https://www.npmjs.com/package/mysql#install 查看一些文档的时候需要在这里查看

连接数据库

由于本地已经有mysql了。

PS C:\Users\mingm\Desktop\test> node test.js
The solution is: 2
AI 代码解读
var mysql = require('mysql');
var connection = mysql.createConnection({
    host: 'student.iming.info',    // 连接的服务器
    user: 'root',    // 用户名
    password: '********',    // 用户密码
    database: 'ming'    // 选择的库
});

connection.connect();    // 创建一个mysql的线程

connection.query('SELECT 1 + 1 AS solution', (err, results, fields) => {
    if (err) {
        throw  err;
    };

    console.log('The solution is:', results[0].solution);    // 返回第一条记录的solution列的内容
});
AI 代码解读

好啦。这就完成了一次连接,使用的是npm下载的mysql模块,使用的是c++语言编写的

数据库操作

PS C:\Users\mingm\Desktop\test> 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: 3,
    name: '微博',
    url: 'http://weibo.com/',
    alexa: 20,
    country: 'CN' },
  RowDataPacket {
    id: 5,
    name: 'Facebook',
    url: 'https://www.facebook.com/',
    alexa: 3,
    country: 'USA' } ]
--------------------------------
AI 代码解读
var mysql = require('mysql');
var connection = mysql.createConnection({
    host: 'student.iming.info',    // 连接的服务器
    user: 'root',    // 用户名
    password: '******************',    // 用户密码
    database: 'ming'    // 选择的库
});

connection.connect();    // 创建一个mysql的线程

// 推荐查询语句使用大写。方便分辨和后期的维护
var sql = 'SELECT * FROM websites';    // sql命令
connection.query(sql, (err, results, fields) => {    // results 为查询的结果 fields 为返回的信息
    if (err) {
        console.log('[SELECT ERROR] -', err.message);
        return;
    };

    console.log('------------SELECT-------------');    
    console.log(results);    // 输出查询的结果
    console.log('--------------------------------');
});
AI 代码解读

下面该是数据库的原子操作了。即CULD

插入数据

PS C:\Users\mingm\Desktop\test> node test.js
------------------INSERT--------------------------
INSERT ID OkPacket {
  fieldCount: 0,
  affectedRows: 1,
  insertId: 6,
  serverStatus: 2,
  warningCount: 0,
  message: '',
  protocol41: true,
  changedRows: 0 }
-------------------------------------------------


PS C:\Users\mingm\Desktop\test>
AI 代码解读
var mysql = require('mysql');
var connection = mysql.createConnection({
    host: 'student.iming.info',    // 连接的服务器
    user: 'root',    // 用户名
    password: '*******************',    // 用户密码
    database: 'ming'    // 选择的库
});

connection.connect();    // 创建一个mysql的线程

var addSql = 'INSERT INTO websites(id, name, url, alexa, country) VALUES(0, ?, ?, ?, ?)'; // 创建一个通用的sql,并预留出填补的空位
var addSqlParams = ['mySoul', 'https://www.iming.info', '0000000', 'CN'];

connection.query(addSql, addSqlParams, (err, result) => {
    if(err){
        console.log('[INSERT ERROR] -', err.message);
        return;
    }

    console.log('------------------INSERT--------------------------')
    console.log('INSERT ID', result);
    console.log('-------------------------------------------------\n\n');
});
AI 代码解读

登陆数据库查看

mysql> select * from websites;
+----+----------+---------------------------+-------+---------+
| id | name     | url                       | alexa | country |
+----+----------+---------------------------+-------+---------+
|  1 | Google   | https://www.google.cm/    |     1 | USA     |
|  2 | 淘宝     | https://www.taobao.com/   |    13 | CN      |
|  3 | 微博     | http://weibo.com/         |    20 | CN      |
|  5 | Facebook | https://www.facebook.com/ |     3 | USA     |
|  6 | mySoul   | https://www.iming.info    |     0 | CN      |
+----+----------+---------------------------+-------+---------+
5 rows in set (0.02 sec)

mysql>
AI 代码解读

很明显已经插入完成

亲,如果数据库ID设置了自动递增,即使用了AUTO_INCREMENT,建议使用自增,因为数据库索引是B+树的加快查询速度。所以一般都设置自增序列

关于JSON 因为数据通信是使用JSON的,所以两个方法,一个JSON转对象 JSON.parse
 对象转JSON JSON.stringify

在加上一个node的框架Express,即可完成和浏览器的交互,这样就完成一个web服务器的搭建

删除数据

var mysql = require('mysql');
var connection = mysql.createConnection({
    host: 'student.iming.info',    // 连接的服务器
    user: 'root',    // 用户名
    password: '****************',    // 用户密码
    database: 'ming'    // 选择的库
});

connection.connect();    // 创建一个mysql的线程

var delSql = 'DELETE FROM websites WHERE id=6';
connection.query(delSql, (err, result) => {
    if(err) {
        console.log('[DELETE ERROR] -', err.message);
        return;
    }

    console.log('------------DELETE------------------');
    console.log('DELETE affectedRows', result);
    console.log('------------------------------------');
})

connection.end();
AI 代码解读
PS C:\Users\mingm\Desktop\test> node test.js
------------DELETE------------------
DELETE affectedRows OkPacket {
  fieldCount: 0,
  affectedRows: 1,
  insertId: 0,
  serverStatus: 2,
  warningCount: 0,
  message: '',
  protocol41: true,
  changedRows: 0 }
------------------------------------
PS C:\Users\mingm\Desktop\test>
AI 代码解读

博客

www.iming.info

相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL,然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
打赏
0
0
0
0
911
分享
相关文章
Unity连接Mysql数据库 增 删 改 查
在 Unity 中连接 MySQL 数据库,需使用 MySQL Connector/NET 作为数据库连接驱动,通过提供服务器地址、端口、用户名和密码等信息建立 TCP/IP 连接。代码示例展示了如何创建连接对象并执行增删改查操作,确保数据交互的实现。测试代码中,通过 `MySqlConnection` 类连接数据库,并使用 `MySqlCommand` 执行 SQL 语句,实现数据的查询、插入、删除和更新功能。
如何排查和解决PHP连接数据库MYSQL失败写锁的问题
通过本文的介绍,您可以系统地了解如何排查和解决PHP连接MySQL数据库失败及写锁问题。通过检查配置、确保服务启动、调整防火墙设置和用户权限,以及识别和解决长时间运行的事务和死锁问题,可以有效地保障应用的稳定运行。
57 25
DBeaver连接MySQL提示Access denied for user ‘‘@‘ip‘ (using password: YES)
“Access denied for user ''@'ip' (using password: YES)”错误通常与MySQL用户权限配置或网络设置有关。通过检查并正确配置用户名和密码、用户权限、MySQL配置文件及防火墙设置,可以有效解决此问题。希望本文能帮助您成功连接MySQL数据库。
355 4
【赵渝强老师】MySQL的连接方式
本文介绍了MySQL数据库服务器启动后的三种连接方式:本地连接、远程连接和安全连接。详细步骤包括使用root用户登录、修改密码、创建新用户、授权及配置SSL等。并附有视频讲解,帮助读者更好地理解和操作。
593 1
java连接mysql查询数据(基础版,无框架)
【10月更文挑战第12天】该示例展示了如何使用Java通过JDBC连接MySQL数据库并查询数据。首先在项目中引入`mysql-connector-java`依赖,然后通过`JdbcUtil`类中的`main`方法实现数据库连接、执行SQL查询及结果处理,最后关闭相关资源。
418 6
node博客小项目:接口开发、连接mysql数据库
【10月更文挑战第14天】node博客小项目:接口开发、连接mysql数据库
Node.js 连接 MongoDB
10月更文挑战第20天
55 0
Docker Compose V2 安装常用数据库MySQL+Mongo
以上内容涵盖了使用 Docker Compose 安装和管理 MySQL 和 MongoDB 的详细步骤,希望对您有所帮助。
106 42

热门文章

最新文章

AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等