使用nodejs连接mysql数据库

使用nodejs连接mysql数据库

BUG集散地

2018-09-12 10:10 阅读 190 喜欢 0 nodejs mysql

使用nodejs 连接mysql数据库还是很简单的,有现成的模块可以直接调用。下面介绍下 mysql 的调用。

mysql 模块

使用模块mysql 异步处理async

定义mysql 配置
var config = {
    mysql :  {
        host : '127.0.0.1',
        port : '3306',
        user : 'root',
        password : 'root',
        database : 'picconvert'
    }
};
module.exports = config;
定义一个常用的mysql调用的工具类
 var mysql = require('mysql');

var config = require('../config/config');

var async = require('async');
// 使用连接池,提升性能
// var pool  = mysql.createPool($util.extend({}, $conf.mysql));
var pool  = mysql.createPool(config.mysql);

//1. 执行语句返回结果
var onebyone = function(list,callback){
    if(!list.length){
        list = [list];
    }
    return new Promise(function(resolve,reject){
        pool.getConnection(function (err, connection) {
            if (err) {
                reject(err);
            }
            connection.beginTransaction(function (err) {
                if (err) {
                    reject(err);
                }
                var funcAry = [];
                list.forEach(function (sql_param) {
                    var temp = function (cb) {
                        var sql = sql_param.sql;
                        var param = sql_param.params;
                        connection.query(sql, param||[], function (tErr, rows, fields) {
                            if (tErr) {
                                connection.rollback(function () {
                                    throw tErr;
                                });
                            } else {
                                cb(null,rows);
                            }
                        })
                    };
                    funcAry.push(temp);
                });

                async.parallel(funcAry, function (err, result) {
                    if (err) {
                        connection.rollback(function (err2) {
                            connection.release();
                            // connection.destroy();\
                            reject(err2);
                        });
                    } else {
                        connection.commit(function (err2, info) {
                            if (err2) {
                                console.log("执行事务失败," + err2);
                                connection.rollback(function (err3) {
                                    connection.release();
                                    // connection.destroy();
                                    reject(err3);
                                });
                            } else {
                                connection.release();
                                // connection.destroy();
                                resolve(result);
                            }
                        })
                    }
                });
            });
        }); 
    });

};

module.exports = onebyone;

上面可以执行多条sql 同步执行,然后获得返回结果进行处理。

如何调用
/**
操作attach表,修改数据
**/

var query = require('../lib/sql');

var sqls = {
    uploadOne : 'insert into attach (filePath,ip,browser,createTime,filedel,type) values (?,?,?,?,?,?) ',
    successOne : 'update attach set filedel=?,type=? where id=? ',
    failOne : 'update attach set filedel=1,type=0 where id=? ',
    getById : 'select * from attach where id=? ',
    getLastData : 'select * from attach where createTime <= date_sub(now(),interval 5 minute) and filedel=0',
    updateNewPath : 'update attach set targetPath=? where id=? '
};

module.exports = {
    /**
     * 上传一个新的图片文件,插入数据库
     **/
    uploadOne : function( data ){
        var list = {
            sql : sqls.uploadOne,
            params : [data.filePath,data.ip,data.browser,new Date(),0,0]
        };
        return query(list);
    },
    /***
       * 将文件处理完毕并成功下载,
       * 1.更新删除状态
       * 2.更新处理状态
     **/
    successOne : function( id ){
        var list = {
            sql : sqls.successOne,
            params : [1,1,id]
        };
        return query(list);
    },
    /***
     * 删除或替换
     *
     ***/
    failOne : function( id ,cb ){
        var list = {
            sql : sqls.failOne,
            params : [id]
        };
        return query(list);
    },
    /***
     * 根据ID获得信息
     *
     ***/
    getById : function( id ){
        var list = {sql : sqls.getById,params : [id]};
        return query(list);
    },
    /***
     * 获得距离当前5分钟之前的未处理的数据,并将对应的数据清空
     **/
    getLastData : function(){
        var list = {
            sql : sqls.getLastData,
            params : []
        };
        return query(list);
    },
    /**
     * 更新新的文件路径
     ***/
    updateNewPath : function(id,newPath){
        var list = {
            sql : sqls.updateNewPath,
            params : [newPath,id]
        };
        return query(list);
    }
};

直接定义sql语句,然后通过工具类调用查询数据并返回。 工具类中还用了promise,对promise还不熟悉,正在学习实践中... 以上就是通过nodejs 连接 mysql数据库的过程.. 目前在各种自学中.. 期待共同提高~大神请轻拍..

转载请注明出处: https://chrunlee.cn/article/mysql-nodejs-connect.html


如果对你有用的话,请赏给作者一个馒头吧 ...或帮点下页面底部的广告,感谢!!

赞赏支持
提交评论
评论信息(请文明评论)
暂无评论,快来快来写想法...
推荐
记录下通过nodejs调用imagemagick 的时候发现的一个错误,command failed -- crop .
前段时间学习到了nodejs的net模块这部分,正好想实现一个局域网内的文件下载小demo,噔噔噔噔... 兴趣推动 ,马上搞一搞。
之前在知乎上有看到,基本上都是一致的,这里提供一个nodejs版本的针对微信内dat文件进行处理恢复为图片的方法。
最近有接触到针对二维码进行识别的功能,然后对图片进行位置纠正、二维码扫描,并将数据进行整理。以下是通过nodejs做的,相对简单一些,没有太过严格,识别率也不是很高大约80%左右
学习爬虫的时候突然有想到想做一个音乐播放小站,可以给自己或朋友听,但是音乐哪里来呢??想到自己常听的豆瓣FM,就越发的想把这些音乐都拿下来,因此有了下文通过豆瓣FM批量抓取上万首音乐,目前已经3W+。
在通过axios读取页面的时候,经常会碰到gbk的编码,如果不进行转化的话,在获取信息或读取上都会很麻烦。
目前了解的有两个模块可以实现二维码的模块,一个是node-qrcode ,这个算是比较大众的,不过环境比较复杂,所以...连看都没看;还有一个是小众的 qr-image ,这个比较简单,没有其他环境依赖,安装即可用,因为要实现一个简单的在线二维码生成,就先用这个试试水了
互联网应用经常需要存储用户上传的图片,比如facebook相册。 facebook目前存储了2600亿张照片,总大小为20PB,每张照片约为80KB。用户每周新增照片数量为10亿。(总大小60TB),平均每秒新增3500张照片(3500次写请求),读操作峰值可以达到每秒百万次