diff --git a/conn_pool.go b/conn_pool.go index e8972a0b..344f00d7 100644 --- a/conn_pool.go +++ b/conn_pool.go @@ -341,7 +341,8 @@ func (p *ConnPool) afterConnectionCreated(c *Conn) (*Conn, error) { } for _, ps := range p.preparedStatements { - if _, err := c.Prepare(ps.Name, ps.SQL); err != nil { + opts := &PrepareExOptions{ParameterOIDs: ps.ParameterOIDs} + if _, err := c.PrepareEx(context.Background(), ps.Name, ps.SQL, opts); err != nil { c.die(err) return nil, err }