Hibernate
/
hibernate-orm
mirror of https://github.com/hibernate/hibernate-orm
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

HHH-7251 PostgreSQL dialects now convert proper HibernateExceptions for Deadlock / lock timeout (not available with NOWAIT query).

This commit is contained in:
Bryan Varner 2012-04-17 13:40:48 -04:00 committed by Steve Ebersole
parent 0bca4ab9d9
commit eb66fed976
1 changed files with 34 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
hibernate-core/src/main/java/org/hibernate/dialect/PostgreSQL81Dialect.java
View File

@ -28,13 +28,18 @@ import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
import org.hibernate.JDBCException;
import org.hibernate.LockOptions;
import org.hibernate.PessimisticLockException;
import org.hibernate.cfg.Environment;
import org.hibernate.dialect.function.NoArgSQLFunction;
import org.hibernate.dialect.function.PositionSubstringFunction;
import org.hibernate.dialect.function.SQLFunctionTemplate;
import org.hibernate.dialect.function.StandardSQLFunction;
import org.hibernate.dialect.function.VarArgsSQLFunction;
import org.hibernate.exception.LockAcquisitionException;
import org.hibernate.exception.internal.SQLStateConversionDelegate;
import org.hibernate.exception.spi.SQLExceptionConversionDelegate;
import org.hibernate.exception.spi.TemplatedViolatedConstraintNameExtracter;
import org.hibernate.exception.spi.ViolatedConstraintNameExtracter;
import org.hibernate.id.SequenceGenerator;
@ -367,6 +372,35 @@ public class PostgreSQL81Dialect extends Dialect {
}
};
@Override
public SQLExceptionConversionDelegate buildSQLExceptionConversionDelegate() {
SQLExceptionConversionDelegate delegate = super.buildSQLExceptionConversionDelegate();
if (delegate == null) {
delegate = new SQLStateConversionDelegate(this) {
@Override
public JDBCException convert(SQLException sqlException, String message, String sql) {
JDBCException exception = super.convert(sqlException, message, sql);
if (exception == null) {
String sqlState = JdbcExceptionHelper.extractSqlState(sqlException);
if ("40P01".equals(sqlState)) { // DEADLOCK DETECTED
exception = new LockAcquisitionException(message, sqlException, sql);
}
if ("55P03".equals(sqlState)) { // LOCK NOT AVAILABLE
exception = new PessimisticLockException(message, sqlException, sql);
}
}
return exception;
}
};
}
return delegate;
}
public int registerResultSetOutParameter(CallableStatement statement, int col) throws SQLException {
// Register the type of the out param - PostgreSQL uses Types.OTHER
statement.registerOutParameter(col++, Types.OTHER);