任何人都可以发布一个使用node.js查询postgresql数据库的RXJS示例？

任何人都可以发布一个使用node.js查询postgresql数据库的RXJS示例？

谷歌似乎没有任何关于此…

问候

肖恩。

Answer 1

瞧！

 var Rx = require('rx'); var pg = require('pg'); var rowObservable = Rx.Observable.create(function(observer) { var pgClient = new pg.Client(); pgClient.connect(); var pgQuery = pgClient.query("SELECT * FROM information_schema.tables;"); pgQuery.on('error', observer.onError.bind(observer)); pgQuery.on('row', observer.onNext.bind(observer)); pgQuery.on('end', observer.onCompleted.bind(observer)); return pgClient.end.bind(pgClient); }); var subscription = rowObservable.subscribe(function(row) { console.log(row); }, function(err) { console.error(err); }, function() { subscription.dispose(); }); 

在这个例子中，客户端连接pgClient在处理订阅时closures。 其余的是很自我解释我认为:-)