package liquibase.database.jvm;
   
   import liquibase.exception.DatabaseException;
   
   import java.sql.Connection;
   import java.sql.SQLException;
   import java.sql.Statement;
   
   public class DerbyConnection extends JdbcConnection {
  
      public DerbyConnection(Connection connection) {
          super(connection);
      }
  
      @Override
      public void commit() throws DatabaseException {
          super.commit();
  
          checkPoint();
      }
  
      @Override
      public void rollback() throws DatabaseException {
          super.rollback();
  
          checkPoint();
      }
  
      private void checkPoint() throws DatabaseException {
          Statement st = null;
          try {
              st = createStatement();
              st.execute("CALL SYSCS_UTIL.SYSCS_CHECKPOINT_DATABASE()");
          } catch (SQLException e) {
              throw new DatabaseException(e);
          } finally {
              if (st != null) {
                  try {
                      st.close();
                  } catch (SQLException e) {
                      // ok
                  }
              }
          }
      }
  }