From b9a2373aa5d4ded0380dc29db5c7a1d639f85a15 Mon Sep 17 00:00:00 2001 From: Kelsey Francis Date: Thu, 13 Apr 2017 11:41:52 -0700 Subject: [PATCH] Fix ConnPool/Tx CopyFrom signature to take CopyFromSource --- conn_pool.go | 2 +- tx.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/conn_pool.go b/conn_pool.go index 2a7b4db2..1913699e 100644 --- a/conn_pool.go +++ b/conn_pool.go @@ -518,7 +518,7 @@ func (p *ConnPool) CopyTo(tableName string, columnNames []string, rowSrc CopyToS // CopyFrom acquires a connection, delegates the call to that connection, and // releases the connection. -func (p *ConnPool) CopyFrom(tableName Identifier, columnNames []string, rowSrc CopyToSource) (int, error) { +func (p *ConnPool) CopyFrom(tableName Identifier, columnNames []string, rowSrc CopyFromSource) (int, error) { c, err := p.Acquire() if err != nil { return 0, err diff --git a/tx.go b/tx.go index 1e32cff3..deb6c01c 100644 --- a/tx.go +++ b/tx.go @@ -168,7 +168,7 @@ func (tx *Tx) CopyTo(tableName string, columnNames []string, rowSrc CopyToSource } // CopyFrom delegates to the underlying *Conn -func (tx *Tx) CopyFrom(tableName Identifier, columnNames []string, rowSrc CopyToSource) (int, error) { +func (tx *Tx) CopyFrom(tableName Identifier, columnNames []string, rowSrc CopyFromSource) (int, error) { if tx.status != TxStatusInProgress { return 0, ErrTxClosed }