mirror of https://github.com/jackc/pgx.git
Remove unused Batch.inTx
parent
898925303d
commit
187157e773
7
batch.go
7
batch.go
|
@ -23,7 +23,6 @@ type Batch struct {
|
|||
resultsRead int
|
||||
ctx context.Context
|
||||
err error
|
||||
inTx bool
|
||||
|
||||
mrr *pgconn.MultiResultReader
|
||||
}
|
||||
|
@ -33,12 +32,6 @@ func (c *Conn) BeginBatch() *Batch {
|
|||
return &Batch{conn: c}
|
||||
}
|
||||
|
||||
// BeginBatch returns a *Batch query for tx. Since this *Batch is already part
|
||||
// of a transaction it will not automatically be wrapped in a transaction.
|
||||
func (tx *Tx) BeginBatch() *Batch {
|
||||
return &Batch{conn: tx.conn, inTx: true}
|
||||
}
|
||||
|
||||
// Conn returns the underlying connection that b will or was performed on.
|
||||
func (b *Batch) Conn() *Conn {
|
||||
return b.conn
|
||||
|
|
5
tx.go
5
tx.go
|
@ -185,6 +185,11 @@ func (tx *Tx) CopyFrom(ctx context.Context, tableName Identifier, columnNames []
|
|||
return tx.conn.CopyFrom(ctx, tableName, columnNames, rowSrc)
|
||||
}
|
||||
|
||||
// BeginBatch returns a *Batch query for the tx's connection.
|
||||
func (tx *Tx) BeginBatch() *Batch {
|
||||
return &Batch{conn: tx.conn}
|
||||
}
|
||||
|
||||
// Status returns the status of the transaction from the set of
|
||||
// pgx.TxStatus* constants.
|
||||
func (tx *Tx) Status() int8 {
|
||||
|
|
Loading…
Reference in New Issue