diff options
Diffstat (limited to 'src/payload-processor/processor/db.go')
-rw-r--r-- | src/payload-processor/processor/db.go | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/payload-processor/processor/db.go b/src/payload-processor/processor/db.go index bad31d1..ce7d5bb 100644 --- a/src/payload-processor/processor/db.go +++ b/src/payload-processor/processor/db.go @@ -2,14 +2,13 @@ package processor import ( "context" - "time" "github.com/jmoiron/sqlx" ) //go:generate mockgen -source=$GOFILE -package=$GOPACKAGE -destination=mock_$GOFILE type DB interface { - TestInsert(ctx context.Context, message string) error + InsertFile(ctx context.Context, file File) error } type DBImpl struct { @@ -22,7 +21,7 @@ func NewDB(db *sqlx.DB) DB { return &DBImpl{db: db} } -func (db DBImpl) TestInsert(ctx context.Context, message string) error { - _, err := db.db.ExecContext(ctx, "INSERT INTO test (created_at, test) VALUES ($1, $2)", time.Now(), message) +func (db DBImpl) InsertFile(ctx context.Context, file File) error { + _, err := db.db.NamedExecContext(ctx, "INSERT INTO private.file (user_id, absolute_path, contents, timestamp) VALUES (:user_id, :absolute_path, :contents, :timestamp)", file) return err } |