Mercurial > sqlpython
changeset 10:2ef0e2608123
reworking pull
author | devlinjs@FA7CZA6N1254998.wrightpatterson.afmc.ds.af.mil |
---|---|
date | Tue, 18 Dec 2007 17:00:45 -0500 |
parents | f70cc3be6377 |
children | cab368ea3ec8 |
files | sqlpyPlus.py |
diffstat | 1 files changed, 49 insertions(+), 47 deletions(-) [+] |
line wrap: on
line diff
--- a/sqlpyPlus.py Tue Dec 18 10:45:45 2007 -0500 +++ b/sqlpyPlus.py Tue Dec 18 17:00:45 2007 -0500 @@ -26,38 +26,6 @@ """ # note in cmd.cmd about supporting emacs commands? -pullQueries = { -'PROCEDURE':(""" -text -FROM all_source -WHERE owner = :owner -AND name = :object_name -""",), -'PACKAGE':(""" -text -FROM all_source -WHERE owner = :owner -AND name = :object_name -AND type = 'PACKAGE_BODY' -""",), -'TYPE':(""" -text -FROM all_source -WHERE owner = :owner -AND name = :object_name -AND type = 'TYPE' -""", -""" -text -FROM all_source -WHERE owner = :owner -AND name = :object_name -AND type = 'TYPE_BODY' -""",) - } -pullQueries['TRIGGER'] = pullQueries['PROCEDURE'] -pullQueries['FUNCTION'] = pullQueries['PROCEDURE'] - descQueries = { 'TABLE': (""" atc.column_name, @@ -188,6 +156,34 @@ WHERE atc.table_name = :object_name AND atc.owner = :owner ORDER BY atc.column_id;""", +#thanks to Senora.pm for "refs" +'refs': """ + NULL referenced_by, + c2.table_name references, + c1.constraint_name constraint +FROM + user_constraints c1, + user_constraints c2 +WHERE + c1.table_name = :object_name + and c1.constraint_type ='R' + and c1.r_constraint_name = c2.constraint_name + and c1.r_owner = c2.owner + and c1.owner = :owner +UNION +SELECT c1.table_name referenced_by, + NULL references, + c1.constraint_name constraint +FROM + user_constraints c1, + user_constraints c2 +WHERE + c2.table_name = :object_name + and c1.constraint_type ='R' + and c1.r_constraint_name = c2.constraint_name + and c1.r_owner = c2.owner + and c1.owner = :owner +""" } import sys, os, re, sqlpython, cx_Oracle, pyparsing @@ -369,7 +365,7 @@ if getme < 0: return self[:(-1 * getme)] else: - return self[getme-1] + return [self[getme-1]] except IndexError: return [] except (ValueError, TypeError): @@ -399,7 +395,7 @@ self.failover = False self.multiline = '''select insert update delete tselect create drop alter'''.split() - self.excludeFromHistory = '''run r list l history hi ed'''.split() + self.excludeFromHistory = '''run r list l history hi ed li'''.split() def default(self, arg, do_everywhere=False): sqlpython.sqlpython.default(self, arg, do_everywhere) @@ -464,10 +460,12 @@ def postcmd(self, stop, line): """Hook method executed just after a command dispatch is finished.""" - command = line.split(None,1)[0].lower() - if command not in self.excludeFromHistory: - self.history.append(line) - return stop + try: + command = line.split(None,1)[0].lower() + if command not in self.excludeFromHistory: + self.history.append(line) + finally: + return stop def onecmd_plus_hooks(self, line): line = self.precmd(line) @@ -669,11 +667,9 @@ object_type, owner, object_name = self.resolve(arg.strip(self.terminator).upper()) print "%s %s.%s" % (object_type, owner, object_name) - pullQ = pullQueries.get(object_type) - if pullQ: - for q in pullQ: - self.do_select(q,bindVarsIn={'object_name':object_name, 'owner':owner}) - + print self.curs.callfunc('DBMS_METADATA.GET_DDL', cx_Oracle.CLOB, + [object_type, object_name, owner]) + def do_describe(self, arg): "emulates SQL*Plus's DESCRIBE" object_type, owner, object_name = self.resolve(arg.strip(self.terminator).upper()) @@ -683,10 +679,11 @@ for q in descQ: self.do_select(q,bindVarsIn={'object_name':object_name, 'owner':owner}) elif object_type == 'PACKAGE': - self.curs.execute(descQueries['PackageObjects'], {'package_name':object_name, 'owner':owner}) - for (packageObj_name,) in self.curs: + self.curs.execute(descQueries['PackageObjects'][0], {'package_name':object_name, 'owner':owner}) + packageContents = self.curs.fetchall() + for (packageObj_name,) in packageContents: print packageObj_name - self.do_select(descQueries['PackageObjArgs'],bindVarsIn={'package_name':object_name, 'owner':owner, 'object_name':packageObj_name}) + self.do_select(descQueries['PackageObjArgs'][0],bindVarsIn={'package_name':object_name, 'owner':owner, 'object_name':packageObj_name}) do_desc = do_describe def do_comments(self, arg): @@ -949,8 +946,8 @@ targets = arg.split() pattern = targets.pop(0) for target in targets: + target = target.rstrip(';') sql = [] - print 'select * from %s where 1=0' % target try: self.curs.execute('select * from %s where 1=0' % target) sql = ' or '.join("%s LIKE '%%%s%%'" % (d[0], pattern) for d in self.curs.description) @@ -961,6 +958,11 @@ import traceback traceback.print_exc(file=sys.stdout) + def do_refs(self, arg): + object_type, owner, object_name = self.resolve(arg.strip(self.terminator).upper()) + if object_type == 'TABLE': + self.do_select(queries['refs'],bindVarsIn={'object_name':object_name, 'owner':owner}) + def _test(): import doctest doctest.testmod()