Compare commits

...

4 Commits

Author SHA1 Message Date
Timon Ringwald
31258a50a4 improved Delete func 2022-09-06 10:51:21 +02:00
Timon Ringwald
2ce3d755bd improved Delete 2022-09-06 10:49:22 +02:00
Timon Ringwald
f7bae81df7 added Delete 2022-09-06 10:42:09 +02:00
Timon Ringwald
3f8e334dbb panic when initializing already initialized database 2022-08-04 09:37:01 +02:00
4 changed files with 17 additions and 59 deletions

4
db.go
View File

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

11
delete.go Normal file
View File

@ -0,0 +1,11 @@
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
}
}

View File

@ -11,4 +11,6 @@ type QueryOneContextFunc[T any] func(ctx context.Context, args ...interface{}) *
type InsertFunc[T any] func(v *T) error type InsertFunc[T any] func(v *T) error
type UpdateFunc[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 type ScanFunc = func(args ...interface{}) error

59
stmt.go
View File

@ -1,59 +0,0 @@
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)
// }