pg_lib.py 文件源码

def create_tables(self, drop_tables=False, store_tables=True):
            for table in self.table_ddl:
                if drop_tables:
                    sql_drop_clear='DROP TABLE IF EXISTS  "%s"."%s" CASCADE ;' % (self.pg_conn.dest_schema, table,)
                    sql_drop_obf='DROP TABLE IF EXISTS  "%s"."%s" CASCADE ;' % (self.obf_schema, table,)
                    self.pg_conn.pgsql_cur.execute(sql_drop_clear)
                    self.pg_conn.pgsql_cur.execute(sql_drop_obf)
                try:
                    ddl_enum=self.type_ddl[table]
                    for sql_type in ddl_enum:
                        self.pg_conn.pgsql_cur.execute(sql_type)
                except:
                    pass
                sql_create=self.table_ddl[table]
                try:
                    self.pg_conn.pgsql_cur.execute(sql_create)
                except psycopg2.Error as e:
                    self.logger.error("SQLCODE: %s SQLERROR: %s" % (e.pgcode, e.pgerror))
                    self.logger.error(sql_create)
                self.logger.debug('Storing table %s in t_replica_tables' % (table, ))
                if store_tables:
                    self.store_table(table)