change full sync to order by xmin::text::bigint (#73)

* change to order by xmin::text::bigint

* pylint

Author: MortenHegewald

tap_postgres/sync_strategies/full_table.py

@@ -120,15 +120,15 @@ def sync_table(conn_info, stream, state, desired_columns, md_map):
                     LOGGER.info("Resuming Full Table replication %s from xmin %s", nascent_stream_version, xmin)
                     select_sql = """SELECT {}, xmin::text::bigint
                                       FROM {} where age(xmin::xid) <= age('{}'::xid)
-                                     ORDER BY xmin::text ASC""".format(','.join(escaped_columns),
-                                                                       post_db.fully_qualified_table_name(schema_name, stream['table_name']),
-                                                                       xmin)
+                                     ORDER BY xmin::text::bigint ASC""".format(','.join(escaped_columns),
+                                                                               post_db.fully_qualified_table_name(schema_name, stream['table_name']),
+                                                                               xmin)
                 else:
                     LOGGER.info("Beginning new Full Table replication %s", nascent_stream_version)
                     select_sql = """SELECT {}, xmin::text::bigint
                                       FROM {}
-                                     ORDER BY xmin::text ASC""".format(','.join(escaped_columns),
-                                                                       post_db.fully_qualified_table_name(schema_name, stream['table_name']))
+                                     ORDER BY xmin::text::bigint ASC""".format(','.join(escaped_columns),
+                                                                               post_db.fully_qualified_table_name(schema_name, stream['table_name']))
 
 
                 LOGGER.info("select %s with itersize %s", select_sql, cur.itersize)