diff options
author | Richard Mudgett <rmudgett@digium.com> | 2014-03-05 18:51:37 +0000 |
---|---|---|
committer | Richard Mudgett <rmudgett@digium.com> | 2014-03-05 18:51:37 +0000 |
commit | 15140883d0b9312e0c298d1f4a76ed3aa84fd6b5 (patch) | |
tree | 8a18d484bb065b49bd3e176ab1a62c223214f95d /contrib/ast-db-manage/cdr/env.py | |
parent | ad39358e197632cf0f0638046cd446bbb993fac6 (diff) |
alembic: Add missing queue and CDR table creation scripts.
* Added the queues and queue_members tables to the config alembic scripts.
* Added the CDR table alembic creation script. The CDR table is more of
an example for new setups since the actual table can be fully customized
in cdr_adaptive_odbc.conf.
(closes issue ASTERISK-23233)
Reported by: jmls
Review: https://reviewboard.asterisk.org/r/3227/
........
Merged revisions 409885 from http://svn.asterisk.org/svn/asterisk/branches/12
git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@409889 65c4cc65-6c06-0410-ace0-fbb531ad65f3
Diffstat (limited to 'contrib/ast-db-manage/cdr/env.py')
-rwxr-xr-x | contrib/ast-db-manage/cdr/env.py | 71 |
1 files changed, 71 insertions, 0 deletions
diff --git a/contrib/ast-db-manage/cdr/env.py b/contrib/ast-db-manage/cdr/env.py new file mode 100755 index 000000000..f72400b10 --- /dev/null +++ b/contrib/ast-db-manage/cdr/env.py @@ -0,0 +1,71 @@ +from __future__ import with_statement +from alembic import context +from sqlalchemy import engine_from_config, pool +from logging.config import fileConfig + +# 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) + +# add your model's MetaData object here +# for 'autogenerate' support +# from myapp import mymodel +# target_metadata = mymodel.Base.metadata +target_metadata = None + +# 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) + + 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. + + """ + engine = engine_from_config( + config.get_section(config.config_ini_section), + prefix='sqlalchemy.', + poolclass=pool.NullPool) + + connection = engine.connect() + context.configure( + connection=connection, + target_metadata=target_metadata + ) + + try: + with context.begin_transaction(): + context.run_migrations() + finally: + connection.close() + +if context.is_offline_mode(): + run_migrations_offline() +else: + run_migrations_online() + |