aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorFelix Hanley <felix@userspace.com.au>2018-03-23 05:07:03 +0000
committerFelix Hanley <felix@userspace.com.au>2018-03-23 05:07:03 +0000
commit38277d4acd5d8f5f3ceec0e387f45e3fc669418d (patch)
treefa6bec2ab5b4e8b7d3ff8cac344e6052400c5250
parent103ff73bbfd17f15865acd5c7d43ac3400331c4d (diff)
downloaddhtsearch-38277d4acd5d8f5f3ceec0e387f45e3fc669418d.tar.gz
dhtsearch-38277d4acd5d8f5f3ceec0e387f45e3fc669418d.tar.bz2
Bind tag SQL to transaction
-rw-r--r--db/sqlite.go10
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)
}