讲一个简单的例子python连接mongodb做跨表跨库查询的正确姿势

1.数据准备

db.createCollection(customers);

101,name:

MongoClient(mongodb://admin:adminlocalhost:27017/)#

选择数据库和集合

list(db_orders.aggregate(pipeline))#

打印结果

经过代码测试会发现pipeline走到lookup结束customer_info为空lookup是作用于单个数据库下的不同集合之间的联合查询但不支持跨库而网络上充斥着所谓支持跨库查询的案例。

。

。

3.跨库查询

思考想象我们做的业务通常都是模块化的之间都是通过服务/应用层接口调用来实现的其底层正对应着不同的数据库。

比如常见的订单系统和用户系统因为集中式管理(单个数据库)容易造成性能瓶颈会按业务进行合理拆分也更容易复用和拓展。

所以所谓的跨库查询实际上就跟业务之间的通信是类似的这里并不是单库下的主外键查询问题而是实际场景中多库下多个服务之间的数据互通与一致性查询问题一般处理手段是将一些联合查询问题放到业务层解决当然针对做不同数据库的相同表做同步复制也是可以的不过显然这与业务拆分的初衷相违背了。

from

MongoClient(mongodb://admin:adminlocalhost:27017/)

client_db2

MongoClient(mongodb://admin:adminlocalhost:27017/)#

选择数据库和集合

client_db2.order_dbcustomers_collection

orders_collection

customers_data_dict.get(customer_id)if

matching_customer:#

matching_customer}result.append(merged_data)#

打印结果