diff --git a/src/main/java/com/samskivert/depot/impl/IdentityValueGenerator.java b/src/main/java/com/samskivert/depot/impl/IdentityValueGenerator.java index cab2523..3e4b85e 100644 --- a/src/main/java/com/samskivert/depot/impl/IdentityValueGenerator.java +++ b/src/main/java/com/samskivert/depot/impl/IdentityValueGenerator.java @@ -38,7 +38,11 @@ public class IdentityValueGenerator extends ValueGenerator public int nextGeneratedValue (Connection conn, DatabaseLiaison liaison, Statement stmt) throws SQLException { - return liaison.lastInsertedId(conn, stmt, _dm.getTableName(), _fm.getColumnName()); + Integer id = liaison.lastInsertedId(conn, stmt, _dm.getTableName(), _fm.getColumnName()); + if (id == null) throw new SQLException( + "Unable to obtain last inserted id [table=" + _dm.getTableName() + + ", column=" + _fm.getColumnName() + "]"); + return id; } @Override // from ValueGenerator