parent
4748435779
commit
f45ecfebcc
6 changed files with 0 additions and 131 deletions
|
|
@ -1,31 +0,0 @@
|
||||||
// Code generated by sqlc. DO NOT EDIT.
|
|
||||||
// versions:
|
|
||||||
// sqlc v1.26.0
|
|
||||||
|
|
||||||
package database
|
|
||||||
|
|
||||||
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,9 +0,0 @@
|
||||||
-- +migrate Up
|
|
||||||
CREATE table users (
|
|
||||||
id INTEGER PRIMARY KEY,
|
|
||||||
first_name text NOT NULL,
|
|
||||||
email text NOT NULL
|
|
||||||
);
|
|
||||||
|
|
||||||
-- +migrate Down
|
|
||||||
DROP TABLE users;
|
|
||||||
|
|
@ -1,11 +0,0 @@
|
||||||
// Code generated by sqlc. DO NOT EDIT.
|
|
||||||
// versions:
|
|
||||||
// sqlc v1.26.0
|
|
||||||
|
|
||||||
package database
|
|
||||||
|
|
||||||
type User struct {
|
|
||||||
ID int64
|
|
||||||
FirstName string
|
|
||||||
Email string
|
|
||||||
}
|
|
||||||
|
|
@ -1,2 +0,0 @@
|
||||||
-- name: ListUsers :many
|
|
||||||
SELECT * FROM users;
|
|
||||||
|
|
@ -1,41 +0,0 @@
|
||||||
package database
|
|
||||||
|
|
||||||
import (
|
|
||||||
"database/sql"
|
|
||||||
"embed"
|
|
||||||
"fmt"
|
|
||||||
|
|
||||||
_ "github.com/mattn/go-sqlite3"
|
|
||||||
migrate "github.com/rubenv/sql-migrate"
|
|
||||||
)
|
|
||||||
|
|
||||||
type Repository struct {
|
|
||||||
queries *Queries
|
|
||||||
db *sql.DB
|
|
||||||
}
|
|
||||||
|
|
||||||
//go:embed migrations/*
|
|
||||||
var dbMigrations embed.FS
|
|
||||||
|
|
||||||
func NewRepository(filename string) (*Repository, error) {
|
|
||||||
db, err := sql.Open("sqlite3", filename)
|
|
||||||
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
migrations := migrate.EmbedFileSystemMigrationSource{
|
|
||||||
FileSystem: dbMigrations,
|
|
||||||
Root: "migrations",
|
|
||||||
}
|
|
||||||
|
|
||||||
n, err := migrate.Exec(db, "sqlite3", migrations, migrate.Up)
|
|
||||||
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
fmt.Printf("Applied %d migrations - Database is ready!\n", n)
|
|
||||||
|
|
||||||
return &Repository{queries: New(db), db: db}, nil
|
|
||||||
}
|
|
||||||
|
|
@ -1,37 +0,0 @@
|
||||||
// Code generated by sqlc. DO NOT EDIT.
|
|
||||||
// versions:
|
|
||||||
// sqlc v1.26.0
|
|
||||||
// source: users.sql
|
|
||||||
|
|
||||||
package database
|
|
||||||
|
|
||||||
import (
|
|
||||||
"context"
|
|
||||||
)
|
|
||||||
|
|
||||||
const listAuthors = `-- name: ListAuthors :many
|
|
||||||
SELECT id, first_name, email FROM users
|
|
||||||
`
|
|
||||||
|
|
||||||
func (q *Queries) ListAuthors(ctx context.Context) ([]User, error) {
|
|
||||||
rows, err := q.db.QueryContext(ctx, listAuthors)
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
defer rows.Close()
|
|
||||||
var items []User
|
|
||||||
for rows.Next() {
|
|
||||||
var i User
|
|
||||||
if err := rows.Scan(&i.ID, &i.FirstName, &i.Email); err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
items = append(items, i)
|
|
||||||
}
|
|
||||||
if err := rows.Close(); err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
if err := rows.Err(); err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
return items, nil
|
|
||||||
}
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue