Mercurial > repos > jjohnson > query_tabular

annotate query_tabular.py @ 5:727620f718c2 draft

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit eefe7cbd5c59de67db7574847bb91e4a404adc03-dirty
author jjohnson
date Fri, 12 Feb 2016 07:29:55 -0500
parents afdbc7198353
children aa2409ae9dc0
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
0
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
1 #!/usr/bin/env python
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
2 """
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
3 """
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
4 import sys
4
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
5 import re
0
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
6 import os.path
4
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
7 import json
0
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
8 import sqlite3 as sqlite
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
9 import optparse
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
10 from optparse import OptionParser
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
11
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
12 """
4
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
13 TODO:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
14 - could read column names from comment lines, but issues with legal names
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
15 - could add some transformations on tabular columns,
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
16 e.g. a regex to format date/time strings
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
17 c2 : re.sub('pat', 'sub', c2)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
18 c3 :
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
19 - column_defs dict of columns to create from tabular input
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
20 column_defs : { 'name1' : 'expr', 'name2' : 'expr'}
0
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
21 - allow multiple queries and outputs
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
22 - add a --json input for table definitions (or yaml)
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
23 JSON config:
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
24 { tables : [
4
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
25 { file_path : '/home/galaxy/dataset_101.dat',
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
26 table_name : 't1',
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
27 column_names : ['c1', 'c2', 'c3'],
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
28 comment_lines : 1
0
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
29 },
4
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
30 { file_path : '/home/galaxy/dataset_102.dat',
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
31 table_name : 't2',
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
32 column_names : ['c1', 'c2', 'c3']
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
33 },
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
34 { file_path : '/home/galaxy/dataset_103.dat',
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
35 table_name : 'test',
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
36 column_names : ['c1', 'c2', 'c3']
0
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
37 }
4
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
38 ]
0
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
39 }
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
40 """
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
41
4
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
42 tables_query = \
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
43 "SELECT name, sql FROM sqlite_master WHERE type='table' ORDER BY name"
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
44
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
45
0
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
46 def getValueType(val):
4
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
47 if val or 0. == val:
0
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
48 try:
4
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
49 int(val)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
50 return 'INTEGER'
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
51 except:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
52 try:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
53 float(val)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
54 return 'REAL'
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
55 except:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
56 return 'TEXT'
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
57 return None
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
58
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
59
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
60 def get_column_def(file_path, table_name, skip=0, comment_char='#',
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
61 column_names=None, max_lines=100):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
62 col_pref = ['TEXT', 'REAL', 'INTEGER', None]
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
63 col_types = []
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
64 data_lines = 0
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
65 try:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
66 with open(file_path, "r") as fh:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
67 for linenum, line in enumerate(fh):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
68 if linenum < skip:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
69 continue
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
70 if line.startswith(comment_char):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
71 continue
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
72 data_lines += 1
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
73 try:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
74 fields = line.split('\t')
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
75 while len(col_types) < len(fields):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
76 col_types.append(None)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
77 for i, val in enumerate(fields):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
78 colType = getValueType(val)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
79 if col_pref.index(colType) < col_pref.index(col_types[i]):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
80 col_types[i] = colType
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
81 except Exception, e:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
82 print >> sys.stderr, 'Failed at line: %d err: %s' % (linenum, e)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
83 except Exception, e:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
84 print >> sys.stderr, 'Failed: %s' % (e)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
85 for i, col_type in enumerate(col_types):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
86 if not col_type:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
87 col_types[i] = 'TEXT'
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
88 col_names = ['c%d' % i for i in range(1, len(col_types) + 1)]
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
89 if column_names:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
90 for i, cname in enumerate([cn.strip() for cn in column_names.split(',')]):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
91 if cname and i < len(col_names):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
92 col_names[i] = cname
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
93 col_def = []
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
94 for i, col_name in enumerate(col_names):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
95 col_def.append('%s %s' % (col_names[i], col_types[i]))
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
96 return col_names, col_types, col_def
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
97
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
98
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
99 def create_table(conn, file_path, table_name, skip=0, comment_char='#', column_names=None):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
100 col_names, col_types, col_def = get_column_def(file_path, table_name, skip=skip, comment_char=comment_char, column_names=column_names)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
101 col_func = [float if t == 'REAL' else int if t == 'INTEGER' else str for t in col_types]
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
102 table_def = 'CREATE TABLE %s (\n %s\n);' % (table_name, ', \n '.join(col_def))
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
103 # print >> sys.stdout, table_def
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
104 insert_stmt = 'INSERT INTO %s(%s) VALUES(%s)' % (table_name, ','.join(col_names), ','.join(["?" for x in col_names]))
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
105 # print >> sys.stdout, insert_stmt
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
106 data_lines = 0
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
107 try:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
108 c = conn.cursor()
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
109 c.execute(table_def)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
110 with open(file_path, "r") as fh:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
111 for linenum, line in enumerate(fh):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
112 if linenum < skip or line.startswith(comment_char):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
113 continue
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
114 data_lines += 1
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
115 try:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
116 fields = line.rstrip('\r\n').split('\t')
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
117 vals = [col_func[i](x) if x else None for i, x in enumerate(fields)]
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
118 c.execute(insert_stmt, vals)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
119 except Exception, e:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
120 print >> sys.stderr, 'Failed at line: %d err: %s' % (linenum, e)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
121 conn.commit()
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
122 c.close()
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
123 except Exception, e:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
124 print >> sys.stderr, 'Failed: %s' % (e)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
125 exit(1)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
126
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
127
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
128 def regex_match(expr, item):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
129 return re.match(expr, item) is not None
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
130
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
131
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
132 def regex_search(expr, item):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
133 return re.search(expr, item) is not None
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
134
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
135
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
136 def regex_sub(expr, replace, item):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
137 return re.sub(expr, replace, item)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
138
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
139
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
140 def get_connection(sqlitedb_path, addfunctions=False):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
141 conn = sqlite.connect(sqlitedb_path)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
142 if addfunctions:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
143 conn.create_function("re_match", 2, regex_match)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
144 conn.create_function("re_search", 2, regex_search)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
145 conn.create_function("re_sub", 3, regex_sub)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
146 return conn
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
147
0
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
148
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
149 def __main__():
4
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
150 # Parse Command Line
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
151 parser = optparse.OptionParser()
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
152 parser.add_option('-s', '--sqlitedb', dest='sqlitedb', default=None, help='The SQLite Database')
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
153 parser.add_option('-t', '--table', dest='tables', action="append", default=[], help='Tabular file: file_path[=table_name[:column_name, ...]')
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
154 parser.add_option('-j', '--jsonfile', dest='jsonfile', default=None, help='Tabular file: file_path[=table_name[:column_name, ...]')
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
155 parser.add_option('-q', '--query', dest='query', default=None, help='SQL query')
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
156 parser.add_option('-Q', '--query_file', dest='query_file', default=None, help='SQL query file')
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
157 parser.add_option('-n', '--no_header', dest='no_header', action='store_true', default=False, help='Include a column headers line')
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
158 parser.add_option('-o', '--output', dest='output', default=None, help='Output file for query results')
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
159 (options, args) = parser.parse_args()
0
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
160
4
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
161 # open sqlite connection
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
162 conn = get_connection(options.sqlitedb)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
163 # determine output destination
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
164 if options.output is not None:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
165 try:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
166 outputPath = os.path.abspath(options.output)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
167 outputFile = open(outputPath, 'w')
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
168 except Exception, e:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
169 print >> sys.stderr, "failed: %s" % e
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
170 exit(3)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
171 else:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
172 outputFile = sys.stdout
0
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
173
4
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
174 # get table defs
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
175 if options.tables:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
176 for ti, table in enumerate(options.tables):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
177 table_name = 't%d' % (ti + 1)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
178 column_names = None
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
179 fields = table.split('=')
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
180 path = fields[0]
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
181 if len(fields) > 1:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
182 names = fields[1].split(':')
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
183 table_name = names[0] if names[0] else table_name
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
184 if len(names) > 1:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
185 column_names = names[1]
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
186 # print >> sys.stdout, '%s %s' % (table_name, path)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
187 create_table(conn, path, table_name, column_names=column_names)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
188 if options.jsonfile:
0
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
189 try:
4
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
190 fh = open(options.jsonfile)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
191 tdef = json.load(fh)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
192 if 'tables' in tdef:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
193 for ti, table in enumerate(tdef['tables']):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
194 path = table['file_path']
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
195 table_name = table['table_name'] if 'table_name' in table else 't%d' % (ti + 1)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
196 column_names = table['column_names'] if 'column_names' in table else None
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
197 comment_lines = table['comment_lines'] if 'comment_lines' in table else 0
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
198 create_table(conn, path, table_name, column_names=column_names, skip=comment_lines)
0
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
199 except Exception, exc:
4
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
200 print >> sys.stderr, "Error: %s" % exc
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
201 conn.close()
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
202
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
203 query = None
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
204 if (options.query_file is not None):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
205 with open(options.query_file, 'r') as fh:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
206 query = ''
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
207 for line in fh:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
208 query += line
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
209 elif (options.query is not None):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
210 query = options.query
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
211
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
212 if (query is None):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
213 try:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
214 conn = get_connection(options.sqlitedb)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
215 c = conn.cursor()
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
216 rslt = c.execute(tables_query).fetchall()
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
217 for table, sql in rslt:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
218 print >> sys.stderr, "Table %s:" % table
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
219 try:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
220 col_query = 'SELECT * FROM %s LIMIT 0' % table
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
221 cur = conn.cursor().execute(col_query)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
222 cols = [col[0] for col in cur.description]
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
223 print >> sys.stderr, " Columns: %s" % cols
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
224 except Exception, exc:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
225 print >> sys.stderr, "Error: %s" % exc
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
226 except Exception, exc:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
227 print >> sys.stderr, "Error: %s" % exc
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
228 exit(0)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
229 # if not sqlite.is_read_only_query(query):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
230 # print >> sys.stderr, "Error: Must be a read only query"
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
231 # exit(2)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
232 try:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
233 conn = get_connection(options.sqlitedb, addfunctions=True)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
234 cur = conn.cursor()
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
235 results = cur.execute(query)
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
236 if not options.no_header:
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
237 outputFile.write("#%s\n" % '\t'.join([str(col[0]) for col in cur.description]))
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
238 # yield [col[0] for col in cur.description]
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
239 for i, row in enumerate(results):
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
240 # yield [val for val in row]
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
241 outputFile.write("%s\n" % '\t'.join([str(val) for val in row]))
0
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
242 except Exception, exc:
4
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
243 print >> sys.stderr, "Error: %s" % exc
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
244 exit(1)
0
763c4f968dc6 Uploaded
jjohnson
parents:
diff changeset
245
4
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
246 if __name__ == "__main__":
afdbc7198353 planemo upload for repository https://github.com/jj-umn/galaxytools/tree/master/query_tabular commit 9ae87502ea7c3da33ecc453872c4eb2f41ecea4a-dirty
jjohnson
parents: 2
diff changeset
247 __main__()