summaryrefslogtreecommitdiff
path: root/python/skytools/dbstruct.py
diff options
context:
space:
mode:
authorMarko Kreen2011-04-06 17:42:31 +0000
committerMarko Kreen2011-04-06 17:44:52 +0000
commitf6a8d2ceec20e2e97ba05094827d4bdbda4ef0f6 (patch)
tree7a245ebdad567611855762a91b9bb07e23d3a148 /python/skytools/dbstruct.py
parent72d2fd72df5837c33e69b509daaad17b0413f1d7 (diff)
Avoid direct symbol imports
Always use import skytools def xx(): skytools.foo this allows maximum laziness when importing.
Diffstat (limited to 'python/skytools/dbstruct.py')
-rw-r--r--python/skytools/dbstruct.py25
1 files changed, 12 insertions, 13 deletions
diff --git a/python/skytools/dbstruct.py b/python/skytools/dbstruct.py
index df09669d..acdb8176 100644
--- a/python/skytools/dbstruct.py
+++ b/python/skytools/dbstruct.py
@@ -3,10 +3,9 @@
import re
-from skytools.sqltools import fq_name_parts, get_table_oid, exists_table
-from skytools.quoting import quote_ident, quote_fqident, quote_literal
-from skytools.quoting import unquote_ident, unquote_fqident
-from skytools.parsing import parse_pgarray, parse_acl
+import skytools
+
+from skytools import quote_ident, quote_fqident
__all__ = ['TableStruct', 'SeqStruct',
'T_TABLE', 'T_CONSTRAINT', 'T_INDEX', 'T_TRIGGER',
@@ -294,8 +293,8 @@ class TGrant(TElem):
if relacl is None:
return []
tup_list = []
- for sacl in parse_pgarray(relacl):
- acl = parse_acl(sacl)
+ for sacl in skytools.parse_pgarray(relacl):
+ acl = skytools.parse_acl(sacl)
if not acl:
continue
tup_list.append(acl)
@@ -381,7 +380,7 @@ class TColumn(TElem):
self.sequence = None
if row['seqname']:
- self.seqname = unquote_fqident(row['seqname'])
+ self.seqname = skytools.unquote_fqident(row['seqname'])
class TGPDistKey(TElem):
@@ -562,20 +561,20 @@ class TableStruct(BaseStruct):
self.table_name = table_name
# fill args
- schema, name = fq_name_parts(table_name)
+ schema, name = skytools.fq_name_parts(table_name)
args = {
'schema': schema,
'table': name,
'fqname': self.fqname,
- 'fq2name': quote_literal(self.fqname),
- 'oid': get_table_oid(curs, table_name),
- 'pg_class_oid': get_table_oid(curs, 'pg_catalog.pg_class'),
+ 'fq2name': skytools.quote_literal(self.fqname),
+ 'oid': skytools.get_table_oid(curs, table_name),
+ 'pg_class_oid': skytools.get_table_oid(curs, 'pg_catalog.pg_class'),
}
# load table struct
self.col_list = self._load_elem(curs, self.name, args, TColumn)
# if db is GP then read also table distribution keys
- if exists_table(curs, "pg_catalog.gp_distribution_policy"):
+ if skytools.exists_table(curs, "pg_catalog.gp_distribution_policy"):
self.dist_key_list = self._load_elem(curs, self.name, args,
TGPDistKey)
else:
@@ -588,7 +587,7 @@ class TableStruct(BaseStruct):
for col in self.col_list:
if col.seqname:
owner = self.fqname + '.' + quote_ident(col.name)
- seq_args = { 'fqname': col.seqname, 'owner': quote_literal(owner) }
+ seq_args = { 'fqname': col.seqname, 'owner': skytools.quote_literal(owner) }
self.seq_list += self._load_elem(curs, col.seqname, seq_args, TSeq)
self.object_list += self.seq_list