diff --git a/cmd/pg-lockless-fifo-demo/main.go b/cmd/pg-lockless-fifo-demo/main.go index 364e54b..da91848 100644 --- a/cmd/pg-lockless-fifo-demo/main.go +++ b/cmd/pg-lockless-fifo-demo/main.go @@ -9,9 +9,6 @@ import ( "time" "pg/src/with" - - _ "github.com/lib/pq" - _ "modernc.org/sqlite" ) func main() { @@ -22,14 +19,14 @@ func main() { func run(ctx context.Context) error { fs := flag.NewFlagSet(os.Args[0], flag.ContinueOnError) - c := fs.String("c", "postgresql://pulsegres:pulsegres@localhost:15432", "conn string") + c := fs.String("c", "sqlite://", "conn string") if err := fs.Parse(os.Args[1:]); err != nil { panic(err) } - return with.PSQL(ctx, *c, func(pg *sql.DB) error { + return with.SQL(ctx, *c, func(db *sql.DB) error { go with.Every(ctx, 5*time.Second, func() { - row := pg.QueryRowContext(ctx, `SELECT 1`) + row := db.QueryRowContext(ctx, `SELECT 1`) var n int if err := row.Err(); err != nil { log.Println("query err:", err)