Add support for insert as row_alias (#2383)

dengliming · web-flow · commit 4e3d7a56fdd4 · 2026-02-22T23:16:52.000+07:00
* Add support for insert as row_alias

* format code
diff --git a/src/main/java/net/sf/jsqlparser/statement/insert/Insert.java b/src/main/java/net/sf/jsqlparser/statement/insert/Insert.java
@@ -9,6 +9,7 @@
  */
 package net.sf.jsqlparser.statement.insert;
 
+import net.sf.jsqlparser.expression.Alias;
 import net.sf.jsqlparser.expression.OracleHint;
 import net.sf.jsqlparser.expression.operators.relational.ExpressionList;
 import net.sf.jsqlparser.schema.Column;
@@ -53,6 +54,7 @@ public class Insert implements Statement {
     private InsertConflictTarget conflictTarget;
     private InsertConflictAction conflictAction;
     private InsertDuplicateAction duplicateAction;
+    private Alias rowAlias;
 
     public List<UpdateSet> getDuplicateUpdateSets() {
         if (duplicateAction != null) {
@@ -340,6 +342,9 @@ public String toString() {
         if (setUpdateSets != null && !setUpdateSets.isEmpty()) {
             sql.append("SET ");
             sql = UpdateSet.appendUpdateSetsTo(sql, setUpdateSets);
+            if (rowAlias != null) {
+                sql.append(" ").append(rowAlias);
+            }
         }
 
         if (duplicateAction != null) {
@@ -411,4 +416,12 @@ public InsertDuplicateAction getDuplicateAction() {
     public void setDuplicateAction(InsertDuplicateAction duplicateAction) {
         this.duplicateAction = duplicateAction;
     }
+
+    public Alias getRowAlias() {
+        return rowAlias;
+    }
+
+    public void setRowAlias(Alias rowAlias) {
+        this.rowAlias = rowAlias;
+    }
 }
diff --git a/src/main/java/net/sf/jsqlparser/util/deparser/InsertDeParser.java b/src/main/java/net/sf/jsqlparser/util/deparser/InsertDeParser.java
@@ -113,6 +113,9 @@ public void deParse(Insert insert) {
         if (insert.getSetUpdateSets() != null) {
             builder.append(" SET ");
             deparseUpdateSets(insert.getSetUpdateSets(), builder, expressionVisitor);
+            if (insert.getRowAlias() != null) {
+                builder.append(" ").append(insert.getRowAlias());
+            }
         }
 
         if (insert.getDuplicateAction() != null) {
diff --git a/src/main/jjtree/net/sf/jsqlparser/parser/JSqlParserCC.jjt b/src/main/jjtree/net/sf/jsqlparser/parser/JSqlParserCC.jjt
@@ -2811,6 +2811,8 @@ Insert Insert():
 
     String name = null;
     boolean useAs = false;
+    boolean useSet = false;
+    Alias rowAlias = null;
     OutputClause outputClause = null;
 
     InsertConflictTarget conflictTarget = null;
@@ -2848,12 +2850,20 @@ Insert Insert():
         <K_DEFAULT> <K_VALUES> { insert.setOnlyDefaultValues(true); }
         |
         (
-            <K_SET> updateSets = UpdateSets() { insert.withSetUpdateSets(updateSets); }
+            <K_SET> updateSets = UpdateSets() { insert.withSetUpdateSets(updateSets); useSet = true; }
         )
         |
         select = Select()
     )
 
+    [ LOOKAHEAD(2, { select instanceof Values || useSet }) rowAlias = Alias() {
+        if (select instanceof Values) {
+            select.setAlias(rowAlias);
+        } else {
+            insert.setRowAlias(rowAlias);
+        }
+    } ]
+
     [ LOOKAHEAD(2) <K_ON> <K_DUPLICATE> <K_KEY> <K_UPDATE>
                  duplicateAction = InsertDuplicateAction() { insert.setDuplicateAction(duplicateAction); }
     ]
diff --git a/src/test/java/net/sf/jsqlparser/statement/insert/InsertTest.java b/src/test/java/net/sf/jsqlparser/statement/insert/InsertTest.java
@@ -9,6 +9,20 @@
  */
 package net.sf.jsqlparser.statement.insert;
 
+import static net.sf.jsqlparser.test.TestUtils.assertDeparse;
+import static net.sf.jsqlparser.test.TestUtils.assertOracleHintExists;
+import static net.sf.jsqlparser.test.TestUtils.assertSqlCanBeParsedAndDeparsed;
+import static net.sf.jsqlparser.test.TestUtils.assertStatementCanBeDeparsedAs;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.junit.jupiter.api.Assertions.assertNull;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.jupiter.api.Assertions.assertThrowsExactly;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+import java.io.StringReader;
+import java.util.List;
 import net.sf.jsqlparser.JSQLParserException;
 import net.sf.jsqlparser.expression.Alias;
 import net.sf.jsqlparser.expression.DoubleValue;
@@ -34,21 +48,6 @@
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.ValueSource;
 
-import java.io.StringReader;
-import java.util.List;
-
-import static net.sf.jsqlparser.test.TestUtils.assertDeparse;
-import static net.sf.jsqlparser.test.TestUtils.assertOracleHintExists;
-import static net.sf.jsqlparser.test.TestUtils.assertSqlCanBeParsedAndDeparsed;
-import static net.sf.jsqlparser.test.TestUtils.assertStatementCanBeDeparsedAs;
-import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertFalse;
-import static org.junit.jupiter.api.Assertions.assertNotNull;
-import static org.junit.jupiter.api.Assertions.assertNull;
-import static org.junit.jupiter.api.Assertions.assertThrows;
-import static org.junit.jupiter.api.Assertions.assertThrowsExactly;
-import static org.junit.jupiter.api.Assertions.assertTrue;
-
 public class InsertTest {
 
     private final CCJSqlParserManager parserManager = new CCJSqlParserManager();
@@ -395,10 +394,23 @@ public void testInsertValuesWithDuplicateEliminationInDeparsing() throws JSQLPar
                 + "ON DUPLICATE KEY UPDATE COUNTER = COUNTER + 1");
     }
 
+    @Test
+    public void testInsertValuesAliasWithDuplicateEliminationIssue() throws JSQLParserException {
+        assertSqlCanBeParsedAndDeparsed("INSERT INTO t1 (a,b,c) VALUES (1,2,3),(4,5,6) AS new"
+                + "  ON DUPLICATE KEY UPDATE c = new.a+new.b;");
+
+        assertSqlCanBeParsedAndDeparsed(
+                "INSERT INTO t1 (a,b,c) VALUES (1,2,3),(4,5,6) AS new(m,n,p) "
+                        + "  ON DUPLICATE KEY UPDATE c = m+n;");
+    }
+
     @Test
     public void testInsertSetWithDuplicateEliminationInDeparsing() throws JSQLParserException {
         assertSqlCanBeParsedAndDeparsed("INSERT INTO mytable SET col1 = 122 "
                 + "ON DUPLICATE KEY UPDATE col2 = col2 + 1, col3 = 'saint'");
+
+        assertSqlCanBeParsedAndDeparsed("INSERT INTO t1 SET a=1,b=2,c=3 AS new"
+                + "  ON DUPLICATE KEY UPDATE c = new.a+new.b;");
     }
 
     @Test

Original file line number	Diff line number	Diff line change
`@@ -113,6 +113,9 @@ public void deParse(Insert insert) {`
`113`	`113`	`if (insert.getSetUpdateSets() != null) {`
`114`	`114`	`builder.append(" SET ");`
`115`	`115`	`deparseUpdateSets(insert.getSetUpdateSets(), builder, expressionVisitor);`
	`116`	`+ if (insert.getRowAlias() != null) {`
	`117`	`+ builder.append(" ").append(insert.getRowAlias());`
	`118`	`+ }`
`116`	`119`	`}`
`117`	`120`
`118`	`121`	`if (insert.getDuplicateAction() != null) {`
Original file line number	Diff line number	Diff line change
`@@ -2811,6 +2811,8 @@ Insert Insert():`
`2811`	`2811`
`2812`	`2812`	`String name = null;`
`2813`	`2813`	`boolean useAs = false;`
	`2814`	`+ boolean useSet = false;`
	`2815`	`+ Alias rowAlias = null;`
`2814`	`2816`	`OutputClause outputClause = null;`
`2815`	`2817`
`2816`	`2818`	`InsertConflictTarget conflictTarget = null;`
`@@ -2848,12 +2850,20 @@ Insert Insert():`
`2848`	`2850`	`<K_DEFAULT> <K_VALUES> { insert.setOnlyDefaultValues(true); }`
`2849`	`2851`	`\|`
`2850`	`2852`	`(`
`2851`		`- <K_SET> updateSets = UpdateSets() { insert.withSetUpdateSets(updateSets); }`
	`2853`	`+ <K_SET> updateSets = UpdateSets() { insert.withSetUpdateSets(updateSets); useSet = true; }`
`2852`	`2854`	`)`
`2853`	`2855`	`\|`
`2854`	`2856`	`select = Select()`
`2855`	`2857`	`)`
`2856`	`2858`
	`2859`	`+ [ LOOKAHEAD(2, { select instanceof Values \|\| useSet }) rowAlias = Alias() {`
	`2860`	`+ if (select instanceof Values) {`
	`2861`	`+ select.setAlias(rowAlias);`
	`2862`	`+ } else {`
	`2863`	`+ insert.setRowAlias(rowAlias);`
	`2864`	`+ }`
	`2865`	`+ } ]`
	`2866`	`+`
`2857`	`2867`	`[ LOOKAHEAD(2) <K_ON> <K_DUPLICATE> <K_KEY> <K_UPDATE>`
`2858`	`2868`	`duplicateAction = InsertDuplicateAction() { insert.setDuplicateAction(duplicateAction); }`
`2859`	`2869`	`]`