avoid sql placeholder

PeerDB-io · Feb 15, 2024 · 3eb09d7 · 3eb09d7
1 parent c0bc2ea
commit 3eb09d7
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/flow/connectors/postgres/validate.go b/flow/connectors/postgres/validate.go
@@ -67,7 +67,8 @@ func (c *PostgresConnector) CheckReplicationPermissions(ctx context.Context, use
 	}
 
 	var replicationRes bool
-	err := c.conn.QueryRow(ctx, "SELECT rolreplication FROM pg_roles WHERE rolname = $1", username).Scan(&replicationRes)
+	err := c.conn.QueryRow(ctx, "SELECT rolreplication FROM pg_roles WHERE rolname = "+
+		QuoteLiteral(username)).Scan(&replicationRes)
 	if err != nil {
 		return err
 	}