1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
|
package sophia
import "errors"
// TxStatus transactional status
type TxStatus int
const (
// TxError means that transaction has been completed with error
TxError TxStatus = -1
// TxOk means that transaction has been completed
TxOk TxStatus = 0
// TxRollback status means that transaction has been rollbacked by another concurrent transaction
TxRollback TxStatus = 1
// TxLock status means that transaction is not finished and waiting for concurrent transaction to complete.
// In that case commit should be retried later or transaction can be rollbacked.
TxLock TxStatus = 2
)
// Transaction multi-statement transaction is automatically processed when Set(), Delete(), Upsert(), Get() are used on a transactional object.
// The BeginTx() function is used to start a multi-statement transaction.
// During transaction, no updates are written to the database files until a Commit() is called.
// On commit, all modifications that were made are written to the log file in a single batch.
// To discard any changes made during transaction operation, Rollback() function should be used.
// No nested transactions are supported.
// There are no limit on a number of concurrent transactions.
// Any number of databases can be involved in a multi-statement transaction.
type Transaction struct {
*dataStore
}
// Commit commits the transaction and returns it's status.
// Any error happened during multi-statement transaction does not rollback a transaction.
func (tx *Transaction) Commit() TxStatus {
return TxStatus(spCommit(tx.ptr))
}
// Rollback rollbacks transaction and destroy transaction object.
func (tx *Transaction) Rollback() error {
if !spDestroy(tx.ptr) {
return errors.New("tx: failed to rollback")
}
return nil
}
|
