mirror of
https://github.com/veekun/pokedex.git
synced 2024-08-20 18:16:34 +00:00
Fixed table loading under SQLAlchemy 0.5.3.
Apparently the secret property on a singleton hidden in the guts of SQLAlchemy has been made private recently, so what I wanted to do (get a list of all ORM classes) is now impossible. I gave up on trying to find a real solution and just slapped together something using dir().
This commit is contained in:
parent
9fc09eb0ec
commit
8812dd9654
1 changed files with 31 additions and 12 deletions
|
@ -3,7 +3,7 @@ import sys
|
||||||
|
|
||||||
import sqlalchemy.types
|
import sqlalchemy.types
|
||||||
|
|
||||||
from .db import connect, metadata
|
from .db import connect, metadata, tables as tables_module
|
||||||
|
|
||||||
def main():
|
def main():
|
||||||
if len(sys.argv) <= 1:
|
if len(sys.argv) <= 1:
|
||||||
|
@ -20,7 +20,7 @@ def main():
|
||||||
help()
|
help()
|
||||||
|
|
||||||
|
|
||||||
def csvimport(engine_uri, dir='.'):
|
def csvimport(engine_uri, directory='.'):
|
||||||
import csv
|
import csv
|
||||||
|
|
||||||
from sqlalchemy.orm.attributes import instrumentation_registry
|
from sqlalchemy.orm.attributes import instrumentation_registry
|
||||||
|
@ -35,18 +35,36 @@ def csvimport(engine_uri, dir='.'):
|
||||||
if 'mysql' in engine_uri:
|
if 'mysql' in engine_uri:
|
||||||
session.execute('SET FOREIGN_KEY_CHECKS = 0')
|
session.execute('SET FOREIGN_KEY_CHECKS = 0')
|
||||||
|
|
||||||
# This is a secret attribute on a secret singleton of a secret class that
|
# SQLAlchemy is retarded and there is no way for me to get a list of ORM
|
||||||
# appears to hopefully contain all registered classes as keys.
|
# classes besides to inspect the module they all happen to live in for
|
||||||
# There is no other way to accomplish this, as far as I can tell.
|
# things that look right.
|
||||||
# Fuck.
|
table_base = tables_module.TableBase
|
||||||
for table in sorted(instrumentation_registry.manager_finders.keys(),
|
orm_classes = {}
|
||||||
key=lambda self: self.__table__.name):
|
|
||||||
table_name = table.__table__.name
|
for name in dir(tables_module):
|
||||||
|
# dir() returns strings! How /convenient/.
|
||||||
|
thingy = getattr(tables_module, name)
|
||||||
|
|
||||||
|
if not isinstance(thingy, type):
|
||||||
|
# Not a class; bail
|
||||||
|
continue
|
||||||
|
elif not issubclass(thingy, table_base):
|
||||||
|
# Not a declarative table; bail
|
||||||
|
continue
|
||||||
|
elif thingy == table_base:
|
||||||
|
# Declarative table base, so not a real table; bail
|
||||||
|
continue
|
||||||
|
|
||||||
|
# thingy is definitely a table class! Hallelujah.
|
||||||
|
orm_classes[thingy.__table__.name] = thingy
|
||||||
|
|
||||||
|
# Okay, run through the tables and actually load the data now
|
||||||
|
for table_name, table in sorted(orm_classes.items()):
|
||||||
# Print the table name but leave the cursor in a fixed column
|
# Print the table name but leave the cursor in a fixed column
|
||||||
print table_name + '...', ' ' * (40 - len(table_name)),
|
print table_name + '...', ' ' * (40 - len(table_name)),
|
||||||
|
|
||||||
try:
|
try:
|
||||||
csvfile = open("%s/%s.csv" % (dir, table_name), 'rb')
|
csvfile = open("%s/%s.csv" % (directory, table_name), 'rb')
|
||||||
except IOError:
|
except IOError:
|
||||||
# File doesn't exist; don't load anything!
|
# File doesn't exist; don't load anything!
|
||||||
print 'no data!'
|
print 'no data!'
|
||||||
|
@ -87,7 +105,7 @@ def csvimport(engine_uri, dir='.'):
|
||||||
session.execute('SET FOREIGN_KEY_CHECKS = 1')
|
session.execute('SET FOREIGN_KEY_CHECKS = 1')
|
||||||
|
|
||||||
|
|
||||||
def csvexport(engine_uri, dir='.'):
|
def csvexport(engine_uri, directory='.'):
|
||||||
import csv
|
import csv
|
||||||
session = connect(engine_uri)
|
session = connect(engine_uri)
|
||||||
|
|
||||||
|
@ -95,7 +113,8 @@ def csvexport(engine_uri, dir='.'):
|
||||||
print table_name
|
print table_name
|
||||||
table = metadata.tables[table_name]
|
table = metadata.tables[table_name]
|
||||||
|
|
||||||
writer = csv.writer(open("%s/%s.csv" % (dir, table_name), 'wb'), lineterminator='\n')
|
writer = csv.writer(open("%s/%s.csv" % (directory, table_name), 'wb'),
|
||||||
|
lineterminator='\n')
|
||||||
columns = [col.name for col in table.columns]
|
columns = [col.name for col in table.columns]
|
||||||
writer.writerow(columns)
|
writer.writerow(columns)
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue