from pymongo import MongoClient
import re
class MongoDB(object):
""""""
#----------------------------------------------------------------------
def __init__(self, host, port, database):
"""Constructor"""
self.host = host
self.port = port
self.database = database
self.conn = MongoClient(self.host, self.port)
self.coll = self.conn[self.database]
Mongo = MongoDB('127.0.0.1', 27017, 'wangzuxian')
#whois_dict = Mongo.coll['dirUrl'].find({'URL':re.compile('sh')})
#whois_dict = Mongo.coll['dirUrl'].find({"URL": {"$regex": "com|sh"}})
#query = Mongo.coll['liuxin_1129'].find({"漏洞名称": {"$regex": "Hadoop|Hive|Spark|HBase|HDFS|Hive|Tez|ambari|sqoop|Zookeeper|MapReduce|Kafka|Redis|Yarn|Oozie|impala|Storm|Flume","$options":"i"}},{"_id":0})
try:
whois_dict = Mongo.coll['dirUrl'].find({"$or":[{"URL":{"$regex":"com"}},{"URL":{"$regex":"sh"}}]})
except Exception,e:
print e
print whois_dict
s = whois_dict.distinct('URL')
for i in s:
print i
1 第一句查询
image.png
2 第二句查询
image.png
3 第三条查询
image.png
#模糊查询
query = Mongo.coll['dirUrl'].find({"URL": {"$regex": "com"}})
#多个模糊查询
query = Mongo.coll['dirUrl'].find({"URL": {"$regex": "com|sh"}})
#过滤字段
query = Mongo.coll['dirUrl'].find({}, {"_id":0, "key": 1})
#时间范围查询
query = Mongo.coll['dirUrl'].find({"URL": {"$gte": "2017-04-25"}})
query = Mongo.coll['dirUrl'].find({"URL": {"$gte": "2017-04-25", "$lt": "2017-04-26"}})
参考链接
https://docs.mongodb.com/manual/reference/operator/query/or/#op._S_or
