(t *testing.T)
| 178 | } |
| 179 | |
| 180 | func GeneratePostgresPeer(t *testing.T) *protos.Peer { |
| 181 | t.Helper() |
| 182 | peer := &protos.Peer{ |
| 183 | Name: "catalog", |
| 184 | Type: protos.DBType_POSTGRES, |
| 185 | Config: &protos.Peer_PostgresConfig{ |
| 186 | PostgresConfig: internal.GetAncillaryPostgresConfigFromEnv(), |
| 187 | }, |
| 188 | } |
| 189 | CreatePeer(t, peer) |
| 190 | return peer |
| 191 | } |
| 192 | |
| 193 | func (s *PostgresSource) Exec(ctx context.Context, sql string, args ...any) error { |
| 194 | _, err := s.PostgresConnector.Conn().Exec(ctx, sql, args...) |