Nodejs操作MySQL - 增删改查
2024-10-21 20:35:58
先安装npm模块项目
npm init
安装mysql
npm install mysql --save
Nodejs 连接msyql
// 导入mysql
const mysql = require('mysql');
// 连接mysql
const connection = mysql.createConnection({
host: '127.0.0.1',
user: 'root',
password: 'password',
port: '3306',
database: 'test'
});
connection.connect();
// 结束连接
connection.end();
增
// 引入mysql
const mysql = require('mysql');
// 连接myql
const connection = mysql.createConnection({
host: '127.0.0.1',
user: 'root',
password: 'password',
port: '3306',
database: 'test',
});
connection.connect();
// 插入语句
let addSql = "insert into article (title, author, date) values (?, ?, now())";
let addSqlParams = ['Today is noce', 'Bob'];
// 执行插入语句
connection.query(addSql, addSqlParams, (err, result) => {
if (err) {
throw err;
}
// 插入成功输出
console.log('插入成功');
console.log(result);
});
// 断开连接msyql
connection.end();
删
// 引入mysql
const mysql = require('mysql');
// 连接mysql
const connection = mysql.createConnection({
host: '127.0.0.1',
user: 'root',
password: 'password',
port: '3306',
database: 'test'
});
connection.connect();
// 删除语句
let sql = "delete from article where id = 10";
// 执行删除语句
connection.query(sql, (err, data) => {
if (err) {
throw err;
}
// 执行成功
console.log('delete success!');
console.log(data);
});
// 断开连接msyql
connection.end();
改
// 导入mysql
const mysql = require('mysql');
// 连接mysql
const connection = mysql.createConnection({
host: '127.0.0.1',
user: 'root',
password: 'password',
port: '3306',
database: 'test'
});
connection.connect();
// 更新语句
let modSql = "update article set title = ?, author = ? where id like ?";
let modSqlParams = ['今晚学习nodejs', '一波万波', 12];
// 执行更新语句
connection.query(modSql, modSqlParams, (err, data) => {
if (err) {
throw err;
}
console.log('upload success!');
console.log(data)
});
connection.end();
查
// 导入mysql
const mysql = require('mysql');
// 连接mysql
const connection = mysql.createConnection({
host: '127.0.0.1',
user: 'root',
password: 'password',
port: '3306',
database: 'test',
});
connection.connect();
// 查询语句
let sql = 'SELECT * FROM article';
// 执行查询语句
connection.query(sql, (err, data) => {
if (err) {
console.log('[SELECT ERROR] - ', err.message);
return;
}
// 查询成功
console.log(data);
});
connection.end();
最新文章
- xmpp openfire smack 介绍和openfire安装及使用
- js判断是否是移动端 访问移动端网址
- linux琐碎命令学习
- Huge Page 是否是拯救性能的万能良药？
- Thinkpad 笔记本VMware Workstation 安装虚拟机出现“此主机支持 Intel VT-x，但 Intel VT-x 处于禁用状态”解决方法
- 不错的linux下通用的java程序启动脚本
- sqlserver临时启用和关闭约束
- Inno Setup的使用笔记
- OAuth 2.0
- hadoop部署小结的命令
- HTML5之Canvas影片广场
- 【Win 10 应用开发】MIDI 音乐合成——更改乐器音色
- VB使用API进行RC4加密解密(MD5密钥)
- project 2013 设置工期为1个工作日，但开始时间与结束时间不是同一天
- 【ASP.NET MVC系列】浅谈Google Chrome浏览器（操作篇）（下）
- 将搬家至CSDN
- Linux速成（一）
- 【转】 PreTranslateMessage作用和使用方法
- r与java整合（转）
- python小知识点复习