added InsertStructs

Author: ungerik

connection.go

@@ -76,9 +76,14 @@ type Connection interface {
 	// Optional ColumnFilter can be passed to ignore mapped columns.
 	InsertStruct(table string, rowStruct any, ignoreColumns ...ColumnFilter) error
 
+	// InsertStructs inserts a slice or array of structs
+	// as new rows into table using the connection's
+	// StructFieldMapper to map struct fields to column names.
+	// Optional ColumnFilter can be passed to ignore mapped columns.
+	//
 	// TODO optimized version with single query if possible
 	// split into multiple queries depending or maxArgs for query
-	// InsertStructs(table string, rowStructs any, ignoreColumns ...ColumnFilter) error
+	InsertStructs(table string, rowStructs any, ignoreColumns ...ColumnFilter) error
 
 	// InsertUniqueStruct inserts a new row into table using the connection's
 	// StructFieldMapper to map struct fields to column names.

errors.go

@@ -33,7 +33,8 @@ func IsOtherThanErrNoRows(err error) bool {
 // and is meant to be used to declare const sentinel errors.
 //
 // Example:
-//   const ErrUserNotFound impl.sentinelError = "user not found"
+//
+//	const ErrUserNotFound impl.sentinelError = "user not found"
 type sentinelError string
 
 func (s sentinelError) Error() string {
@@ -128,6 +129,10 @@ func (e connectionWithError) InsertStruct(table string, rowStruct any, ignoreCol
 	return e.err
 }
 
+func (e connectionWithError) InsertStructs(table string, rowStructs any, ignoreColumns ...ColumnFilter) error {
+	return e.err
+}
+
 func (e connectionWithError) InsertUniqueStruct(table string, rowStruct any, onConflict string, ignoreColumns ...ColumnFilter) (inserted bool, err error) {
 	return false, e.err
 }

impl/connection.go

@@ -106,6 +106,10 @@ func (conn *connection) InsertStruct(table string, rowStruct any, ignoreColumns
 	return InsertStruct(conn, table, rowStruct, conn.structFieldNamer, conn.argFmt, ignoreColumns)
 }
 
+func (conn *connection) InsertStructs(table string, rowStructs any, ignoreColumns ...sqldb.ColumnFilter) error {
+	return InsertStructs(conn, table, rowStructs, ignoreColumns...)
+}
+
 func (conn *connection) InsertUniqueStruct(table string, rowStruct any, onConflict string, ignoreColumns ...sqldb.ColumnFilter) (inserted bool, err error) {
 	return InsertUniqueStruct(conn, table, rowStruct, onConflict, conn.structFieldNamer, conn.argFmt, ignoreColumns)
 }

impl/insert.go

@@ -142,3 +142,18 @@ func insertStructValues(table string, rowStruct any, namer sqldb.StructFieldMapp
 	columns, _, vals = ReflectStructValues(v, namer, append(ignoreColumns, sqldb.IgnoreReadOnly))
 	return columns, vals, nil
 }
+
+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)
+	}
+	l := v.Len()
+	for i := 0; i < l; i++ {
+		err := conn.InsertStruct(table, v.Index(i).Interface(), ignoreColumns...)
+		if err != nil {
+			return err
+		}
+	}
+	return nil
+}

impl/transaction.go

@@ -86,6 +86,10 @@ func (conn *transaction) InsertStruct(table string, rowStruct any, ignoreColumns
 	return InsertStruct(conn, table, rowStruct, conn.structFieldNamer, conn.parent.argFmt, ignoreColumns)
 }
 
+func (conn *transaction) InsertStructs(table string, rowStructs any, ignoreColumns ...sqldb.ColumnFilter) error {
+	return InsertStructs(conn, table, rowStructs, ignoreColumns...)
+}
+
 func (conn *transaction) InsertUniqueStruct(table string, rowStruct any, onConflict string, ignoreColumns ...sqldb.ColumnFilter) (inserted bool, err error) {
 	return InsertUniqueStruct(conn, table, rowStruct, onConflict, conn.structFieldNamer, conn.parent.argFmt, ignoreColumns)
 }

mockconn/connection.go

@@ -107,6 +107,10 @@ func (conn *connection) InsertStruct(table string, rowStruct any, ignoreColumns
 	return impl.InsertStruct(conn, table, rowStruct, conn.structFieldNamer, conn.argFmt, ignoreColumns)
 }
 
+func (conn *connection) InsertStructs(table string, rowStructs any, ignoreColumns ...sqldb.ColumnFilter) error {
+	return impl.InsertStructs(conn, table, rowStructs, ignoreColumns...)
+}
+
 func (conn *connection) InsertUniqueStruct(table string, rowStruct any, onConflict string, ignoreColumns ...sqldb.ColumnFilter) (inserted bool, err error) {
 	return impl.InsertUniqueStruct(conn, table, rowStruct, onConflict, conn.structFieldNamer, conn.argFmt, ignoreColumns)
 }

pqconn/connection.go

@@ -127,6 +127,10 @@ func (conn *connection) InsertStruct(table string, rowStruct any, ignoreColumns
 	return impl.InsertStruct(conn, table, rowStruct, conn.structFieldNamer, argFmt, ignoreColumns)
 }
 
+func (conn *connection) InsertStructs(table string, rowStructs any, ignoreColumns ...sqldb.ColumnFilter) error {
+	return impl.InsertStructs(conn, table, rowStructs, ignoreColumns...)
+}
+
 func (conn *connection) InsertUniqueStruct(table string, rowStruct any, onConflict string, ignoreColumns ...sqldb.ColumnFilter) (inserted bool, err error) {
 	return impl.InsertUniqueStruct(conn, table, rowStruct, onConflict, conn.structFieldNamer, argFmt, ignoreColumns)
 }

pqconn/transaction.go

@@ -110,6 +110,10 @@ func (conn *transaction) UpsertStruct(table string, rowStruct any, ignoreColumns
 	return impl.UpsertStruct(conn, table, rowStruct, conn.structFieldNamer, argFmt, ignoreColumns)
 }
 
+func (conn *transaction) InsertStructs(table string, rowStructs any, ignoreColumns ...sqldb.ColumnFilter) error {
+	return impl.InsertStructs(conn, table, rowStructs, ignoreColumns...)
+}
+
 func (conn *transaction) QueryRow(query string, args ...any) sqldb.RowScanner {
 	rows, err := conn.tx.QueryContext(conn.parent.ctx, query, args...)
 	if err != nil {