Skip to content
Snippets Groups Projects
Commit 7cbf6bf0 authored by Andreas Klöckner's avatar Andreas Klöckner
Browse files

Merge branch 'master' of hpcgeek:/users/astock/code/pytools

parents f87e50cb d409ca8f
No related branches found
No related tags found
No related merge requests found
...@@ -261,7 +261,9 @@ def gather_multi_file(outfile, infiles, fmap, qmap, fg, features, ...@@ -261,7 +261,9 @@ def gather_multi_file(outfile, infiles, fmap, qmap, fg, features,
db_conn = sqlite3.connect(outfile) db_conn = sqlite3.connect(outfile)
run_columns = [ run_columns = [
"id integer primary key", "id integer primary key",
"dirname text"] + ["%s %s" % (fmap.get(fname, fname), ftype) "dirname text",
"filename text",
] + ["%s %s" % (fmap.get(fname, fname), ftype)
for fname, ftype in features.iteritems()] for fname, ftype in features.iteritems()]
db_conn.execute("create table runs (%s)" % ",".join(run_columns)) db_conn.execute("create table runs (%s)" % ",".join(run_columns))
db_conn.execute("create index runs_id on runs (id)") db_conn.execute("create index runs_id on runs (id)")
...@@ -276,7 +278,7 @@ def gather_multi_file(outfile, infiles, fmap, qmap, fg, features, ...@@ -276,7 +278,7 @@ def gather_multi_file(outfile, infiles, fmap, qmap, fg, features,
created_tables = set() created_tables = set()
from os.path import dirname from os.path import dirname, basename
uid_to_run_id = {} uid_to_run_id = {}
written_run_ids = set() written_run_ids = set()
...@@ -292,9 +294,12 @@ def gather_multi_file(outfile, infiles, fmap, qmap, fg, features, ...@@ -292,9 +294,12 @@ def gather_multi_file(outfile, infiles, fmap, qmap, fg, features,
if run_id not in written_run_ids: if run_id not in written_run_ids:
dbfeatures = fg.get_db_features(dbname, logmgr) dbfeatures = fg.get_db_features(dbname, logmgr)
qry = "insert into runs (%s) values (%s)" % ( qry = "insert into runs (%s) values (%s)" % (
",".join(["id", "dirname"]+[fmap.get(f[0], f[0]) for f in dbfeatures]), ",".join(["id", "dirname", "filename"]
",".join("?" * (len(dbfeatures)+2))) + [fmap.get(f[0], f[0]) for f in dbfeatures]),
rows = db_conn.execute(qry, [run_id, dirname(dbname)]+[f[2] for f in dbfeatures]) ",".join("?" * (len(dbfeatures)+3)))
rows = db_conn.execute(qry,
[run_id, dirname(dbname), basename(dbname)]
+ [f[2] for f in dbfeatures])
written_run_ids.add(run_id) written_run_ids.add(run_id)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment