node使用mysql

因业务需求，自己封装了一些mysql方法，有不足之处请尽管提

安装

npm install mysql

使用

const mysql = require("mysql");

function handleError(){
    getConn()
}

function getConn(){
    var db = null;
    var pingInterval = null;
    var set = {
　　　　host:'localhost',
　　　　user = 'root',
　　　　password = 'root',
　　　　database = 'database',
　　　　multipleStatements: true
　　};
    if(db !== null){
        db.destroy();
        db = null;
    }
    db = mysql.createConnection(set)
    db.connect(function(err){
        if (err){
            setTimeout(connect,2000)
        }
    });
    db.on('error', handleError)
    // 每个小时ping一次数据库，保持数据库连接状态
    clearInterval(pingInterval);
    pingInterval = setInterval(() => {
        console.log('ping...');
        db.ping((err) => {
            if (err) {
                console.log('ping error: ' + JSON.stringify(err));
            }
        });
    }, 3600000);
    return db;
}

/**
 * @param {number} type 1是所有数据，2是获取只取一条，3是count（*）
 *  */ 
function execute(sql, type = 1){
    var promise = new Promise(function (resolve, reject){
        var db = getConn();
        db.query(sql, function (err, result) {
            if(err){
                console.log('[SELECT ERROR] - ', err.message);
                return
            }
            var resultStr = JSON.stringify(result);
            var json = JSON.parse(resultStr);
            if(type == 1){
                resolve(json)
            }else if(type == 2){
                resolve(json[0])
            }else if(type == 3){
                resolve(json[0]['count(*)'])
            }
        });
        db.end()
    })
    promise.then(function (value){
        return value
    },function (value){})
    return promise
}

/**
 * 批量执行sql
 * @param {sql} sql sql语句
 * @param {array} sql_param  要操作的数据（数组）
 */
function many_execute(sql, sql_param){
    if (sql_param == ""){
        return
    }
    var db = getConn()
    db.query(sql, [sql_param], function(err, result){
        if(err){
            console.log('[SELECT ERROR] - ', err.message)
            return
        }
        // console.log(result);
        return result;
    })
    db.end()
}

/**
 * 删除
 * @param {str} table 表名
 * @param {str} delSr where语句
 */
function del(table, delSr){
    execute("delete from "+ table +" where "+ delSr)
}

 /**
  * 修改
  * @param {str} table 表名
  * @param {str} editSr 修改字段语句
  * @param {str} where where语句
  */
  function edit(table, editSr, where){
      execute("update "+ table +" set "+ editSr +" where "+ where)
  }

 案例

删除某条数据

del("user", "id=1")

删除所有数据

del("user", "1=1")

批量添加数据

var addVal = [[1,2,3,4,5]];

many_execute( "insert into user(gid,min_order,link,source,keyword) values ?", addVal)

 获取数据

execute("select * from user")

获取数据总数

execute("select count(*) from user",3)

 修改一条数据

edit("user","age=1","id=1")

修改所有数据

edit("user","age=1","1=1")