# -*- coding: utf-8 -*- from __future__ import absolute_import from . import get_db_type SQL = { "sqlite": [ 'ALTER TABLE "email" ADD COLUMN user_id VARCHAR(255);', 'CREATE INDEX "ix_email_user_id" ON "email" (user_id);', ], "postgres": [ 'ALTER TABLE "email" ADD COLUMN user_id VARCHAR(255);', 'CREATE INDEX "ix_email_user_id" ON "email" USING btree (user_id);', ], "mysql": [ 'ALTER TABLE `email` ADD COLUMN user_id VARCHAR(255);', 'CREATE INDEX `ix_email_user_id` ON `email` (user_id(255));', ], } def apply(store): """Add the user_address table""" dbtype = get_db_type(store) for statement in SQL[dbtype]: store.execute(statement) store.commit()