连接数据库后需要用代码操作的是,传入mysql语句,和参数,然后就是回调了

新增

// 新增app.post('/process_post', urlencodedParser, function (req, res) {  //post处理方法var response = {"names":req.body.names,   //得到页面提交的数据"passwords":req.body.passwords};//鏈接數據庫var mysql = require("mysql");var connection = mysql.createConnection({  //配置参数,然后添加你的数据库里面的表host: '数据库地址',user: '用户名',password: '密码',database: '数据库名称'})connection.connect();  //连接//插入數據var addSql = "insert into formtable(name,password) values(?,?)"; //mysql语句var addParmas = [response.names, response.passwords];//传递参数进入connection.query(addSql, addParmas, function(err, res) {if(err) {console.log("[insert error]-", err.message);return;}else{show(res)//回调}})function show(arr){result.data=arr;res.json(result);//返回给前端res.end();}   })

  上面的urlencodedParser是一个编码解释工具

删除

 //删除数据app.post('/del', urlencodedParser, function (req, res) {  //post处理方法var response = {"ids":req.body.id   //得到页面提交的数据};//鏈接數據庫var mysql = require("mysql");var connection = mysql.createConnection({  //配置参数,然后添加你的数据库里面的表host: '数据库地址',user: '用户名',password: '密码',database: '数据库名称'})connection.connect();  //连接var  userDelSql = 'DELETE FROM formtable WHERE id = ?';var addParmas = [response.ids];connection.query(userDelSql,addParmas,function(err, res) {if(err) {console.log('[select error]-', err.message);return;}else{show(res)} })function show(arr){result.data=arr;res.json(result);res.end();}   })

  查询

// 初始化app.post('/init', urlencodedParser, function (req, res) {  //post处理方法var response = {"names":req.body.names   //得到页面提交的数据};//鏈接數據庫var mysql = require("mysql");var connection = mysql.createConnection({  //配置参数,然后添加你的数据库里面的表host: '数据库地址',user: '用户名',password: '密码',database: '数据库名称'})connection.connect();  //连接var selectSql = "select * from formtable";connection.query(selectSql, function(err, res) {if(err) {console.log('[select error]-', err.message);return;}else{show(res)} })function show(arr){result.data=arr;res.json(result);res.end();}   })

  修改

//修改数据app.post('/modify', urlencodedParser, function (req, res) {  //post处理方法var response = {"ids":req.body.ids,   //得到页面提交的数据"names":req.body.names,"passwords":req.body.passwords};//鏈接數據庫var mysql = require("mysql");var connection = mysql.createConnection({  //配置参数,然后添加你的数据库里面的表host: '数据库地址',user: '用户名',password: '密码',database: '数据库名称'})connection.connect();  //连接var userModSql = 'UPDATE formtable SET name = ?,password = ? WHERE id = ?';var addParmas = [response.names,response.passwords,response.ids];console.log(addParmas);connection.query(userModSql,addParmas,function(err, res) {if(err) {console.log('[select error]-', err.message);return;}else{show(res)} })function show(arr){result.data=arr;res.json(result);res.end();}   })

  以上的"/modify" '/del' '/init''/process_post'这个四个就是四个接口,看完上面四个你就会觉得连接数据库增删改查没有什么的,当然啦,关于里面的方法你可以自己进行封装一下啦,增加他的复用性

完整代码

