HHH-19708 auto-propagate the read-only mode to the JDBC Connection

Author: gavinking

hibernate-core/src/main/java/org/hibernate/SessionBuilder.java

@@ -167,9 +167,11 @@ public interface SessionBuilder {
 
 	/**
 	 * Specify a {@linkplain Session#isDefaultReadOnly read-only mode}
-	 * for the session.
+	 * for the session. If a session is created in read-only mode, then
+	 * {@link Connection#setReadOnly} is called when a JDBC connection
+	 * is obtained.
 	 * <p>
-	 * If read/write replication is in use, then:
+	 * Furthermore, if read/write replication is in use, then:
 	 * <ul>
 	 * <li>a read-only session will connect to a read-only replica, but
 	 * <li>a non-read-only session will connect to a writable replica.

hibernate-core/src/main/java/org/hibernate/StatelessSessionBuilder.java

@@ -55,9 +55,11 @@ public interface StatelessSessionBuilder {
 	StatelessSessionBuilder tenantIdentifier(Object tenantIdentifier);
 
 	/**
-	 * Specify a read-only mode for the stateless session.
+	 * Specify a read-only mode for the stateless session. If a session
+	 * is created in read-only mode, then {@link Connection#setReadOnly}
+	 * is called when a JDBC connection is obtained.
 	 * <p>
-	 * If read/write replication is in use, then:
+	 * Furthermore, if read/write replication is in use, then:
 	 * <ul>
 	 * <li>a read-only session will connect to a read-only replica, but
 	 * <li>a non-read-only session will connect to a writable replica.

hibernate-core/src/main/java/org/hibernate/internal/AbstractSharedSessionContract.java

@@ -733,13 +733,19 @@ public void afterObtainConnection(Connection connection) throws SQLException {
 			initialSchema = connection.getSchema();
 			connection.setSchema( tenantSchema() );
 		}
+		if ( readOnly ) {
+			connection.setReadOnly( true );
+		}
 	}
 
 	@Override
 	public void beforeReleaseConnection(Connection connection) throws SQLException {
 		if ( useSchemaBasedMultiTenancy() ) {
 			connection.setSchema( initialSchema );
 		}
+		if ( readOnly ) {
+			connection.setReadOnly( false );
+		}
 	}
 
 	@Override