From 433c1ad7385c39b6f15cfa21c72b237b196fada3 Mon Sep 17 00:00:00 2001
From: Deji Ibrahim <31637316+dejii@users.noreply.github.com>
Date: Fri, 29 Nov 2024 02:31:47 +0100
Subject: [PATCH] fix: retrieve distinct columns

---
 pg_replicate/src/clients/postgres.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pg_replicate/src/clients/postgres.rs b/pg_replicate/src/clients/postgres.rs
index 22168c6..744a304 100644
--- 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,