-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathmodels.py
More file actions
123 lines (102 loc) · 3.12 KB
/
Copy pathmodels.py
File metadata and controls
123 lines (102 loc) · 3.12 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
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
import enum
#from sqlalchemy import Column, String, Integer, DateTime, Enum
from flask_sqlalchemy import SQLAlchemy
db = SQLAlchemy()
'''
setup_db(app)
binds a flask application and a SQLAlchemy service
'''
def setup_db(app, database_path):
app.config["SQLALCHEMY_DATABASE_URI"] = database_path
app.config["SQLALCHEMY_TRACK_MODIFICATIONS"] = False
db.app = app
db.init_app(app)
# db.create_all()
#
# Gender Enum type for actor
#
class Gender(enum.Enum):
male = 'M'
female = 'F'
#
# The association table to handle the many to many relationship
# of Actor and Movie
#
association_table = db.Table('association',
db.Column('movie_id', db.Integer, db.ForeignKey('movie.id')),
db.Column('actor_id', db.Integer, db.ForeignKey('actor.id'))
)
class Movie(db.Model):
__tablename__ = 'movie'
id = db.Column(db.Integer, primary_key=True)
title = db.Column(db.String(255))
date_release = db.Column(db.Date)
actors = db.relationship('Actor', secondary=association_table,
backref=db.backref('movies'))
def __init__(self, title, date_release, actors):
self.title = title
self.date_release = date_release
self.actors = actors
def insert(self):
db.session.add(self)
db.session.commit()
def update(self):
db.session.commit()
def delete(self):
db.session.delete(self)
db.session.commit()
def get_actors(self):
actors = []
for i in self.actors:
actors.append(i.id)
return actors
def format(self):
return {
'id': self.id,
'title': self.title,
'date_release': self.date_release.strftime('%Y%m%d'),
'actors_id': self.get_actors(),
}
class Actor(db.Model):
__tablename__ = 'actor'
id = db.Column(db.Integer, primary_key=True)
name = db.Column(db.String(255))
age = db.Column(db.Integer)
gender = db.Column(db.Enum(Gender))
def __init__(self, name, age, gender):
self.name = name
self.age = age
self.gender = gender
def insert(self):
db.session.add(self)
db.session.commit()
def update(self):
db.session.commit()
def delete(self):
db.session.delete(self)
db.session.commit()
def get_movies(self):
movies = []
for i in self.movies:
movies.append(i.id)
return movies
def format(self):
return {
'id': self.id,
'name': self.name,
'age': self.age,
'gender': self.gender.value,
'movies_id': self.get_movies(),
}
#
# Event listener to check the table Movie and delete any movie
# will does not have any actor assiociated with it
#
# https://stackoverflow.com/questions/9234082/setting-delete-orphan-on-sqlalchemy-relationship-causes-assertionerror-this-att
#
@db.event.listens_for(db.session, "after_flush")
def after_flush(session, flush_context):
#print("After flush.......")
session.query(Movie).\
filter(~Movie.actors.any()).\
delete(synchronize_session=False)