db.go

@@ -15,10 +15,6 @@ type Database struct {
 func InitDatabase(database *Database, conn *sql.DB) {
 	panicOnNil(database)
 
-	if database.db != nil {
-		panic("database is initialized already")
-	}
-
 	*database = Database{
 		db:    conn,
 		stmts: map[string]*sql.Stmt{},

delete.go

@@ -1,11 +0,0 @@
-package advsql
-
-func Delete(db *Database, query string) DeleteFunc {
-	prepareGlobal(db, query)
-
-	return func(args ...interface{}) error {
-		s := db.stmt(query)
-		_, err := s.Exec(args...)
-		return err
-	}
-}

func_types.go

@@ -11,6 +11,4 @@ type QueryOneContextFunc[T any] func(ctx context.Context, args ...interface{}) *
 type InsertFunc[T any] func(v *T) error
 type UpdateFunc[T any] func(v *T) error
 
-type DeleteFunc func(args ...interface{}) error
-
 type ScanFunc = func(args ...interface{}) error

stmt.go

@@ -0,0 +1,59 @@
+package advsql
+
+// import (
+// 	"database/sql"
+// )
+
+// type Stmt[M any] struct {
+// 	stmt *sql.Stmt
+// 	scan func(Scanner) (*M, error)
+// }
+
+// func NewStmt[M any](db *Database, query string, scan func(s Scanner) (*M, error)) (*Stmt[M], error) {
+// 	s, err := db.db.Prepare(query)
+// 	if err != nil {
+// 		return nil, err
+// 	}
+
+// 	stmt := Stmt[M]{
+// 		stmt: s,
+// 		scan: scan,
+// 	}
+// 	db.closefuncs = append(db.closefuncs, stmt.Close)
+// 	return &stmt, err
+// }
+
+// func (stmt *Stmt[M]) Close() error {
+// 	return stmt.stmt.Close()
+// }
+
+// func (stmt *Stmt[M]) Many(args ...interface{}) (<-chan *M, error) {
+// 	rows, err := stmt.stmt.Query(args...)
+// 	if err != nil {
+// 		return nil, err
+// 	}
+
+// 	out := make(chan *M, 10)
+
+// 	go func() {
+// 		defer rows.Close()
+// 		defer close(out)
+
+// 		for rows.Next() {
+// 			if v, err := stmt.scan(rows); err == nil {
+// 				out <- v
+// 			}
+// 		}
+// 	}()
+
+// 	return out, nil
+// }
+
+// func (stmt *Stmt[M]) Single(args ...interface{}) (*M, error) {
+// 	rows, err := stmt.stmt.Query(args...)
+// 	if err != nil {
+// 		return nil, err
+// 	}
+// 	defer rows.Close()
+// 	return stmt.scan(rows)
+// }