Added readIfAll() to cope with all-or-nothing parsing for WHEN MATCHED THEN/WHEN…

Added readIfAll() to cope with all-or-nothing parsing for WHEN MATCHED THEN/WHEN NOT MATCHED THEN syntax

h2/src/main/org/h2/command/Parser.java

@@ -1112,7 +1112,10 @@ public class Parser {
             /* a select query is supplied */
             if (isSelect()) {
                 command.setQuery(parseSelect());
+                // TODO: the schema name is sometimes reset in the parseSelect call - fix this by resetting it
+                if(schemaName==null){
                     schemaName = savedSchemaName;
+                }
                 read(")");
             }
             command.setQueryAlias(readFromAlias(null, Arrays.asList("ON")));
@@ -1147,7 +1150,7 @@ public class Parser {
         command.setOnCondition(condition);
         read(")");
         
-        if(readIf("WHEN")&&readIf("MATCHED")&&readIf("THEN")){
+        if(readIfAll(Arrays.asList("WHEN","MATCHED","THEN"))){
             int startMatched = lastParseIndex;
             if (readIf("UPDATE")){
                 Update updateCommand = new Update(session);
@@ -1166,7 +1169,7 @@ public class Parser {
                 command.setDeleteCommand(deleteCommand);
             }            
         }
-        if(readIf("WHEN")&&readIf("NOT")&&readIf("MATCHED")&&readIf("THEN")){
+        if(readIfAll(Arrays.asList("WHEN","NOT","MATCHED","THEN"))){
             if (readIf("INSERT")){
                 Insert insertCommand = new Insert(session);
                 insertCommand.setTable(command.getTargetTable());
@@ -3439,6 +3442,24 @@ public class Parser {
         return false;
     }
     
+    private boolean readIfAll(List<String> tokens) {
+        // save parse location in case we have to fail this test
+        int start = lastParseIndex;
+        for(String token: tokens){
+            String currentTokenUpper = currentToken.toUpperCase();
+            if (!currentTokenQuoted && equalsToken(token, currentTokenUpper)) {
+                read();
+            }
+            else{
+                // revert parse location
+                parseIndex = start;
+                read();
+                return false;
+            }
+        }
+        return true;
+    }
+    
     private boolean isToken(String token) {
         boolean result = equalsToken(token, currentToken) &&
                 !currentTokenQuoted;

h2/src/test/org/h2/test/db/TestMergeUsing.java

@@ -114,6 +114,15 @@ public class TestMergeUsing extends TestBase {
                 3
                 );        
         
+        // Only insert clause
+        testMergeUsing(
+                "CREATE TABLE PARENT AS (SELECT X AS ID, 'Marcy'||X AS NAME FROM SYSTEM_RANGE(1,1) );"+
+                        "DELETE FROM PARENT;",
+                "MERGE INTO PARENT AS P USING (SELECT X AS ID, 'Marcy'||X AS NAME FROM SYSTEM_RANGE(1,3) ) AS S ON (P.ID = S.ID) WHEN NOT MATCHED THEN INSERT (ID, NAME) VALUES (S.ID, S.NAME)",
+                GATHER_ORDERED_RESULTS_SQL,
+                "SELECT X AS ID, 'Marcy'||X AS NAME FROM SYSTEM_RANGE(1,3)",
+                3
+                );
        // Duplicate source keys: SQL standard says duplicate or repeated updates in same statement should cause errors
         // One insert, one update one delete happens, target table missing PK, no source or target alias
         testMergeUsingException(