5 changed files with 267 additions and 0 deletions
-
1migrations/README
-
45migrations/alembic.ini
-
96migrations/env.py
-
24migrations/script.py.mako
-
101migrations/versions/2267f00a4594_.py
@ -0,0 +1 @@ |
|||
Generic single-database configuration. |
|||
@ -0,0 +1,45 @@ |
|||
# A generic, single database configuration. |
|||
|
|||
[alembic] |
|||
# template used to generate migration files |
|||
# file_template = %%(rev)s_%%(slug)s |
|||
|
|||
# set to 'true' to run the environment during |
|||
# the 'revision' command, regardless of autogenerate |
|||
# revision_environment = false |
|||
|
|||
|
|||
# Logging configuration |
|||
[loggers] |
|||
keys = root,sqlalchemy,alembic |
|||
|
|||
[handlers] |
|||
keys = console |
|||
|
|||
[formatters] |
|||
keys = generic |
|||
|
|||
[logger_root] |
|||
level = WARN |
|||
handlers = console |
|||
qualname = |
|||
|
|||
[logger_sqlalchemy] |
|||
level = WARN |
|||
handlers = |
|||
qualname = sqlalchemy.engine |
|||
|
|||
[logger_alembic] |
|||
level = INFO |
|||
handlers = |
|||
qualname = alembic |
|||
|
|||
[handler_console] |
|||
class = StreamHandler |
|||
args = (sys.stderr,) |
|||
level = NOTSET |
|||
formatter = generic |
|||
|
|||
[formatter_generic] |
|||
format = %(levelname)-5.5s [%(name)s] %(message)s |
|||
datefmt = %H:%M:%S |
|||
@ -0,0 +1,96 @@ |
|||
from __future__ import with_statement |
|||
|
|||
import logging |
|||
from logging.config import fileConfig |
|||
|
|||
from sqlalchemy import engine_from_config |
|||
from sqlalchemy import pool |
|||
|
|||
from alembic import context |
|||
|
|||
# this is the Alembic Config object, which provides |
|||
# access to the values within the .ini file in use. |
|||
config = context.config |
|||
|
|||
# Interpret the config file for Python logging. |
|||
# This line sets up loggers basically. |
|||
fileConfig(config.config_file_name) |
|||
logger = logging.getLogger('alembic.env') |
|||
|
|||
# add your model's MetaData object here |
|||
# for 'autogenerate' support |
|||
# from myapp import mymodel |
|||
# target_metadata = mymodel.Base.metadata |
|||
from flask import current_app |
|||
config.set_main_option( |
|||
'sqlalchemy.url', current_app.config.get( |
|||
'SQLALCHEMY_DATABASE_URI').replace('%', '%%')) |
|||
target_metadata = current_app.extensions['migrate'].db.metadata |
|||
|
|||
# other values from the config, defined by the needs of env.py, |
|||
# can be acquired: |
|||
# my_important_option = config.get_main_option("my_important_option") |
|||
# ... etc. |
|||
|
|||
|
|||
def run_migrations_offline(): |
|||
"""Run migrations in 'offline' mode. |
|||
|
|||
This configures the context with just a URL |
|||
and not an Engine, though an Engine is acceptable |
|||
here as well. By skipping the Engine creation |
|||
we don't even need a DBAPI to be available. |
|||
|
|||
Calls to context.execute() here emit the given string to the |
|||
script output. |
|||
|
|||
""" |
|||
url = config.get_main_option("sqlalchemy.url") |
|||
context.configure( |
|||
url=url, target_metadata=target_metadata, literal_binds=True |
|||
) |
|||
|
|||
with context.begin_transaction(): |
|||
context.run_migrations() |
|||
|
|||
|
|||
def run_migrations_online(): |
|||
"""Run migrations in 'online' mode. |
|||
|
|||
In this scenario we need to create an Engine |
|||
and associate a connection with the context. |
|||
|
|||
""" |
|||
|
|||
# this callback is used to prevent an auto-migration from being generated |
|||
# when there are no changes to the schema |
|||
# reference: http://alembic.zzzcomputing.com/en/latest/cookbook.html |
|||
def process_revision_directives(context, revision, directives): |
|||
if getattr(config.cmd_opts, 'autogenerate', False): |
|||
script = directives[0] |
|||
if script.upgrade_ops.is_empty(): |
|||
directives[:] = [] |
|||
logger.info('No changes in schema detected.') |
|||
|
|||
connectable = engine_from_config( |
|||
config.get_section(config.config_ini_section), |
|||
prefix='sqlalchemy.', |
|||
poolclass=pool.NullPool, |
|||
) |
|||
|
|||
with connectable.connect() as connection: |
|||
context.configure( |
|||
connection=connection, |
|||
target_metadata=target_metadata, |
|||
process_revision_directives=process_revision_directives, |
|||
**current_app.extensions['migrate'].configure_args |
|||
) |
|||
|
|||
with context.begin_transaction(): |
|||
context.run_migrations() |
|||
|
|||
|
|||
if context.is_offline_mode(): |
|||
run_migrations_offline() |
|||
else: |
|||
run_migrations_online() |
|||
@ -0,0 +1,24 @@ |
|||
"""${message} |
|||
|
|||
Revision ID: ${up_revision} |
|||
Revises: ${down_revision | comma,n} |
|||
Create Date: ${create_date} |
|||
|
|||
""" |
|||
from alembic import op |
|||
import sqlalchemy as sa |
|||
${imports if imports else ""} |
|||
|
|||
# revision identifiers, used by Alembic. |
|||
revision = ${repr(up_revision)} |
|||
down_revision = ${repr(down_revision)} |
|||
branch_labels = ${repr(branch_labels)} |
|||
depends_on = ${repr(depends_on)} |
|||
|
|||
|
|||
def upgrade(): |
|||
${upgrades if upgrades else "pass"} |
|||
|
|||
|
|||
def downgrade(): |
|||
${downgrades if downgrades else "pass"} |
|||
@ -0,0 +1,101 @@ |
|||
"""empty message |
|||
|
|||
Revision ID: 2267f00a4594 |
|||
Revises: |
|||
Create Date: 2020-01-04 15:20:33.461410 |
|||
|
|||
""" |
|||
from alembic import op |
|||
import sqlalchemy as sa |
|||
|
|||
|
|||
# revision identifiers, used by Alembic. |
|||
revision = '2267f00a4594' |
|||
down_revision = None |
|||
branch_labels = None |
|||
depends_on = None |
|||
|
|||
|
|||
def upgrade(): |
|||
# ### commands auto generated by Alembic - please adjust! ### |
|||
op.create_table('tags', |
|||
sa.Column('id', sa.Integer(), nullable=False), |
|||
sa.Column('tagname', sa.String(length=100), nullable=True), |
|||
sa.PrimaryKeyConstraint('id') |
|||
) |
|||
op.create_table('users', |
|||
sa.Column('id', sa.Integer(), nullable=False), |
|||
sa.Column('username', sa.String(length=80), nullable=False), |
|||
sa.Column('email', sa.String(length=100), nullable=False), |
|||
sa.Column('password', sa.Binary(), nullable=True), |
|||
sa.Column('created_at', sa.DateTime(), nullable=False), |
|||
sa.Column('updated_at', sa.DateTime(), nullable=False), |
|||
sa.Column('bio', sa.String(length=300), nullable=True), |
|||
sa.Column('image', sa.String(length=120), nullable=True), |
|||
sa.PrimaryKeyConstraint('id'), |
|||
sa.UniqueConstraint('email'), |
|||
sa.UniqueConstraint('username') |
|||
) |
|||
op.create_table('userprofile', |
|||
sa.Column('id', sa.Integer(), nullable=False), |
|||
sa.Column('user_id', sa.Integer(), nullable=False), |
|||
sa.ForeignKeyConstraint(['user_id'], ['users.id'], ), |
|||
sa.PrimaryKeyConstraint('id'), |
|||
sa.UniqueConstraint('user_id') |
|||
) |
|||
op.create_table('article', |
|||
sa.Column('id', sa.Integer(), nullable=False), |
|||
sa.Column('slug', sa.Text(), nullable=True), |
|||
sa.Column('title', sa.String(length=100), nullable=False), |
|||
sa.Column('description', sa.Text(), nullable=False), |
|||
sa.Column('body', sa.Text(), nullable=True), |
|||
sa.Column('createdAt', sa.DateTime(), nullable=False), |
|||
sa.Column('updatedAt', sa.DateTime(), nullable=False), |
|||
sa.Column('author_id', sa.Integer(), nullable=False), |
|||
sa.ForeignKeyConstraint(['author_id'], ['userprofile.id'], ), |
|||
sa.PrimaryKeyConstraint('id'), |
|||
sa.UniqueConstraint('slug') |
|||
) |
|||
op.create_table('followers_assoc', |
|||
sa.Column('follower', sa.Integer(), nullable=True), |
|||
sa.Column('followed_by', sa.Integer(), nullable=True), |
|||
sa.ForeignKeyConstraint(['followed_by'], ['userprofile.user_id'], ), |
|||
sa.ForeignKeyConstraint(['follower'], ['userprofile.user_id'], ) |
|||
) |
|||
op.create_table('comment', |
|||
sa.Column('id', sa.Integer(), nullable=False), |
|||
sa.Column('body', sa.Text(), nullable=True), |
|||
sa.Column('createdAt', sa.DateTime(), nullable=False), |
|||
sa.Column('updatedAt', sa.DateTime(), nullable=False), |
|||
sa.Column('author_id', sa.Integer(), nullable=False), |
|||
sa.Column('article_id', sa.Integer(), nullable=False), |
|||
sa.ForeignKeyConstraint(['article_id'], ['article.id'], ), |
|||
sa.ForeignKeyConstraint(['author_id'], ['userprofile.id'], ), |
|||
sa.PrimaryKeyConstraint('id') |
|||
) |
|||
op.create_table('favoritor_assoc', |
|||
sa.Column('favoriter', sa.Integer(), nullable=True), |
|||
sa.Column('favorited_article', sa.Integer(), nullable=True), |
|||
sa.ForeignKeyConstraint(['favorited_article'], ['article.id'], ), |
|||
sa.ForeignKeyConstraint(['favoriter'], ['userprofile.id'], ) |
|||
) |
|||
op.create_table('tag_assoc', |
|||
sa.Column('tag', sa.Integer(), nullable=True), |
|||
sa.Column('article', sa.Integer(), nullable=True), |
|||
sa.ForeignKeyConstraint(['article'], ['article.id'], ), |
|||
sa.ForeignKeyConstraint(['tag'], ['tags.id'], ) |
|||
) |
|||
# ### end Alembic commands ### |
|||
|
|||
|
|||
def downgrade(): |
|||
# ### commands auto generated by Alembic - please adjust! ### |
|||
op.drop_table('tag_assoc') |
|||
op.drop_table('favoritor_assoc') |
|||
op.drop_table('comment') |
|||
op.drop_table('followers_assoc') |
|||
op.drop_table('article') |
|||
op.drop_table('userprofile') |
|||
op.drop_table('users') |
|||
op.drop_table('tags') |
|||
# ### end Alembic commands ### |
|||
Write
Preview
Loading…
Cancel
Save
Reference in new issue