transaction

zdb/tx.go

@@ -26,6 +26,13 @@ func (d *Pool) TxNew(ctx context.Context) (*Tx, error) {
 
 func (d *Pool) MustTx() *Tx {
 	tx, _ := d.TxNew(d.ctx)
+
+	return tx
+}
+
+func (d *Pool) MustTxCtx(ctx context.Context) *Tx {
+	tx, _ := d.TxNew(ctx)
+
 	return tx
 }