diff options
| author | Felix Hanley <felix@userspace.com.au> | 2018-03-23 05:07:03 +0000 |
|---|---|---|
| committer | Felix Hanley <felix@userspace.com.au> | 2018-03-23 05:07:03 +0000 |
| commit | 38277d4acd5d8f5f3ceec0e387f45e3fc669418d (patch) | |
| tree | fa6bec2ab5b4e8b7d3ff8cac344e6052400c5250 | |
| parent | 103ff73bbfd17f15865acd5c7d43ac3400331c4d (diff) | |
| download | dhtsearch-38277d4acd5d8f5f3ceec0e387f45e3fc669418d.tar.gz dhtsearch-38277d4acd5d8f5f3ceec0e387f45e3fc669418d.tar.bz2 | |
Bind tag SQL to transaction
| -rw-r--r-- | db/sqlite.go | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/db/sqlite.go b/db/sqlite.go index 4c93ace..f78498a 100644 --- a/db/sqlite.go +++ b/db/sqlite.go @@ -85,7 +85,7 @@ func (s *Store) SaveTorrent(t *models.Torrent) error { var torrentID int64 var res sql.Result - res, err = tx.Stmt(s.stmts["insertTorrent"]).Exec(t.Name, t.Infohash, t.Size) + res, err = tx.Stmt(s.stmts["insertTorrent"]).Exec(t.Name, t.Infohash.Bytes(), t.Size) if err != nil { return fmt.Errorf("insertTorrent: %s", err) } @@ -95,7 +95,13 @@ func (s *Store) SaveTorrent(t *models.Torrent) error { // Write tags for _, tag := range t.Tags { - tagID, err := s.SaveTag(tag) + var tagID int64 + + res, err = tx.Stmt(s.stmts["insertTag"]).Exec(tag) + if err != nil { + return fmt.Errorf("saveTag: %s", err) + } + tagID, err = res.LastInsertId() if err != nil { return fmt.Errorf("saveTag: %s", err) } |
