From 52e8d0d679c43816cd27e6c86356ba03589ebc27 Mon Sep 17 00:00:00 2001 From: Jack Christensen Date: Sat, 2 Feb 2019 12:45:10 -0600 Subject: [PATCH] Remove *Conn.sendQuery --- conn.go | 7 ------- replication.go | 2 +- 2 files changed, 1 insertion(+), 8 deletions(-) diff --git a/conn.go b/conn.go index 99858ba6..3818d253 100644 --- a/conn.go +++ b/conn.go @@ -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 diff --git a/replication.go b/replication.go index ad812947..8d67db85 100644 --- a/replication.go +++ b/replication.go @@ -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 }