[HHH-19365]on duplicate key update do nothing

Author: liubao68

hibernate-core/src/main/java/org/hibernate/dialect/GaussDBSqlAstTranslator.java

@@ -114,7 +114,7 @@ protected void renderFromClauseAfterUpdateSet(UpdateStatement statement) {
 
 	@Override
 	protected void visitConflictClause(ConflictClause conflictClause) {
-		visitStandardConflictClause( conflictClause );
+		visitOnDuplicateKeyConflictClauseWithDoNothing( conflictClause );
 	}
 
 	@Override

hibernate-core/src/main/java/org/hibernate/sql/ast/spi/AbstractSqlAstTranslator.java

@@ -2051,6 +2051,43 @@ protected void visitOnDuplicateKeyConflictClause(ConflictClause conflictClause)
 		clauseStack.pop();
 	}
 
+	protected void visitOnDuplicateKeyConflictClauseWithDoNothing(ConflictClause conflictClause) {
+		if ( conflictClause == null ) {
+			return;
+		}
+		// The duplicate key clause does not support specifying the constraint name or constraint column names,
+		// but to allow compatibility, we have to require the user to specify either one in the SQM conflict clause.
+		// To allow meaningful usage, we simply ignore the constraint column names in this emulation.
+		// A possible problem with this is when the constraint column names contain the primary key columns,
+		// but the insert fails due to a unique constraint violation. This emulation will not cause a failure to be
+		// propagated, but instead will run the respective conflict action.
+		final String constraintName = conflictClause.getConstraintName();
+		if ( constraintName != null ) {
+			if ( conflictClause.isDoUpdate() ) {
+				throw new IllegalQueryOperationException( "Insert conflict 'do update' clause with constraint name is not supported" );
+			}
+			else {
+				return;
+			}
+		}
+		clauseStack.push( Clause.CONFLICT );
+		appendSql( " on duplicate key update" );
+		final List<Assignment> assignments = conflictClause.getAssignments();
+		if ( assignments.isEmpty() ) {
+			try {
+				clauseStack.push( Clause.SET );
+				appendSql( " nothing " );
+			}
+			finally {
+				clauseStack.pop();
+			}
+		}
+		else {
+			renderPredicatedSetAssignments( assignments, conflictClause.getPredicate() );
+		}
+		clauseStack.pop();
+	}
+
 	private void renderPredicatedSetAssignments(List<Assignment> assignments, Predicate predicate) {
 		char separator = ' ';
 		try {

hibernate-core/src/test/java/org/hibernate/orm/test/query/hql/InsertConflictTests.java

@@ -61,7 +61,6 @@ public void cleanupData(SessionFactoryScope scope) {
 	}
 
 	@Test
-	@SkipForDialect( dialectClass = GaussDBDialect.class, reason = "type:resolving.syntax error at or near \"conflict do\"")
 	public void testOnConflictDoNothing(SessionFactoryScope scope) {
 		scope.inTransaction(
 				session -> {
@@ -86,7 +85,6 @@ public void testOnConflictDoNothing(SessionFactoryScope scope) {
 
 	@Test
 	@RequiresDialectFeature(feature = DialectFeatureChecks.SupportsUpsertOrMerge.class)
-	@SkipForDialect( dialectClass = GaussDBDialect.class, reason = "type:resolving.syntax error at or near \"conflict(\"")
 	public void testOnConflictDoUpdate(SessionFactoryScope scope) {
 		scope.inTransaction(
 				session -> {
@@ -114,7 +112,6 @@ public void testOnConflictDoUpdate(SessionFactoryScope scope) {
 
 	@Test
 	@RequiresDialectFeature(feature = DialectFeatureChecks.SupportsUpsertOrMerge.class)
-	@SkipForDialect( dialectClass = GaussDBDialect.class, reason = "type:resolving.syntax error at or near \"conflict(")
 	public void testOnConflictDoUpdateWithWhere(SessionFactoryScope scope) {
 		scope.inTransaction(
 				session -> {
@@ -134,6 +131,10 @@ else if ( scope.getSessionFactory().getJdbcServices().getDialect() instanceof Sy
 						// Sybase seems to report all matched rows as affected and ignores additional predicates
 						assertEquals( 1, updated );
 					}
+					else if ( scope.getSessionFactory().getJdbcServices().getDialect() instanceof GaussDBDialect ) {
+						// GaussDB seems to report all matched rows as affected and ignores additional predicates
+						assertEquals( 1, updated );
+					}
 					else {
 						assertEquals( 0, updated );
 					}
@@ -145,7 +146,6 @@ else if ( scope.getSessionFactory().getJdbcServices().getDialect() instanceof Sy
 
 	@Test
 	@RequiresDialectFeature(feature = DialectFeatureChecks.SupportsUpsertOrMerge.class)
-	@SkipForDialect( dialectClass = GaussDBDialect.class, reason = "type:resolving.syntax error at or near \"conflict(")
 	public void testOnConflictDoUpdateWithWhereCriteria(SessionFactoryScope scope) {
 		scope.inTransaction(
 				session -> {
@@ -171,6 +171,10 @@ else if ( scope.getSessionFactory().getJdbcServices().getDialect() instanceof Sy
 						// Sybase seems to report all matched rows as affected and ignores additional predicates
 						assertEquals( 1, updated );
 					}
+					else if ( scope.getSessionFactory().getJdbcServices().getDialect() instanceof GaussDBDialect ) {
+						// GaussDB seems to report all matched rows as affected and ignores additional predicates
+						assertEquals( 1, updated );
+					}
 					else {
 						assertEquals( 0, updated );
 					}
@@ -181,7 +185,6 @@ else if ( scope.getSessionFactory().getJdbcServices().getDialect() instanceof Sy
 	}
 
 	@Test
-	@SkipForDialect( dialectClass = GaussDBDialect.class, reason = "type:resolving.syntax error at or near \"conflict do\"")
 	public void testOnConflictDoNothingMultiTable(SessionFactoryScope scope) {
 		scope.inTransaction(
 				session -> {
@@ -209,7 +212,6 @@ public void testOnConflictDoNothingMultiTable(SessionFactoryScope scope) {
 	@Test
 	@RequiresDialectFeature(feature = DialectFeatureChecks.SupportsUpsertOrMerge.class)
 	@SkipForDialect(dialectClass = SybaseASEDialect.class, reason = "MERGE into a table that has a self-referential FK does not work")
-	@SkipForDialect( dialectClass = GaussDBDialect.class, reason = "type:resolving.syntax error at or near \"conflict(")
 	public void testOnConflictDoUpdateMultiTable(SessionFactoryScope scope) {
 		scope.inTransaction(
 				session -> {
@@ -238,7 +240,6 @@ public void testOnConflictDoUpdateMultiTable(SessionFactoryScope scope) {
 	@Test
 	@RequiresDialectFeature(feature = DialectFeatureChecks.SupportsUpsertOrMerge.class)
 	@SkipForDialect(dialectClass = SybaseASEDialect.class, reason = "MERGE into a table that has a self-referential FK does not work")
-	@SkipForDialect( dialectClass = GaussDBDialect.class, reason = "syntax error at or near \"conflict(\"")
 	public void testOnConflictDoUpdateWithWhereMultiTable(SessionFactoryScope scope) {
 		scope.inTransaction(
 				session -> {
@@ -258,6 +259,10 @@ else if ( scope.getSessionFactory().getJdbcServices().getDialect() instanceof Sy
 						// Sybase seems to report all matched rows as affected and ignores additional predicates
 						assertEquals( 1, updated );
 					}
+					else if ( scope.getSessionFactory().getJdbcServices().getDialect() instanceof GaussDBDialect ) {
+						// GaussDB seems to report all matched rows as affected and ignores additional predicates
+						assertEquals( 1, updated );
+					}
 					else {
 						assertEquals( 0, updated );
 					}

hibernate-core/src/test/java/org/hibernate/orm/test/query/hql/InsertConflictWithCriteriaCopyTreeEnabledTests.java

@@ -8,7 +8,6 @@
 import jakarta.persistence.Id;
 import jakarta.persistence.Tuple;
 import org.hibernate.cfg.QuerySettings;
-import org.hibernate.dialect.GaussDBDialect;
 import org.hibernate.query.criteria.HibernateCriteriaBuilder;
 import org.hibernate.query.criteria.JpaCriteriaInsertSelect;
 import org.hibernate.query.criteria.JpaCriteriaInsertValues;
@@ -19,7 +18,6 @@
 import org.hibernate.testing.orm.junit.SessionFactory;
 import org.hibernate.testing.orm.junit.SessionFactoryScope;
 import org.hibernate.testing.orm.junit.Setting;
-import org.hibernate.testing.orm.junit.SkipForDialect;
 import org.junit.jupiter.api.Test;
 
 
@@ -34,7 +32,6 @@
 )
 @SessionFactory
 @JiraKey("HHH-19314")
-@SkipForDialect( dialectClass = GaussDBDialect.class, reason = "type:resovling.not support")
 public class InsertConflictWithCriteriaCopyTreeEnabledTests {
 
 	@Test