v0.0.35

langext/string.go

@@ -107,3 +107,11 @@ func NumToStringOpt[V IntConstraint](v *V, fallback string) string {
 		return fmt.Sprintf("%d", v)
 	}
 }
+
+func StrRepeat(val string, count int) string {
+	r := ""
+	for i := 0; i < count; i++ {
+		r += val
+	}
+	return r
+}

sq/scanner.go

@@ -0,0 +1,52 @@
+package sq
+
+import (
+	"database/sql"
+	"errors"
+	"github.com/jmoiron/sqlx"
+)
+
+func ScanSingle[TData any](rows *sqlx.Rows, close bool) (TData, error) {
+	if rows.Next() {
+		var data TData
+		err := rows.StructScan(&data)
+		if err != nil {
+			return *new(TData), err
+		}
+		if rows.Next() {
+			_ = rows.Close()
+			return *new(TData), errors.New("sql returned more than onw row")
+		}
+		if close {
+			err = rows.Close()
+			if err != nil {
+				return *new(TData), err
+			}
+		}
+		return data, nil
+	} else {
+		if close {
+			_ = rows.Close()
+		}
+		return *new(TData), sql.ErrNoRows
+	}
+}
+
+func ScanAll[TData any](rows *sqlx.Rows, close bool) ([]TData, error) {
+	res := make([]TData, 0)
+	for rows.Next() {
+		var data TData
+		err := rows.StructScan(&data)
+		if err != nil {
+			return nil, err
+		}
+		res = append(res, data)
+	}
+	if close {
+		err := rows.Close()
+		if err != nil {
+			return nil, err
+		}
+	}
+	return res, nil
+}