removed unnecessary stuff, renamed sql folder
This commit is contained in:
@@ -1,11 +0,0 @@
|
|||||||
package main
|
|
||||||
|
|
||||||
import (
|
|
||||||
"mmaschedule-go/events"
|
|
||||||
"mmaschedule-go/scraper"
|
|
||||||
)
|
|
||||||
|
|
||||||
func stuff(db events.DbEvent) {
|
|
||||||
e := scraper.Event{}
|
|
||||||
db.ReadData(&e)
|
|
||||||
}
|
|
||||||
@@ -1,31 +0,0 @@
|
|||||||
// Code generated by sqlc. DO NOT EDIT.
|
|
||||||
// versions:
|
|
||||||
// sqlc v1.26.0
|
|
||||||
|
|
||||||
package events
|
|
||||||
|
|
||||||
import (
|
|
||||||
"context"
|
|
||||||
"database/sql"
|
|
||||||
)
|
|
||||||
|
|
||||||
type DBTX interface {
|
|
||||||
ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
|
|
||||||
PrepareContext(context.Context, string) (*sql.Stmt, error)
|
|
||||||
QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
|
|
||||||
QueryRowContext(context.Context, string, ...interface{}) *sql.Row
|
|
||||||
}
|
|
||||||
|
|
||||||
func New(db DBTX) *Queries {
|
|
||||||
return &Queries{db: db}
|
|
||||||
}
|
|
||||||
|
|
||||||
type Queries struct {
|
|
||||||
db DBTX
|
|
||||||
}
|
|
||||||
|
|
||||||
func (q *Queries) WithTx(tx *sql.Tx) *Queries {
|
|
||||||
return &Queries{
|
|
||||||
db: tx,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -1,43 +0,0 @@
|
|||||||
package events
|
|
||||||
|
|
||||||
import (
|
|
||||||
"bytes"
|
|
||||||
"encoding/gob"
|
|
||||||
)
|
|
||||||
|
|
||||||
func decode(data []byte, value any) error {
|
|
||||||
buf := bytes.NewBuffer(data)
|
|
||||||
dec := gob.NewDecoder(buf)
|
|
||||||
return dec.Decode(value)
|
|
||||||
}
|
|
||||||
|
|
||||||
func encode(value any) ([]byte, error) {
|
|
||||||
var buf bytes.Buffer
|
|
||||||
enc := gob.NewEncoder(&buf)
|
|
||||||
err := enc.Encode(value)
|
|
||||||
return buf.Bytes(), err
|
|
||||||
}
|
|
||||||
|
|
||||||
func (e *DbEvent) ReadData(value any) error {
|
|
||||||
return decode(e.Data, value)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (e *DbEvent) WriteData(value any) error {
|
|
||||||
b, err := encode(value)
|
|
||||||
if err == nil {
|
|
||||||
e.Data = b
|
|
||||||
}
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
func (e *DbEvent) ReadHistory(value any) error {
|
|
||||||
return decode(e.History, value)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (e *DbEvent) WriteHistory(value any) error {
|
|
||||||
b, err := encode(value)
|
|
||||||
if err == nil {
|
|
||||||
e.History = b
|
|
||||||
}
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
@@ -1,11 +0,0 @@
|
|||||||
// Code generated by sqlc. DO NOT EDIT.
|
|
||||||
// versions:
|
|
||||||
// sqlc v1.26.0
|
|
||||||
|
|
||||||
package events
|
|
||||||
|
|
||||||
type DbEvent struct {
|
|
||||||
Url string `json:"url"`
|
|
||||||
Data []byte `json:"data"`
|
|
||||||
History []byte `json:"history"`
|
|
||||||
}
|
|
||||||
@@ -1,60 +0,0 @@
|
|||||||
// Code generated by sqlc. DO NOT EDIT.
|
|
||||||
// versions:
|
|
||||||
// sqlc v1.26.0
|
|
||||||
// source: query.sql
|
|
||||||
|
|
||||||
package events
|
|
||||||
|
|
||||||
import (
|
|
||||||
"context"
|
|
||||||
)
|
|
||||||
|
|
||||||
const createEvent = `-- name: CreateEvent :exec
|
|
||||||
INSERT INTO
|
|
||||||
db_events (url)
|
|
||||||
VALUES
|
|
||||||
(?) ON CONFLICT (url) DO NOTHING
|
|
||||||
`
|
|
||||||
|
|
||||||
func (q *Queries) CreateEvent(ctx context.Context, url string) error {
|
|
||||||
_, err := q.db.ExecContext(ctx, createEvent, url)
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
const getEvent = `-- name: GetEvent :one
|
|
||||||
SELECT
|
|
||||||
url, data, history
|
|
||||||
FROM
|
|
||||||
db_events
|
|
||||||
WHERE
|
|
||||||
url = ?
|
|
||||||
LIMIT
|
|
||||||
1
|
|
||||||
`
|
|
||||||
|
|
||||||
func (q *Queries) GetEvent(ctx context.Context, url string) (DbEvent, error) {
|
|
||||||
row := q.db.QueryRowContext(ctx, getEvent, url)
|
|
||||||
var i DbEvent
|
|
||||||
err := row.Scan(&i.Url, &i.Data, &i.History)
|
|
||||||
return i, err
|
|
||||||
}
|
|
||||||
|
|
||||||
const updateEvent = `-- name: UpdateEvent :exec
|
|
||||||
UPDATE db_events
|
|
||||||
set
|
|
||||||
data = ?,
|
|
||||||
history = ?
|
|
||||||
WHERE
|
|
||||||
url = ?
|
|
||||||
`
|
|
||||||
|
|
||||||
type UpdateEventParams struct {
|
|
||||||
Data []byte `json:"data"`
|
|
||||||
History []byte `json:"history"`
|
|
||||||
Url string `json:"url"`
|
|
||||||
}
|
|
||||||
|
|
||||||
func (q *Queries) UpdateEvent(ctx context.Context, arg UpdateEventParams) error {
|
|
||||||
_, err := q.db.ExecContext(ctx, updateEvent, arg.Data, arg.History, arg.Url)
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
Reference in New Issue
Block a user