指令碼開發 / 聯結器物件 DFF.CONN / MongoDB

MongoDB 聯結器操作物件主要提供一些操作 MongoDB 的方法。

DFF.CONN(...) 引數如下：

引數	型別	必須 / 預設值	說明
connector_id	str	必須	聯結器 ID
database	str	None	指定資料庫

.db(...)

獲取資料庫操作物件，引數如下：

引數	型別	必須 / 預設值	說明
db_name	str	None	資料庫名。未傳遞名稱時，返回預設資料庫操作物件。

# 獲取預設資料庫物件
db = helper.db()
# 獲取指定資料庫物件
db = helper.db('some_db')
# 獲取集合物件
collection = db['some_collection']
# 查詢處理
data = collection.find_one()
# 寫成一行
data = helper.db('some_db')['some_collection'].find_one()

未傳入 db_name 時使用聯結器配置的預設資料庫；如果聯結器沒有配置預設資料庫，應顯式傳入資料庫名。

.list_databases(...)

返回當前連線可訪問的資料庫名稱列表。

database_names = helper.list_databases()

.list_collections(...)

返回指定資料庫中的集合名稱列表。

引數	型別	必須 / 預設值	說明
db_name	str	None	資料庫名；省略時使用聯結器配置的預設資料庫

collection_names = helper.list_collections('some_db')

.run_method(...)

.run_method(...) 是舊版相容方法，用於獲取資料庫列表或集合列表。新程式碼應優先使用 .list_databases(...) 和 .list_collections(...)。

引數	型別	必須 / 預設值	說明
method	str	必須	執行方法，列舉： list_database_names：列出資料庫 list_collection_names：列出集合
db_name	str	None	執行 list_collection_names 時可傳遞，指定資料庫； 不傳遞則為預設資料庫 必須以命名引數方式傳遞

db_list = helper.run_method('list_database_names')
collection_list = helper.run_method('list_collection_names')
collection_list = helper.run_method('list_collection_names', db_name='some_db')

具體查詢語法和格式請參考 MongoDB 官方文件。