fix: add InsertQuery.ColumnExpr to specify columns

internal/dbtest/query_test.go

@@ -564,6 +564,9 @@ func TestQuery(t *testing.T) {
 			}
 			return db.NewInsert().Model(&Model{ID: 123, Time: time.Unix(0, 0)})
 		},
+		func(db *bun.DB) schema.QueryAppender {
+			return db.NewInsert().ColumnExpr("id, name").Table("dest").Table("src")
+		},
 	}
 
 	timeRE := regexp.MustCompile(`'\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}\.\d+(\+\d{2}:\d{2})?'`)

internal/dbtest/testdata/snapshots/TestQuery-mysql5-89

@@ -0,0 +1 @@
+INSERT INTO `dest` (id, name) SELECT id, name FROM `src`

internal/dbtest/testdata/snapshots/TestQuery-mysql8-89

@@ -0,0 +1 @@
+INSERT INTO `dest` (id, name) SELECT id, name FROM `src`

internal/dbtest/testdata/snapshots/TestQuery-pg-89

@@ -0,0 +1 @@
+INSERT INTO "dest" (id, name) SELECT id, name FROM "src"

internal/dbtest/testdata/snapshots/TestQuery-pgx-89

@@ -0,0 +1 @@
+INSERT INTO "dest" (id, name) SELECT id, name FROM "src"

internal/dbtest/testdata/snapshots/TestQuery-sqlite-89

@@ -0,0 +1 @@
+INSERT INTO "dest" (id, name) SELECT id, name FROM "src"

query_insert.go

@@ -84,6 +84,11 @@ func (q *InsertQuery) Column(columns ...string) *InsertQuery {
 	return q
 }
 
+func (q *InsertQuery) ColumnExpr(query string, args ...interface{}) *InsertQuery {
+	q.addColumn(schema.SafeQuery(query, args))
+	return q
+}
+
 func (q *InsertQuery) ExcludeColumn(columns ...string) *InsertQuery {
 	q.excludeColumn(columns)
 	return q
@@ -209,7 +214,18 @@ func (q *InsertQuery) appendColumnsValues(
 			b = append(b, ")"...)
 		}
 
-		b = append(b, " SELECT * FROM "...)
+		b = append(b, " SELECT "...)
+
+		if q.columns != nil {
+			b, err = q.appendColumns(fmter, b)
+			if err != nil {
+				return nil, err
+			}
+		} else {
+			b = append(b, "*"...)
+		}
+
+		b = append(b, " FROM "...)
 		b, err = q.appendOtherTables(fmter, b)
 		if err != nil {
 			return nil, err