编写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()

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

编写Model

初始化数据库表

更多相关文章

随机推荐