sqlpython: sqlpyPlus.py comparison

comparison sqlpyPlus.py @ 40:1fb9f7dee7d8

tearing out cmd2

author	devlinjs@FA7CZA6N1254998.wrightpatterson.afmc.ds.af.mil
date	Fri, 18 Jan 2008 15:07:10 -0500
parents	5d29e6a21c6f
children	33c9bc61db66

comparison

equal deleted inserted replaced

-:5d29e6a21c6f
+:1fb9f7dee7d8
 FROM all_tab_columns atc
 WHERE atc.table_name = :object_name
 AND      atc.owner = :owner
 ORDER BY atc.column_id;""",),
 'PROCEDURE': ("""
-	     argument_name,
+argument_name,
-	     data_type,
+data_type,
-	     in_out,
+in_out,
-	     default_value
+default_value
 FROM all_arguments
 WHERE object_name = :object_name
 AND      owner = :owner
 AND      package_name IS NULL
 AND      argument_name IS NOT NULL
 FROM all_arguments
 WHERE package_name = :package_name
 AND      owner = :owner""",),
 'PackageObjArgs':("""
 object_name,
-	     argument_name,
+argument_name,
-	     data_type,
+data_type,
-	     in_out,
+in_out,
-	     default_value
+default_value
 FROM all_arguments
 WHERE package_name = :package_name
 AND      object_name = :object_name
 AND      owner = :owner
 AND      argument_name IS NOT NULL
 descQueries['FUNCTION'] = descQueries['PROCEDURE']
 queries = {
 'resolve': """
 SELECT object_type, object_name, owner FROM (
-	SELECT object_type, object_name, user owner, 1 priority
+SELECT object_type, object_name, user owner, 1 priority
-	FROM   user_objects
+FROM   user_objects
-	WHERE object_name = :objName
+WHERE object_name = :objName
 UNION ALL
-	SELECT ao.object_type, ao.object_name, ao.owner, 2 priority
+SELECT ao.object_type, ao.object_name, ao.owner, 2 priority
-	FROM    all_objects ao
+FROM    all_objects ao
-	JOIN      user_synonyms us ON (us.table_owner = ao.owner AND us.table_name = ao.object_name)
+JOIN      user_synonyms us ON (us.table_owner = ao.owner AND us.table_name = ao.object_name)
-	WHERE us.synonym_name = :objName
+WHERE us.synonym_name = :objName
 AND   ao.object_type != 'SYNONYM'
 UNION ALL
-	SELECT ao.object_type, ao.object_name, ao.owner, 3 priority
+SELECT ao.object_type, ao.object_name, ao.owner, 3 priority
-	FROM    all_objects ao
+FROM    all_objects ao
-	JOIN      all_synonyms asyn ON (asyn.table_owner = ao.owner AND asyn.table_name = ao.object_name)
+JOIN      all_synonyms asyn ON (asyn.table_owner = ao.owner AND asyn.table_name = ao.object_name)
-	WHERE asyn.synonym_name = :objName
+WHERE asyn.synonym_name = :objName
 AND   ao.object_type != 'SYNONYM'
-	AND      asyn.owner = 'PUBLIC'
+AND      asyn.owner = 'PUBLIC'
 UNION ALL
 SELECT 'DIRECTORY' object_type, dir.directory_name, dir.owner, 6 priority
 FROM   all_directories dir
 WHERE  dir.directory_name = :objName
 UNION ALL
 FROM    all_tab_comments
 WHERE owner = :owner
 AND      table_name = :table_name""",
 'colComments': """
 atc.column_name,
 acc.comments
 FROM all_tab_columns atc
 JOIN all_col_comments acc ON (atc.owner = acc.owner and atc.table_name = acc.table_name and atc.column_name = acc.column_name)
 WHERE atc.table_name = :object_name
 AND      atc.owner = :owner
 ORDER BY atc.column_id;""",
 # overrides cmd's parseline
 shortcuts = {'?': 'help', '@': 'getrun', '!': 'shell', ':': 'setbind', '\\': 'psql'}
 def parseline(self, line):
 """Parse the line into a command name and a string containing
 the arguments.  Returns a tuple containing (command, args, line).
 'command' and 'args' may be None if the line couldn't be parsed.
 Overrides cmd.cmd.parseline to accept variety of shortcuts.."""
-	cmd, arg. line = sqlpython.parseline(self, line)
+cmd, arg. line = sqlpython.parseline(self, line)
 if cmd in ('select', 'sleect', 'insert', 'update', 'delete', 'describe',
 'desc', 'comments', 'pull', 'refs', 'desc', 'triggers', 'find') \
-	       and not hasattr(self, 'curs'):
+and not hasattr(self, 'curs'):
 print 'Not connected.'
 return '', '', ''
 return cmd, arg, line
 def precmd(self, line):
 result = '\n' + sqlpython.pmatrix(transpr,newdesc)
 else:
 result = sqlpython.pmatrix(self.rows, self.curs.description, self.maxfetch)
 return result
+def findTerminator(statement):
+m = self.statementEndPattern.search(statement)
+if m:
+return m.groups()
+else:
+return statement, None, None
 def do_select(self, arg, bindVarsIn=None, override_terminator=None):
 """Fetch rows from a table.
 Limit the number of rows retrieved by appending
 an integer after the terminator
 Output may be formatted by choosing an alternative terminator
 ("help terminators" for details)
 """
 bindVarsIn = bindVarsIn or {}
 self.query = 'select ' + arg
-(self.query, terminator, rowlimit) = sqlpython.findTerminator(self.query)
+(self.query, terminator, rowlimit) = self.findTerminator(self.query)
 if override_terminator:
 terminator = override_terminator
 rowlimit = int(rowlimit or 0)
 try:
 self.varsUsed = findBinds(self.query, self.binds, bindVarsIn)
 print e
 import traceback
 traceback.print_exc(file=sys.stdout)
 self.sqlBuffer.append(self.query)
 pullflags = flagReader.FlagSet([flagReader.Flag('full')])
 def do_pull(self, arg):
 """Displays source code.
-	--full, -f: get dependent objects as well"""
+--full, -f: get dependent objects as well"""
 options, arg = self.pullflags.parse(arg)
 object_type, owner, object_name = self.resolve(arg.strip(self.terminator).upper())
 print "%s %s.%s" % (object_type, owner, object_name)
-	print self.curs.callfunc('DBMS_METADATA.GET_DDL', cx_Oracle.CLOB,
+print self.curs.callfunc('DBMS_METADATA.GET_DDL', cx_Oracle.CLOB,
-				 [object_type, object_name, owner])
+[object_type, object_name, owner])
-	if options.has_key('full'):
+if options.has_key('full'):
 for dependent_type in ('OBJECT_GRANT', 'CONSTRAINT', 'TRIGGER'):
-		try:
+try:
-		    print self.curs.callfunc('DBMS_METADATA.GET_DEPENDENT_DDL', cx_Oracle.CLOB,
+print self.curs.callfunc('DBMS_METADATA.GET_DEPENDENT_DDL', cx_Oracle.CLOB,
-		 			 [dependent_type, object_name, owner])
+[dependent_type, object_name, owner])
-		except cx_Oracle.DatabaseError:
+except cx_Oracle.DatabaseError:
-		    pass
+pass
 findflags = flagReader.FlagSet([flagReader.Flag('insensitive')])
 def do_find(self, arg):
-	"""Finds argument in source code.
+"""Finds argument in source code.
-	--insensitive, -i: case-insensitive search"""
+--insensitive, -i: case-insensitive search"""
 options, arg = self.findflags.parse(arg)
-	if options.has_key('insensitive'):
+if options.has_key('insensitive'):
-	    searchfor = "LOWER(text)"
+searchfor = "LOWER(text)"
-	    arg = arg.lower()
+arg = arg.lower()
-	else:
+else:
-	    searchfor = "text"
+searchfor = "text"
-	self.do_select("* from all_source where %s like '%%%s%%'" % (searchfor, arg))
+self.do_select("* from all_source where %s like '%%%s%%'" % (searchfor, arg))
 def do_describe(self, arg):
 "emulates SQL*Plus's DESCRIBE"
 object_type, owner, object_name = self.resolve(arg.strip(self.terminator).upper())
 print "%s %s.%s" % (object_type, owner, object_name)
 descQ = descQueries.get(object_type)
 if descQ:
 for q in descQ:
 self.do_select(q,bindVarsIn={'object_name':object_name, 'owner':owner})
 elif object_type == 'PACKAGE':
 self.curs.execute(descQueries['PackageObjects'][0], {'package_name':object_name, 'owner':owner})
-	    packageContents = self.curs.fetchall()
+packageContents = self.curs.fetchall()
 for (packageObj_name,) in packageContents:
 print packageObj_name
 self.do_select(descQueries['PackageObjArgs'][0],bindVarsIn={'package_name':object_name, 'owner':owner, 'object_name':packageObj_name})
 do_desc = do_describe
 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':
+if object_type == 'TABLE':
-	    self.do_select(queries['refs'],bindVarsIn={'object_name':object_name, 'owner':owner})
+self.do_select(queries['refs'],bindVarsIn={'object_name':object_name, 'owner':owner})
 def _test():
 import doctest
 doctest.testmod()

Mercurial > sqlpython

comparison sqlpyPlus.py @ 40:1fb9f7dee7d8