()
| 82 | } |
| 83 | |
| 84 | func (s *State) openHandler() { |
| 85 | if s.level == sql.LevelReadUncommitted { |
| 86 | var err error |
| 87 | if s.handler, err = s.strg.Writer().Begin(); err != nil { |
| 88 | log.WithError(err).Fatal("failed to open transaction") |
| 89 | } |
| 90 | } else { |
| 91 | s.handler = s.strg.Writer() |
| 92 | } |
| 93 | } |
| 94 | |
| 95 | func (s *State) reader() *sql.DB { |
| 96 | if s.level == sql.LevelReadUncommitted { |