node.js 增删改查

桃扇骨 2022-06-02 04:59 163阅读 0赞

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

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