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
 	}