add custom join option

doug-martin · Sep 9, 2024 · 95f448a · 95f448a
1 parent 27c29e0
commit 95f448a
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 0 deletions.
diff --git a/exp/exp.go b/exp/exp.go
@@ -533,6 +533,7 @@ const (
 	NaturalRightJoinType
 	NaturalFullJoinType
 	CrossJoinType
+	CustomJoinType
 
 	UsingJoinCondType JoinConditionType = iota
 	OnJoinCondType

diff --git a/select_dataset.go b/select_dataset.go
@@ -343,6 +343,11 @@ func (sd *SelectDataset) CrossJoin(table exp.Expression) *SelectDataset {
 	return sd.joinTable(exp.NewUnConditionedJoinExpression(exp.CrossJoinType, table))
 }
 
+// Adds a custom join clause. See examples
+func (sd *SelectDataset) CustomJoin(expression exp.Expression) *SelectDataset {
+	return sd.joinTable(exp.NewUnConditionedJoinExpression(exp.CustomJoinType, expression))
+}
+
 // Joins this Datasets table with another
 func (sd *SelectDataset) joinTable(join exp.JoinExpression) *SelectDataset {
 	return sd.copy(sd.clauses.JoinsAppend(join))

diff --git a/sqlgen/sql_dialect_options.go b/sqlgen/sql_dialect_options.go
@@ -547,6 +547,7 @@ func DefaultDialectOptions() *SQLDialectOptions {
 			exp.NaturalRightJoinType: []byte(" NATURAL RIGHT JOIN "),
 			exp.NaturalFullJoinType:  []byte(" NATURAL FULL JOIN "),
 			exp.CrossJoinType:        []byte(" CROSS JOIN "),
+			exp.CustomJoinType:       []byte(" "), // User need to fill in the join statement themselves
 		},
 
 		TimeFormat: time.RFC3339Nano,