data-work
Mike Holloway 3 months ago
parent ff6de84731
commit b886c39ac9
  1. 57
      main.go
  2. 15
      models.go

@ -1,14 +1,15 @@
package main package main
import ( import (
"fmt"
"context" "context"
"errors"
"database/sql" "database/sql"
"errors"
"fmt"
"github.com/uptrace/bun" "github.com/uptrace/bun"
"github.com/uptrace/bun/extra/bundebug"
"github.com/uptrace/bun/dialect/pgdialect" "github.com/uptrace/bun/dialect/pgdialect"
"github.com/uptrace/bun/driver/pgdriver" "github.com/uptrace/bun/driver/pgdriver"
"github.com/uptrace/bun/extra/bundebug"
) )
var feeds []Feed var feeds []Feed
@ -29,28 +30,58 @@ func main() {
bundebug.FromEnv("BUNDEBUG"), bundebug.FromEnv("BUNDEBUG"),
)) ))
// Turn these into funcs with error handling, logging, return vals etc. // Turn these into funcs with error handling, logging, return vals etc.
feederr := db.NewSelect().Model(&feeds).OrderExpr("title ASC").Limit(10).Scan(ctx) feederr := db.NewSelect().
Model(&feeds).
OrderExpr("title ASC").
Limit(10).
Scan(ctx)
if feederr != nil { if feederr != nil {
errors.Join(feederr, err) errors.Join(feederr, err)
} }
categoryerr := db.NewSelect().Model(&categories).OrderExpr("title ASC").Scan(ctx) categoryerr := db.NewSelect().
Model(&categories).
OrderExpr("title ASC").
Scan(ctx)
if categoryerr != nil { if categoryerr != nil {
errors.Join(categoryerr, err) errors.Join(categoryerr, err)
} }
entryerr := db.NewSelect().Model(&entries).OrderExpr("published_at ASC").Limit(10).Scan(ctx) entryerr := db.NewSelect().
Model(&entries).
OrderExpr("published_at ASC").
Limit(10).
Scan(ctx)
if entryerr != nil { if entryerr != nil {
errors.Join(entryerr, err) errors.Join(entryerr, err)
} }
usererr := db.NewSelect().Model(&users).OrderExpr("id ASC").Scan(ctx) usererr := db.NewSelect().
Model(&users).
OrderExpr("id ASC").
Scan(ctx)
if usererr != nil { if usererr != nil {
errors.Join(usererr, err) errors.Join(usererr, err)
} }
fmt.Printf("%+v\n", entries)
fmt.Printf("%+v\n", categories) fmt.Printf("[]Entry\n")
fmt.Printf("%+v\n", feeds) for _, val := range entries {
fmt.Printf("%+v\n", users) fmt.Printf("val = %s\n", val)
// }
fmt.Printf("[]Category\n")
for _, val := range categories {
fmt.Printf("val = %s\n", val)
}
fmt.Printf("[]Feed\n")
for _, val := range feeds {
fmt.Printf("val = %s\n", val)
}
fmt.Printf("[]User\n")
for _, val := range users {
fmt.Printf("val = %s\n", val)
}
// fmt.Printf("%+v\n", entries)
// fmt.Printf("%+v\n", categories)
// fmt.Printf("%+v\n", feeds)
// fmt.Printf("%+v\n", users)
} }

@ -4,6 +4,15 @@ import (
"github.com/uptrace/bun" "github.com/uptrace/bun"
) )
type AnvilDB struct {
DBContext *Context
}
type AnvilData struct {
Feeds []Feed
Categories []Category
Entries []Entry
Users []User
}
type User struct { type User struct {
bun.BaseModel `bun:"table:users"` bun.BaseModel `bun:"table:users"`
@ -17,7 +26,7 @@ type Feed struct {
ID int64 `bun:"id,pk,autoincrement"` ID int64 `bun:"id,pk,autoincrement"`
CategoryID int64 `bun:"category_id"` CategoryID int64 `bun:"category_id"`
Title string `bun:"title"` Title string `bun:"title"`
//SELECT id,category_id,title FROM feeds ORDER BY id; // SELECT id,category_id,title FROM feeds ORDER BY id;
} }
type Entry struct { type Entry struct {
bun.BaseModel `bun:"table:entries"` bun.BaseModel `bun:"table:entries"`
@ -25,13 +34,13 @@ type Entry struct {
ID int64 `bun:"id,pk,autoincrement"` ID int64 `bun:"id,pk,autoincrement"`
Title string `bun:"title"` Title string `bun:"title"`
Author string `bun:"author"` Author string `bun:"author"`
//SELECT id,title,author FROM entries ORDER BY published_at LIMIT 10; // SELECT id,title,author FROM entries ORDER BY published_at LIMIT 10;
} }
type Category struct { type Category struct {
bun.BaseModel `bun:"table:categories"` bun.BaseModel `bun:"table:categories"`
ID int64 `bun:"id,pk,autoincrement"` ID int64 `bun:"id,pk,autoincrement"`
Title string `bun:"title"` Title string `bun:"title"`
//SELECT id,title from categories; //SELECT id,title from categories;
} }

Loading…
Cancel
Save