Mercurial > sqlpython
changeset 341:aa16fe026f01
working on gerald transition experiment
author | Catherine Devlin <catherine.devlin@gmail.com> |
---|---|
date | Tue, 14 Apr 2009 16:12:33 -0400 |
parents | 001d01eeac90 |
children | d185c87766bd |
files | setup.py sqlpython/exampleSession.txt sqlpython/sqlpyPlus.py sqlpython/sqlpython.py |
diffstat | 4 files changed, 49 insertions(+), 12 deletions(-) [+] |
line wrap: on
line diff
--- a/setup.py Thu Apr 09 15:54:08 2009 -0400 +++ b/setup.py Tue Apr 14 16:12:33 2009 -0400 @@ -17,7 +17,7 @@ url="http://packages.python.org/sqlpython", packages=find_packages(), include_package_data=True, - install_requires=['pyparsing','cmd2>=0.5.2','cx_Oracle','genshi>=0.5','sqlalchemy','gerald'], + install_requires=['pyparsing','cmd2>=0.5.2','cx_Oracle','genshi>=0.5','sqlalchemy',], keywords = 'client oracle database', license = 'MIT', platforms = ['any'],
--- a/sqlpython/exampleSession.txt Thu Apr 09 15:54:08 2009 -0400 +++ b/sqlpython/exampleSession.txt Tue Apr 14 16:12:33 2009 -0400 @@ -7,6 +7,9 @@ SQL.No_Connection> connect testschema/testschema@orcl 0:testschema@orcl> drop table play; /.*/ +0:testschema@orcl> set colors off +colors - was: True +now: False 0:testschema@orcl> CREATE TABLE play ( > title VARCHAR2(40) CONSTRAINT xpk_play PRIMARY KEY, > author VARCHAR2(40));
--- a/sqlpython/sqlpyPlus.py Thu Apr 09 15:54:08 2009 -0400 +++ b/sqlpython/sqlpyPlus.py Tue Apr 14 16:12:33 2009 -0400 @@ -410,14 +410,7 @@ return str(datum) def output(self, outformat, rowlimit): - try: - self.tblname = self.tableNameFinder.search(self.querytext).group(1) - except AttributeError: - self.tblname = '' - self.colnames = [d[0] for d in self.curs.description] if outformat in output_templates: - self.colnamelen = max(len(colname) for colname in self.colnames) - self.coltypes = [d[1] for d in self.curs.description] result = output_templates[outformat].generate(formattedForSql=self.formattedForSql, **self.__dict__) elif outformat == '\\t': # transposed rows = [self.colnames] @@ -636,7 +629,17 @@ return total_len -= len(rset) self.pystate['r'][i] = [] - + + def set_query_metadata(self): + try: + self.tblname = self.tableNameFinder.search(self.querytext).group(1) + except AttributeError: + self.tblname = '' + self.colnames = [d[0] for d in self.curs.description] + if outformat in output_templates: + self.colnamelen = max(len(colname) for colname in self.colnames) + # self.coltypes = [d[1] for d in self.curs.description] never used? + def do_select(self, arg, bindVarsIn=None, terminator=None): """Fetch rows from a table. @@ -678,6 +681,7 @@ row.resultset = resultset self.pystate['r'].append(resultset) self.age_out_resultsets() + self.set_query_metadata() self.stdout.write('\n%s\n' % (self.output(arg.parsed.terminator, rowlimit))) if self.rc == 0: self.pfeedback('\nNo rows Selected.\n') @@ -932,7 +936,31 @@ sql = self.parsed(descQueries['PackageObjArgs'][0], terminator=arg.parsed.terminator or ';', suffix=arg.parsed.suffix) self.do_select(sql, bindVarsIn={'package_name':object_name, 'owner':owner, 'object_name':packageObj_name}) - + def _str_datatype_(self, datatype, length, scale, precision): + if precision is not None: + result = '%s(%s,%s)' % (datatype, scale, precision) + elif length is not None: + result = '%s(%s)' % (datatype, length) + else: + result = datatype + return result + + @options([make_option('-l', '--long', action='store_true', help='include column #, comments')]) + def do_describe(self, arg, opts): + schema = self.connections[self.connection_number]['gerald']().schema + target = arg.upper().strip() + for (objname, obj) in schema.items(): + if objname.upper() == target: + self.poutput(objname) + if hasattr(obj, 'columns'): + self.tblname = objname + columns = obj.columns.values() + columns.sort() + self.rows = [c[0], c[1], self._str_datatype_(c[2], c[3], c[4], c[5]), c[6], c[7] for c in columns] + self.colnames = 'position name type nullable default'.split() + self.colnamelen = max(len(colname) for colname in self.colnames) + self.output(arg.parsed.terminator, rowlimit) + def do_deps(self, arg): '''Lists all objects that are dependent upon the object.''' target = arg.upper()
--- a/sqlpython/sqlpython.py Thu Apr 09 15:54:08 2009 -0400 +++ b/sqlpython/sqlpython.py Tue Apr 14 16:12:33 2009 -0400 @@ -8,8 +8,8 @@ # Best used with the companion modules sqlpyPlus and mysqlpy # See also http://twiki.cern.ch/twiki/bin/view/PSSGroup/SqlPython -import cmd2,getpass,binascii,cx_Oracle,re,os -import sqlpyPlus, sqlalchemy, pyparsing +import cmd2,getpass,binascii,cx_Oracle,re,os,functools +import sqlpyPlus, sqlalchemy, pyparsing, gerald __version__ = '1.6.4' class Parser(object): @@ -95,13 +95,19 @@ self.curs = None self.no_connection() + gerald_classes = {'oracle': (gerald.OracleSchema, 'oracle',), + 'postgres': (gerald.PostgresSchema, 'public'), + 'mysql': (gerald.MySQLSchema, 'nil')} def url_connect(self, arg): eng = sqlalchemy.create_engine(arg) self.conn = eng.connect().connection conn = {'conn': self.conn, 'prompt': self.prompt, 'dbname': eng.url.database, 'rdbms': eng.url.drivername, 'user': eng.url.username or '', 'eng': eng} + gerclass = self.gerald_classes[eng.url.drivername] + conn['gerald'] = functools.partial(gerclass[0], gerclass[1], arg.split('/?')[:1][0]) return conn + def ora_connect(self, arg): modeval = 0 oraserv = None