Python廖雪峰实战web开发（day4-编写Model）

编写Model

结合上文编写完ORM，我们就可以把博客中需要用到的

Uers

,

blogs

以及

comments

各自的信息，存储到数据库的三个表中，并透过使用

Model

表示出来。

编写代码如下：

#!usr/bin/env python
# -*- coding: utf-8 -*-

'''
创建model
'''

__author__='Seiei'

import uuid,time
import asyncio
from web_app import orm
from web_app.orm import Model,StringField,IntegerField,BooleanField,TextField,FloatField
#from orm import Model,StringField,IntegerField,BooleanField,TextField,FloatField

def next_id():#随机生成id
return '%015d%s000'%(int(time.time()*1000),uuid.uuid4().hex)

class User(Model):
__table__ = 'users'
id = StringField(primary_key=True, default=next_id, ddl='varchar(50)')
email =  StringField(ddl='varchar(50)')
passwd = StringField(ddl='varchar(50)')
admin = BooleanField()
name = StringField(ddl='varchar(50)')
image = StringField(ddl='varchar(500)')#注意由于是image，所以这里接受字节是500
create_at = FloatField(default=time.time)

class Blog(Model):
__table__ = 'blogs'
id = StringField(primary_key=True, default=next_id,ddl='varchar(50)')
user_id = StringField(ddl='varchar(50)')
user_name = StringField(ddl='varchar(50)')
user_image = StringField(ddl='varchar(500)')
name = StringField(ddl='varchar(50)')
summary = StringField(ddl='varchar(200)')
content = TextField()
create_at = FloatField(default=time.time)

class Comment(Model):
__table__ = 'comments'
id = StringField(primary_key=True, default=next_id, ddl='varchar(50)')
blog_id = StringField(ddl='varchar(50)')
user_id = StringField(ddl='varchar(50)')
user_name = StringField(ddl='varchar(50)')
user_image = StringField(ddl='varchar(500)')
content = TextField()
create_at = FloatField(default=time.time)

if __name__== '__main__':

async def test():
await orm.create_pool(loop,user='www-data', password='www-data', db='awesome')
u = User(name='Test', email='test@example.com', passwd='123456780', image='about:blank')
await u.save()
a = await u.findall() #这个要打印才显示出来
print(a)

loop = asyncio.get_event_loop()
loop.run_until_complete(test())
orm.__pool.close()  #在关闭event loop之前，首先需要关闭连接池。
loop.run_until_complete(orm.__pool.wait_closed())#在关闭event loop之前，首先需要关闭连接池。
loop.close()

在编写完

Model

代码后，我自行添加了数据访问代码，试着检测一下所写

ORM

以及

Model

是否有误。

但在此之前，得先初始化数据库表。

初始化数据库表

我是直接使用Python中的

mysql

模块对数据库进行操作。教程可看廖老师的，或看详细的官方文档。

代码如下：

#!/usr/bin/env python3
# -*- coding: utf-8 -*-

__author__ = 'Seiei'

import mysql.connector

conn = mysql.connector.connect(user='root', password='password', database='awesome')#连接MySQL数据库中的awesome数据库
cursor = conn.cursor()#创建游标
cursor.execute('create table users (id varchar(50) primary key,email varchar(50),passwd varchar(50),name varchar(50),image varchar(500),admin boolean,create_at real)')#创建users表-->表列都要定义名字及类型，主键后还要跟primary key
cursor.execute('create table blogs (id varchar(50) primary key,user_id varchar(50),user_name varchar(50),user_image varchar(500),name varchar(50),summary varchar(200),content text,create_at real)')#创建blogs表
cursor.execute('create table comments (id varchar(50) primary key,blog_id varchar(50),user_id varchar(50),user_name varchar(50),user_image varchar(500),content text,create_at real)')#创建comments表
cursor.close()
conn.commit()
conn.close()