精华内容
下载资源
问答
  • node增删改查完整项目

    2017-07-24 18:28:16
    才学node,做了一个node的小demo
  • node.js 增删改查

    2018-01-04 14:17:56
    init.js /** * Created by web-01 on 2018/1/4. */ const mysql=require("mysql"); //创建连接 var conn=mysql.createConnection({ host:'127.0.0.1', user:"root", password:"", database:"test",

    init.js

    /**
     * Created by web-01 on 2018/1/4.
     */
    const mysql=require("mysql");
    //创建连接
    var conn=mysql.createConnection({
        host:'127.0.0.1',
        user:"root",
        password:"",
        database:"test",
        port:3306
    });
    
    module.exports.conn=conn;
    
    insert.js

    var m=require("./init.js");
    var conn=m.conn;
    
    //增
    var sql="INSERT INTO test VALUES(null,'fff')";
    conn.query(sql,(err,result)=>{ //这里是异步操作
        if(err) throw err;
    console.log(result.affectedRows);
    //关闭连接
    conn.end();//注:需要放在里面
    console.log("操作完成");
    });
    delete.js

    var m=require("./init.js");
    var conn=m.conn;
    
    //删
    var sql="DELETE FROM test WHERE tid=1";
    conn.query(sql,(err,result)=>{ //这里是异步操作
        if(err) throw err;
    console.log(result.affectedRows);
    //关闭连接
    conn.end();//注:需要放在里面
    console.log("操作完成");
    });
    update.js

    var m=require("./init.js");
    var conn=m.conn;
    
    //改
    var sql="UPDATE test SET tname='abc2' WHERE tid=2";
    conn.query(sql,(err,result)=>{ //这里是异步操作
        if(err) throw err;
    console.log(result.affectedRows);
    //关闭连接
    conn.end();//注:需要放在里面
    console.log("操作完成");
    });
    selete.js

    var m=require("./init.js");
    var conn=m.conn;
    
    //查
    var sql="SELECT * FROM t_user WHERE uid=1 AND uname='james'";
    conn.query(sql,(err,result)=>{ //这里是异步操作
        if(err) throw err;
    //关闭连接
    conn.end();//注:需要放在里面
    if(result.length>0){
        console.log(result);
    }else{
        console.log("操作失败");
    }
    });

    可以通过连接池提高效率:

    const mysql=require("mysql");
    var pool=mysql.createPool({
        host:'127.0.0.1',
        user:"root",
        password:"",
        database:"test",
        port:3306,
        connectionLimit:25 //连接数量限制
    });
    //连接池会常驻内存,所以程序不会停止
    
    var sql="SELECT * FROM test WHERE tid=3";
    pool.getConnection((err,conn)=>{
        conn.query(sql,(err,res)=>{
            console.log(res);
            //释放连接 必须要释放,否则很快占满连接数!!!
            conn.release();
        });
    });








    展开全文
  • 5.数据库的增删改查 6.完整代码 1.新建数据库user_login,创建数据表tb_user 2.在文件当前目录下载mysql模块 下载命令(前提是电脑安装了node.js): npm install mysql 3.引入mysql模块 /*引入mysql...

    目录

    1.新建数据库user_login,创建数据表tb_user

     2.在文件当前目录下载mysql模块

    3.引入mysql模块

    4.创建数据库对象,连接数据库

    5.数据库的增删改查

    6.完整代码


    1.新建数据库user_login,创建数据表tb_user

     2.在文件当前目录下载mysql模块

    下载命令(前提是电脑安装了node.js):

     npm install mysql

    3.引入mysql模块

    /*引入mysql模块
    */
    let mysql = require("mysql");

    4.创建数据库对象,连接数据库

    // 创建数据库连接对象
    const db = {
        host: "localhost",//地址
        user: "root",//数据库用户名
        password: "root",//数据库密码
        port: "3306",//端口号
        database: "user_login"//数据库名
    }
    
    // 连接数据库
    let connect = mysql.createConnection(db);
    connect.connect(function (err) {
        if (err) {
            console.log(err);
        } else {
            console.log("-----数据库连接成功-----");
        }
    
    });

    5.数据库的增删改查

    // 创建关闭数据库函数
    function closeMysql(con) {
        con.end((err) => {
            if (err) return console.log(err);
            console.log("数据库关闭成功");
        })
    }
    
    // /*1 获取数据  查*/
    let sqlSelect="select userName from tb_user where userId=1";
    connect.query(sqlSelect,function(err,result){
        if(err) return console.log(err);
        console.log("数据查找成功");
        console.log(result);
        closeMysql(connect);
    });
    
    
    // /*2 增加数据  增*/
    
    let sqlAdd="insert into tb_user(userName,userPwd,userAge) values(?,?,?)";
    let addDates=["张三","123123",16];
    connect.query(sqlAdd,addDates,function(err,result){
        if(err){
            console.log(err);
        }else{
            console.log("------数据增加成功--------");
            console.log(result);
            console.log("------end--------");
            closeMysql(connect);
        }
    })
    
    
    
    // 3删除数据  删
    
    let sqlDel="delete from tb_user where userId=3";
    connect.query(sqlDel,function(err,res){
        if(err){
            console.log(err);
        }else{
            console.log("------数据删除成功--------");
            console.log(res);
            console.log("------end--------");
            closeMysql(connect);
        }
    })
    
    
    /*4修改数据  改*/
    let sqlUpdate = "update tb_user set userName=?,userAge=? where userId=?";
    let dateAlter = ["赵四", 30, 5];
    connect.query(sqlUpdate, dateAlter, function (err, res) {
        if (err) return console.log(err);
    
        console.log("------数据修改成功--------");
        console.log(res);
        console.log("------end--------");
        closeMysql(connect);
    
    })
    

    6.完整代码

    /*引入mysql模块
    */
    let mysql = require("mysql");
    
    // 创建数据库连接对象
    const db = {
        host: "localhost",//地址
        user: "root",//数据库用户名
        password: "root",//数据库密码
        port: "3306",//端口号
        database: "user_login"//数据库名
    }
    
    // 连接数据库
    let connect = mysql.createConnection(db);
    connect.connect(function (err) {
        if (err) {
            console.log(err);
        } else {
            console.log("-----数据库连接成功-----");
        }
    
    });
    // 关闭数据库
    function closeMysql(con) {
        con.end((err) => {
            if (err) return console.log(err);
            console.log("数据库关闭成功");
        })
    }
    
    // /*1 获取数据  查*/
    let sqlSelect="select userName from tb_user where userId=1";
    connect.query(sqlSelect,function(err,result){
        if(err) return console.log(err);
        console.log("数据查找成功");
        console.log(result);
        closeMysql(connect);
    });
    
    
    // /*2 增加数据  增*/
    
    let sqlAdd="insert into tb_user(userName,userPwd,userAge) values(?,?,?)";
    let addDates=["张三","123123",16];
    connect.query(sqlAdd,addDates,function(err,result){
        if(err){
            console.log(err);
        }else{
            console.log("------数据增加成功--------");
            console.log(result);
            console.log("------end--------");
            closeMysql(connect);
        }
    })
    
    
    
    // 3删除数据  删
    
    let sqlDel="delete from tb_user where userId=3";
    connect.query(sqlDel,function(err,res){
        if(err){
            console.log(err);
        }else{
            console.log("------数据删除成功--------");
            console.log(res);
            console.log("------end--------");
            closeMysql(connect);
        }
    })
    
    
    /*4修改数据  改*/
    let sqlUpdate = "update tb_user set userName=?,userAge=? where userId=?";
    let dateAlter = ["赵四", 30, 5];
    connect.query(sqlUpdate, dateAlter, function (err, res) {
        if (err) return console.log(err);
    
        console.log("------数据修改成功--------");
        console.log(res);
        console.log("------end--------");
        closeMysql(connect);
    
    })
    

    展开全文
  • 主要介绍了Node.js+Express+Mysql 实现增删改查,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
  • 主要介绍了node.js中 mysql 增删改查操作及async,await处理,结合实例形式分析了node.js中 mysql库安装、增删改查操作及async,await处理相关实现技巧,需要的朋友可以参考下
  • koa2-mongo-mongoose 一套基于koa2 mongo mongoose的简单的nodejs server,实现数据库增删改查逻辑
  • Node.js官网 使用node -v(version)查看Node版本,确定是否安装成功 MySql官网 使用mysql -u 用户名 -p 密码查看MySql是否安装成功 NaviCat官网,Navicat是一个数据库可视化图形工具 然后创建一个空文件夹(我创建...

    首先需要准备好一些环境和开发工具

    然后创建一个空文件夹(我创建的是demo),进入空文件夹所在的命令行,然后使用npm init -y命令进行初始化操作

    // 初始化结果如下
    {
      "name": "demo",
      "version": "1.0.0",
      "description": "",
      "main": "index.js",
      "scripts": {
        "test": "echo \"Error: no test specified\" && exit 1"
      },
      "keywords": [],
      "author": "",
      "license": "ISC"
    }
    

    然后再在此命令行下安装两个模块:expressmysql,express实现路由比较方便

    npm install(i) express
    npm install(i) mysql
    
    // 也可一次安装两个模块
    npm i express mysql
    

    一、不做处理直接实现增删改查

    然后在文件夹的根目录创建index.jsapi.http(文件名可以随便起,自己能认出即可),api.http文件用来测试路由编写是否成功,可以同时测试get、post、delete和put请求方式,需要安装REST Client插件才能使用

    • 注意
      getdelete请求方式在req.query中取值,传参形式直接在路径后拼接
      postput请求方式在req.body中取值,传参形式必须遵守严格json模式

    在index.js文件中编写代码,搭建一个简易服务器

    const express = require('express')
    const mysql = require('mysql') // 引入下载的两个模块
    
    const app = express() // 对express模块进行实例化
    
    app.use(express.json()) // express.json()函数是express中的内置中间件函数,它使用body-parser解析带有json有效负载的传入请求
    
    // 测试服务器是否搭建成功
    app.get('/', (req, res) => {
        res.send('你已经成功了~~')
    })
    
    app.listen(3030, () => {
        console.log('服务器开启在3030端口...')
    })
    

    进入index.js所在目录的命令行窗口,然后使用node index.js命令运行
    当出现以下结果时,说明服务器已经搭建成功了
    在这里插入图片描述
    然后封装一个连接数据库的函数,并将连接方法进行返回

    // 封装连接数据数据的方法
    function Db() {
        let conn = mysql.createConnection({
            host: 'localhost', // 主机名,默认为localhost
            port: '3306', // MySql连接端口,3306为默认端口号
            user: 'root', // 连接数据库的用户名
            password: '123456', // 密码
            database: 'demo' // 数据库名
        })
        conn.connect((err) => {
            if (err) throw err
        })
        return conn // 将封装好的连接方法进行返回
    }
    

    api.http文件中编写操作数据库的具体数据,完整的api.http代码如下

    // api.http
    @url = http://localhost:3030 // 设置的端口号是3030
    
    POST {{url}}/addData
    Content-Type: application/json
    
    {
        "username": "root",
        "password": "123456",
        "sex": "女",
        "age": "23"
    }
    
    ### 这是注释,必须写,用来分隔不同路由
    DELETE {{url}}/deleteData?username=bbb
    
    ###
    PUT {{url}}/updateData
    Content-Type: application/json
    
    {
        "username": "root",
        "age": "27"
    }
    
    ###
    GET {{url}}/selectData?username=root
    

    上面一切准备工作做好以后,就可以实现数据库的增删改查了

    添加数据

    // 添加数据
    app.post('/addData', (req, res) => {
        let { username, password, sex, age } = req.body
        let conn = Db() // 建立连接
        let sql = `insert into users(username, password, sex, age) values('${username}', '${password}', '${sex}', '${age}')`
        conn.query(sql, (err, result) => {
            if(err){
                console.log(err)
            } else{
                res.send(result)
            }
        })
        conn.end() // 关闭连接
    })
    

    没有执行添加数据之前的数据表如下
    在这里插入图片描述
    点击Send Request发送请求,请求结果如下
    在这里插入图片描述
    请求成功后的数据表如下
    在这里插入图片描述

    删除数据

    // 删除数据
    app.delete('/deleteData', (req, res) => {
        let { username } = req.query
        let conn = Db()
        let sql = `delete from users where username = '${username}'`
        conn.query(sql, (err, result) => {
            if(err){
                console.log(err)
            } else{
                res.send(result)
            }
        })
        conn.end()
    })
    

    删除之前的数据表如下
    在这里插入图片描述
    api.http文件中的操作和添加数据时一样,但要发送delete 请求
    删除之后的数据表如下
    在这里插入图片描述

    修改数据

    // 修改数据
    app.put('/updateData', (req, res) => {
        let { username, age } = req.body
        let conn = Db()
        let sql = `update users set age = '${age}' where username = '${username}'`
        conn.query(sql, (err, result) => {
            if(err){
                console.log(err)
            } else{
                res.send(result)
            }
        })
        conn.end()
    })
    

    修改数据之前数据表如下
    在这里插入图片描述
    api.http文件中的操作和添加数据时一样,但要发送put请求
    修改数据之后数据表如下,可以看出年龄已经发生了变化
    在这里插入图片描述

    查询数据

    // 查找数据
    app.get('/selectData', (req, res) => {
        let { username } = req.query
        let conn = Db()
        let sql = `select * from users where username = '${username}'`
        conn.query(sql, (err, result) => {
            if(err){
                console.log(err)
            } else{
                res.send(result)
            }
        })
        conn.end()
    })
    

    api.http文件中的操作和添加数据时一样,但要发送get请求
    数据表中数据如下
    在这里插入图片描述
    查询结果如下
    在这里插入图片描述
    以上就实现了Node操作MySql的增删改查操作,完整的index.js代码如下,api.http完整代码在上方

    // index.js
    const express = require('express')
    const mysql = require('mysql') // 引入下载的两个模块
    
    const app = express() // 对express模块进行实例化
    
    app.use(express.json()) // express.json()函数是express中的内置中间件函数,它使用body-parser解析带有json有效负载的传入请求
    
    // 封装连接数据数据的方法
    function Db() {
        let conn = mysql.createConnection({
            host: 'localhost', // 主机名,默认为localhost
            port: '3306', // MySql连接端口,3306为默认端口号
            user: 'root', // 连接数据库的用户名
            password: '123456', // 密码
            database: 'demo' // 数据库名
        })
        conn.connect((err) => {
            if (err) throw err
        })
        return conn // 将封装好的连接方法进行返回
    }
    
    // 测试服务器是否搭建成功
    app.get('/', (req, res) => {
        res.send('你已经成功了~~')
    })
    
    // 增加数据
    app.post('/addData', (req, res) => {
        let { username, password, sex, age } = req.body
        let conn = Db() // 建立连接
        let sql = `insert into users(username, password, sex, age) values('${username}', '${password}', '${sex}', '${age}')`
        conn.query(sql, (err, result) => {
            if(err){
                console.log(err)
            } else{
                res.send(result)
            }
        })
        conn.end() // 关闭连接
    })
    
    // 删除数据
    app.delete('/deleteData', (req, res) => {
        let { username } = req.query
        let conn = Db()
        let sql = `delete from users where username = '${username}'`
        conn.query(sql, (err, result) => {
            if(err){
                console.log(err)
            } else{
                res.send(result)
            }
        })
        conn.end()
    })
    
    // 修改数据
    app.put('/updateData', (req, res) => {
        let { username, age } = req.body
        let conn = Db()
        let sql = `update users set age = '${age}' where username = '${username}'`
        conn.query(sql, (err, result) => {
            if(err){
                console.log(err)
            } else{
                res.send(result)
            }
        })
        conn.end()
    })
    
    // 查找数据
    app.get('/selectData', (req, res) => {
        let { username } = req.query
        let conn = Db()
        let sql = `select * from users where username = '${username}'`
        conn.query(sql, (err, result) => {
            if(err){
                console.log(err)
            } else{
                res.send(result)
            }
        })
        conn.end()
    })
    
    app.listen(3030, () => {
        console.log('服务器开启在3030端口...')
    })
    

    二、使用Promise结合async、await实现增删改查

    Promise是一个异步装载容器,能够结合asyncawait将异步操作转化为同步操作,进而能够解决回调地狱问题
    和上面一样,在index_Promise.js文件中编写代码,创建一个简单的服务器

    const express = require('express')
    const mysql = require('mysql')
    
    const app = express()
    
    app.use(express.json())
    
    // 测试
    app.get('/', (req, res) => {
        res.send('您成功了!!')
    })
    
    app.listen(4040, () => {
        console.log('服务器启动在4040端口...')
    })
    

    进入index_Promise.js所在目录的命令行窗口,然后使用node index_Promise.js命令运行
    当出现以下结果时,说明服务器已经搭建成功了
    在这里插入图片描述
    然后开始连接数据库

    // 连接数据库
    const Db = mysql.createConnection({
        host:'localhost',
        user:'root',
        password:'123456',
        database:'demo',
        port:3306
    })
    Db.connect((err)=> {
        if(err) throw err
    })
    

    封装Promise函数,实现对数据库的操作,并将结果通过一维数组返回

    // 封装Promise函数
    function Query(sql){
        return new Promise((resolve, reject) => {
            Db.query(sql, (err, result) => {
                if(!err){
                    resolve([null, result])
                } else{
                    resolve([err])
                }
            })
        })
    }
    

    封装处理错误信息函数,对错误信息的格式进行了统一处理

    // 封装处理错误信息函数
    function Error(options){
        let { status, message, result = [] } = options
        return {
            status,
            message,
            result
        }
    }
    

    封装处理正确结果函数,对返回的正确结果信息的格式进行了统一处理

    // 封装正确结果函数
    function Success(options){
        let { status = 200, message, result} = options
        return {
            status,
            message,
            result
        }
    }
    

    api_Promise.http文件中编写操作数据库的具体数据,完整的api_Promise.http代码如下

    // api_Promise.http
    @url = http://localhost:4040 // 这次设置的为4040端口
    
    POST {{url}}/addData
    Content-Type: application/json
    
    {
        "username": "张三",
        "password": "123456",
        "sex": "男",
        "age": "23"
    }
    
    ###
    DELETE {{url}}/deleteData?username=李四
    
    ###
    PUT {{url}}/updateData
    Content-Type: application/json
    
    {
        "username": "张三",
        "age": "25"
    }
    
    ###
    GET {{url}}/selectData?username=张三
    

    上面一切准备工作做好以后,就可以实现数据库的增删改查了

    添加数据

    // 添加数据
    app.post('/addData', async (req, res, next) => {
        let { username, password, sex, age } = req.body
        let sql = `insert into users(username, password, sex, age) values('${username}', '${password}', '${sex}',' ${age}')`
        let [err, result] = await Query(sql)
        if(err){
            res.send(Error({
                status: 500,
                message: '添加失败'
            }))
            return ;
        } 
        res.send(Success({
            message: '添加成功',
            result
        }))
    })
    

    添加前数据表如下
    在这里插入图片描述
    添加结果如下
    在这里插入图片描述
    添加后数据表内容如下
    在这里插入图片描述

    删除数据

    // 删除数据
    app.delete('/deleteData', async(req, res, next) => {
        let { username } = req.query
        let sql = `delete from users where username = '${username}'`
        let [err, result] = await Query(sql)
        if(err){
            res.send(Error({
                status: 500,
                message: '删除失败'
            }))
            return ;
        } 
        res.send(Success({
            message: '删除成功',
            result
        }))
    })
    

    删除前数据表内容如下
    在这里插入图片描述
    删除后数据表内容如下
    在这里插入图片描述

    修改数据

    // 修改数据
    app.put('/updateData', async(req, res, next) => {
        let { username, age } = req.body
        let sql = `update users set age = '${age}' where username = '${username}'`
        let [err, result] = await Query(sql)
        if(err){
            res.send(Error({
                status: 500,
                message: '修改失败'
            }))
            return ;
        } 
        res.send(Success({
            message: '修改成功',
            result
        }))
    })
    

    修改前数据表内容如下
    在这里插入图片描述
    修改后数据表内容如下,可以看出年龄已经发生了变化
    在这里插入图片描述

    查找数据

    // 查找数据
    app.get('/selectData', async(req, res, next) => {
        let { username } = req.query
        let sql = `select * from users where username = '${username}'`
        // let sql = `select * from users`
        let [err, result] = await Query(sql)
        if(err){
            res.send(Error({
                status: 500,
                message: '查找失败'
            }))
            return ;
        } 
        res.send(Success({
            message: '查找成功',
            result
        }))
    })
    

    数据表中内容如下
    在这里插入图片描述
    查找数据的结果如下
    在这里插入图片描述
    以上就实现了Promise结合asyncawait操作MySql的增删改查操作,完整的index_Promise.js代码如下,api_Promise.http完整代码在上方

    // index_Promise.js
    const express = require('express')
    const mysql = require('mysql')
    
    const app = express()
    
    app.use(express.json())
    
    // 连接数据库
    const Db = mysql.createConnection({
        host:'localhost',
        user:'root',
        password:'123456',
        database:'demo',
        port:3306
    })
    Db.connect((err)=> {
        if(err) throw err
    })
    
    // 封装Promise函数
    function Query(sql){
        return new Promise((resolve, reject) => {
            Db.query(sql, (err, result) => {
                if(!err){
                    resolve([null, result])
                } else{
                    resolve([err])
                }
            })
        })
    }
    
    // 封装处理错误信息函数
    function Error(options){
        let { status, message, result = [] } = options
        return {
            status,
            message,
            result
        }
    }
    
    // 封装正确结果函数
    function Success(options){
        let { status = 200, message, result} = options
        return {
            status,
            message,
            result
        }
    }
    
    // 测试
    app.get('/', (req, res) => {
        res.send('您成功了!!')
    })
    
    // 添加数据
    app.post('/addData', async (req, res, next) => {
        let { username, password, sex, age } = req.body
        let sql = `insert into users(username, password, sex, age) values('${username}', '${password}', '${sex}',' ${age}')`
        let [err, result] = await Query(sql)
        if(err){
            res.send(Error({
                status: 500,
                message: '添加失败'
            }))
            return ;
        } 
        res.send(Success({
            message: '添加成功',
            result
        }))
    })
    
    // 删除数据
    app.delete('/deleteData', async(req, res, next) => {
        let { username } = req.query
        let sql = `delete from users where username = '${username}'`
        let [err, result] = await Query(sql)
        if(err){
            res.send(Error({
                status: 500,
                message: '删除失败'
            }))
            return ;
        } 
        res.send(Success({
            message: '删除成功',
            result
        }))
    })
    
    // 修改数据
    app.put('/updateData', async(req, res, next) => {
        let { username, age } = req.body
        let sql = `update users set age = '${age}' where username = '${username}'`
        let [err, result] = await Query(sql)
        if(err){
            res.send(Error({
                status: 500,
                message: '修改失败'
            }))
            return ;
        } 
        res.send(Success({
            message: '修改成功',
            result
        }))
    })
    
    // 查找数据
    app.get('/selectData', async(req, res, next) => {
        let { username } = req.query
        let sql = `select * from users where username = '${username}'`
        // let sql = `select * from users`
        let [err, result] = await Query(sql)
        if(err){
            res.send(Error({
                status: 500,
                message: '查找失败'
            }))
            return ;
        } 
        res.send(Success({
            message: '查找成功',
            result
        }))
    })
    
    app.listen(4040, () => {
        console.log('服务器启动在4040端口...')
    })
    

    以上就是两种方式实现Node操作MySql进行数据的增删改查,如果有看不懂的地方欢迎留言~~

    展开全文
  • 主要介绍了Node.js对MongoDB进行增删改查操作 ,需要的朋友可以参考下
  • 使用nodejs+express操作文件,是数据持久化,实现数据的增删改查操作!
  • 安装mysql驱动 npm install mysql --save 插入数据 /* 插入数据 */ // 加载数据库驱动 const mysql = require('mysql');...const connection = mysql.createConnection({ host: 'localhost', // 数据库所在的...
    • 安装mysql驱动
    npm install mysql --save
    • 插入数据
    /*
        插入数据
    */
    // 加载数据库驱动
    const mysql = require('mysql');
    // 创建数据库连接
    const connection = mysql.createConnection({
        host: 'localhost', // 数据库所在的服务器的域名或者IP地址
        user: 'root', // 登录数据库的账号
        password: '', // 登录数据库的密码
        database: 'book' // 数据库名称
    });
    // 执行连接操作
    connection.connect();
    
    let sql = 'insert into book set ?'
    let data = {
        name : '明朝那些事',
        author : '当年明月',
        category : '文学',
        description : '明朝的历史'
    }
    // 操作数据库
    connection.query(sql,data, function(error, results, fields) {
        if (error) throw error;
        // console.log(results);
        if(results.affectedRows == 1){
            console.log('数据插入成功');
        }
    });
    // 关闭数据库
    connection.end();
    • 删除数据
    /*
        删除数据
    */
    // 加载数据库驱动
    const mysql = require('mysql');
    // 创建数据库连接
    const connection = mysql.createConnection({
        host: 'localhost', // 数据库所在的服务器的域名或者IP地址
        user: 'root', // 登录数据库的账号
        password: '', // 登录数据库的密码
        database: 'book' // 数据库名称
    });
    // 执行连接操作
    connection.connect();
    
    let sql = 'delete from book where id = ?';
    let data = [9];
    
    // 操作数据库
    connection.query(sql,data, function(error, results, fields) {
        if (error) throw error;
        // console.log(results);
        if(results.affectedRows == 1){
            console.log('删除成功');
        }
    });
    // 关闭数据库
    connection.end();
    • 更新数据
    /*
        更新数据
    */
    // 加载数据库驱动
    const mysql = require('mysql');
    // 创建数据库连接
    const connection = mysql.createConnection({
        host: 'localhost', // 数据库所在的服务器的域名或者IP地址
        user: 'root', // 登录数据库的账号
        password: '', // 登录数据库的密码
        database: 'book' // 数据库名称
    });
    // 执行连接操作
    connection.connect();
    
    let sql = 'update book set name=?,author=?,category=?,description=? where id=?';
    let data = ['浪潮之巅','吴军','计算机','IT巨头的兴衰史',8];
    
    // 操作数据库
    connection.query(sql,data, function(error, results, fields) {
        if (error) throw error;
        // console.log(results);
        if(results.affectedRows == 1){
            console.log('更新成功');
        }
    });
    // 关闭数据库
    connection.end();
    • 查询数据
    /*
        查询数据
    */
    // 加载数据库驱动
    const mysql = require('mysql');
    // 创建数据库连接
    const connection = mysql.createConnection({
        host: 'localhost', // 数据库所在的服务器的域名或者IP地址
        user: 'root', // 登录数据库的账号
        password: '', // 登录数据库的密码
        database: 'book' // 数据库名称
    });
    // 执行连接操作
    connection.connect();
    
    let sql = 'select * from book where id = ?';
    let data = [6];
    
    // 操作数据库
    connection.query(sql,data, function(error, results, fields) {
        if (error) throw error;
        console.log(results[0].name);
        // console.log(results);
    });
    // 关闭数据库
    connection.end();

     

    展开全文
  • 最近看了廖雪峰的js教程里面有一章节专门讲的node.js(https://www.liaoxuefeng.com/wiki/001434446689867b27157e896e74d51a89c25cc8b43bdb3000/001434501245426ad4b91f2b880464ba876a8e3043fc8ef000),感觉很不错...
  • 实现图书的增删改查 1.分析 2.文件 生成json文件包 F:\others\XAMPP\htdocs\Epr\mybook>npm init -y Wrote to F:\others\XAMPP\htdocs\Epr\mybook\package.json: { "name": "mybook", "version": "1.0.0", ...
  • 主要介绍了node.js使用mongoose操作数据库实现购物车的增、删、改、查功能,结合实例形式详细分析了node.js使用mongoose框架操作MongoDB数据实现购物车增删改查相关技巧与使用注意事项,需要的朋友可以参考下
  • nodejs 开发一个小demo,用于初学者学习,内含登录以及增删改查功能。
  • 主要介绍了详解利用nodejs对本地json文件进行增删改查,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
  • node.js封装mongodb增删改查函数的操作 mongo使用是,我们首先用npm install mongodb,先来下载我们使用的mongodb包,下载后应该是3.0以上的版本,早一点的是2.0的版本,2.0版本和3.0版本在语法使用上还是有差异的,...
  • http.js // 服务器启动模块 var http = require('http'); var luyou = require('./luyou'); // 创建服务 var server = http.createServer(); // 调用luyou模块中的binds方法,设置监听事件 luyou.binds(server); //...
  • node.js+express+mysql实现增删改查+分页,以及图片上传操作
  • 本文给大家分享的是使用node.js实现对mysql数据库的增删改查操作,有需要的小伙伴可以参考下,希望对大家学习node有所帮助。
  • node-mysql实现增删改查

    2019-01-05 12:35:11
    node-mysql实现增删改查 环境需求:安装node.js 解压项目npm install 下载项目中所需要的脚手架依赖 npm run 运行项目 测试地址http://127.0.0.1:3000/dist/index.html#/
  • 写一个js用来配置 const express = require('express'); const bodyParser = require('body-parser'); const server = express(); /** * 配置跨域请求头 */ server.all('*', function(req, res, next) { // ...
  • 接着使用nodejs对数据库进行增删改查: .【活动】2017 CSDN博客专栏评选 【评论送书】SQL优化、深度学习、数据科学家 CSDN日报20170527 ——《人机大战,历史的见证》 CSDN 日报 | 4.19-5.19 上榜作者排行出炉 ...
  • 使用node.js平台连接mongodb数据库; 文章目录实现效果实现步骤第一步第二步第三步 实现效果 mongodb是一个非关系型数据库,数据结构类似与json,在实现连接之前,需要安装好node.js平台和mongodb数据库。为了显示...
  • 使用nodejs操作mongodb,并使用express实现增删改查1. 本地环境及项目结构展示1.1 本地环境1.2 项目结构图1.3 案例介绍 - 学生档案管理2. 数据库环境搭建2.1 Mongoose第三方包创建一个表格设定内容居中、居左、居右...
  • 初学node.js的笔记
  • Node.js实现对MySQL数据库的增删改查

    多人点赞 2021-10-11 18:22:20
    如何对MySQL数据库进行增删改查操作? 操作数据库的具体步骤是什么?
  • NODEJS数据库增删改查

    2021-11-04 20:19:32
    // 当有了构造函数模型后,就可以使用构造函数对user集合的数据为所欲为,进行修改 // 增删改查 //添加数据 var admin = new User({ username: 'admin', password: '123456', email: 'admin@admin.com', }) admin....
  • 主要介绍使用Node.js操作mysql数据库增删改查的相关资料,需要的朋友可以参考下
  • 在本篇文章中我们将实现基本的数据交互并实现简单的增删改查。如果你还未阅读上篇文章请移步阅读~~~ 1. 在上篇文章的项目基础上配置MySQL 确保你电脑中已安装了MySQL环境,我们使用的IDE为Navicat. 新建test数...
  • node.js +express +ajax + mysql 对数据库增删改查,数据库有用户表和商品列表

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 13,362
精华内容 5,344
关键字:

node.js增删改查