Skip to content

Commit

Permalink
Merge branch 'master' of github.com:okfn/ckan
Browse files Browse the repository at this point in the history
  • Loading branch information
kindly committed Mar 1, 2013
2 parents 2f52a52 + 7e1b30f commit 15c23b2
Show file tree
Hide file tree
Showing 2 changed files with 32 additions and 21 deletions.
35 changes: 20 additions & 15 deletions ckan/migration/versions/027_adjust_harvester.py
Original file line number Diff line number Diff line change
@@ -1,26 +1,31 @@
import warnings

from sqlalchemy import exc as sa_exc
from sqlalchemy import *
from migrate import *
import migrate.changeset


def upgrade(migrate_engine):
metadata = MetaData()
metadata.bind = migrate_engine
# ignore reflection warnings
with warnings.catch_warnings():
warnings.simplefilter("ignore", category=sa_exc.SAWarning)
metadata = MetaData()
metadata.bind = migrate_engine

harvest_source_table = Table('harvest_source', metadata, autoload=True)
package_table = Table('package', metadata, autoload=True)
harvest_source_table = Table('harvest_source', metadata, autoload=True)
package_table = Table('package', metadata, autoload=True)

harvested_document_table = Table('harvested_document', metadata,
Column('url', UnicodeText, nullable=False),
Column('guid', UnicodeText, default=u''),
Column('source_id', UnicodeText, ForeignKey('harvest_source.id')),
Column('package_id', UnicodeText, ForeignKey('package.id')),
)
harvested_document_table = Table('harvested_document', metadata,
Column('url', UnicodeText, nullable=False),
Column('guid', UnicodeText, default=u''),
Column('source_id', UnicodeText, ForeignKey('harvest_source.id')),
Column('package_id', UnicodeText, ForeignKey('package.id')),
)

harvested_document_table.c.url.drop()
harvested_document_table.c.guid.create(harvested_document_table)
harvested_document_table.c.source_id.create(harvested_document_table)
harvested_document_table.c.package_id.create(harvested_document_table)
harvested_document_table.c.url.drop()
harvested_document_table.c.guid.create(harvested_document_table)
harvested_document_table.c.source_id.create(harvested_document_table)
harvested_document_table.c.package_id.create(harvested_document_table)

def downgrade(migrate_engine):
raise NotImplementedError()
Expand Down
18 changes: 12 additions & 6 deletions ckan/migration/versions/045_user_name_unique.py
Original file line number Diff line number Diff line change
@@ -1,11 +1,17 @@
import warnings

from sqlalchemy import exc as sa_exc
from sqlalchemy import *
from migrate import *
from migrate.changeset.constraint import UniqueConstraint

def upgrade(migrate_engine):
metadata = MetaData()
metadata.bind = migrate_engine
user_table = Table('user', metadata, autoload=True)
# name_column = user_table.c.name
unique_name_constraint = UniqueConstraint('name', table=user_table)
unique_name_constraint.create()
# ignore reflection warnings
with warnings.catch_warnings():
warnings.simplefilter("ignore", category=sa_exc.SAWarning)
metadata = MetaData()
metadata.bind = migrate_engine
user_table = Table('user', metadata, autoload=True)
# name_column = user_table.c.name
unique_name_constraint = UniqueConstraint('name', table=user_table)
unique_name_constraint.create()

0 comments on commit 15c23b2

Please sign in to comment.