qliksense创建连接mongoDB的connector

Posted 2023-04-28

如图所示，只有这一个选项，请问连接mongoDB是这样操作吗？

参考技术A Mongodb+Thinkphp要先建立Model然后用D()方法创建数据库对象之后按ThinkPHP的文档来就能解决CURD问题了

MongoDB代码——Python篇

需要安装的库：pymongo

一、添加文档

from pymongo import MongoClient
# 连接服务器
conn = MongoClient("localhost", 27017)
# 连接数据库，mydb是数据库名
db = conn.mydb
# 获取集合，student是集合名
collection = db.student

# 添加文档
# collection.insert({"name":"abc", "age":19, "gender":1,"address":"北京", "isDelete":0})
# 添加多个文档
collection.insert([{"name":"abc1", "age":19, "gender":1,"address":"北京", "isDelete":0},{"name":"abc2", "age":19, "gender":1,"address":"北京", "isDelete":0}])

# 断开连接
conn.close()

二、查询文档

import pymongo
#用于ID查询
from bson.objectid import ObjectId

# 查询部分文档
res = collection.find({"age":{"$gt":18}})
for row in res:
    print(row)
    print(type(row))

# 查询所有文档
res = collection.find()
for row in res:
    print(row)
    print(type(row))

# 统计查询
res = collection.find({"age":{"$gt":18}}).count()
print(res)

# 根据id查询
res = collection.find({"_id":ObjectId("5995084b019723fe2a0d8d14")})
print(res[0])

# 排序，默认升序
# res = collection.find().sort("age")
# 降序需要 import pymongo
res = collection.find().sort("age", pymongo.DESCENDING)
for row in res:
    print(row)

# 分页查询
res = collection.find().skip(3).limit(5)
for row in res:
    print(row)

三、更新文档

collection.update({"name":"lilei"},{"$set":{"age":25}})

四、删除文档

# 按条件删除
collection.remove({"name":"lilei"})
# 全部删除
collection.remove()

 

完成