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")