Support IDENTITY for Integer with MySQL

DavideD · DavideD · commit cd49b1f9d273 · 2023-03-16T11:26:24.000+01:00
diff --git a/hibernate-reactive-core/src/main/java/org/hibernate/reactive/pool/impl/SqlClientConnection.java b/hibernate-reactive-core/src/main/java/org/hibernate/reactive/pool/impl/SqlClientConnection.java
@@ -324,6 +324,9 @@ private static <T> T getLastInsertedId(RowSet<Row> rows, Class<T> idClass, Strin
 			if ( Long.class.equals( idClass ) ) {
 				return (T) mySqlId;
 			}
+			if ( Integer.class.equals( idClass ) ) {
+				return (T) ( Integer.valueOf( mySqlId.intValue() ) );
+			}
 			throw LOG.nativelyGeneratedValueMustBeLong();
 		}
 		final Row oracleKeys = rows.property( ORACLE_GENERATED_KEYS );

Original file line number	Diff line number	Diff line change
`@@ -324,6 +324,9 @@ private static <T> T getLastInsertedId(RowSet<Row> rows, Class<T> idClass, Strin`
`324`	`324`	`if ( Long.class.equals( idClass ) ) {`
`325`	`325`	`return (T) mySqlId;`
`326`	`326`	`}`
	`327`	`+ if ( Integer.class.equals( idClass ) ) {`
	`328`	`+ return (T) ( Integer.valueOf( mySqlId.intValue() ) );`
	`329`	`+ }`
`327`	`330`	`throw LOG.nativelyGeneratedValueMustBeLong();`
`328`	`331`	`}`
`329`	`332`	`final Row oracleKeys = rows.property( ORACLE_GENERATED_KEYS );`