使用node封装连接各类数据库

客官°小女子只卖身不卖艺 2022-04-05 10:53 172阅读 0赞

这篇文章直接指出**node如何连接mysql数据库**,**node如何连接mongodb**,**node如何连接redis**

**mysql连接:**

var mysql = require('mysql');
    //mysql配置
    var pool = mysql.createPool({    
        host:'192.168.1.1339',       //主机
        user:'index',            //MySQL认证用户名
        password:'123456',
        port:'3306',
        database:'ys_finance_dev'
    });
    /***使用案例****/
    pool.getConnection(function(err,connection) {  
        if(err) {  
            console.log("建立连接失败",err);  
        }else{  
            //成功链接
            
        }
         connection.release();//释放,如果不释放链接累计会越来越多,最终导致服务器cpu过高或者瘫痪
    }

**redis连接:**

var redis = require('redis'),
    	RDS_PORT = 6379,        //端口号
    	RDS_HOST = '192.168.1.171',    //服务器IP
    	RDS_OPTS = {},            //设置项
    	client = redis.createClient(RDS_PORT,RDS_HOST,RDS_OPTS);
    	client.on('ready',function(err){
    		if(err){
    			console.log(err)
    		}
    		console.log('ready')
    	})
        //报错监控,以防万一
        client.on("error", function (err) {
           report('RedisError');
           logger.error("Error " + err);
        });
     
        var client = redis.createClient({
            retry_strategy: function (options) {
                if (options.error.code === 'ECONNREFUSED') {
                    report('连接被拒绝');
                }
                if (options.times_connected > 10) {
                    report('重试连接超过十次');        
                }
            // reconnect after 
                return Math.max(options.attempt * 100, 3000);
            }
        });
        //捕获异常,防止node进程中断
        function uncaughtExceptionHandler(err){
            if(err && err.code == 'ECONNREFUSED'){
                
            }else{
                process.exit(1);
            }
        }
        process.on('uncaughtException', uncaughtExceptionHandler);
    
        /**使用案例***/
        client.select('2', function(error){
            client.set("some key", "some val");
        }

**MongoDB连接:**

var MongoClient = require("mongodb").MongoClient;
    var DB_CONN_STR = "mongodb://localhost:27017/";
    module.exports = {
      mongoConnect: function(dbName,sucessCb,failCb){
        MongoClient.connect(DB_CONN_STR + dbName,(err,db) => {
          if(err){
    //      console.log(err)
            failCb(err)
          }else{
    //      console.log("数据库链接成功")
            sucessCb(db)
          }
        })
      }
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，172人围观）

还没有评论，来说两句吧...

相关阅读

相关如何使用 Node.js 连接和操作 MongoDB 数据库？

Node.js 是一种基于 JavaScript 的服务器端编程语言，而 MongoDB 是一个流行的 NoSQL 数据库。Node.js 可以与 MongoDB 集成，从而创

快来打我*/ 2023年10月13日 23:53/ 0 赞/ 98 阅读

相关 node学习(四)连接数据库

故心故心故心故心小故冲啊 -------------------- 文章目录 1.数据库连接 1.1通过脚本自动生成所有的数据模型对象

Dear 丶/ 2023年01月07日 01:27/ 0 赞/ 171 阅读

相关 node.js连接mysql数据库，封装成api。

导语：我们在写后台程序的时候，总要把一些数据写入到数据库中，所以合理的数据库函数调用是很有必要的，本文就写一写用node连接数据库，并且封装成函数。 1，创建文件con

清疚/ 2022年12月12日 04:37/ 0 赞/ 221 阅读

相关各类JDBC数据库连接方式

转自：[jdbc链接数据库大全][jdbc] 1、链接Sqlserver2000 驱动类 com.microsoft.jdbc.sqlserver.SQLS

悠悠/ 2022年08月23日 15:53/ 0 赞/ 242 阅读

相关 JSP连接各类数据库大全

现在有好多初学JSP的网友经常会问数据库怎么连接啊，怎么老出错啊？所以我集中的在这写篇文章供大家参考，其实这种把数据库逻辑全部放在jsp里未必是好的做法，但是有利于初学者学习，

迷南。/ 2022年08月13日 04:28/ 0 赞/ 231 阅读

相关 Node.js连接数据库总结

node.js连接mysql数据库在node中输入npm install mysql（注意安装路径）电脑必须安装mysql数据库（这是前提），创建一个数据库，建立

女爷i/ 2022年08月07日 04:44/ 0 赞/ 190 阅读

相关 java数据库连接池封装及使用

ConnectionPool类: package com.vl.sql; import java.sql.Connection; import

不念不忘少年蓝@/ 2022年08月04日 15:49/ 0 赞/ 188 阅读

相关 JDBCUtil类-封装数据库连接和关闭连接

> JDBC类是对获得数据库连接和关闭数据库连接的一个封装，在需要使用到数据库的时候，我们需要访问数据库，然后获得数据库连接，在一个程序或项目中难免会有多处需要使用到数据

﹏ヽ暗。殇╰゛Y/ 2022年05月21日 05:47/ 0 赞/ 260 阅读

相关 node.js连接mongoDB数据库

前面已经讲了mongoDB数据库的安装和使用，今天来研究一下node.js中如何连接和使用mongoDB数据库。方法一：mongoose连接一、配置mongoos

爱被打了一巴掌/ 2022年05月08日 05:58/ 0 赞/ 281 阅读

相关使用node封装连接各类数据库

这篇文章直接指出node如何连接mysql数据库,node如何连接mongodb,node如何连接redis mysql连接: var mysql = requir

客官°小女子只卖身不卖艺/ 2022年04月05日 10:53/ 0 赞/ 173 阅读