Remove *Conn.sendQuery

pull/483/head
Jack Christensen 2019-02-02 12:45:10 -06:00
parent 1ccd6527f5
commit 52e8d0d679
2 changed files with 1 additions and 8 deletions

View File

@ -614,13 +614,6 @@ func (c *Conn) CauseOfDeath() error {
return c.causeOfDeath
}
func (c *Conn) sendQuery(sql string, arguments ...interface{}) (err error) {
if ps, present := c.preparedStatements[sql]; present {
return c.sendPreparedQuery(ps, arguments...)
}
return c.sendSimpleQuery(sql, arguments...)
}
func (c *Conn) sendSimpleQuery(sql string, args ...interface{}) error {
if err := c.ensureConnectionReadyForQuery(); err != nil {
return err

View File

@ -416,7 +416,7 @@ func (rc *ReplicationConn) StartReplication(slotName string, startLsn uint64, ti
queryString += fmt.Sprintf(" ( %s )", strings.Join(pluginArguments, ", "))
}
if err = rc.c.sendQuery(queryString); err != nil {
if err = rc.c.sendSimpleQuery(queryString); err != nil {
return
}