mirror of https://github.com/jackc/pgx.git
Fix: Handle (n > 0 and err == io.EOF) in CopyFromReader as per io.Reader documentation
parent
0b00887bf8
commit
c6cec81e2c
|
@ -298,7 +298,7 @@ func (c *Conn) CopyFromReader(r io.Reader, sql string) error {
|
||||||
sp := len(buf)
|
sp := len(buf)
|
||||||
for {
|
for {
|
||||||
n, err := r.Read(buf[5:cap(buf)])
|
n, err := r.Read(buf[5:cap(buf)])
|
||||||
if err == io.EOF {
|
if err == io.EOF && n == 0 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
buf = buf[0 : n+5]
|
buf = buf[0 : n+5]
|
||||||
|
|
|
@ -1,7 +1,12 @@
|
||||||
package pgx_test
|
package pgx_test
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"compress/gzip"
|
||||||
|
"fmt"
|
||||||
|
"io/ioutil"
|
||||||
|
"os"
|
||||||
"reflect"
|
"reflect"
|
||||||
|
"strconv"
|
||||||
"strings"
|
"strings"
|
||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
@ -639,3 +644,91 @@ func TestConnCopyFromReaderNoTableError(t *testing.T) {
|
||||||
|
|
||||||
ensureConnValid(t, conn)
|
ensureConnValid(t, conn)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestConnCopyFromGzipReader(t *testing.T) {
|
||||||
|
t.Parallel()
|
||||||
|
|
||||||
|
conn := mustConnect(t, *defaultConnConfig)
|
||||||
|
defer closeConn(t, conn)
|
||||||
|
|
||||||
|
mustExec(t, conn, `create temporary table foo(
|
||||||
|
a int4,
|
||||||
|
b varchar
|
||||||
|
)`)
|
||||||
|
|
||||||
|
f, err := ioutil.TempFile("", "*")
|
||||||
|
if err != nil {
|
||||||
|
t.Fatalf("Unexpected error for ioutil.TempFile: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
gw := gzip.NewWriter(f)
|
||||||
|
|
||||||
|
inputRows := [][]interface{}{}
|
||||||
|
for i := 0; i < 1000; i++ {
|
||||||
|
val := strconv.Itoa(i * i)
|
||||||
|
inputRows = append(inputRows, []interface{}{int32(i), val})
|
||||||
|
_, err = gw.Write([]byte(fmt.Sprintf("%d,\"%s\"\n", i, val)))
|
||||||
|
if err != nil {
|
||||||
|
t.Errorf("Unexpected error for gw.Write: %v", err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
err = gw.Close()
|
||||||
|
if err != nil {
|
||||||
|
t.Fatalf("Unexpected error for gw.Close: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
_, err = f.Seek(0, 0)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatalf("Unexpected error for f.Seek: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
gr, err := gzip.NewReader(f)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatalf("Unexpected error for gzip.NewReader: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
err = conn.CopyFromReader(gr, "COPY foo FROM STDIN WITH (FORMAT csv)")
|
||||||
|
if err != nil {
|
||||||
|
t.Errorf("Unexpected error for CopyFromReader: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
err = gr.Close()
|
||||||
|
if err != nil {
|
||||||
|
t.Errorf("Unexpected error for gr.Close: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
err = f.Close()
|
||||||
|
if err != nil {
|
||||||
|
t.Errorf("Unexpected error for f.Close: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
err = os.Remove(f.Name())
|
||||||
|
if err != nil {
|
||||||
|
t.Errorf("Unexpected error for os.Remove: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
rows, err := conn.Query("select * from foo")
|
||||||
|
if err != nil {
|
||||||
|
t.Errorf("Unexpected error for Query: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
var outputRows [][]interface{}
|
||||||
|
for rows.Next() {
|
||||||
|
row, err := rows.Values()
|
||||||
|
if err != nil {
|
||||||
|
t.Errorf("Unexpected error for rows.Values(): %v", err)
|
||||||
|
}
|
||||||
|
outputRows = append(outputRows, row)
|
||||||
|
}
|
||||||
|
|
||||||
|
if rows.Err() != nil {
|
||||||
|
t.Errorf("Unexpected error for rows.Err(): %v", rows.Err())
|
||||||
|
}
|
||||||
|
|
||||||
|
if !reflect.DeepEqual(inputRows, outputRows) {
|
||||||
|
t.Errorf("Input rows and output rows do not equal")
|
||||||
|
}
|
||||||
|
|
||||||
|
ensureConnValid(t, conn)
|
||||||
|
}
|
||||||
|
|
Loading…
Reference in New Issue