From 7abe2a8c05ae96223d73b2bea1b4fd64bbee79e2 Mon Sep 17 00:00:00 2001
From: Nazar Kanaev <nkanaev@live.com>
Date: Mon, 22 Jun 2020 23:14:06 +0100
Subject: [PATCH] bulk-insert items

---
 main.go            | 46 +++++++++++++++++++++++++++++++++++++++++++++-
 storage/item.go    | 33 ++++++++++++++++++++++++++++++++-
 storage/storage.go |  6 +++++-
 3 files changed, 82 insertions(+), 3 deletions(-)

diff --git a/main.go b/main.go
index eecd733..058b291 100644
--- a/main.go
+++ b/main.go
@@ -6,10 +6,11 @@ import (
 )
 
 func main() {
-	storage, err := storage.New()
+	store, err := storage.New()
 	if err != nil {
 		log.Fatal(err)
 	}
+	log.Print(store)
 	/*
 	folder := storage.CreateFolder("foo")
 	storage.RenameFolder(folder.Id, "bar")
@@ -20,4 +21,47 @@ func main() {
 		"title", "description", "link", "feedlink", "icon", 1)
 	storage.RenameFeed(feed.Id, "newtitle")
 	*/
+	/*
+	items := make([]storage.Item, 3, 3)
+	items = append(items, storage.Item{
+		Id: "id",
+		FeedId: 0,
+		Title: "title",
+		Link: "link",
+		Description: "description",
+		Content: "content",
+		Author: "author",
+		Date: 1,
+		DateUpdated: 1,
+		Status: storage.UNREAD,
+		Image: "image",
+	})
+	items = append(items, storage.Item{
+		Id: "id2",
+		FeedId: 0,
+		Title: "title",
+		Link: "link",
+		Description: "description",
+		Content: "content",
+		Author: "author",
+		Date: 1,
+		DateUpdated: 50,
+		Status: storage.UNREAD,
+		Image: "image",
+	})
+	items = append(items, storage.Item{
+		Id: "id",
+		FeedId: 0,
+		Title: "title",
+		Link: "link",
+		Description: "description",
+		Content: "content",
+		Author: "author",
+		Date: 1,
+		DateUpdated: 100,
+		Status: storage.UNREAD,
+		Image: "image",
+	})
+	log.Print(store.CreateItems(items))
+	*/
 }
diff --git a/storage/item.go b/storage/item.go
index b233348..b507580 100644
--- a/storage/item.go
+++ b/storage/item.go
@@ -9,7 +9,7 @@ const (
 )
 
 type Item struct {
-	Id int64
+	Id string
 	FeedId int64
 	Title string
 	Link string
@@ -23,5 +23,36 @@ type Item struct {
 }
 
 func (s *Storage) CreateItems(items []Item) bool {
+	tx, err := s.db.Begin()
+	if err != nil {
+		s.log.Print(err)
+		return false
+	}
+	for _, item := range items {
+		_, err = tx.Exec(`
+			insert into items (
+				id, feed_id, title, link, description,
+				content, author, date, date_updated, status, image
+			)
+			values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
+			on conflict (id) do update set date_updated=?`,
+			item.Id, item.FeedId, item.Title, item.Link, item.Description,
+			item.Content, item.Author, item.Date, item.DateUpdated, UNREAD, item.Image,
+			// upsert values
+			item.DateUpdated,
+		)
+		if err != nil {
+			s.log.Print(err)
+			if err = tx.Rollback(); err != nil {
+				s.log.Print(err)
+				return false
+			}
+			return false
+		}
+	}
+	if err = tx.Commit(); err != nil {
+		s.log.Print(err)
+		return false
+	}
 	return true
 }
diff --git a/storage/storage.go b/storage/storage.go
index a6ef80e..5e6dab9 100644
--- a/storage/storage.go
+++ b/storage/storage.go
@@ -1,6 +1,8 @@
 package storage
 
 import (
+	"os"
+	"log"
 	"database/sql"
 	_ "github.com/mattn/go-sqlite3"
 )
@@ -44,6 +46,7 @@ create index if not exists idx_item_status  on items(status);
 
 type Storage struct {
 	db *sql.DB
+	log *log.Logger
 }
 
 func New() (*Storage, error) {
@@ -56,7 +59,8 @@ func New() (*Storage, error) {
 	if err != nil {
 		return nil, err
 	}
-	return &Storage{db: db}, nil
+	logger := log.New(os.Stdout, "storage: ", log.Ldate | log.Ltime | log.Lshortfile)
+	return &Storage{db: db, log: logger}, nil
 }
 
 func intOrNil(id int64) interface{} {