diff --git a/pgloader/pgloader.py b/pgloader/pgloader.py index 26333d5..6ab2479 100644 --- a/pgloader/pgloader.py +++ b/pgloader/pgloader.py @@ -101,6 +101,10 @@ class PGLoader: self.filename, self.input_encoding, self.table, self.columns) + # Now reset database connection + if not DRY_RUN: + self.db.reset() + if DEBUG: print '%s init done' % name print @@ -529,10 +533,6 @@ class PGLoader: mesg = 'Configuration errors for section %s' % self.name raise PGLoader_Error, mesg - # Now reset database connection - if not DRY_RUN: - self.db.reset() - def _parse_fields(self, attr, str, btype = False, argtype = 'int'): """ parse the user string str for fields definition to store into self.attr """