使用async.waterfall封装数据库查询

绝地灬酷狼 2022-04-11 09:16 66阅读 0赞

近来学习node.js，想到一个使用async.waterfall封装数据库访问的简单方法，代码很容易，一看就明白。  
　　需要注意的就是waterfall传入参数(使用第二个函数传入参数)、传出结果的方法。

var oracledb = require('oracledb');
    var dbConfig = require('./dbconfig');
    
    function doConnect(cb) {
       
    	oracledb.getConnection(
    		{
       
    			user          : dbConfig.user,
    			password      : dbConfig.password,
    			connectString : dbConfig.connectString
    		},
    		cb);
    };
    
    function doRelease(conn) {
       
    	conn.release(function (err) {
       
    		if (err)
    			console.error(err.message);
    	});
    };
    
    function doQuery(conn,sql,param, cb) {
       
    	console.log('sql='+sql+', param='+param);
    	conn.execute(
    		sql,
    		param, 
    		{ outFormat: oracledb.OBJECT }, 
    		function(err, result)
    		{
       
    			if (err) {
       
    				return cb(err, conn);
    			} else {
       
    				return cb(null, conn,result.rows);
    			}
    		});
    };
    
    function select(sql,param,callback){
       
    	var async = require('async');
    	async.waterfall([
    		doConnect,
    		function(conn,cb) {
       
    			cb(null, conn, sql, param);
    		},
    		doQuery
    	],function(err,conn,result){
       
    		if (err) { console.error("In waterfall error cb: ==>", err, "<=="); }
    		else{callback(result);}
    		if (conn){ doRelease(conn);}
    	});
    };
    
    module.exports.select = select;

使用示例：

var dbUtil = require('./server/util/DbUtil');//上面的文件
    
    dbUtil.select("select * from tab",{},function(result){
       
        console.log(result);
    });

发表评论取消回复

表情：

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

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

相关阅读

相关 mybatis手动封装查询结果

一、有些时候，我们类的属性名并不能与数据库中的列名一一对应，这时候可以使用resultMap接收查询结果，手动封装属性与列的映射关系二、先看没有手动封装时的查询结...

桃扇骨/ 2024年04月17日 18:00/ 0 赞/ 74 阅读

相关查询数据库连接池使用情况

适用于mysql show full PROCESSLIST show open tables where In_use > 0

骑猪看日落/ 2023年01月06日 11:52/ 0 赞/ 127 阅读

相关封装JPA动态查询（CriteriaQuery）

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][] 封装JPA动态查询（CriteriaQuery）

向右看齐/ 2022年10月01日 14:57/ 0 赞/ 308 阅读

相关 Android room数据库封装

一、背景平常咱们使用数据库的时候，基本操作都差不太多，增，删，改，查，但如果操作不同的数据时，就需要写较多的重复的代码，仅仅是因为操作的类对象变化了。下面咱们就通过泛型

朱雀/ 2022年09月12日 08:49/ 0 赞/ 252 阅读

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

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

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

相关 PHP封装一个数据库类，方便查询调用

<?php // 负责数据库连接 function connectDB(){ $con = mysqli_connect('localh

- 日理万妓/ 2022年05月24日 04:21/ 0 赞/ 217 阅读

相关 pymysql封装操作数据库

pymysql封装操作数据库安装pymysql 简单写操作简单读操作封装工具类多操作 %d format: a number is r

墨蓝/ 2022年04月13日 15:20/ 0 赞/ 356 阅读

相关使用async.waterfall封装数据库查询

　　近来学习node.js，想到一个使用async.waterfall封装数据库访问的简单方法，代码很容易，一看就明白。　　需要注意的就是waterfall传入参数(使用

绝地灬酷狼/ 2022年04月11日 09:16/ 0 赞/ 67 阅读

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

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

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

相关不用封装实体类查询出数据库中的值

public List<Map<String, Object>> findName() { // TODO Auto-generated

爱被打了一巴掌/ 2021年11月04日 18:02/ 0 赞/ 301 阅读