欢迎访问上海市某某有限公司
上海市某某有限公司专注网站制作10年!为企业打造专业的互联网营销解决方案
全国咨询热线: 18123456789
联系我们

上海市某某有限公司

地址:某某市某某区某某公路666弄66号

手机:18123456789

电话:021-6666666

邮箱:313801120@qq.com

当前位置:首页 > 新闻资讯 > 编程语言 > nodejs >

nodejs操作mysql数据库(增删改查)

时间:2022/7/15 11:22:51 作者: 点击:119次

第一种:查询

 
 //安装mysql    npm install mysql 
  
 //1 导入 mysql 模块 
 var mysql = require('mysql'); 
 //2 建立与 MySQL 数据库的连接关系 
 const db = mysql.createPool({ 
     host:'localhost', //数据库的 IP 地址 localhost或127.0.0.1 
     user:'root', //登录数据库的账号 
     password:'root123456',//登录数据库密码 
     database:'phpwebdata',//指定要操作那个数据库 
 }) 
  
 //查询 admin 表中所有的数据 
 const sql='select * from xy_admin'; 
 db.query(sql,(err,results)=>{ 
     //查询数据失败 
     if(err)return console.log("err",err.message); 
     //查询数据成功 
     console.log(results); 
 }) 
   
  
 
第二种:增加
 
 //1 导入 mysql 模块 
 var mysql = require('mysql'); 
 //2 建立与 MySQL 数据库的连接关系 
 const db = mysql.createPool({ 
     host:'localhost', //数据库的 IP 地址 localhost或127.0.0.1 
     user:'root', //登录数据库的账号 
     password:'root123456',//登录数据库密码 
     database:'phpwebdata',//指定要操作那个数据库 
 }) 
  
 //向 admin 表中,新增一条数据,其中 username 的值为 xiyueta,password 的值为 pass 
 const user = {username:'xiyueta',password:'pass'} 
 //定义待执行的 SQL 语句 
 const sql='insert into xy_admin(username,pwd) values(?,?)'; 
 db.query(sql,[user.username,user.password],(err,results)=>{ 
     //执行 SQL 语句失败了 
     if(err)return console.log("err",err.message); 
     //成功了 } 
     //注意:如果执行的是 insert into 插入语句,则results 是一个对象  
     //可以通过 affectedRows 属性,来判断是否插入数据成功 
     if(results.affectedRows==1){ 
         console.log('插入数据成功!',results); 
     } 
  
 }) 
   
 
第三种:插入数据的便捷方式
 
 //1 导入 mysql 模块 
 var mysql = require('mysql'); 
 //2 建立与 MySQL 数据库的连接关系 
 const db = mysql.createPool({ 
     host:'localhost', //数据库的 IP 地址 localhost或127.0.0.1 
     user:'root', //登录数据库的账号 
     password:'root123456',//登录数据库密码 
     database:'phpwebdata',//指定要操作那个数据库 
 }) 
  
 //演示插入数据的便捷方式 
  
 //向 admin 表中,新增一条数据,其中 username 的值为 xiyueta,password 的值为 pass 
 const user = {username:'xiyueta2',pwd:'pass2'} 
 //定义待执行的 SQL 语句 
 const sql='insert into xy_admin set?'; 
 db.query(sql,user,(err,results)=>{ 
     //执行 SQL 语句失败了 
     if(err)return console.log("err",err.message); 
     //成功了 } 
     //注意:如果执行的是 insert into 插入语句,则results 是一个对象  
     //可以通过 affectedRows 属性,来判断是否插入数据成功 
     if(results.affectedRows==1){ 
         console.log('插入数据成功!',results); 
     } 
 }) 
  
 
