diff --git a/trino/trino.go b/trino/trino.go index b79056d..2bedea8 100644 --- a/trino/trino.go +++ b/trino/trino.go @@ -921,6 +921,14 @@ func (st *driverStmt) exec(ctx context.Context, args []driver.NamedValue) (*stmt continue } + if arg.Name == accessTokenConfig { + if st.conn.forwardAuthorizationHeader { + token := arg.Value.(string) + hs.Add(authorizationHeader, getAuthorization(token)) + } + continue + } + s, err := Serial(arg.Value) if err != nil { return nil, err