v0.0.39

langext/sort.go

@@ -0,0 +1,39 @@
+package langext
+
+import "sort"
+
+func Sort[T OrderedConstraint](arr []T) {
+	sort.Slice(arr, func(i1, i2 int) bool {
+		return arr[i1] < arr[i2]
+	})
+}
+
+func SortStable[T OrderedConstraint](arr []T) {
+	sort.SliceStable(arr, func(i1, i2 int) bool {
+		return arr[i1] < arr[i2]
+	})
+}
+
+func IsSorted[T OrderedConstraint](arr []T) bool {
+	return sort.SliceIsSorted(arr, func(i1, i2 int) bool {
+		return arr[i1] < arr[i2]
+	})
+}
+
+func SortSlice[T any](arr []T, less func(v1, v2 T) bool) {
+	sort.Slice(arr, func(i1, i2 int) bool {
+		return less(arr[i1], arr[i2])
+	})
+}
+
+func SortSliceStable[T any](arr []T, less func(v1, v2 T) bool) {
+	sort.SliceStable(arr, func(i1, i2 int) bool {
+		return less(arr[i1], arr[i2])
+	})
+}
+
+func IsSliceSorted[T any](arr []T, less func(v1, v2 T) bool) bool {
+	return sort.SliceIsSorted(arr, func(i1, i2 int) bool {
+		return less(arr[i1], arr[i2])
+	})
+}

sq/database.go

@@ -36,7 +36,7 @@ func (db *database) SetListener(listener Listener) {
 
 func (db *database) Exec(ctx context.Context, sql string, prep PP) (sql.Result, error) {
 	if db.lstr != nil {
-		db.lstr.OnExec(nil, sql, &prep)
+		db.lstr.OnExec(nil, &sql, &prep)
 	}
 
 	res, err := db.db.NamedExecContext(ctx, sql, prep)
@@ -48,7 +48,7 @@ func (db *database) Exec(ctx context.Context, sql string, prep PP) (sql.Result,
 
 func (db *database) Query(ctx context.Context, sql string, prep PP) (*sqlx.Rows, error) {
 	if db.lstr != nil {
-		db.lstr.OnQuery(nil, sql, &prep)
+		db.lstr.OnQuery(nil, &sql, &prep)
 	}
 
 	rows, err := db.db.NamedQueryContext(ctx, sql, prep)

sq/listener.go

@@ -1,8 +1,8 @@
 package sq
 
 type Listener interface {
-	OnQuery(txID *uint16, sql string, params *PP)
-	OnExec(txID *uint16, sql string, params *PP)
+	OnQuery(txID *uint16, sql *string, params *PP)
+	OnExec(txID *uint16, sql *string, params *PP)
 	OnPing()
 	OnTxBegin(txid uint16)
 	OnTxCommit(txid uint16)

sq/transaction.go

@@ -46,7 +46,7 @@ func (tx *transaction) Commit() error {
 
 func (tx *transaction) Exec(ctx context.Context, sql string, prep PP) (sql.Result, error) {
 	if tx.lstr != nil {
-		tx.lstr.OnExec(langext.Ptr(tx.id), sql, &prep)
+		tx.lstr.OnExec(langext.Ptr(tx.id), &sql, &prep)
 	}
 
 	res, err := tx.tx.NamedExecContext(ctx, sql, prep)
@@ -58,7 +58,7 @@ func (tx *transaction) Exec(ctx context.Context, sql string, prep PP) (sql.Resul
 
 func (tx *transaction) Query(ctx context.Context, sql string, prep PP) (*sqlx.Rows, error) {
 	if tx.lstr != nil {
-		tx.lstr.OnQuery(langext.Ptr(tx.id), sql, &prep)
+		tx.lstr.OnQuery(langext.Ptr(tx.id), &sql, &prep)
 	}
 
 	rows, err := sqlx.NamedQueryContext(ctx, tx.tx, sql, prep)