//表單提價 from_submit();  //为了方便管理我用函数包起来调用var result = {"status": "200","message": "success",  }//表單提價 function from_submit(){var express = require('express');  //调用模板var app = express();  //不污染本来,用变量来表示var bodyParser = require('body-parser');  //调用模板var mysql = require('mysql');app.use(express.static('public'));  //设置今天文件目录// app.get('/form_index.html',function(req,res){//     res.sendFile(__dirname+"/"+form_index.html); //提供静态文件// })//设置跨域访问app.all('*', function(req, res, next) {res.header("Access-Control-Allow-Origin", "*");res.header("Access-Control-Allow-Headers", "X-Requested-With");res.header("Access-Control-Allow-Methods","PUT,POST,GET,DELETE,OPTIONS");res.header("X-Powered-By",' 3.2.1');res.header("Content-Type", "application/json;charset=utf-8");next();});//創建編碼解析var urlencodedParser = bodyParser.urlencoded({ extended: false })// 新增app.post('/process_post', urlencodedParser, function (req, res) {  //post处理方法// 输出 JSON 格式var response = {"names":req.body.names,   //得到页面提交的数据"passwords":req.body.passwords};//鏈接數據庫var mysql = require("mysql");var connection = mysql.createConnection({  //配置参数,然后添加你的数据库里面的表host: 'localhost',user: 'root',password: 'root',database: 'test'})connection.connect();  //连接//插入數據var addSql = "insert into formtable(name,password) values(?,?)"; //存放数据库语言的,这里是添加var addParmas = [response.names, response.passwords];connection.query(addSql, addParmas, function(err, res) {if(err) {console.log("[insert error]-", err.message);return;}else{show(res)}})function show(arr){result.data=arr;res.json(result);res.end();}   })// 初始化app.post('/init', urlencodedParser, function (req, res) {  //post处理方法// 输出 JSON 格式var response = {"names":req.body.names   //得到页面提交的数据};//鏈接數據庫var mysql = require("mysql");var connection = mysql.createConnection({  //配置参数,然后添加你的数据库里面的表host: 'localhost',user: 'root',password: 'root',database: 'test'})connection.connect();  //连接var selectSql = "select * from formtable";connection.query(selectSql, function(err, res) {if(err) {console.log('[select error]-', err.message);return;}else{show(res)} })function show(arr){result.data=arr;res.json(result);res.end();}   })//删除数据app.post('/del', urlencodedParser, function (req, res) {  //post处理方法// 输出 JSON 格式var response = {"ids":req.body.id   //得到页面提交的数据};//鏈接數據庫var mysql = require("mysql");var connection = mysql.createConnection({  //配置参数,然后添加你的数据库里面的表host: 'localhost',user: 'root',password: 'root',database: 'test'})connection.connect();  //连接var  userDelSql = 'DELETE FROM formtable WHERE id = ?';var addParmas = [response.ids];connection.query(userDelSql,addParmas,function(err, res) {if(err) {console.log('[select error]-', err.message);return;}else{show(res)} })function show(arr){result.data=arr;res.json(result);res.end();}   })//修改数据app.post('/modify', urlencodedParser, function (req, res) {  //post处理方法// 输出 JSON 格式var response = {"ids":req.body.ids,   //得到页面提交的数据"names":req.body.names,"passwords":req.body.passwords};//鏈接數據庫var mysql = require("mysql");var connection = mysql.createConnection({  //配置参数,然后添加你的数据库里面的表host: 'localhost',user: 'root',password: 'root',database: 'test'})connection.connect();  //连接var userModSql = 'UPDATE formtable SET name = ?,password = ? WHERE id = ?';var addParmas = [response.names,response.passwords,response.ids];console.log(addParmas);connection.query(userModSql,addParmas,function(err, res) {if(err) {console.log('[select error]-', err.message);return;}else{show(res)} })function show(arr){result.data=arr;res.json(result);res.end();}   })var server = app.listen(3000, function () {  //监听var host = server.address().addressvar port = server.address().portconsole.log("应用实例,访问地址为 http://%s:%s", host, port)})}

  写这个主要还是方便我自己学习啦,如果有好的建议可以一起交流或者指教我一下~

  注:上面代码中的formtable 是我本地数据库的其中一个表而已,如果你的表明不是这个记得链接数据库后传入的mysql语句中修改一下

转载于:https://www.cnblogs.com/ldlx-mars/p/9060682.html

