fix: retrieve distinct columns

supabase · Nov 29, 2024 · 433c1ad · 433c1ad
1 parent 84d93f0
commit 433c1ad
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pg_replicate/src/clients/postgres.rs b/pg_replicate/src/clients/postgres.rs
@@ -133,7 +133,7 @@ impl ReplicationClient {
         table_id: TableId,
     ) -> Result<Vec<ColumnSchema>, ReplicationClientError> {
         let column_info_query = format!(
-            "select a.attname,
+            "select distinct a.attname,
                 a.atttypid,
                 a.atttypmod,
                 a.attnotnull,