标签:string 重复 keyword ken pop 计算 mode upd push
class User(Document): email = StringField(required=True) first_name = StringField(max_length=50) last_name = StringField(max_length=50)
文档都是继承Document类。
预留:
字段类型:
ListField(StringField(max_length=30))
字段限制:
class Post(Document): title = StringField(max_length=120, required=True) author = ReferenceField(User) meta = {‘allow_inheritance‘: True} class TextPost(Post): content = StringField() class ImagePost(Post): image_path = StringField() class LinkPost(Post): link_url = StringField()
只需要再父类的meta的 ‘allow_inheritance‘ 设置为True
一篇文章post内的所有评论comments直接嵌入这篇文章的内部是mongodb常见的思路,首先创建一个comments的model:
class Comment(EmbeddedDocument): content = StringField() name = StringField(max_length=120)
这个model继承了EmbeddedDocument类,声明了他就是一个内嵌的文档,它不会在数据库里有个专门的文档保存,例如post这样的文档。post的model应该这样写:
class Post(Document): title = StringField(max_length=120, required=True) author = ReferenceField(User) tags = ListField(StringField(max_length=30)) comments = ListField(EmbeddedDocumentField(Comment))
ReferenceField这个字段似乎是一个外键,创建model是指定reverse_delete_rule的值,可以设定关联删除的规则,如:
class Post(Document): title = StringField(max_length=120, required=True) author = ReferenceField(User, reverse_delete_rule=CASCADE) tags = ListField(StringField(max_length=30)) comments = ListField(EmbeddedDocumentField(Comment))
此例中reverse_delete_rule的值设定为CASCADE,这样如果删除了一个用户,用户下所有的关联的post都会被删除。更多字段查询ReferenceField API
现在我们可以添加数据了,写法有两种。如:
ross = User(email=‘ross@example.com‘, first_name=‘Ross‘, last_name=‘Lawley‘).save()
再如:
ross = User(email=‘ross@example.com‘) ross.first_name = ‘Ross‘ ross.last_name = ‘Lawley‘ ross.save()
以上两种都是可以的。注意它可以用属性赋值的语法。如果save()了之后,又修改了属性,再save()就可以了,非常方便。
添加几个数据之后,我们可以来使用这些数据了。所有的model,例如上面的Post,User,都有一个objects属性,可以检索出此类下所有的文档。例如我们用继承自Post类的TextPost做个最简单的示范。
for post in TextPost.objects: print post.content
这样会print出所有属于TextPost的文档的content。如果用Post.objects,可以得到所有属于Post或者继承自Post的model实例化的文档,这是一个QuerySet对象,(类似一个游标对象,不知道对不对)。如:
for post in Post.objects: print post.title print ‘=‘ * len(post.title) if isinstance(post, TextPost): print post.content if isinstance(post, LinkPost): print ‘Link:‘, post.link_url
可见objects的类是不一样的,只是父类都是Post。
检索指定字段的值的文档也很方便,例:
for post in Post.objects(tags=‘mongodb‘): print post.title
这样就能检索出tags里有‘mongodb‘的文档。我觉得很方便,普通的查询条件如name=‘foo‘
这样的写法很正常,但tags是一个列表,用这样的写法,直接给个值他就能自己遍历判断是否是列表里的一个值,隐去了列表这个细节,很赞。
objects对象和sqlAlchemy的游标一样,也可以调用first()或者count(),意思都是一样。如:
num_posts = Post.objects(tags=‘mongodb‘).count() print ‘Found %d posts with tag "mongodb"‘ % num_posts
mongoengine连接数据可也很方便,最简单的传入数据库名如:
from mongoengine import connect
connect(‘project1‘)
connect还接收, name(数据库名),username,password,host等参数。
新建model的时候可以指定model可以属于哪个数据库,可以都添加进来例:
class User(Document): name = StringField() meta = {"db_alias": "user-db"} # 根据元属性确认哪一个数据库 class Book(Document): name = StringField() meta = {"db_alias": "book-db"}# 根据元属性确认哪一个数据库
class AuthorBooks(Document):
author = ReferenceField(User)
book = ReferenceField(Book)
meta = {"db_alias": "users-books-db"} # 根据元属性确认哪一个数据库
不过这些数据库先要用connet连接。
model表虽然设计了存储的数据库,但是有些数据需要存储到另一个数据库怎么办。可以转换:
from mongoengine.context_managers import switch_db class User(Document): name = StringField() meta = {"db_alias": "user-db"} with switch_db(User, ‘archive-user-db‘) as User: User(name="Ross").save() # Saves the ‘archive-user-db‘
这样,应该默认保存在“user-db”这个数据库里的User,现在是作为“archive-user-db”的User保存了。这是跨db的保存。
同样mongoegnine也支持collection的转换, 如:
from mongoengine.context_managers import switch_collection class Group(Document): name = StringField() Group(name="test").save() # Saves in the default db with switch_collection(Group, ‘group2000‘) as Group: Group(name="hello Group 2000 collection!").save() # Saves in group2000 collection
保存到里一个集合,第一个参数为需要转换的model,第二个为目标集合名,最后的model名可以不变。
这是一个设置相关document的fields,如:
class User(Document): name = StringField() class Page(Document): content = StringField() author = ReferenceField(User) john = User(name="John Smith") john.save() post = Page(content="Test Page") post.author = john post.save()
这样就可以引用了。
可以用ListField保存ReferenceField的方法来保存一对多的关系。例:
class User(Document): name = StringField() class Page(Document): content = StringField() authors = ListField(ReferenceField(User)) bob = User(name="Bob Jones").save() john = User(name="John Smith").save() Page(content="Test Page", authors=[bob, john]).save() Page(content="Another Page", authors=[john]).save() # Find all pages Bob authored Page.objects(authors__in=[bob]) # Find all pages that both Bob and John have authored Page.objects(authors__all=[bob, john]) # Remove Bob from the authors for a page. Page.objects(id=‘...‘).update_one(pull__authors=bob) # Add John to the authors for a page. Page.objects(id=‘...‘).update_one(push__authors=john)
一次插入和删除一条关联可见最后两行,多个的方法还不知道。
如果关联的文档发生了变化,如何同步改变呢?例如ReferenceField在子级的多对一,一对一关系,如何能删除了关联的父级,子级也一并删除呢?
class Parent(Document): name = StringField() class Child(Document): name = StringField() parent = ReferenceField(Parent, reverse_delete_rule=CASCADE)
定义一个反向删除的规则,CASCADE,就能一并删除了。
其实用这样的多对一的方式做到一对多并不方便,这个应用场景更多是一对一的关联。那如何方便的一对多呢。ListField:
class Child(Document): name = StringField() class Parent(Document): name = StringField() child = ListField(ReferenceField(Child, reverse_delete_rule=PULL))
首先子级要先定义,应为父级的ReferenceField要传入子级的类。父级定义一个列表保存所有子级ReferenceField。反向删除规则为PULL,这样删除一个child,他的关联就会自动从父级的ListField中删掉了。
另外还有DO_NOTHING,DENY,NULLIFY。
另外GenericReferenceField不需要传入关联类,可以任意指定。
这个库默认保存的文档是定义的类的缩写加下划线,可以用meta = {‘collection‘: ‘YourDocument‘}
来设置你想要的文档名称
如果需要限制一个文档的数量或者大小,可以用meta = {‘max_documents‘: 1000, ‘max_size‘: 2000000}
再meta中放入ordering,可以指定文档的默认排序方式,例如meta = {‘ordering‘: [‘-published_date‘]}
,不过order_by()方法的优先级更高。
文档调用save()时,如果定义了clean,会先调用clean,如:
class Essay(Document): status = StringField(choices=(‘Published‘, ‘Draft‘), required=True) pub_date = DateTimeField() def clean(self): """Ensures that only published essays have a `pub_date` and automatically sets the pub_date if published and not set""" if self.status == ‘Draft‘ and self.pub_date is not None: msg = ‘Draft entries should not have a publication date.‘ raise ValidationError(msg) # Set the pub_date for published items if not set. if self.status == ‘Published‘ and self.pub_date is None: self.pub_date = datetime.now()
ne – not equal to,不等于 lt – less than,小于 lte – less than or equal to,小于或等于 gt – greater than,大于 gte – greater than or equal to,大于或等于 not – negate a standard check, may be used before other operators (e.g. Q(age__not__mod=5)),否,与其他操作符一起用 in – value is in list (a list of values should be provided),提供一个列表,数据库值在列表内 nin – value is not in list (a list of values should be provided),提供一个列表,数据库值不在列表内 mod – value % x == y, where x and y are two provided values,整除 all – every item in list of values provided is in array,提供的列表元素都在数据库数组内 size – the size of the array is,数据库数组的大小 exists – value for field exists,field存在
exact – string field exactly matches value,完全匹配 iexact – string field exactly matches value (case insensitive),完全匹配,不区分大小写 contains – string field contains value,包含 icontains – string field contains value (case insensitive),包含,不区分大小写 startswith – string field starts with value,开始于 istartswith – string field starts with value (case insensitive),开始于,不区分大小写 endswith – string field ends with value,结束于 iendswith – string field ends with value (case insensitive),结束于,不区分大小写 match – performs an $elemMatch so you can match an entire document within an array,匹配?
如果一个域是个列表,同样可以传入一个元素,这样做的意思是检索所有这个列表域中包含这个元素的文档,例:
class Page(Document): tags = ListField(StringField()) # This will match all pages that have the word ‘coding‘ as an item in the # ‘tags‘ list Page.objects(tags=‘coding‘)
当然也可以指定这个列表域的序号来匹配,如:
Page.objects(tags__0=‘db‘)
这样即是匹配列表域第一个元素为‘db’的文档
如果对列表检索的内的结果需要分割,可如:
# comments - skip 5, limit 10 Page.objects.fields(slice__comments=[5, 10])
可以使用limit()和skip()方法,但是比较好的是:
# Only the first 5 people users = User.objects[:5] # All except for the first 5 people users = User.objects[5:] # 5 users, starting from the 11th user found users = User.objects[10:15]
可以定义自己的object方法:
class BlogPost(Document): title = StringField() date = DateTimeField() @queryset_manager def objects(doc_cls, queryset): # This may actually also be done by defining a default ordering for # the document, but this illustrates the use of manager methods return queryset.order_by(‘-date‘)
这样可行,但是也别闲着没事干去改默认的函数,还是自己定义一个吧:
class BlogPost(Document): title = StringField() published = BooleanField() @queryset_manager def live_posts(doc_cls, queryset): return queryset.filter(published=True) BlogPost(title=‘test1‘, published=False).save() BlogPost(title=‘test2‘, published=True).save() assert len(BlogPost.objects) == 2 assert len(BlogPost.live_posts()) == 1
计算一个域的总和,使用sum():
yearly_expense = Employee.objects.sum(‘salary‘)
计算一个域的平均值,使用average():
mean_age = User.objects.average(‘age‘)
使用only()只会得到文档中的某个域,以及是默认值的域,如:
class Film(Document): title = StringField() year = IntField() rating = IntField(default=3) Film(title=‘The Shawshank Redemption‘, year=1994, rating=5).save() f = Film.objects.only(‘title‘).first() f.title # ‘The Shawshank Redemption‘ f.year # None f.rating # default value 3
exclude()是和它相反的方法。
另外,如果用了only(),之后有需要其他的值了,可以使用reload()
可以使用update_one(), update() 和 modify() 方法对 QuerySet 进行更新,和使用modify() 和 save() 对一个文档进行更新。下面是一些搭配使用
的修改符:
set – set a particular value,设置某个值 unset – delete a particular value (since MongoDB v1.3),删除某个值 inc – increment a value by a given amount,增加 dec – decrement a value by a given amount,减少 push – append a value to a list,增加列表一个值 push_all – append several values to a list,增加列表多个值(传入一个列表) pop – remove the first or last element of a list depending on the value,取出一个列表最前或最后的值 pull – remove a value from a list,删除一个列表的值 pull_all – remove several values from a list,删除一个列表多个值 add_to_set – add value to a list only if its not in the list already,加入列表一个值,如果它之前不在其中。
这些修改符和检索操作符用法差不多,只是他们在域名之前:
post = BlogPost(title=‘Test‘, page_views=0, tags=[‘database‘]) post.save() BlogPost.objects(id=post.id).update_one(inc__page_views=1) post.reload() # the document has been changed, so we need to reload it post.page_views # 1 BlogPost.objects(id=post.id).update_one(set__title=‘Example Post‘) post.reload() post.title # ‘Example Post‘ BlogPost.objects(id=post.id).update_one(push__tags=‘nosql‘) post.reload() post.tags # [‘database‘, ‘nosql‘]
如果没有指定修改符,那么默认是set,所以以下两句实际是相同的:
BlogPost.objects(id=post.id).update(title=‘Example Post‘) BlogPost.objects(id=post.id).update(set__title=‘Example Post‘)
常用查询方法
https://blog.csdn.net/weixin_42042680/article/details/87909424
个人实际示例
https://www.cnblogs.com/clbao/p/11428794.html
标签:string 重复 keyword ken pop 计算 mode upd push
原文地址:https://www.cnblogs.com/clbao/p/11640658.html