模型层
orm简介
ORM是“对象-关系-映射”的简称。
MVC或者MTV框架中包括一个重要的部分ORM,它实现了数据模型与数据库的解耦,即数据模型的设计不需要依赖于特定的数据库,通过简单的配置就可以轻松更换数据库,这极大的减轻了开发人员的工作量,不需要面对因数据库变更而导致的无效劳动。
比如,之前的数据库用的是oracle,后来因为维护成本高,想换mysql,没有orm就需要重新熟悉mysql,编写新脚本升级,有了orm就不需要顾虑这件事,直接将配置由oracle改成mysql,orm会自己去映射正确的mysql语法。
代码如下:
1 #sql中的表
2
3 #创建表:
4 CREATE TABLE employee(
5 id INT PRIMARY KEY auto_increment ,
6 name VARCHAR (20),
7 gender BIT default 1,
8 birthday DATA ,
9 department VARCHAR (20),
10 salary DECIMAL (8,2) unsigned,
11 );
12
13
14 #sql中的表纪录
15
16 #添加一条表纪录:
17 INSERT employee (name,gender,birthday,salary,department)
18 VALUES ("alex",1,"1985-12-12",8000,"保洁部");
19
20 #查询一条表纪录:
21 SELECT * FROM employee WHERE age=24;
22
23 #更新一条表纪录:
24 UPDATE employee SET birthday="1989-10-24" WHERE id=1;
25
26 #删除一条表纪录:
27 DELETE FROM employee WHERE name="alex"
28
29
30
31
32
33 #python的类
34 class Employee(models.Model):
35 id=models.AutoField(primary_key=True)
36 name=models.CharField(max_length=32)
37 gender=models.BooleanField()
38 birthday=models.DateField()
39 department=models.CharField(max_length=32)
40 salary=models.DecimalField(max_digits=8,decimal_places=2)
41
42
43 #python的类对象
44 #添加一条表纪录:
45 emp=Employee(name="alex",gender=True,birthday="1985-12-12",epartment="保洁部")
46 emp.save()
47 #查询一条表纪录:
48 Employee.objects.filter(age=24)
49 #更新一条表纪录:
50 Employee.objects.filter(id=1).update(birthday="1989-10-24")
51 #删除一条表纪录:
52 Employee.objects.filter(name="alex").delete()
View Code
环境搭建及配置
settings配置
在settings文件增加以下配置:
1.增加链接数据库的基本信息
DATABASES = {
'default': {
'ENGINE': 'django.db.backends.mysql',
'NAME':'orm',# 要连接的数据库,连接前需要创建好
'USER':'root',# 连接数据库的用户名
'PASSWORD':'root',# 连接数据库的密码
'HOST':'127.0.0.1',# 连接主机,默认本级
'PORT':3306 # 端口 默认3306
}
}
2.增加以下配置可以控制台可输出sql日志
LOGGING = {
'version': 1,
'disable_existing_loggers': False,
'handlers': {
'console':{
'level':'DEBUG',
'class':'logging.StreamHandler',
},
},
'loggers': {
'django.db.backends': {
'handlers': ['console'],
'propagate': True,
'level':'DEBUG',
},
}
}
3.在INSTALLED_APPS配置中增加应用名称
项目配置
启动的时候报错:no module named MySQLdb 。这是因为django默认你导入的驱动是MySQLdb,可是MySQLdb 对于py3有很大问题,所以我们需要的驱动是PyMySQL。
在项目的__init__.py文件中增加以下语句,比如我这里是 06 django模型层\django_models\django_models\__init__.py
import
pymysql
pymysql.install_as_MySQLdb()
django配置
1.MySQLclient版本问题
MySQLclient目前只支持到python3.4,因此如果使用的更高版本的python,会报错:django.core.exceptions.ImproperlyConfigured: mysqlclient
1.3``.``3
or
newer
is
required; you have
0.7``.``11.None
需要修改如下:
找到这个文件 python的安装路径\Lib\site-packages\django\db\backends\mysql\base.py
注释掉以下这段话即可
if version < (1, 3, 13):
raise ImproperlyConfigured('mysqlclient 1.3.13 or newer is required; you have %s.' % Database.__version__)
2.数据库版本问题
因为django2.1版本以上不再支持mysql5.5,所以在启动运行的时候会报错
Running migrations:
Traceback (most recent call last):
File "/usr/local/lib/python3.6/site-packages/django/db/backends/utils.py", line 83, in _execute
return self.cursor.execute(sql)
File "/usr/local/lib/python3.6/site-packages/django/db/backends/mysql/base.py", line 71, in execute
return self.cursor.execute(query, args)
File "/usr/local/lib/python3.6/site-packages/MySQLdb/cursors.py", line 250, in execute
self.errorhandler(self, exc, value)
File "/usr/local/lib/python3.6/site-packages/MySQLdb/connections.py", line 50, in defaulterrorhandler
raise errorvalue
File "/usr/local/lib/python3.6/site-packages/MySQLdb/cursors.py", line 247, in execute
res = self._query(query)
File "/usr/local/lib/python3.6/site-packages/MySQLdb/cursors.py", line 412, in _query
rowcount = self._do_query(q)
File "/usr/local/lib/python3.6/site-packages/MySQLdb/cursors.py", line 375, in _do_query
db.query(q)
File "/usr/local/lib/python3.6/site-packages/MySQLdb/connections.py", line 276, in query
_mysql.connection.query(self, query)
_mysql_exceptions.ProgrammingError: (1064, "You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near '(6) NOT NULL)' at line 1")
这个时候只能升级mysql了,因为mysql5.5不支持 datetime(6)这种精度的写法,升级到mysql5.7解决该问题。
3.operations.py转码问题
如果运行报错如下:
File "D:\Miniconda3\lib\site-packages\django\db\backends\mysql\operations.py", line 146, in last_executed_query
query = query.decode(errors='replace')
AttributeError: 'str' object has no attribute 'decode'
解决方法:找到这个文件
django\db\backends\mysql\operations.py
修改第146行,将 decode 改成encode ,问题解决
单表操作
创建表
以上配置都弄完后,在models.py文件,编写orm操作类,如下:
from django.db import models
# Create your models here.
class Book(models.Model):
id=models.AutoField(primary_key=True)
title=models.CharField(max_length=32)
state=models.BooleanField()
pub_date=models.DateField()
price=models.DecimalField(max_digits=8,decimal_places=2)
publish=models.CharField(max_length=32)
注意:在运行manage.py文件之前需要在mysql中创建好orm数据库,这个是根据settings中的数据库配置来的,连接的哪个库就需要手动创建哪个库,因为models只是针对表的操作,并不能操作数据库。
类写完后,运行manage.py文件,会生成django的相关表和自己定义的这个类的表,命令如下:
python manage.py makemigrations
python manage.py migrate
结果如下:
删表重新创建表:
先到数据库把表删掉:drop table
注释django中对应的Model
执行以下命令:
python manage.py makemigrations
python manage.py migrate --fake
去掉注释重新迁移
python manage.py makemigrations
python manage.py migrate
更多的字段和参数:
每个字段有一些特有的参数,例如,CharField需要max_length参数来指定VARCHAR
数据库字段的大小。还有一些适用于所有字段的通用参数。 这些参数在文档中有详细定义,这里我们只简单介绍一些最常用的:
字段:
1 '''
2 <1> CharField
3 字符串字段, 用于较短的字符串.
4 CharField 要求必须有一个参数 maxlength, 用于从数据库层和Django校验层限制该字段所允许的最大字符数.
5
6 <2> IntegerField
7 #用于保存一个整数.
8
9 <3> FloatField
10 一个浮点数. 必须 提供两个参数:
11
12 参数 描述
13 max_digits 总位数(不包括小数点和符号)
14 decimal_places 小数位数
15 举例来说, 要保存最大值为 999 (小数点后保存2位),你要这样定义字段:
16
17 models.FloatField(..., max_digits=5, decimal_places=2)
18 要保存最大值一百万(小数点后保存10位)的话,你要这样定义:
19
20 models.FloatField(..., max_digits=19, decimal_places=10)
21 admin 用一个文本框(<input type="text">)表示该字段保存的数据.
22
23 <4> AutoField
24 一个 IntegerField, 添加记录时它会自动增长. 你通常不需要直接使用这个字段;
25 自定义一个主键:my_id=models.AutoField(primary_key=True)
26 如果你不指定主键的话,系统会自动添加一个主键字段到你的 model.
27
28 <5> BooleanField
29 A true/false field. admin 用 checkbox 来表示此类字段.
30
31 <6> TextField
32 一个容量很大的文本字段.
33 admin 用一个 <textarea> (文本区域)表示该字段数据.(一个多行编辑框).
34
35 <7> EmailField
36 一个带有检查Email合法性的 CharField,不接受 maxlength 参数.
37
38 <8> DateField
39 一个日期字段. 共有下列额外的可选参数:
40 Argument 描述
41 auto_now 当对象被保存时,自动将该字段的值设置为当前时间.通常用于表示 "last-modified" 时间戳.
42 auto_now_add 当对象首次被创建时,自动将该字段的值设置为当前时间.通常用于表示对象创建时间.
43 (仅仅在admin中有意义...)
44
45 <9> DateTimeField
46 一个日期时间字段. 类似 DateField 支持同样的附加选项.
47
48 <10> ImageField
49 类似 FileField, 不过要校验上传对象是否是一个合法图片.#它有两个可选参数:height_field和width_field,
50 如果提供这两个参数,则图片将按提供的高度和宽度规格保存.
51 <11> FileField
52 一个文件上传字段.
53 要求一个必须有的参数: upload_to, 一个用于保存上载文件的本地文件系统路径. 这个路径必须包含 strftime #formatting,
54 该格式将被上载文件的 date/time
55 替换(so that uploaded files don't fill up the given directory).
56 admin 用一个<input type="file">部件表示该字段保存的数据(一个文件上传部件) .
57
58 注意:在一个 model 中使用 FileField 或 ImageField 需要以下步骤:
59 (1)在你的 settings 文件中, 定义一个完整路径给 MEDIA_ROOT 以便让 Django在此处保存上传文件.
60 (出于性能考虑,这些文件并不保存到数据库.) 定义MEDIA_URL 作为该目录的公共 URL. 要确保该目录对
61 WEB服务器用户帐号是可写的.
62 (2) 在你的 model 中添加 FileField 或 ImageField, 并确保定义了 upload_to 选项,以告诉 Django
63 使用 MEDIA_ROOT 的哪个子目录保存上传文件.你的数据库中要保存的只是文件的路径(相对于 MEDIA_ROOT).
64 出于习惯你一定很想使用 Django 提供的 get_<#fieldname>_url 函数.举例来说,如果你的 ImageField
65 叫作 mug_shot, 你就可以在模板中以 {{ object.#get_mug_shot_url }} 这样的方式得到图像的绝对路径.
66
67 <12> URLField
68 用于保存 URL. 若 verify_exists 参数为 True (默认), 给定的 URL 会预先检查是否存在( 即URL是否被有效装入且
69 没有返回404响应).
70 admin 用一个 <input type="text"> 文本框表示该字段保存的数据(一个单行编辑框)
71
72 <13> NullBooleanField
73 类似 BooleanField, 不过允许 NULL 作为其中一个选项. 推荐使用这个字段而不要用 BooleanField 加 null=True 选项
74 admin 用一个选择框 <select> (三个可选择的值: "Unknown", "Yes" 和 "No" ) 来表示这种字段数据.
75
76 <14> SlugField
77 "Slug" 是一个报纸术语. slug 是某个东西的小小标记(短签), 只包含字母,数字,下划线和连字符.#它们通常用于URLs
78 若你使用 Django 开发版本,你可以指定 maxlength. 若 maxlength 未指定, Django 会使用默认长度: 50. #在
79 以前的 Django 版本,没有任何办法改变50 这个长度.
80 这暗示了 db_index=True.
81 它接受一个额外的参数: prepopulate_from, which is a list of fields from which to auto-#populate
82 the slug, via JavaScript,in the object's admin form: models.SlugField
83 (prepopulate_from=("pre_name", "name"))prepopulate_from 不接受 DateTimeFields.
84
85 <13> XMLField
86 一个校验值是否为合法XML的 TextField,必须提供参数: schema_path, 它是一个用来校验文本的 RelaxNG schema #的文件系统路径.
87
88 <14> FilePathField
89 可选项目为某个特定目录下的文件名. 支持三个特殊的参数, 其中第一个是必须提供的.
90 参数 描述
91 path 必需参数. 一个目录的绝对文件系统路径. FilePathField 据此得到可选项目.
92 Example: "/home/images".
93 match 可选参数. 一个正则表达式, 作为一个字符串, FilePathField 将使用它过滤文件名.
94 注意这个正则表达式只会应用到 base filename 而不是
95 路径全名. Example: "foo.*\.txt^", 将匹配文件 foo23.txt 却不匹配 bar.txt 或 foo23.gif.
96 recursive可选参数.要么 True 要么 False. 默认值是 False. 是否包括 path 下面的全部子目录.
97 这三个参数可以同时使用.
98 match 仅应用于 base filename, 而不是路径全名. 那么,这个例子:
99 FilePathField(path="/home/images", match="foo.*", recursive=True)
100 ...会匹配 /home/images/foo.gif 而不匹配 /home/images/foo/bar.gif
101
102 <15> IPAddressField
103 一个字符串形式的 IP 地址, (i.e. "24.124.1.30").
104 <16> CommaSeparatedIntegerField
105 用于存放逗号分隔的整数值. 类似 CharField, 必须要有maxlength参数.
106
107
108 '''
View Code
参数:
'''
(1)null
如果为True,Django 将用NULL 来在数据库中存储空值。 默认值是 False.
(1)blank
如果为True,该字段允许不填。默认为False。
要注意,这与 null 不同。null纯粹是数据库范畴的,而 blank 是数据验证范畴的。
如果一个字段的blank=True,表单的验证将允许该字段是空值。如果字段的blank=False,该字段就是必填的。
(2)default
字段的默认值。可以是一个值或者可调用对象。如果可调用 ,每有新对象被创建它都会被调用。
(3)primary_key
如果为True,那么这个字段就是模型的主键。如果你没有指定任何一个字段的primary_key=True,
Django 就会自动添加一个IntegerField字段做为主键,所以除非你想覆盖默认的主键行为,
否则没必要设置任何一个字段的primary_key=True。
(4)unique
如果该值设置为 True, 这个数据字段的值在整张表中必须是唯一的
(5)choices
由二元组组成的一个可迭代对象(例如,列表或元组),用来给字段提供选择项。 如果设置了choices ,默认的表单将是一个选择框而不是标准的文本框,<br>而且这个选择框的选项就是choices 中的选项。
'''
View Code
增删改查
1 from django.shortcuts import render,redirect,HttpResponse
2 from model_app01.tools import Mysql
3 from model_app01.models import Book
4
5 # Create your views here.
6
7
8 def output(lis):
9 for i in lis:
10 print(i.id, i.title, i.price)
11
12 def index(request):
13 '''
14 # ================================== 添加记录 ==================================
15 # 添加表记录 方式一 先实例化,然后调用 save方法
16 insert_opration = Book(title='python',state=1,pub_date='2012-01-01',price=23,publish='深圳出版社')
17 insert_opration.save()
18 # 添加表记录 方式二 Book.objects.create() create返回值就是当前生成的对象纪录
19 res = Book.objects.create(title="go",state=0,price=10,publish="北京出版社",pub_date="2014-12-12")
20 print(res.title, res.state, res.price, res.publish, res.pub_date)
21 # 插入一百条记录
22 # for i in range(100):
23 # i = str(i)
24 # Book.objects.create(title="%s山药当归枸杞GO"%i, state=True, price=i, publish="北京%s号出版社"%i, pub_date="2019-01-12")
25
26
27 # ================================== 查询记录 ==================================
28 #(1) all()方法: 返回值一个queryset对象 查询所有结果
29 sql_res = Book.objects.all()
30 print(sql_res) # [obj1,obj2,.....]
31 for obj in sql_res:
32 print(obj.title,obj.price)
33 print(sql_res[5].price)
34
35 # (2)first(),last() : 调用者:queryset对象 返回值:model对象
36 book = Book.objects.all().first()
37 book = Book.objects.all()[0] # 等价于这个
38 print(book,book.title)
39
40 # (3) filter(**kwargs) 返回值:queryset对象 它包含了与所给筛选条件相匹配的对象
41 sql_res = Book.objects.filter(price=80)
42 output(sql_res)
43 sql_res = Book.objects.filter(price__gt=77,price__lt=90,state=1)
44 output(sql_res)
45
46 # (4) get(**kwargs) 有且只有一个查询结果时才有意义 返回值:model对象
47 # 返回与所给筛选条件相匹配的对象,返回结果有且只有一个,如果符合筛选条件的对象超过一个或者没有都会抛出错误。
48 book_obj=Book.objects.get(title="go")
49 book_obj=Book.objects.get(price=100)
50 print(book_obj.price) # 当没有返回值的时候会报错
51
52 # (5) exclude(**kwargs) != 返回值:queryset对象
53 sql_res=Book.objects.exclude(title="go")
54 output(sql_res)
55
56 # (6) order_by(*field) 调用者: queryset对象 返回值: queryset对象 对查询结果排序
57 sql_res = Book.objects.all().order_by('price')
58 sql_res = Book.objects.all().order_by('-id') # - 代表倒序
59 output(sql_res)
60
61 # (7) count() 调用者: queryset对象 返回值: int 返回数据库中匹配查询(QuerySet)的对象数量
62 res = Book.objects.all().count()
63 res2 = Book.objects.filter(price__gt=88).count()
64 print(res,res2)
65
66 # (8) exists() 如果QuerySet包含数据,就返回True,否则返回False
67 res = Book.objects.all().exists()
68 res2 = Book.objects.filter(price__gt=10086).exists()
69 print(res, res2)
70
71 # (9) values(*field) 方法 调用者: queryset对象 返回值:queryset对象 需要的数据列
72 # 返回一个ValueQuerySet——一个特殊的QuerySet,运行后得到的并不是一系列 model的实例化对象,而是一个可迭代的字典序列
73 sql_res = Book.objects.all().values('id','title','price')
74 sql_res = Book.objects.filter(price=77).values('id','title','price')
75 print(sql_res) # QuerySet [{'title': '77山药当归枸杞GO', 'price': Decimal('77.00'), 'id': 80}]
76 print(sql_res[0]['title']) # 77山药当归枸杞GO
77
78 # (10) values_list 方法 调用者: queryset对象 返回值:queryset对象
79 # 它与values()非常相似,它返回的是一个元组序列,values返回的是一个字典序列
80 sql_res = Book.objects.all().values_list('id', 'title', 'price')
81 sql_res = Book.objects.filter(price=77).values_list('id', 'title', 'price')
82 print(sql_res) # [(80, '77山药当归枸杞GO', Decimal('77.00'))]
83 print(sql_res[0][1]) # 77山药当归枸杞GO
84
85 # 11 distinct 从返回结果中剔除重复纪录
86 sql_res = Book.objects.all().count()
87 sql_res2 = Book.objects.values('price').distinct().count()
88 print(sql_res,sql_res2)
89
90 # 点语法 可以一直点下去
91 # Book.objects.all().filter().order_by().filter().reverse().first()
92
93
94 # ================================== 模糊查询 ==================================
95 # __gt 大于 __gte 大于等于 __lt 小于 __lte 小于等于 __in 存在于一个list范围内
96 # __startswith 以...开头 __istartswith 以...开头 忽略大小写 contains 包含 like '%aaa%'
97 # __icontains 包含 忽略大小写 ilike '%aaa%',但是对于sqlite来说,contains的作用效果等同于icontains
98 # __exact 精确等于 like 'aaa'__range 在...范围内 __year 日期字段的年份
99 # __month 日期字段的月份 __day 日期字段的日 __isnull=True/False
100 sql_res = Book.objects.filter(price__in=[100, 200, 300])
101 sql_res = Book.objects.filter(price__gt=100)
102 sql_res = Book.objects.filter(price__lt=100)
103 sql_res = Book.objects.filter(price__range=[100, 200])
104 sql_res = Book.objects.filter(title__contains="python")
105 sql_res = Book.objects.filter(title__icontains="python")
106 sql_res = Book.objects.filter(title__startswith="py")
107 sql_res = Book.objects.filter(pub_date__year=2012)
108
109 # ================================== 删除和修改 ===============================
110 # delete: 调用者: queryset对象 model对象 但是如果没有查询到记录,delete时会报错
111 sql_res=Book.objects.filter(price=2).delete()
112 print(sql_res)
113 Book.objects.filter(price=66).first().delete()
114 # 也可以一次性删除多个对象。每个 QuerySet 都有一个 delete() 方法,它一次性删除 QuerySet 中所有的对象
115 Book.objects.filter(pub_date__year=2019).delete()
116 #要注意的是: delete() 方法是 QuerySet 上的方法,但并不适用于 Manager 本身。
117 #这是一种保护机制,是为了避免意外地调用 Entry.objects.delete() 方法导致 所有的 记录被误删除。如果你确认要删除所有的对象,那么你必须显式地调用:
118 Book.objects.all().delete()
119 '''
120 # update() : 调用者: queryset对象
121 # update()方法对于任何结果集(QuerySet)均有效,这意味着你可以同时更新多条记录update()方法会返回一个整型数值,表示受影响的记录条数。
122 sql_res = Book.objects.filter(title="php").update(title="java")
123 print(sql_res) # 受影响的条数
124 return render(request,'index.html',locals())
125
126
127 def login(request):
128 method = request.method
129 if method.lower() == 'post':
130 req_data = request.POST # 一个类似于字典的对象,如果请求中包含表单数据,则将这些数据封装成 QueryDict 对象。
131 print('request.POST:\n',req_data)
132 user = req_data.get('user')
133 pwd = req_data.get('pwd')
134 mysql_check = Mysql('localhost', 3306, 'root', 'root', dbname='oldboy', charset="utf8")
135 sql = "select * from user_info WHERE name=%s and password=%s"
136 res = mysql_check.exec_sql(sql, user, pwd)
137 if res and isinstance(res,list):
138 return render(request, 'index.html')
139 else:
140 return HttpResponse('username or password is wrong!')
141 else:
142 print('request.GET:\n',request.GET) # 一个类似于字典的对象,包含 HTTP GET 的所有参数。详情请参考 QueryDict 对象
143 return render(request, 'login.html')
144
145
146 def regist(request):
147 method = request.method
148 if method.lower() == 'post':
149 req_data = request.POST
150 user = req_data.get('user')
151 pwd = req_data.get('pwd')
152 if user and pwd:
153 mysql_check = Mysql('localhost', 3306, 'root', 'root', dbname='oldboy', charset="utf8")
154 sql = "select * from user_info WHERE name=%s"
155 res = mysql_check.exec_sql(sql, user)
156 if res and isinstance(res,list):
157 return HttpResponse('username is already exits!')
158 insert_sql = 'insert into user_info (name,password) VALUES (%s,%s) '
159 mysql_check.exec_sql(insert_sql, user,pwd)
160 return redirect("/app01/index") # redirect() 重定向 传递要重定向的一个硬编码的URL
161 # return redirect("http://127.0.0.1:8080/app01/index/") # 也可以是一个完整的URL
162 return HttpResponse('username or password can not be empty !')
163 return render(request,'register.html',{'word':'hello world!'})
练习:
图书管理系统:
实现功能:book单表的增删改查
查询操作练习:
1
查询人民出版社出版过的价格大于``200``的书籍
2
查询``2017``年``8``月出版的所有以py开头的书籍名称
3
查询价格为``50``,``100``或者``150``的所有书籍名称及其出版社名
4
查询价格在``100``到``200``之间的所有书籍名称及其价格
5
查询所有人民出版社出版的书籍的价格(从高到低排序,去重)