gopkg/pgx
2
0
Fork 0
Code Activity

Fix ConnPool/Tx CopyFrom signature to take CopyFromSource

Browse Source
This commit is contained in:
Kelsey Francis
2017-04-13 11:41:52 -07:00
parent b84338d7d6
commit b9a2373aa5
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
conn_pool.go
+1 -1
View File
@@ -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 // CopyFrom acquires a connection, delegates the call to that connection, and
// releases the connection. // 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() c, err := p.Acquire()
if err != nil { if err != nil {
return 0, err return 0, err
tx.go
+1 -1
View File
@@ -168,7 +168,7 @@ func (tx *Tx) CopyTo(tableName string, columnNames []string, rowSrc CopyToSource
} }
// CopyFrom delegates to the underlying *Conn // 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 { if tx.status != TxStatusInProgress {
return 0, ErrTxClosed return 0, ErrTxClosed
} }