diff options
| author | Baitinq <[email protected]> | 2024-06-09 23:11:12 +0200 |
|---|---|---|
| committer | Baitinq <[email protected]> | 2024-06-09 23:19:35 +0200 |
| commit | 49c6b32518e919a25a8f9ca11d6733fe9766c090 (patch) | |
| tree | 72eb264dc47af54dd20761d83edc3bd2bf7d9956 | |
| parent | payload-processor: fix bug inserting multiple files (diff) | |
| download | fs-tracer-backend-49c6b32518e919a25a8f9ca11d6733fe9766c090.tar.gz fs-tracer-backend-49c6b32518e919a25a8f9ca11d6733fe9766c090.tar.bz2 fs-tracer-backend-49c6b32518e919a25a8f9ca11d6733fe9766c090.zip | |
payload-processor: bulk insert files
| -rw-r--r-- | src/payload-processor/processor/db.go | 15 |
1 files changed, 7 insertions, 8 deletions
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 } |