(tx *sql.Tx)
| 158 | } |
| 159 | |
| 160 | func (this *Batch) commitTx(tx *sql.Tx) error { |
| 161 | // always commit without checking database closing status |
| 162 | this.db.EndUpdating() |
| 163 | return tx.Commit() |
| 164 | } |
| 165 | |
| 166 | func (this *Batch) execItem(tx *sql.Tx, item *batchItem) error { |
| 167 | // check database status |
no test coverage detected