impl.InsertStructs with transaction

Author: ungerik

impl/insert.go

@@ -143,17 +143,23 @@ func insertStructValues(table string, rowStruct any, namer sqldb.StructFieldMapp
 	return columns, vals, nil
 }
 
+// InsertStructs is a helper that calls InsertStruct for every
+// struct in the rowStructs slice or array.
+// The inserts are performed within a new transaction
+// if the passed conn is not already a transaction.
 func InsertStructs(conn sqldb.Connection, table string, rowStructs any, ignoreColumns ...sqldb.ColumnFilter) error {
 	v := reflect.ValueOf(rowStructs)
 	if k := v.Type().Kind(); k != reflect.Slice && k != reflect.Array {
-		return fmt.Errorf("InsertStructs needs slice or array, got %T", rowStructs)
+		return fmt.Errorf("InsertStructs expects a slice or array as rowStructs, got %T", rowStructs)
 	}
-	l := v.Len()
-	for i := 0; i < l; i++ {
-		err := conn.InsertStruct(table, v.Index(i).Interface(), ignoreColumns...)
-		if err != nil {
-			return err
+	numRows := v.Len()
+	return sqldb.Transaction(conn, nil, func(tx sqldb.Connection) error {
+		for i := 0; i < numRows; i++ {
+			err := tx.InsertStruct(table, v.Index(i).Interface(), ignoreColumns...)
+			if err != nil {
+				return err
+			}
 		}
-	}
-	return nil
+		return nil
+	})
 }