Function currentSchema

plugins/destination/postgresql/client/client.go:175–183

(ctx context.Context, conn DBPool)

}

func currentSchema(ctx context.Context, conn DBPool) (string, error) {
	var schema string
	err := conn.QueryRow(ctx, "select current_schema()").Scan(&schema)
	if err != nil {
		return "", err
	}

	return schema, nil
}

func (c *Client) getPgType(ctx context.Context) (pgType, error) {
	var version string