Method getPKName

plugins/destination/postgresql/client/migrate.go:481–492

(ctx context.Context, tableName string)

}

func (c *Client) getPKName(ctx context.Context, tableName string) (string, error) {
	var pkConstraintName string
	err := c.conn.QueryRow(ctx, `SELECT tco.constraint_name FROM information_schema.table_constraints tco JOIN information_schema.key_column_usage kcu
     ON kcu.constraint_name = tco.constraint_name
     WHERE tco.constraint_type = 'PRIMARY KEY'
    AND kcu.table_name = $1`, tableName).Scan(&pkConstraintName)
	if err != nil && !errors.Is(err, pgx.ErrNoRows) {
		return "", err
	}

	return pkConstraintName, nil
}

func (c *Client) createPerformanceIndexes(ctx context.Context, table *schema.Table) error {
	columns := []string{"_cq_source_name", "_cq_sync_time"}