2.创建Django项目
虚拟环境
下载django
pythonpip install django==3.2 #指定版本的话
创建django项目
pythondjango-admin startproject DahongSystem . #.为了把项目创建在子目录里
创建app(多app)
python manage.py startapp web apps/web
3.路由系统
本质上:URL和函数的对应关系。
3.1 传统的路由
from django.contrib import admin
from django.urls import path
from apps.web import views
urlpatterns = [
path('home/', views.home),
path('news/<int:nid>/edit/', views.news),
path('article/', views.article),
]
from django.shortcuts import render, HttpResponse
def home(request):
return HttpResponse("成功")
def news(request, nid):
print(nid)
page = request.GET.get("page")
return HttpResponse("新闻")
def article(request):
nid = request.GET.get("nid")
print(nid)
return HttpResponse("文章")
- int,整数
- str,字符串 /
- slug,字母+数字+下滑线+-
- uuid,uuid格式
- path,路径,可以包含 /
3.2 正则表达式路由
- 在django1版本用的多。
- 在django2+版本用的少
3.3 路由分发
假如:200个功能。
inlucde + app(一般),将功能拆分不到不同的app中。
手动路由分发,可以与app无关。
path('user/add/', views.login),
path('user/delete/', views.login),
path('user/edit/', views.login),
path('user/list/', views.login),
path('user/', ([
path('add/', views.login),
path('delete/', views.login), # /user/delete/
path('edit/', views.login),
path('list/', views.login),
], None, None)),
纯粹帮助提取功能的URL,防止重复编写。
路由分发的本质:
URL对应函数
pythonpath('user/add/', views.login),
URL对应元组
pythonpath('user/add/', (元素,appname元素,namespance元素) ),
pythonpath('user/add/', include("apps.api.urls") ), path('user/add/', ([],None,None) ),
3.4 name
3.4.1
给一个路由起个名字 + 根据名字反向生成URL。
urlpatterns = [
path('login/', views.login),
]
# 很多功能,很多URL
urlpatterns = [
path('login/', views.login, name="v1"),
path('auth/', views.auth, name="v2"),
]
有了名字后,以后一般有两处会用到:
在视图函数中生成URL
from django.urls import reverse url = reverse("v2") # /auth/ url = reverse("v1") # /login/
HTML模板,页面上有一个a标签,添加xx。
html<a href="/xxx/xxx/xx/">添加</a>
html<a href="{% url 'v1' %}">添加</a> <a href="{% url 'v2' %}">添加</a>
扩展
以后做权限管理,让name属性配合。
3.4.2 最后的 / 如何解决?
APPEND_SLASH = True
path('login/', views.login),
http://127.0.0.1:8000/login/ 成功
http://127.0.0.1:8000/login django,重定向301
http://127.0.0.1:8000/login/ 成功
path('login', views.login),
http://127.0.0.1:8000/login 成功
http://127.0.0.1:8000/login
http://127.0.0.1:8000/login/ 失败
APPEND_SLASH = False
path('login/', views.login),
http://127.0.0.1:8000/login/ 成功
http://127.0.0.1:8000/login 失败
path('login', views.login),
http://127.0.0.1:8000/login/ 失败
http://127.0.0.1:8000/login 成功
3.5 namespace
辅助name。
主路由
pythonfrom django.urls import path, re_path, include # 很多功能,很多URL urlpatterns = [ path('api/', include("apps.api.urls",namespace='x1')), path('web/', include("apps.web.urls",namespace='x2')), ]
api/urls.py
pythonfrom django.urls import path, re_path from . import views # 很多功能,很多URL urlpatterns = [ path('login/', views.login,name="login"), path('auth/', views.auth, name='auth'), ]
web/urls.py
pythonfrom django.urls import path, re_path from . import views # 很多功能,很多URL urlpatterns = [ path('home/', views.home,name='home'), path('order/', views.order,name='order'), path('auth/', views.order, name='auth'), ]
以后再某个URL或者视图中反向生成:
from django.urls import reverse
url = reverse("x1:login") # /api/login/
url = reverse("x1:order") # /web/login/
url = reverse("x1:auth") # /api/login/
url = reverse("x2:auth") # /web/login/
两个扩展:
namespace需要设置app_name
urlpatterns = [ path('api/', include("apps.api.urls", namespace='x1')), ]
from django.urls import path, re_path from apps.api import views # 很多功能,很多URL urlpatterns = [ path('login/', views.login, name="login"), path('auth/', views.auth, name='auth'), ] app_name = "api"
手动分发
赠送:
4.视图
4.1 文件or文件夹
4.2 相对和绝对导入urls
注意实现:不要再项目根目录做相对导入。
原则:
- 绝对导入
- 相对导入(层级深)
4.3 视图参数(Request是什么?)
requests是什么呢?
对象,包裹,可以放很多东西。
requests是一个对象,存放了浏览器给咱们发过来的所有内容,所以含有:
- 请求相关所有的数据: 当前访问的url、请求方式、...
- django额外添加的数据
from django.shortcuts import HttpResponse
def login(request):
# 1.当前URL /api/login/
print(request.path_info)
# 2.URL传递的参数
print(request.GET)
print(request.GET.get("age"))
# 3.请求方式 GET/POST
print(request.method)
# 4.如果post请求,传递请求体(原始数据,没有原始数据说明请求没收到数据!)
print(request.body)
# b'{"code":"083Sjmll2yla694F3bll2DguCM2SjmlG","unionId":"oP6QCsyT_9bk1dfSaVf0GEV5Y-yE"}' b'v1=123&v2=456'
# 4.1 请求体+请求头 b'v1=123&v2=456' + content-type:application/x-www-form-urlencoded (请求体必须长这样)
print(request.POST)
print(request.POST.get("v1"))
print(request.POST.get("v2"))
# 4.2 请求体+请求头 文件
print(request.FILES) # 文件格式 + multipart/form-data (content_type必须长这样)
print(request.FILES.get("n1"))
print(request.FILES.get("n2"))
# 5.请求头
# {'Content-Length': '', 'Content-Type': 'text/plain', 'Host': '127.0.0.1:8000', 'Connection': 'keep-alive', 'Cache-Control': 'max-age=0', 'Sec-Ch-Ua': '" Not A;Brand";v="99", "Chromium";v="102", "Google Chrome";v="102"', 'Sec-Ch-Ua-Mobile': '?0', 'Sec-Ch-Ua-Platform': '"macOS"', 'Upgrade-Insecure-Requests': '1', 'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/102.0.0.0 Safari/537.36', 'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9', 'Sec-Fetch-Site': 'none', 'Sec-Fetch-Mode': 'navigate', 'Sec-Fetch-User': '?1', 'Sec-Fetch-Dest': 'document', 'Accept-Encoding': 'gzip, deflate, br', 'Accept-Language': 'zh-CN,zh;q=0.9,en;q=0.8,zh-TW;q=0.7', 'Cookie': 'csrftoken=CdidpKSGbLxzmOXnbmlkvrZep1eJmKLAA81T73UjcjxEnMOa4YOZqtc849AkYfUy'}
print(request.headers)
# 5.1 请求头有个特殊的cookie
# request.headers['cookie'] # 'csrftoken=CdidpKSGbLxzmOXnbmlkvrZep1eJmKLAA81T73UjcjxEnMOa4YOZqtc849AkYfUy;session=xxxx'
# {'csrftoken': 'CdidpKSGbLxzmOXnbmlkvrZep1eJmKLAA81T73UjcjxEnMOa4YOZqtc849AkYfUy'}
print(request.COOKIES)
# 6.requests中其他值
print(request.resolver_match)
return HttpResponse("login")
4.4 返回值
- HttpResponse
- JsonResponse
- render
- redirect(里写一个url或者url的name(不推荐),想写URL Name用reverse)
from django.shortcuts import HttpResponse, redirect, render
from django.http import JsonResponse
def auth(request):
pass
def login(request):
# 1.获取请求数据
print(request)
# 2.根据请求数据进行条件的判断 GET/POST GET.get("xx") POST.get("xx")
# 3.返回数据
# 3.1 字符串/字节/文本数据(图片验证码)
# return HttpResponse("login")
# 3.2 JSON格式(前后端分离、app小程序后端、ajax请求)
# data_dict = {"status": True, 'data': [11, 22, 33]}
# return JsonResponse(data_dict)
# 3.3 重定向
# return redirect("https://www.baidu.com")
# return redirect("http://127.0.0.1:8000/api/auth/")
# return redirect("http://127.0.0.1:8000/api/auth/")
# return redirect("/api/auth/")
# return redirect("/api/auth/") # name
#
# from django.urls import reverse
# url = reverse("auth")
# return redirect(url) # name
# return redirect("auth")
# 3.4 渲染
# - a.找到 'login.html' 并读取的内容,问题:去哪里找?
# - 默认先去settings.TEMPLATES.DIRS指定的路径找。(公共)
# - 按注册顺序每个已注册的app中找他templates目录,去这个目录中寻找'login.html'
# - 一般情况下,原则,那个app中的的模板,去哪个那个app中寻找。
# - b.渲染(替换)得到替换完成的字符串
# - c.返回浏览器
return render(request, 'api/login.html')
4.5 响应头
from django.shortcuts import HttpResponse, redirect, render
from django.http import JsonResponse
def login(request):
res = HttpResponse("login") #前后端分离常用
res['xx1'] = "hahaha"
res['xx2'] = "hahaha"
res['xx3'] = "hahaha"
res.set_cookie('k1',"aaaaaaaa")
res.set_cookie('k2',"bbbbbb")
return res
4.6 FBV和CBV
- FBV,视图用函数的形式编写。(目前主流)
- CBV,视图用类的形式编写。
请注意,这一些都是表象,本质一模一样。
5.静态资源
静态资源:
开发需要:css、js、图片。
- 根目录的 /static/ - 已经app目录下载 /static/ 文件夹下
媒体文件:用户上传的数据(excel/pdf/video)
- 根目录的 /media/
5.1 静态文件
INSTALLED_APPS = [
# 'django.contrib.admin',
# 'django.contrib.auth',
# 'django.contrib.contenttypes',
# 'django.contrib.sessions',
# 'django.contrib.messages',
'django.contrib.staticfiles',
"apps.api.apps.ApiConfig",
"apps.web.apps.WebConfig",
]
...
STATIC_URL = '/static/' #这是发请求时用的url,和下面的文件路径不一样,注意区分
STATICFILES_DIRS = (
os.path.join(BASE_DIR, 'static'),
os.path.join(BASE_DIR, 'apps','web','static'), #多app时这么写
)
顺序:...
多app开发:各自app的图片放在各自
/static/app名字/。。。
在开发过程中
禁止
html<img src="/static/api/1.png">
建议
html{% load static %} <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title>Title</title> </head> <body> <h1>登录页面</h1> <a href="/xxx/xxxxx/">调换dao xx</a> <a href="{% url 'login' %}">跳转</a> <img src="{% static 'api/1.png' %}"> </body> </html>
5.2 媒体文件
urls.py
from django.contrib import admin
from django.urls import path, re_path, include
from django.conf.urls.static import static
from django.conf import settings
from apps.api import views
# 很多功能,很多URL
urlpatterns = [
path('api/', include('apps.api.urls')),
] + static(settings.MEDIA_URL, document_root=settings.MEDIA_ROOT)
任务
知识点搞定(动手操作) -> 知识点
两种情况
- 多app
- 单app
设计自己的项目(多app项目)
- 几个app
- 前缀url,分发
- 模板和静态文件
预习
Git版本控制
- 先看 https://www.bilibili.com/video/BV19E411f76x?spm_id_from=333.999.0.0 - 直接用
中间价、ORM、缓存、session、cookie(全家桶)
- 先看全家桶 - 笔记 https://www.cnblogs.com/wupeiqi/articles/6216618.html
内容回顾
请求周期
路由系统
- 最基本路由关系
- 动态路由(含正则)
- 路由分发不同的app中 + include + 本质 + name + namespace
视图
类和函数(FBV和CBV)
参数 request
- 请求数据
- 自定义数据
响应
HttpResponse/JsonResponse/render/redirect return HttpResponse("...") 响应头 obj = HttpResponse("...") obj['xxxxx'] = "值" return obj
其他知识
虚拟环境
纯净版项目,内置app功能去掉。
多app,嵌套到apps目录。
pycharm创建django项目 + 虚拟环境
- 最新的django项目
- 低版本(环境+项目+django文件模板)
settings配置
django默认settings [先加载] 500 项目目录settings [后加载] 20
静态资源
- 静态文件,项目必备【项目根目录,每个app目录下static - app注册顺序】
- 媒体文件,用户上传
1.模板
1.1 寻找html模板
TEMPLATES = [
{
'BACKEND': 'django.template.backends.django.DjangoTemplates',
'DIRS': [os.path.join(BASE_DIR, 'templates')],
'APP_DIRS': True,
'OPTIONS': {
'context_processors': [
'django.template.context_processors.debug',
'django.template.context_processors.request',
# 'django.contrib.auth.context_processors.auth',
# 'django.contrib.messages.context_processors.messages',
],
},
},
]
优先去项目根目录 > 每个已注册的app的templates目录找。
如何选择:
- 简单的项目,模板都放在根目录。
- 复杂的项目,模板放在各自的app中,公共部分放在templates目录。
扩展:修改内置app的模板也是同样的套路。
1.2 模板处理的本质
- 打开 app01/index.html 文件,读取内容。
- 渲染完成,得到一个超长字符串
- 返回给浏览器
渲染:在django中替换 这样的占位符,返回给浏览器超长字符串
像下图这样用js文件导入,django之所以渲染完成后,浏览器的效果是弹出 ,而不是刺头,是因为:
1.Django先读取index.html文件,替换里面的n1,返回给浏览器
2.浏览器发现返回的字符串中还有一个js文件,向这个js文件发请求
3.由于js文件是静态文件,所以发请求得到的是 alert() 这个字符串,所以浏览器弹出,而不是刺头
1.3 常用语法
模版中可以使用生成器
1.4 内置函数
在django模板语法中提供了内置函数让我们来。
1.5 自定义模板功能
三种方式:
filter
- 数据处理,参数:1~2个 - 数据处理,if条件
simple_tag
参数无限制 & 返回文本
inclusion_tag
参数无限制 & HTML片段
需求来了:根据用户权限不同显示不同的菜单。
1.6 继承和母版
1.7 模板的导入
2.django中间件
- 类
- 定义方法
- 注册(中间件可以放在任何路径下,但记得注册!)
2.1 原始方式
2.2 MiddlewareMixin(建议)
注意:django1版本。
源码:
面向对象
pythonclass MyMd(object): def __init__(self....): pass def __call__(self,....): pass django内部默认执行call方法,传入参数。
反射
pythonclass MyMd(object): def __init__(self....): pass def __call__(self,....): if hasattr(self,'process_request'): response = self.process_request(request) ... django内部默认执行call方法,传入参数。
pythonclass MiddlewareMixin: def __init__(self, get_response=None): self.get_response = get_response def __call__(self, request): response = None if hasattr(self, 'process_request'): response = self.process_request(request) response = response or self.get_response(request) if hasattr(self, 'process_response'): response = self.process_response(request, response) return response class MyMd(MiddlewareMixin): def process_request(self,request): ... def process_response(self,request, response): ... django内部默认请求进来了执行call方法,传入参数。
疑问:prcess_request的执行时,是否已执行了路由匹配?
request.resolver_match
注意:process_view是在django中源码中写死了。
上图中第二个中间价的process_view返回值,但不是从第二个中间件返回,而是从最后一个中间价的process_response返回,如下图。
注意:process_request和process_view的区别:
process_request:在执行所有请求之前最先进行筛选或操作。如判断用户是否登陆
process_view:是在所有的process_request通过之后,在执行具体某个请求(view函数)之前进行的步骤,是针对即将进行的view函数进行筛选或操作。如判断用户是否具有当前url的访问权限。
2.3 其他
小结
- 定义中间类
- 类方法
- process_request
- process_view
- process_reponse
- process_exception,视图函数出现异常,自定义异常页面。
- process_template_response,视图函数返回
TemplateResponse
对象 or 对象中含有.render方法。
3.ORM操作
orm,关系对象映射,本质翻译的。
3.1 表结构
实现:创建表、修改表、删除表。
在app中的models.py中按照规则编写类 ===> 表结构。
编写类
pythonfrom django.db import models class UserInfo(models.Model): name = models.CharField(max_length=16) age = models.IntegerField()
注册app
pythonINSTALLED_APPS = [ # 'django.contrib.admin', # 'django.contrib.auth', # 'django.contrib.contenttypes', # 'django.contrib.sessions', # 'django.contrib.messages', 'django.contrib.staticfiles', 'apps.app01.apps.App01Config', 'apps.app02.apps.App02Config', ]
命令,django根据models中类生成一个
对数据库操作的配置文件
=>migrations
python manage.py makemigrations
命令,读取已经注册么给app中的migrations目录将配置文件 -> 转换成:生成表,修改表 SQL -> 连接数据库去运行。
pythonpython manage.py migrate
- 那个数据库?
- 数据库账户和密码?
DATABASES = { 'default': { 'ENGINE': 'django.db.backends.sqlite3', 'NAME': os.path.join(BASE_DIR, 'db.sqlite3'), } }
常见问题:请不要再手动去修改数据的表结构 + 时刻保证 ORM和数据表是对应。
3.1.1 常见字段和参数
字段
CharField SmallIntegerField IntegerField BigIntegerField DateField DateTimeField BooleanField -> 其实数据库不支持真假,根据SmallIntegerField创造出来出来。 0 1 DecimalField -> 精确的小数
参数
pythonname = models.CharField(verbose_name="姓名", max_length=16) name = models.CharField(verbose_name="姓名", max_length=16, default="哈哈哈") # 经常查询,速度快(MySQL,https://www.bilibili.com/video/BV15R4y1b7y9) name = models.CharField(verbose_name="姓名", max_length=16, default="哈哈哈", null=True, blank=True, db_index=True) email = models.CharField(verbose_name="姓名", max_length=16, default="哈哈哈", null=True, blank=True, unique=True) # 在数据库存储时只能是:sh、bj (上海、北京一般用于页面显示中文) code = models.CharField(verbose_name="姓名", max_length=16, choices=(("sh", "上海"), ("bj", "北京")),default="sh")
python# 不用 max_length=16 count = models.IntegerField(verbose_name="数量", default=1, null=True, blank=True, unique=True) code = models.IntegerField(verbose_name="性别",choices=((1, "男"), (2, "女")),default=1)
pythonregister_date = models.DateField(verbose_name="注册时间", auto_now=True)
pythonamount = models.DecimalField(verbose_name="余额", max_digits=10, decimal_places=2)
示例:
from django.db import models
class UserInfo(models.Model):
name = models.CharField(verbose_name="姓名", max_length=16, db_index=True)
age = models.PositiveIntegerField(verbose_name="年龄")
email = models.CharField(verbose_name="邮箱", max_length=128, unique=True)
amount = models.DecimalField(verbose_name="余额", max_digits=10, decimal_places=2, default=0)
register_date = models.DateField(verbose_name="注册时间", auto_now=True)
class Goods(models.Model):
title = models.CharField(verbose_name="标题", max_length=32)
# detail = models.CharField(verbose_name="详细信息", max_length=255)
detail = models.TextField(verbose_name="详细信息")
price = models.PositiveIntegerField(verbose_name="价格")
count = models.PositiveBigIntegerField(verbose_name="库存", default=0)
3.1.2 表关系
注意:ManyToManyField生成的表字段只能id/bid/gid
小结
设计自己项目的业务时,理清楚表与表之间的关系。
强调:设计项目表结构:表名和字段都不要拼音。
3.2 数据
实现:增删改查。
任务
- 知识点
- 自己的项目设计表结构,自己设计。
- 项目功能描述
- 表结构
- 设计图(提交)
- ORM类(主要)
提交形式:zip包 -> markdown编写。
下节预告:
orm数据操作、cookie和session、缓存、刷票平台(表结构设计)、用户管理、用户+权限菜单
day05 知识点+项目
今日概要:
- ORM相关
- session和cookie
- 缓存
- 项目:
- 功能需求
- 表结构
- 功能实现
1.orm
1.1 基本操作
orm,关系对象映射。
类 --> SQL --> 表
对象 --> SQL --> 数据
特点:开发效率高、执行效率低( 程序写的垃圾SQL )。
编写ORM操作的步骤:
settings.py,连接数据库
pythonDATABASES = { 'default': { 'ENGINE': 'django.db.backends.sqlite3', 'NAME': BASE_DIR / 'db.sqlite3', } }
settings.py,注册app
INSTALLED_APP = [ ... "app01.apps.App01Config" ]
编写models.类
pythonclass UserInfo(models.Model): .... .....
执行命令
python manage.py makemigrations # 找到所有已注册的app中的models.py中的类读取 -> migrations配置 python manage.py migrate # 读取已注册的app下的migrations配置 -> SQL语句 -> 同步数据库
1.2 连接数据库
DATABASES = {
'default': {
'ENGINE': 'django.db.backends.sqlite3',
'NAME': BASE_DIR / 'db.sqlite3',
}
}
DATABASES = {
'default': {
'ENGINE': 'django.db.backends.mysql',
'NAME': 'xxxxxxxx', # 数据库名字
'USER': 'root',
'PASSWORD': 'root123',
'HOST': '127.0.0.1', # ip
'PORT': 3306,
}
}
项目连接MySQL:
安装MySQL & 启动MySQL服务
手动创建数据库
django的settings.py配置
pythonDATABASES = { 'default': { 'ENGINE': 'django.db.backends.mysql', 'NAME': 'xxxxxxxx', # 数据库名字 'USER': 'root', 'PASSWORD': 'root123', 'HOST': '127.0.0.1', # ip 'PORT': 3306, } }
安装第三方组件
pymysql
pip install pymysql
项目根目录/项目名目录/__init__.py import pymysql pymysql.install_as_MySQLdb()
mysqlclient
pip install mysqlclient
电脑上先提前安装MySQL。
其他数据库:
DATABASES = {
'default': {
'ENGINE': 'django.db.backends.postgresql',
'NAME': 'mydatabase',
'USER': 'mydatabaseuser',
'PASSWORD': 'mypassword',
'HOST': '127.0.0.1',
'PORT': 5432,
}
}
# 需要 pip install psycopg2
DATABASES = {
'default': {
'ENGINE': 'django.db.backends.oracle',
'NAME': "xxxx", # 库名
"USER": "xxxxx", # 用户名
"PASSWORD": "xxxxx", # 密码
"HOST": "127.0.0.1", # ip
"PORT": 1521, # 端口
}
}
# 需要 pip install cx-Oracle
1.3 连接池
django默认内置没有数据库连接池 。
pymysql -> 操作数据库
DBUtils -> 连接池
https://pypi.org/project/django-db-connection-pool/
pip install django-db-connection-pool
DATABASES = {
"default": {
'ENGINE': 'dj_db_conn_pool.backends.mysql',
'NAME': 'day04', # 数据库名字
'USER': 'root',
'PASSWORD': 'root123',
'HOST': '127.0.0.1', # ip
'PORT': 3306,
'POOL_OPTIONS': {
'POOL_SIZE': 10, # 最小
'MAX_OVERFLOW': 10, # 在最小的基础上,还可以增加10个,即:最大20个。
'RECYCLE': 24 * 60 * 60, # 连接可以被重复用多久,超过会重新创建,-1表示永久。
'TIMEOUT':30, # 池中没有连接最多等待的时间。
}
}
}
注意:组件django-db-connection-pool
不是特别厉害。拿了另外一个支持SQLAchemy数据库连接池的组件。
1.4 多数据库
django支持项目连接多个数据库。
DATABASES = {
"default": {
'ENGINE': 'dj_db_conn_pool.backends.mysql',
'NAME': 'day05db', # 数据库名字
'USER': 'root',
'PASSWORD': 'root123',
'HOST': '127.0.0.1', # ip
'PORT': 3306,
'POOL_OPTIONS': {
'POOL_SIZE': 10, # 最小
'MAX_OVERFLOW': 10, # 在最小的基础上,还可以增加10个,即:最大20个。
'RECYCLE': 24 * 60 * 60, # 连接可以被重复用多久,超过会重新创建,-1表示永久。
'TIMEOUT': 30, # 池中没有连接最多等待的时间。
}
},
"bak": {
'ENGINE': 'dj_db_conn_pool.backends.mysql',
'NAME': 'day05bak', # 数据库名字
'USER': 'root',
'PASSWORD': 'root123',
'HOST': '127.0.0.1', # ip
'PORT': 3306,
'POOL_OPTIONS': {
'POOL_SIZE': 10, # 最小
'MAX_OVERFLOW': 10, # 在最小的基础上,还可以增加10个,即:最大20个。
'RECYCLE': 24 * 60 * 60, # 连接可以被重复用多久,超过会重新创建,-1表示永久。
'TIMEOUT': 30, # 池中没有连接最多等待的时间。
}
},
}
1.4.1 读写分离
192.168.1.2 default master [写]
组件
192.168.2.12 bak slave [读]
生成数据库表
python manage.py makemigrations # 找到所有已注册的app中的models.py中的类读取 -> migrations配置 python manage.py migrate python manage.py migrate --database=default python manage.py migrate --database=bak
后续再进行开发时
pythonmodels.UserInfo.objects.using("default").create(title="武沛齐") models.UserInfo.objects.using("bak").all()
编写router类,简化【后续再进行开发时】
pythonclass DemoRouter(object): def db_for_read(...): return "bak" def db_for_write(...): return "default"
router = ["DemoRouter"]
用DemoClass时要在settings里配置,如下图左边DATABASE_ROUTERS
1.4.2 分库(多个app ->多数据库)
100张表,50表-A数据库【app02】;50表-B数据库【app02】。
app01/models
pythonfrom django.db import models class UserInfo(models.Model): title = models.CharField(verbose_name="标题", max_length=32)
app02/models
pythonfrom django.db import models class Role(models.Model): title = models.CharField(verbose_name="标题", max_length=32)
命令
pythonpython manage.py makemigrations
python manage.py migrate app01 --database=default
python manage.py migrate app02 --database=bak
读写操作
pythonfrom django.shortcuts import render, HttpResponse from app01 import models as m1 from app02 import models as m2 def index(request): # app01中的操作 -> default v1 = m1.UserInfo.objects.all() print(v1) # app02中的操作 -> bak v2 = m2.Role.objects.using('bak').all() print(v2) return HttpResponse("返回")
router
1.4.3 分库(单app)
100张表,50表-A数据库;50表-B数据库。
from django.shortcuts import render, HttpResponse
from app01 import models as m1
def index(request):
# app01中的操作 -> default
v1 = m1.UserInfo.objects.all()
print(v1)
# app01中的操作 -> bak
v2 = m1.Role.objects.using('bak').all()
print(v2)
return HttpResponse("返回")
1.4.4 注意事项
分库,表拆分到不用数据库。
一定不要跨数据库做关联 -> django不支持 怎么办? 尽可能的将有关联的表放在一个库中。
为什么表拆分到不同的库?
1.5 表关系
单表
pythonclass Role(models.Model): title = models.CharField(verbose_name="标题", max_length=32)
一对多
多对多
如果关系表中只有3列
pythonclass Boy(models.Model): """ 1 杰森斯坦森 2 汤普森 """ name = models.CharField(verbose_name="标题", max_length=32, unique=True) b = models.ManyToManyField(to="Girl") class Girl(models.Model): """ 1 alex 2 苑昊 """ name = models.CharField(verbose_name="标题", max_length=32, unique=True)
pythonclass Boy(models.Model): """ 1 杰森斯坦森 2 汤普森 """ name = models.CharField(verbose_name="标题", max_length=32, unique=True) class Girl(models.Model): """ 1 alex 2 苑昊 """ name = models.CharField(verbose_name="标题", max_length=32, unique=True) b = models.ManyToManyField(to="Boy")
pythonclass Boy(models.Model): name = models.CharField(verbose_name="标题", max_length=32, unique=True) class Girl(models.Model): name = models.CharField(verbose_name="标题", max_length=32, unique=True) class B2G(models.Model): bid = models.ForeignKey(to="Boy", on_delete=models.CASCADE) gid = models.ForeignKey(to="Girl", on_delete=models.CASCADE) address = models.CharField(verbose_name="地点", max_length=32)
一对一( 用 models.OneToOneField !!!,models.ForeignKey不唯一!!!)
表,100列 -> 50A表 50B表 博客园为例: - 注册,用户名、密码,无法创建博客 - 开通博客 地址/
1.6 数据操作
单表
pythonclass Role(models.Model): title = models.CharField(verbose_name="标题", max_length=32)
python# obj1 = models.Role.objects.create(title="管理员", od=1) # obj2 = models.Role.objects.create(**{"title": "管理员", "od": 1}) # 内存 -> save # obj = models.Role(title="客户", od=1) # obj.od = 100 # obj.save() # obj = models.Role(**{"title": "管理员", "od": 1}) # obj.od = 100 # obj.save()
python# models.Role.objects.all().delete() models.Role.objects.filter(title="管理员").delete()
表的更新有两种方式:
方式一:
pythonmodels.Role.objects.all().update(od=99) models.Role.objects.filter(id=7).update(od=99, title="管理员") models.Role.objects.filter(id=7).update(**{"od": 99, "title": "管理员"})
方式二:F对象(这里先不写)
表的查询:
python# QuerySet = [obj, obj] v1 = models.Role.objects.all() for obj in v1: print(obj, obj.id, obj.title, obj.od) # QuerySet = [] # v2 = models.Role.objects.filter(od=99, id=99) v2 = models.Role.objects.filter(**{"od": 99, "id": 99}) for obj in v2: print(obj, obj.id, obj.title, obj.od) v3 = models.Role.objects.filter(id=99) print(v3.query) v3 = models.Role.objects.filter(id__gt=2) print(v3.query) v3 = models.Role.objects.filter(id__gte=2) print(v3.query) v3 = models.Role.objects.filter(id__lt=2) print(v3.query) v3 = models.Role.objects.filter(id__in=[11, 22, 33]) print(v3.query) v3 = models.Role.objects.filter(title__contains="户") print(v3.query) v3 = models.Role.objects.filter(title__startswith="户") print(v3.query) v3 = models.Role.objects.filter(title__isnull=True) print(v3.query)
pythonv3 = models.Role.objects.filter(id=99) print(v3.query) # 不等于 v3 = models.Role.objects.exclude(id=99).filter(od=88) print(v3.query)
python# queryset=[obj,obj] v3 = models.Role.objects.filter(id=99) # queryset=[{'id': 6, 'title': '客户'}, {'id': 7, 'title': '客户'}] v4 = models.Role.objects.filter(id__gt=0).values("id", 'title') # QuerySet = [(6, '客户'), (7, '客户')] v5 = models.Role.objects.filter(id__gt=0).values_list("id", 'title') print(v5[0])
pythonv6 = models.Role.objects.filter(id__gt=0).first() # print(v6) # 对象 v7 = models.Role.objects.filter(id__gt=10).exists() print(v7) # True/False
python# asc v8 = models.Role.objects.filter(id__gt=0).order_by("id") # id desc od asc v9 = models.Role.objects.filter(id__gt=0).order_by("-id", 'od')
一对多
pythonclass Depart(models.Model): """ 部门 """ title = models.CharField(verbose_name="标题", max_length=32) class Admin(models.Model): name = models.CharField(verbose_name="姓名", max_length=32) pwd = models.CharField(verbose_name="密码", max_length=32) depart = models.ForeignKey(verbose_name="部门", to="Depart", on_delete=models.CASCADE)
pythonmodels.Admin.objects.create(name='武沛齐1', pwd='123123123', depart_id=2) # models.Admin.objects.create(**{..}) obj = models.Depart.objects.filter(id=2).first() models.Admin.objects.create(name='武沛齐2', pwd='123123123', depart=obj) models.Admin.objects.create(name='武沛齐2', pwd='123123123', depart_id=obj.id)
python# filter() # 当前表的字段 + depart__字段 -> 连表和条件 # 找到部门id=3的所有的员工,删除 # models.Admin.objects.filter(depart_id=3).delete() # 删除销售部的所有员工 # obj = models.Depart.objects.filter(title="销售部").first() # models.Admin.objects.filter(depart_id=obj.id).delete() # models.Admin.objects.filter(depart__title="销售部", name='武沛齐').delete()
python# 1. select * from admin queryset=[obj,obj,] v1 = models.Admin.objects.filter(id__gt=0) for obj in v1: print(obj.name, obj.pwd, obj.id, obj.depart_id) # 2. select * from admin inner join depart queryset=[obj,obj,] v2 = models.Admin.objects.filter(id__gt=0).select_related("depart") # select_related里面写的是Foreign Key的字段,强制连表。 for obj in v2: print(obj.name, obj.pwd, obj.id, obj.depart_id, obj.depart.title) # 3. select id,name.. from admin inner join depart queryset=[{},{}] v3 = models.Admin.objects.filter(id__gt=0).values("id", 'name', 'pwd', "depart__title") print(v3) # 4. select id,name.. from admin inner join depart queryset=[(),()] v4 = models.Admin.objects.filter(id__gt=0).values_list("id", 'name', 'pwd', "depart__title") print(v4)
python# 查询 # models.Admin.objects.filter(id=2).update(name='xxx', pwd='xxxx') # models.Admin.objects.filter(name="武沛齐").update(depart_id=2) # models.Admin.objects.filter(id=2).update(depart__title="技术部") -> 只能更新自己表字段 ,连表只能进行查询,不能删除和更新。

多对多

from django.db import models class Boy(models.Model): name = models.CharField(verbose_name="姓名", max_length=32, db_index=True) class Girl(models.Model): name = models.CharField(verbose_name="姓名", max_length=32, db_index=True) class B2G(models.Model): bid = models.ForeignKey(to="Boy", on_delete=models.CASCADE) gid = models.ForeignKey(to="Girl", on_delete=models.CASCADE) address = models.CharField(verbose_name="地点", max_length=32)
def index(request): # models.Boy.objects.create(name="宝强") # models.Boy.objects.create(name="羽凡") # models.Boy.objects.create(name="乃亮") # # models.Girl.objects.bulk_create( # objs=[models.Girl(name="小路"), models.Girl(name="百合"), models.Girl(name="马蓉")], # batch_size=3 # ) # 创建关系 # models.B2G.objects.create(bid_id=1, gid_id=3, address="北京") # models.B2G.objects.create(bid_id=1, gid_id=2, address="北京") # models.B2G.objects.create(bid_id=2, gid_id=2, address="北京") # models.B2G.objects.create(bid_id=2, gid_id=1, address="北京") # b_obj = models.Boy.objects.filter(name='宝强').first() # g_object = models.Girl.objects.filter(name="小路").first() # models.B2G.objects.create(bid=b_obj, gid=g_object, address="北京") # 1.宝强都与谁约会。 # queyset=[obj,obj,obj] # q = models.B2G.objects.filter(bid__name='宝强').select_related("gid") # for item in q: # print(item.id, item.address, item.bid.name, item.gid.name) # q = models.B2G.objects.filter(bid__name='宝强').values("id", 'bid__name', 'gid__name') # for item in q: # print(item['id'], item['bid__name'], item['gid__name']) # 2.百合 都与谁约会。 # q = models.B2G.objects.filter(gid__name='百合').values("id", 'bid__name', 'gid__name') # for item in q: # print(item['id'], item['bid__name'], item['gid__name']) # 3.删除 # models.B2G.objects.filter(id=1).delete() # models.Boy.objects.filter(id=1).delete() return HttpResponse("返回")
一对一