diff --git a/storage/insert.go b/storage/insert.go new file mode 100644 index 0000000..5fa02e5 --- /dev/null +++ b/storage/insert.go @@ -0,0 +1,43 @@ +package storage + +import ( + "database/sql" + "log" + "synlotto-website/models" +) + +func InsertThunderballResult(db *sql.DB, res models.ThunderballResult) error { + stmt := ` + INSERT INTO results_thunderball ( + draw_date, machine, ballset, + ball1, ball2, ball3, ball4, ball5, thunderball + ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?);` + + _, err := db.Exec(stmt, + res.DrawDate, res.Machine, res.Ballset, + res.Ball1, res.Ball2, res.Ball3, res.Ball4, res.Ball5, res.Thunderball, + ) + if err != nil { + log.Println("❌ InsertThunderballResult error:", err) + } + return err +} + +func InsertMyTicket(db *sql.DB, ticket models.MyTicket) error { + stmt := ` + INSERT INTO my_tickets ( + game_type, draw_date, + ball1, ball2, ball3, ball4, ball5, + bonus1, bonus2 + ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?);` + + _, err := db.Exec(stmt, + ticket.GameType, ticket.DrawDate, + ticket.Ball1, ticket.Ball2, ticket.Ball3, ticket.Ball4, ticket.Ball5, + ticket.Bonus1, ticket.Bonus2, + ) + if err != nil { + log.Println("❌ InsertMyTicket error:", err) + } + return err +}