asdasd

Author: dmigra0

pgxpool/conn.go

@@ -103,6 +103,10 @@ func (c *Conn) CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNam
 	return c.Conn().CopyFrom(ctx, tableName, columnNames, rowSrc)
 }
 
+func (c *Conn) CopyFromText(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error) {
+	return c.Conn().CopyFromText(ctx, tableName, columnNames, rowSrc)
+}
+
 // Begin starts a transaction block from the *Conn without explicitly setting a transaction mode (see BeginTx with TxOptions if transaction mode is required).
 func (c *Conn) Begin(ctx context.Context) (pgx.Tx, error) {
 	return c.Conn().Begin(ctx)

pgxpool/tx.go

@@ -50,6 +50,10 @@ func (tx *Tx) CopyFrom(ctx context.Context, tableName pgx.Identifier, columnName
 	return tx.t.CopyFrom(ctx, tableName, columnNames, rowSrc)
 }
 
+func (tx *Tx) CopyFromText(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error) {
+	return tx.t.CopyFromText(ctx, tableName, columnNames, rowSrc)
+}
+
 func (tx *Tx) SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults {
 	return tx.t.SendBatch(ctx, b)
 }