transaction.go 947 B

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. package dao
  2. /*
  3. import (
  4. "context"
  5. xsql "go-common/database/sql"
  6. )
  7. type TxImpl struct {
  8. *xsql.Tx
  9. }
  10. func NewTx(ctx context.Context) (Tx, error) {
  11. t, err := db.Begin(ctx)
  12. if err != nil {
  13. return nil, err
  14. }
  15. return &TxImpl{t}, nil
  16. }
  17. func (tx *TxImpl) UpdateKeyword(k *Keyword) error {
  18. return updateKeyword(tx.Ctx, tx, k)
  19. }
  20. func (tx *TxImpl) InsertKeyword(k *Keyword) error {
  21. return insertKeyword(tx.Ctx, tx, k)
  22. }
  23. func (tx *TxImpl) InsertRule(r *Rule) error {
  24. return insertRule(tx.Ctx, tx, r)
  25. }
  26. func (tx *TxImpl) UpdateRegexp(r *Regexp) error {
  27. return updateRegexp(tx.Ctx, tx, r)
  28. }
  29. func (tx *TxImpl) InsertRegexp(r *Regexp) error {
  30. return insertRegexp(tx.Ctx, tx, r)
  31. }
  32. func (tx *TxImpl) QueryRow(_ context.Context, sql string, args ...interface{}) *xsql.Row {
  33. return tx.Tx.QueryRow(sql, args)
  34. }
  35. func (tx *TxImpl) Query(_ context.Context, sql string, args ...interface{}) (*xsql.Rows, error) {
  36. return tx.Tx.Query(sql, args)
  37. }*/