1
|
|
|
"""Geolocation, Companies |
2
|
|
|
|
3
|
|
|
Revision ID: 2001fdefaa7e |
4
|
|
|
Revises: 84ae0c957a5 |
5
|
|
|
Create Date: 2016-09-01 16:30:20.397625 |
6
|
|
|
|
7
|
|
|
""" |
8
|
|
|
|
9
|
|
|
# revision identifiers, used by Alembic. |
10
|
|
|
revision = '2001fdefaa7e' |
11
|
|
|
down_revision = '84ae0c957a5' |
12
|
|
|
|
13
|
|
|
from alembic import op |
14
|
|
|
import sqlalchemy as sa |
15
|
|
|
from datetime import datetime |
16
|
|
|
|
17
|
|
|
|
18
|
|
|
def create_nullable_columns(): |
19
|
|
|
op.add_column(u'jobs', sa.Column('address_is_valid', sa.Boolean(), nullable=True)) |
20
|
|
|
op.add_column(u'jobs', sa.Column('geolocation_is_valid', sa.Boolean(), nullable=True)) |
21
|
|
|
op.add_column(u'jobs', sa.Column('last_sync', sa.DateTime(timezone=True), nullable=True)) |
22
|
|
|
op.add_column(u'jobs', sa.Column('latitude', sa.Float(), nullable=True)) |
23
|
|
|
op.add_column(u'jobs', sa.Column('longitude', sa.Float(), nullable=True)) |
24
|
|
|
op.add_column(u'jobs', sa.Column('pushed_on_twitter', sa.Boolean(), nullable=True)) |
25
|
|
|
|
26
|
|
|
|
27
|
|
|
def set_nullable_columns_default_values(): |
28
|
|
|
role = sa.table(u'jobs', sa.column(u'address_is_valid')) |
29
|
|
|
op.execute(role.update().values(address_is_valid=True)) |
30
|
|
|
|
31
|
|
|
role = sa.table(u'jobs', sa.column(u'geolocation_is_valid')) |
32
|
|
|
op.execute(role.update().values(geolocation_is_valid=True)) |
33
|
|
|
|
34
|
|
|
role = sa.table(u'jobs', sa.column(u'last_sync')) |
35
|
|
|
op.execute(role.update().values(last_sync=datetime(1970, 1, 1))) |
36
|
|
|
role = sa.table(u'jobs', sa.column(u'latitude')) |
37
|
|
|
op.execute(role.update().values(latitude=0.0)) |
38
|
|
|
role = sa.table(u'jobs', sa.column(u'longitude')) |
39
|
|
|
op.execute(role.update().values(longitude=0.0)) |
40
|
|
|
|
41
|
|
|
role = sa.table(u'jobs', sa.column(u'pushed_on_twitter')) |
42
|
|
|
op.execute(role.update().values(pushed_on_twitter=True)) |
43
|
|
|
|
44
|
|
|
role = sa.table(u'jobs', sa.column(u'publication_datetime_is_fake')) |
45
|
|
|
op.execute(role.update() |
46
|
|
|
.where(role.c.publication_datetime_is_fake == None) |
47
|
|
|
.values(publication_datetime_is_fake=False)) |
48
|
|
|
|
49
|
|
|
|
50
|
|
|
def set_nullable_columns(): |
51
|
|
|
op.alter_column(u'jobs', u'address_is_valid', nullable=False) |
52
|
|
|
op.alter_column(u'jobs', u'geolocation_is_valid', nullable=False) |
53
|
|
|
op.alter_column(u'jobs', u'last_sync', nullable=False) |
54
|
|
|
op.alter_column(u'jobs', u'latitude', nullable=False) |
55
|
|
|
op.alter_column(u'jobs', u'longitude', nullable=False) |
56
|
|
|
op.alter_column(u'jobs', u'pushed_on_twitter', nullable=False) |
57
|
|
|
|
58
|
|
|
op.alter_column(u'jobs', u'publication_datetime_is_fake', nullable=False) |
59
|
|
|
|
60
|
|
|
|
61
|
|
|
def upgrade(): |
62
|
|
|
### commands auto generated by Alembic - please adjust! ### |
63
|
|
|
op.create_table('companies', |
64
|
|
|
sa.Column('id', sa.String(length=1024), nullable=False), |
65
|
|
|
sa.Column('name', sa.String(length=1024), nullable=False), |
66
|
|
|
sa.Column('logo_url', sa.String(length=1024), nullable=False), |
67
|
|
|
sa.Column('description', sa.Text(), nullable=False), |
68
|
|
|
sa.Column('url', sa.String(length=1024), nullable=False), |
69
|
|
|
sa.Column('technologies', sa.Text(), nullable=False), |
70
|
|
|
sa.Column('address', sa.String(length=1024), nullable=False), |
71
|
|
|
sa.Column('address_is_valid', sa.Boolean(), nullable=False), |
72
|
|
|
sa.Column('email', sa.String(length=1024), nullable=False), |
73
|
|
|
sa.Column('phone', sa.String(length=1024), nullable=False), |
74
|
|
|
sa.Column('latitude', sa.Float(), nullable=False), |
75
|
|
|
sa.Column('longitude', sa.Float(), nullable=False), |
76
|
|
|
sa.Column('geolocation_is_valid', sa.Boolean(), nullable=False), |
77
|
|
|
sa.Column('validated', sa.Boolean(), nullable=False), |
78
|
|
|
sa.Column('last_modified', sa.DateTime(timezone=True), server_default=sa.text(u'now()'), nullable=False), |
79
|
|
|
sa.Column('last_sync', sa.DateTime(timezone=True), nullable=False), |
80
|
|
|
sa.PrimaryKeyConstraint('id') |
81
|
|
|
) |
82
|
|
|
|
83
|
|
|
create_nullable_columns() |
84
|
|
|
set_nullable_columns_default_values() |
85
|
|
|
set_nullable_columns() |
86
|
|
|
|
87
|
|
|
op.add_column(u'jobs', sa.Column('last_modified', sa.DateTime(timezone=True), server_default=sa.text(u'now()'), nullable=False)) |
88
|
|
|
### end Alembic commands ### |
89
|
|
|
|
90
|
|
|
|
91
|
|
|
def downgrade(): |
92
|
|
|
### commands auto generated by Alembic - please adjust! ### |
93
|
|
|
op.alter_column(u'jobs', 'publication_datetime_is_fake', |
94
|
|
|
existing_type=sa.BOOLEAN(), |
95
|
|
|
nullable=True) |
96
|
|
|
op.drop_column(u'jobs', 'pushed_on_twitter') |
97
|
|
|
op.drop_column(u'jobs', 'longitude') |
98
|
|
|
op.drop_column(u'jobs', 'latitude') |
99
|
|
|
op.drop_column(u'jobs', 'last_sync') |
100
|
|
|
op.drop_column(u'jobs', 'last_modified') |
101
|
|
|
op.drop_column(u'jobs', 'geolocation_is_valid') |
102
|
|
|
op.drop_column(u'jobs', 'address_is_valid') |
103
|
|
|
op.drop_table('companies') |
104
|
|
|
### end Alembic commands ### |
105
|
|
|
|