models.py
2.29 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
# -*- coding: utf-8 -*-
import json
from . import Base, db_adapter
from sqlalchemy import Column, Integer, String, DateTime, ForeignKey, Text, TypeDecorator
from sqlalchemy.orm import relation, backref
from server.utils import get_now
def relationship(*arg, **kw):
ret = relation(*arg, **kw)
db_adapter.commit()
return ret
def to_dic(inst, cls):
# add your coversions for things like datetime's
# and what-not that aren't serializable.
convert = dict()
# convert[TZDateTime] = date_serializer
d = dict()
for c in cls.__table__.columns:
v = getattr(inst, c.name)
if c.type.__class__ in convert.keys() and v is not None:
try:
func = convert[c.type.__class__]
d[c.name] = func(v)
except:
d[c.name] = "Error: Failed to covert using ", str(convert[c.type.__class__])
else:
d[c.name] = v
return d
def to_json(inst, cls):
return json.dumps(to_dic(inst, cls))
class DBBase(Base):
"""
DB model base class, providing basic functions
"""
__abstract__ = True
def __init__(self, **kwargs):
super(DBBase, self).__init__(**kwargs)
def dic(self):
return to_dic(self, self.__class__)
def json(self):
return to_json(self, self.__class__)
def __repr__(self):
return '%s: %s' % (self.__class__.__name__, self.json())
class User(DBBase):
__tablename__ = 'user'
id = Column(Integer, primary_key=True)
name = Column(String(64))
password = Column(String(128))
role = Column(String(16))
status = Column(String(32))
create_time = Column(DateTime, default=get_now())
last_login_time = Column(DateTime, default=get_now())
def __init__(self, **kwargs):
super(User, self).__init__(**kwargs)
class UserToken(DBBase):
__tablename__ = 'user_token'
id = Column(Integer, primary_key=True)
token = Column(String(64), unique=True, nullable=False)
user_id = Column(Integer, ForeignKey('user.id', ondelete='CASCADE'))
user = relationship('User', backref=backref('tokens', lazy='dynamic'))
create_time = Column(DateTime, default=get_now())
expire_time = Column(DateTime, nullable=False)
def __init__(self, **kwargs):
super(UserToken, self).__init__(**kwargs)