nodejs连接数据库的增删改查相关推荐

  1. mysql源生插入数据_php+mysql源生连接数据库和增删改查数据

    php+mysql源生连接数据库和增删改查数据 新建一个init.php文件,执行链接数据库.内容如下 header("Content-type: text/html; charset=ut ...

  2. 数据库实验IDEA编程Java程序实现连接数据库以及增删改查JDBC

    IDEA编程Java程序实现连接数据库以及增删改查JDBC IDEA的mysql环境配置建议参考该博客:戳我 我用的是java11和此博客的配置略有出入,不过一般的问题都可以百度解决 这是我实验用的数 ...

  3. 基于springmvc、ajax,后台连接数据库的增删改查

    前言 前段时间在博客园上找了一个springmvc的例子,照着学了一下,算是对springmvc有了一个初步的了解,打一个基础,下面是链接.(我只看了博客,视频太耗时间了) 博客链接:http://w ...

  4. php连接数据库实现增删改查,PHP连接数据库,实现最基本的增删改查(面向过程)

    在我们把PHP的环境搭建好以后,我们来看一下怎样通过PHP连接MySQL数据库,以及怎样实现最基本的增删改查.其它就不多说了,直接上代码吧. 1.PHP连接MySQL数据库 1 2 3 4 5 6 7 ...

  5. node.js学习day03 通过node.js连接数据库实现增删改查

    通过node.js连接mysql数据库实现增删改查 1. npm i mysql 导入mysql模块 2.熟悉数据库增删改查 3.建立连接 通过mysql.createPool 4.案例 const ...

  6. C#的ASP.NET中关于OleDb连接数据库执行增删改查

    一句话解释C#调用数据库原理: 在Web.config文件里面配置相应的代码,然后写相应的oleDB数据库代码进行连接操作 web.config配置 <?xml version="1. ...

  7. oracle改连接数据库,oracle连接数据库以及增删改查(全面)

    import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sq ...

  8. 使用c3p0对mysql进行增删改查_c3p0连接池连接数据库 并增删改查

    使用c3p0连接池连接数据库 示例(mvc模式) 1.mysql.properties (连接数据库的)文件: driver=com.mysql.jdbc.Driver url=jdbc:mysql: ...

  9. nodejs操作mongodb增删改查

    1. Mac系统上安装 使用Homebrew安装 $ brew updata // 更新Homebrew的package数据库 $ brew install mongodb 2. 启动MongoDB ...

最新文章

  1. 深拷贝(deep clone)与浅拷贝(shallow clone)
  2. 学python要多少钱-python学习费用多少合适
  3. NSUserDefaults设置bool值重新启动后bool仅仅设置丢失问题
  4. AC自动机的使用案例
  5. 喜报!良品铺子签约神策数据
  6. Python爬虫利器一Requests库的用法
  7. http模拟登陆及发请求
  8. SpringBoot2.0系列(4)---SpringBoot之使用JPA完成简单的rest api
  9. WindowsXP操作系统进程详细介绍
  10. CSS原理与CSS经验分享
  11. MVC创建通用DropdownList
  12. 祭十大已经逝去的软件
  13. lammps教程:EAM势函数设置详解
  14. hspice标识符语法
  15. 85篇精彩的经典古文
  16. ff14优雷卡补正什么意思_禁地优雷卡 | 新大陆见闻录 - 《最终幻想14》萌新指导手册...
  17. 科大讯飞和 Nuance 在语音识别技术上各有长项和短处?
  18. docker 常用命令
  19. QNX dumper生成的core文件无法拿到堆栈信息
  20. C语言输出各种类型数据的方式

热门文章

  1. puppet 认证错误:Could not request certificate: unknown message digest algorithm
  2. 数据结构课程设计:顺序结构、动态链表结构下的一元多项式的加法、减法、乘法的实现...
  3. 大学生魏则西之死,谁该为违法广告买单?
  4. flash 定义主舞台窗口大小
  5. 每日命令之vim简单使用
  6. 撰写oracle-sql-hint的注意事项
  7. 【博客话题】什么样的学生你都能教好——亲爱的魏老师
  8. 数据库设计三大范式详解
  9. 蓝桥杯 ADV-140 算法提高 开灯游戏
  10. 利用Kafka发送/消费消息-Java示例