From 49c6b32518e919a25a8f9ca11d6733fe9766c090 Mon Sep 17 00:00:00 2001 From: Baitinq Date: Sun, 9 Jun 2024 23:11:12 +0200 Subject: payload-processor: bulk insert files --- src/payload-processor/processor/db.go | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) (limited to 'src/payload-processor') diff --git a/src/payload-processor/processor/db.go b/src/payload-processor/processor/db.go index eb67a79..cb764ac 100644 --- a/src/payload-processor/processor/db.go +++ b/src/payload-processor/processor/db.go @@ -24,14 +24,13 @@ func NewDB(db *sqlx.DB) DB { } func (db DBImpl) InsertFiles(ctx context.Context, files []lib.File, user_id string) error { - for _, file := range files { - file.User_id = user_id - //TODO: Do bulk insert - _, err := db.db.NamedExecContext(ctx, "INSERT INTO public.file (user_id, absolute_path, contents, timestamp) VALUES (:user_id, :absolute_path, :contents, :timestamp)", file) - if err != nil { - return err - } - log.Println("Inserted file: ", file) + for i := range files { + files[i].User_id = user_id } + _, err := db.db.NamedExecContext(ctx, "INSERT INTO public.file (user_id, absolute_path, contents, timestamp) VALUES (:user_id, :absolute_path, :contents, :timestamp)", files) + if err != nil { + return err + } + log.Println("Inserted files: ", files) return nil } -- cgit 1.4.1