首页 > 代码库 > python Django教程 之 模型(数据库)、自定义Field、数据表更改、QuerySet API
python Django教程 之 模型(数据库)、自定义Field、数据表更改、QuerySet API
python Django教程 之 模型(数据库)、自定义Field、数据表更改、QuerySet API
一、Django 模型（数据库）
Django 模型是与数据库相关的，与数据库相关的代码一般写在 models.py 中，Django 支持 sqlite3, MySQL, PostgreSQL等数据库，只需要在settings.py中配置即可，不用更改models.py中的代码，丰富的API极大的方便了使用。
本节的代码：（Django 1.6, Python 2.7 测试环境）
大家按照我步骤来开始做：
django-admin.py startproject learn_models # 新建一个项目cd learn_models # 进入到该项目的文件夹django-admin.py startapp people # 新建一个 people 应用（app)
补充：新建app也可以用 python manage.py startapp people, 需要指出的是，django-admin.py 是安装Django后多出的一个命令，并不是指一个 django-admin.py 脚本在当前目录下。
那么project和app什么关系呢，一个项目一般包含多个应用，一个应用也可以用在多个项目中。
将我们新建的应用（people）添加到 settings.py 中的 INSTALLED_APPS中，也就是告诉Django有这么一个应用。
INSTALLED_APPS = ( ‘django.contrib.admin‘, ‘django.contrib.auth‘, ‘django.contrib.contenttypes‘, ‘django.contrib.sessions‘, ‘django.contrib.messages‘, ‘django.contrib.staticfiles‘, ‘people‘,)
我们打开 people/models.py 文件，修改其中的代码如下：
from django.db import models class Person(models.Model): name = models.CharField(max_length=30) age = models.IntegerField()
我们新建了一个Person类，继承自models.Model, 一个人有姓名和年龄。这里用到了两种Field，更多Field类型可以参考教程最后的链接。
我们来同步一下数据库
python manage.py syncdb # 进入 manage.py 所在的那个文件夹下输入这个命令 注意：Django 1.7 及以上的版本需要用以下命令python manage.py makemigrationspython manage.py migrate
我们会看到，Django生成了一系列的表，也生成了我们新建的people_person这个表，那么如何使用这个表呢？
Django提供了丰富的API, 下面演示如何使用它。
$ python manage.py shell >>> from people.models import Person>>> Person.objects.create(name="WeizhongTu", age=24)<Person: Person object>>>>
我们新建了一个用户WeizhongTu 那么如何从数据库是查询到它呢？
>>> Person.objects.get(name="WeizhongTu")<Person: Person object>>>>
我们用了一个 .objects.get() 方法查询出来符合条件的对象，但是大家注意到了没有，查询结果中显示<Person: Person object>，这里并没有显示出与WeizhongTu的相关信息，如果用户多了就无法知道查询出来的到底是谁，查询结果是否正确，我们重新修改一下 people/models.py
name 和 age 等字段中不能有 __（双下划线，因为在Django QuerySet API中有特殊含义（用于关系，包含，不区分大小写，以什么开头或结尾，日期的大于小于，正则等）
也不能有Python中的关键字，name 是合法的，student_name 也合法，但是student__name不合法，try, class, continue 也不合法，因为它是Python的关键字( import keyword; print(keyword.kwlist) 可以打出所有的关键字)
from django.db import models class Person(models.Model): name = models.CharField(max_length=30) age = models.IntegerField() def __unicode__(self): # 在Python3中使用 def __str__(self) return self.name
按CTRL + C退出当前的Python shell, 重复上面的操作，我们就可以看到:
新建一个对象的方法有以下几种：
Person.objects.create(name=name,age=age)
p = Person(name="WZ", age=23)
p.save()
p = Person(name="TWZ")
p.age = 23
p.save()
Person.objects.get_or_create(name="WZT", age=23)
这种方法是防止重复很好的方法，但是速度要相对慢些，返回一个元组，第一个为Person对象，第二个为True或False, 新建时返回的是True, 已经存在时返回False.
获取对象有以下方法：
Person.objects.all()
Person.objects.all()[:10] 切片操作，获取10个人，不支持负索引，切片可以节约内存
Person.objects.get(name=name)
get是用来获取一个对象的，如果需要获取满足条件的一些人，就要用到filter
Person.objects.filter(name="abc") # 等于Person.objects.filter(name__exact="abc") 名称严格等于 "abc" 的人
Person.objects.filter(name__iexact="abc") # 名称为 abc 但是不区分大小写，可以找到 ABC, Abc, aBC，这些都符合条件
Person.objects.filter(name__contains="abc") # 名称中包含 "abc"的人
Person.objects.filter(name__icontains="abc") #名称中包含 "abc"，且abc不区分大小写
Person.objects.filter(name__regex="^abc") # 正则表达式查询
Person.objects.filter(name__iregex="^abc")# 正则表达式不区分大小写
filter是找出满足条件的，当然也有排除符合某条件的
Person.objects.exclude(name__contains="WZ") # 排除包含 WZ 的Person对象
Person.objects.filter(name__contains="abc").exclude(age=23) # 找出名称含有abc, 但是排除年龄是23岁的
二、Django 自定义Field
Django 的官方提供了很多的 Field，但是有时候还是不能满足我们的需求，不过Django提供了自定义 Field 的方法：
提示：如果现在用不到可以跳过这一节，不影响后面的学习，等用到的时候再来学习不迟。
来一个简单的例子吧。
1. 减少文本的长度，保存数据的时候压缩，读取的时候解压缩，如果发现压缩后更长，就用原文本直接存储：
Django 1.7 以下
from django.db import models class CompressedTextField(models.TextField): """ model Fields for storing text in a compressed format (bz2 by default) """ __metaclass__ = models.SubfieldBase def to_python(self, value): if not value: return value try: return value.decode(‘base64‘).decode(‘bz2‘).decode(‘utf-8‘) except Exception: return value def get_prep_value(self, value): if not value: return value try: value.decode(‘base64‘) return value except Exception: try: tmp = value.encode(‘utf-8‘).encode(‘bz2‘).encode(‘base64‘) except Exception: return value else: if len(tmp) > len(value): return value return tmp
to_python 函数用于转化数据库中的字符到 Python的变量， get_prep_value 用于将Python变量处理后(此处为压缩）保存到数据库，使用和Django自带的 Field 一样。
Django 1.8 以上版本，可以用
#coding:utf-8from django.db import models class CompressedTextField(models.TextField): """ model Fields for storing text in a compressed format (bz2 by default) """ def from_db_value(self, value, expression, connection, context): if not value: return value try: return value.decode(‘base64‘).decode(‘bz2‘).decode(‘utf-8‘) except Exception: return value def to_python(self, value): if not value: return value try: return value.decode(‘base64‘).decode(‘bz2‘).decode(‘utf-8‘) except Exception: return value def get_prep_value(self, value): if not value: return value try: value.decode(‘base64‘) return value except Exception: try: return value.encode(‘utf-8‘).encode(‘bz2‘).encode(‘base64‘) except Exception: return value
Django 1.8及以上版本中，from_db_value 函数用于转化数据库中的字符到 Python的变量。
2. 比如我们想保存一个 列表到数据库中，在读取用的时候要是 Python的列表的形式，我们来自己写一个 ListField：
这个ListField继承自 TextField，代码如下：
from django.db import modelsimport ast class ListField(models.TextField): __metaclass__ = models.SubfieldBase description = "Stores a python list" def __init__(self, *args, **kwargs): super(ListField, self).__init__(*args, **kwargs) def to_python(self, value): if not value: value = [] if isinstance(value, list): return value return ast.literal_eval(value) def get_prep_value(self, value): if value is None: return value return unicode(value) # use str(value) in Python 3 def value_to_string(self, obj): value = self._get_val_from_obj(obj) return self.get_db_prep_value(value)
使用它很简单，首先导入 ListField，像自带的 Field 一样使用：
class Article(models.Model): labels = ListField()
在终端上尝试（运行 python manage.py shell 进入）：
>>> from app.models import Article>>> d = Article()>>> d.labels[]>>> d.labels = ["Python", "Django"]>>> d.labels["Python", "Django"]
三、Django 数据表更改
我们设计数据库的时候，早期设计完后，后期会发现不完善，需要对数据表进行更改.
Django 1.7.x 及以后的版本集成了 South 的功能，在修改models.py了后运行：
python manage.py makemigrationspython manage.py migrate这两行命令就会对我们的models.py 进行检测，自动发现需要更改的，应用到数据库中去。
Django 1.6.x 及以前：
写过Django项目的同学，必然会遇到这个问题：
在Django 1.6以及以前的版本中，我们测试，当发现model要改，怎么办？
我们修改了 models.py 之后，我们运行：
python manage.py syncdb
这句话只会将我们在 models.py 中新加的类创建相应的表。
对于原来有的，现在删除了的类，Django 会询问是否要删除数据库中已经存在的相关数据表。
如果在原来的类上增加字段或者删除字段，可以参考这个命令：
python manage.py sql appname
给出的SQL语句，然后自己手动到数据库执行 SQL 。但是这样非常容易出错！
Django 的第三方 app South 就是专门做数据库表结构自动迁移工作，Jacob Kaplan-Moss 曾做过一次调查，South 名列最受欢迎的第三方 app。事实上，它现在已经俨然成为 Django 事实上的数据库表迁移标准，很多第三方 app 都会带 South migrations 脚本，Django 1.7 中集成了 South 的功能。
1, 安装South
(sudo) pip install South
2. 使用方法
一个好的程序使用起来必定是简单的，South和它的宗旨一样，使用简单。只需要简单几步，针对已经建好model和创建完表的应用。
把south加入到settings.py中的INSTALL_APPS中
# Application definitionINSTALLED_APPS = ( ‘django.contrib.admin‘, ‘django.contrib.auth‘, ‘django.contrib.contenttypes‘, ‘django.contrib.sessions‘, ‘django.contrib.messages‘, ‘django.contrib.staticfiles‘, ‘blog‘, ‘south‘,)
修改好后运行一次 python manage.py syncdb，Django会新建一个 south_migrationhistory 表，用来记录数据表更改(Migration)的历史纪录。
$ python manage.py syncdbSyncing...Creating tables ...Creating table south_migrationhistoryInstalling custom SQL ...Installing indexes ...No fixtures found. Synced: > django.contrib.admin > django.contrib.auth > django.contrib.contenttypes > django.contrib.sessions > django.contrib.messages > django.contrib.staticfiles > blog > south Not synced (use migrations):
如果要把之前建好的比如 blog 这个 app 使用 South 来管理：
$ python manage.py convert_to_south blog
你会发现blog文件夹中多了一个 migrations 目录，里面有一个 0001_initial.py 文件。
注：如果 blog 这个 app 之前就创建过相关的表，可以用下面的来“假装”用 South 创建（伪创建，在改动 models.py 之前运行这个）
python manage.py migrate blog --fake
意思是这个表我以前已经建好了，用 South 只是纪一下这个创建记录，下次 migrate 的时候不必再创建了。
原理就是 south_migrationhistory 中记录下了 models.py 的修改的历史，下次再修改时会和最近一次记录比较，发现改变了什么，然后生成相应的对应文件，最终执行相应的 SQL 更改原有的数据表。
接着，当你对 Blog.models 做任何修改后，只要执行：
$ python manage.py schemamigration blog --auto
South就会帮助我们找出哪些地方做了修改，如果你新增的数据表没有给default值，并且没有设置null=True, south会问你一些问题，因为新增的column对于原来的旧的数据不能为Null的话就得有一个值。顺利的话，在migrations文件夹下会产生一个0002_add_mobile_column.py，但是这一步并没有真正修改数据库的表，我们需要执行 python manage.py migrate ：
$ python manage.py migrateRunning migrations for blog: - Migrating forwards to 0002_add_mobile_column. > blog:0002_add_mobile_column - Loading initial data for blog.No fixtures found.
这样所做的更改就写入到了数据库中了。
恢复到以前
South好处就是可以随时恢复到之前的一个版本，比如我们想要回到最开始的那个版本：
> python manage.py migrate blog 0001 - Soft matched migration 0001 to 0001_initial.Running migrations for blog: - Migrating backwards to just after 0001_initial. < blog:0002_add_mobile_column
这样就搞定了，数据库就恢复到以前了，比你手动更改要方便太多了。
四、Django QuerySet API
从数据库中查询出来的结果一般是一个集合，这个集合叫做 QuerySet。
文中的例子大部分是基于这个 blog/models.py
from django.db import models class Blog(models.Model): name = models.CharField(max_length=100) tagline = models.TextField() def __unicode__(self): # __str__ on Python 3 return self.name class Author(models.Model): name = models.CharField(max_length=50) email = models.EmailField() def __unicode__(self): # __str__ on Python 3 return self.name class Entry(models.Model): blog = models.ForeignKey(Blog) headline = models.CharField(max_length=255) body_text = models.TextField() pub_date = models.DateField() mod_date = models.DateField() authors = models.ManyToManyField(Author) n_comments = models.IntegerField() n_pingbacks = models.IntegerField() rating = models.IntegerField() def __unicode__(self): # __str__ on Python 3 return self.headline
1. QuerySet 创建对象的方法
>>> from blog.models import Blog>>> b = Blog(name=‘Beatles Blog‘, tagline=‘All the latest Beatles news.‘)>>> b.save() 总之，一共有四种方法# 方法 1Author.objects.create(name="WeizhongTu", email="tuweizhong@163.com") # 方法 2twz = Author(name="WeizhongTu", email="tuweizhong@163.com")twz.save() # 方法 3twz = Author()twz.name="WeizhongTu"twz.email="tuweizhong@163.com" # 方法 4，首先尝试获取，不存在就创建，可以防止重复Author.objects.get_or_create(name="WeizhongTu", email="tuweizhong@163.com")# 返回值(object, True/False)
备注：前三种方法返回的都是对应的 object，最后一种方法返回的是一个元组，(object, True/False)，创建时返回 True, 已经存在时返回 False
当有一对多，多对一，或者多对多的关系的时候，先把相关的对象查询出来
>>> from blog.models import Entry>>> entry = Entry.objects.get(pk=1)>>> cheese_blog = Blog.objects.get(name="Cheddar Talk")>>> entry.blog = cheese_blog>>> entry.save()
2. 获取对象的方法（上一篇的部分代码）
Person.objects.all() # 查询所有Person.objects.all()[:10] 切片操作，获取10个人，不支持负索引，切片可以节约内存，不支持负索引，后面有相应解决办法，第7条Person.objects.get(name="WeizhongTu") # 名称为 WeizhongTu 的一条，多条会报错 get是用来获取一个对象的，如果需要获取满足条件的一些人，就要用到filterPerson.objects.filter(name="abc") # 等于Person.objects.filter(name__exact="abc") 名称严格等于 "abc" 的人Person.objects.filter(name__iexact="abc") # 名称为 abc 但是不区分大小写，可以找到 ABC, Abc, aBC，这些都符合条件 Person.objects.filter(name__contains="abc") # 名称中包含 "abc"的人Person.objects.filter(name__icontains="abc") #名称中包含 "abc"，且abc不区分大小写 Person.objects.filter(name__regex="^abc") # 正则表达式查询Person.objects.filter(name__iregex="^abc")# 正则表达式不区分大小写 # filter是找出满足条件的，当然也有排除符合某条件的Person.objects.exclude(name__contains="WZ") # 排除包含 WZ 的Person对象Person.objects.filter(name__contains="abc").exclude(age=23) # 找出名称含有abc, 但是排除年龄是23岁的
3. QuerySet 是可迭代的，比如：
es = Entry.objects.all()for e in es: print(e.headline)
Entry.objects.all() 或者 es 就是 QuerySet 是查询所有的 Entry 条目。
注意事项：
(1). 如果只是检查 Entry 中是否有对象，应该用 Entry.objects.all().exists()
(2). QuerySet 支持切片 Entry.objects.all()[:10] 取出10条，可以节省内存
(3). 用 len(es) 可以得到Entry的数量，但是推荐用 Entry.objects.count()来查询数量，后者用的是SQL：SELECT COUNT(*)
(4). list(es) 可以强行将 QuerySet 变成 列表
4. QuerySet 是可以用pickle序列化到硬盘再读取出来的
>>> import pickle>>> query = pickle.loads(s) # Assuming ‘s‘ is the pickled string.>>> qs = MyModel.objects.all()>>> qs.query = query # Restore the original ‘query‘.
5. QuerySet 查询结果排序
作者按照名称排序
Author.objects.all().order_by(‘name‘)Author.objects.all().order_by(‘-name‘) # 在 column name 前加一个负号，可以实现倒序
6. QuerySet 支持链式查询
Author.objects.filter(name__contains="WeizhongTu").filter(email="tuweizhong@163.com")Author.objects.filter(name__contains="Wei").exclude(email="tuweizhong@163.com") # 找出名称含有abc, 但是排除年龄是23岁的Person.objects.filter(name__contains="abc").exclude(age=23)
7. QuerySet 不支持负索引
Person.objects.all()[:10] 切片操作，前10条Person.objects.all()[-10:] 会报错！！！ # 1. 使用 reverse() 解决Person.objects.all().reverse()[:2] # 最后两条Person.objects.all().reverse()[0] # 最后一条 # 2. 使用 order_by，在栏目名（column name）前加一个负号Author.objects.order_by(‘-id‘)[:20] # id最大的20条
8. QuerySet 重复的问题，使用 .distinct() 去重
一般的情况下，QuerySet 中不会出来重复的，重复是很罕见的，但是当跨越多张表进行检索后，结果并到一起，可以会出来重复的值（我最近就遇到过这样的问题）
qs1 = Pathway.objects.filter(label__name=‘x‘)qs2 = Pathway.objects.filter(reaction__name=‘A + B >> C‘)qs3 = Pathway.objects.filter(inputer__name=‘WeizhongTu‘) # 合并到一起qs = qs1 | qs2 | qs3这个时候就有可能出现重复的 # 去重方法qs = qs.distinct()
参考网址：
https://djangosnippets.org/snippets/2014/
https://docs.djangoproject.com/en/dev/howto/custom-model-fields/
参考文档：
Django models 官方教程: https://docs.djangoproject.com/en/dev/topics/db/models/
Fields相关官方文档：https://docs.djangoproject.com/en/dev/ref/models/fields/
Django数据库操作官方文档： QuerySet API: https://docs.djangoproject.com/en/dev/ref/models/querysets/
python Django教程 之 模型(数据库)、自定义Field、数据表更改、QuerySet API