第四种:更新数据
 
 //1 导入 mysql 模块 
 var mysql = require('mysql'); 
 //2 建立与 MySQL 数据库的连接关系 
 const db = mysql.createPool({ 
     host:'localhost', //数据库的 IP 地址 localhost或127.0.0.1 
     user:'root', //登录数据库的账号 
     password:'root123456',//登录数据库密码 
     database:'phpwebdata',//指定要操作那个数据库 
 }) 
   
 //演示如何更新admin的信息 
  
 //向 admin 表中,新增一条数据,其中 username 的值为 xiyueta,password 的值为 pass 
 const user = {id:3,username:'newuser',pwd:'newpass'} 
 //定义待执行的 SQL 语句 
 const sql='update xy_admin set username=?,pwd=? where id=?'; 
 db.query(sql,[user.username,user.pwd,user.id],(err,results)=>{ 
     //执行 SQL 语句失败了 
     if(err)return console.log("err",err.message); 
     //成功了 }  
     //可以通过 affectedRows 属性,来判断是否更新数据成功 
     if(results.affectedRows==1){ 
         console.log('更新成功!',results); 
     } 
 }) 
  
 
第五种:更新数据的便捷方式
 
 //1 导入 mysql 模块 
 var mysql = require('mysql'); 
 //2 建立与 MySQL 数据库的连接关系 
 const db = mysql.createPool({ 
     host:'localhost', //数据库的 IP 地址 localhost或127.0.0.1 
     user:'root', //登录数据库的账号 
     password:'root123456',//登录数据库密码 
     database:'phpwebdata',//指定要操作那个数据库 
 }) 
   
 //演示更新数据的便捷方式 
  
 //向 admin 表中,新增一条数据,其中 username 的值为 xiyueta,password 的值为 pass 
 const user = {id:3,username:'newuser3333',pwd:'newpass4444'} 
 //定义待执行的 SQL 语句 
 const sql='update xy_admin set ? where id=?'; 
 db.query(sql,[user,user.id],(err,results)=>{ 
     //执行 SQL 语句失败了 
     if(err)return console.log("err",err.message); 
     //可以通过 affectedRows 属性,来判断是否更新数据成功 
     if(results.affectedRows==1){ 
         console.log('更新成功!',results); 
     } 
 }) 
  
 
第六种:删除一条数据
 
 //1 导入 mysql 模块 
 var mysql = require('mysql'); 
 //2 建立与 MySQL 数据库的连接关系 
 const db = mysql.createPool({ 
     host:'localhost', //数据库的 IP 地址 localhost或127.0.0.1 
     user:'root', //登录数据库的账号 
     password:'root123456',//登录数据库密码 
     database:'phpwebdata',//指定要操作那个数据库 
 }) 
   
 //删除 id 为 4 的数据  
  
 //定义待执行的 SQL 语句 
 const sql='delete from xy_admin where id=?'; 
 db.query(sql,4,(err,results)=>{ 
     //执行 SQL 语句失败了 
     if(err)return console.log("err",err.message); 
     //可以通过 affectedRows 属性,来判断是否删除数据成功 
     if(results.affectedRows==1){ 
         console.log('删除成功!',results); 
     }else{ 
     	console.log("删除失败,没有数据"); 
     } 
 }) 
  
 
第七种:标记删除
 
 //1 导入 mysql 模块 
 var mysql = require('mysql'); 
 //2 建立与 MySQL 数据库的连接关系 
 const db = mysql.createPool({ 
     host:'localhost', //数据库的 IP 地址 localhost或127.0.0.1 
     user:'root', //登录数据库的账号 
     password:'root123456',//登录数据库密码 
     database:'phpwebdata',//指定要操作那个数据库 
 }) 
   
 //标记删除 
 const sql='update xy_admin set isthrough=? where id=?'; 
 db.query(sql,[0,3],(err,results)=>{ 
     //执行 SQL 语句失败了 
     if(err)return console.log("err",err.message); 
     //可以通过 affectedRows 属性,来判断是否删除数据成功 
     if(results.affectedRows==1){ 
         console.log('标记删除成功!',results); 
     }else{ 
     	console.log("标记删除失败,没有数据"); 
     } 
 })