// --------------------------------------------------------------------------------
// Copyright 2002-2026 Echo Three, LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
// --------------------------------------------------------------------------------
// Generated File -- DO NOT EDIT BY HAND
// --------------------------------------------------------------------------------

/**
 * TrainingClassDetailFactory.java
 */

package com.echothree.model.data.training.server.factory;

import com.echothree.model.data.training.common.pk.TrainingClassPK;
import com.echothree.model.data.workeffort.common.pk.WorkEffortScopePK;

import com.echothree.model.data.training.server.entity.TrainingClass;
import com.echothree.model.data.workeffort.server.entity.WorkEffortScope;

import com.echothree.model.data.training.common.TrainingClassDetailConstants;
import com.echothree.model.data.training.common.pk.TrainingClassDetailPK;
import com.echothree.model.data.training.server.value.TrainingClassDetailValue;
import com.echothree.model.data.training.server.entity.TrainingClassDetail;
import com.echothree.util.common.exception.PersistenceDatabaseException;
import com.echothree.util.common.exception.PersistenceDatabaseUpdateException;
import com.echothree.util.common.exception.PersistenceNotNullException;
import com.echothree.util.server.persistence.BaseFactory;
import com.echothree.util.server.persistence.EntityIdGenerator;
import com.echothree.util.server.persistence.EntityPermission;
import com.echothree.util.server.persistence.PersistenceDebugFlags;
import com.echothree.util.server.persistence.Session;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
import java.io.ByteArrayInputStream;
import java.io.StringReader;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import javax.enterprise.context.ApplicationScoped;
import javax.enterprise.inject.spi.CDI;
import javax.inject.Inject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

@ApplicationScoped
public class TrainingClassDetailFactory
        implements BaseFactory<TrainingClassDetailPK, TrainingClassDetail> {
    
    @Inject
    Session session;
    
    //private static final Logger log = LoggerFactory.getLogger(TrainingClassDetailFactory.class);
    
    final private static String SQL_SELECT_READ_ONLY = "SELECT trnclsdt_trainingclassdetailid, trnclsdt_trncls_trainingclassid, trnclsdt_trainingclassname, trnclsdt_estimatedreadingtime, trnclsdt_readingtimeallowed, trnclsdt_estimatedtestingtime, trnclsdt_testingtimeallowed, trnclsdt_requiredcompletiontime, trnclsdt_wes_workeffortscopeid, trnclsdt_defaultpercentagetopass, trnclsdt_overallquestioncount, trnclsdt_testingvaliditytime, trnclsdt_expiredretentiontime, trnclsdt_alwaysreassignonexpiration, trnclsdt_isdefault, trnclsdt_sortorder, trnclsdt_fromtime, trnclsdt_thrutime FROM trainingclassdetails WHERE trnclsdt_trainingclassdetailid = ?";
    final private static String SQL_SELECT_READ_WRITE = "SELECT trnclsdt_trainingclassdetailid, trnclsdt_trncls_trainingclassid, trnclsdt_trainingclassname, trnclsdt_estimatedreadingtime, trnclsdt_readingtimeallowed, trnclsdt_estimatedtestingtime, trnclsdt_testingtimeallowed, trnclsdt_requiredcompletiontime, trnclsdt_wes_workeffortscopeid, trnclsdt_defaultpercentagetopass, trnclsdt_overallquestioncount, trnclsdt_testingvaliditytime, trnclsdt_expiredretentiontime, trnclsdt_alwaysreassignonexpiration, trnclsdt_isdefault, trnclsdt_sortorder, trnclsdt_fromtime, trnclsdt_thrutime FROM trainingclassdetails WHERE trnclsdt_trainingclassdetailid = ? FOR UPDATE";
    final private static String SQL_INSERT = "INSERT INTO trainingclassdetails (trnclsdt_trainingclassdetailid, trnclsdt_trncls_trainingclassid, trnclsdt_trainingclassname, trnclsdt_estimatedreadingtime, trnclsdt_readingtimeallowed, trnclsdt_estimatedtestingtime, trnclsdt_testingtimeallowed, trnclsdt_requiredcompletiontime, trnclsdt_wes_workeffortscopeid, trnclsdt_defaultpercentagetopass, trnclsdt_overallquestioncount, trnclsdt_testingvaliditytime, trnclsdt_expiredretentiontime, trnclsdt_alwaysreassignonexpiration, trnclsdt_isdefault, trnclsdt_sortorder, trnclsdt_fromtime, trnclsdt_thrutime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
    final private static String SQL_UPDATE = "UPDATE trainingclassdetails SET trnclsdt_trncls_trainingclassid = ?, trnclsdt_trainingclassname = ?, trnclsdt_estimatedreadingtime = ?, trnclsdt_readingtimeallowed = ?, trnclsdt_estimatedtestingtime = ?, trnclsdt_testingtimeallowed = ?, trnclsdt_requiredcompletiontime = ?, trnclsdt_wes_workeffortscopeid = ?, trnclsdt_defaultpercentagetopass = ?, trnclsdt_overallquestioncount = ?, trnclsdt_testingvaliditytime = ?, trnclsdt_expiredretentiontime = ?, trnclsdt_alwaysreassignonexpiration = ?, trnclsdt_isdefault = ?, trnclsdt_sortorder = ?, trnclsdt_fromtime = ?, trnclsdt_thrutime = ? WHERE trnclsdt_trainingclassdetailid = ?";
    final private static String SQL_DELETE = "DELETE FROM trainingclassdetails WHERE trnclsdt_trainingclassdetailid = ?";
    final private static String SQL_VALID = "SELECT COUNT(*) FROM trainingclassdetails WHERE trnclsdt_trainingclassdetailid = ?";
    
    final private static String PK_COLUMN = "trnclsdt_trainingclassdetailid";
    final private static String ALL_COLUMNS = "trnclsdt_trainingclassdetailid, trnclsdt_trncls_trainingclassid, trnclsdt_trainingclassname, trnclsdt_estimatedreadingtime, trnclsdt_readingtimeallowed, trnclsdt_estimatedtestingtime, trnclsdt_testingtimeallowed, trnclsdt_requiredcompletiontime, trnclsdt_wes_workeffortscopeid, trnclsdt_defaultpercentagetopass, trnclsdt_overallquestioncount, trnclsdt_testingvaliditytime, trnclsdt_expiredretentiontime, trnclsdt_alwaysreassignonexpiration, trnclsdt_isdefault, trnclsdt_sortorder, trnclsdt_fromtime, trnclsdt_thrutime";
    final public static String TABLE_NAME = "trainingclassdetails";
    
    final public static String TRNCLSDT_TRAININGCLASSDETAILID = "trnclsdt_trainingclassdetailid";
    final public static String TRNCLSDT_TRNCLS_TRAININGCLASSID = "trnclsdt_trncls_trainingclassid";
    final public static String TRNCLSDT_TRAININGCLASSNAME = "trnclsdt_trainingclassname";
    final public static String TRNCLSDT_ESTIMATEDREADINGTIME = "trnclsdt_estimatedreadingtime";
    final public static String TRNCLSDT_READINGTIMEALLOWED = "trnclsdt_readingtimeallowed";
    final public static String TRNCLSDT_ESTIMATEDTESTINGTIME = "trnclsdt_estimatedtestingtime";
    final public static String TRNCLSDT_TESTINGTIMEALLOWED = "trnclsdt_testingtimeallowed";
    final public static String TRNCLSDT_REQUIREDCOMPLETIONTIME = "trnclsdt_requiredcompletiontime";
    final public static String TRNCLSDT_WES_WORKEFFORTSCOPEID = "trnclsdt_wes_workeffortscopeid";
    final public static String TRNCLSDT_DEFAULTPERCENTAGETOPASS = "trnclsdt_defaultpercentagetopass";
    final public static String TRNCLSDT_OVERALLQUESTIONCOUNT = "trnclsdt_overallquestioncount";
    final public static String TRNCLSDT_TESTINGVALIDITYTIME = "trnclsdt_testingvaliditytime";
    final public static String TRNCLSDT_EXPIREDRETENTIONTIME = "trnclsdt_expiredretentiontime";
    final public static String TRNCLSDT_ALWAYSREASSIGNONEXPIRATION = "trnclsdt_alwaysreassignonexpiration";
    final public static String TRNCLSDT_ISDEFAULT = "trnclsdt_isdefault";
    final public static String TRNCLSDT_SORTORDER = "trnclsdt_sortorder";
    final public static String TRNCLSDT_FROMTIME = "trnclsdt_fromtime";
    final public static String TRNCLSDT_THRUTIME = "trnclsdt_thrutime";
    
    final private static EntityIdGenerator entityIdGenerator = new EntityIdGenerator(TrainingClassDetailConstants.COMPONENT_VENDOR_NAME, TrainingClassDetailConstants.ENTITY_TYPE_NAME);
    
    /** Creates a new instance of TrainingClassDetailFactory */
    protected TrainingClassDetailFactory() {
        super();
    }
    
    public static TrainingClassDetailFactory getInstance() {
        return CDI.current().select(TrainingClassDetailFactory.class).get();
    }
    
    @Override
    public String getPKColumn() {
        return PK_COLUMN;
    }
    
    @Override
    public String getAllColumns() {
        return ALL_COLUMNS;
    }
    
    @Override
    public String getTableName() {
        return TABLE_NAME;
    }
    
    @Override
    public String getComponentVendorName() {
        return TrainingClassDetailConstants.COMPONENT_VENDOR_NAME;
    }
    
    @Override
    public String getEntityTypeName() {
        return TrainingClassDetailConstants.ENTITY_TYPE_NAME;
    }
    
    public PreparedStatement prepareStatement(String query) {
        return session.prepareStatement(TrainingClassDetailFactory.class, query);
    }
    
    public TrainingClassDetailPK getNextPK() {
        return new TrainingClassDetailPK(entityIdGenerator.getNextEntityId());
    }
    
    public Set<TrainingClassDetailPK> getPKsFromResultSetAsSet(ResultSet rs)
            throws PersistenceDatabaseException {
        Set<TrainingClassDetailPK> _result = new HashSet<>();
        
        try {
            while(rs.next()) {
                _result.add(getPKFromResultSet(rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public java.util.List<TrainingClassDetailPK> getPKsFromResultSetAsList(ResultSet rs)
            throws PersistenceDatabaseException {
        java.util.List<TrainingClassDetailPK> _result = new ArrayList<>();
        
        try {
            while(rs.next()) {
                _result.add(getPKFromResultSet(rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public TrainingClassDetailPK getPKFromResultSet(ResultSet rs)
            throws PersistenceDatabaseException {
        TrainingClassDetailPK _result;
        
        try {
            long trnclsdt_trainingclassdetailid = rs.getLong(TRNCLSDT_TRAININGCLASSDETAILID);
            Long _entityId = rs.wasNull() ? null : trnclsdt_trainingclassdetailid;
            
            _result = new TrainingClassDetailPK(_entityId);
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public java.util.List<TrainingClassDetailValue> getValuesFromPKs(Collection<TrainingClassDetailPK> pks)
            throws PersistenceDatabaseException {
        java.util.List<TrainingClassDetailValue> _values = new ArrayList<>(pks.size());
        
        for(TrainingClassDetailPK _pk: pks) {
            _values.add(getValueFromPK(_pk));
        }
        
        return _values;
    }
    
    public TrainingClassDetailValue getValueFromPK(TrainingClassDetailPK pk)
            throws PersistenceDatabaseException {
        TrainingClassDetailValue _value;
        
        // See if we already have the entity in the session cache
        TrainingClassDetail _entity = (TrainingClassDetail)session.getEntity(pk);
        if(_entity == null)
            _value = getEntityFromPK(EntityPermission.READ_ONLY, pk).getTrainingClassDetailValue();
        else
            _value = _entity.getTrainingClassDetailValue();
        
        return _value;
    }
    
    public java.util.List<TrainingClassDetailValue> getValuesFromResultSet(ResultSet rs)
            throws PersistenceDatabaseException {
        java.util.List<TrainingClassDetailValue> _result = new ArrayList<>();
        
        try {
            while(rs.next()) {
                _result.add(getValueFromResultSet(rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public TrainingClassDetailValue getValueFromResultSet(ResultSet rs)
            throws PersistenceDatabaseException {
        TrainingClassDetailValue _value;
        
        try {
            Long trnclsdt_trainingclassdetailid = rs.getLong(TRNCLSDT_TRAININGCLASSDETAILID);
            TrainingClassDetailPK _pk = new TrainingClassDetailPK(trnclsdt_trainingclassdetailid);
            
            // See if we already have the entity in the session cache
            TrainingClassDetail _entity = (TrainingClassDetail)session.getEntity(_pk);
            
            if(_entity == null) {
                Long trnclsdt_trncls_trainingclassid = rs.getLong(TRNCLSDT_TRNCLS_TRAININGCLASSID);
                if(rs.wasNull())
                    trnclsdt_trncls_trainingclassid = null;
                
                String trnclsdt_trainingclassname = rs.getString(TRNCLSDT_TRAININGCLASSNAME);
                if(rs.wasNull())
                    trnclsdt_trainingclassname = null;
                
                Long trnclsdt_estimatedreadingtime = rs.getLong(TRNCLSDT_ESTIMATEDREADINGTIME);
                if(rs.wasNull())
                    trnclsdt_estimatedreadingtime = null;
                
                Long trnclsdt_readingtimeallowed = rs.getLong(TRNCLSDT_READINGTIMEALLOWED);
                if(rs.wasNull())
                    trnclsdt_readingtimeallowed = null;
                
                Long trnclsdt_estimatedtestingtime = rs.getLong(TRNCLSDT_ESTIMATEDTESTINGTIME);
                if(rs.wasNull())
                    trnclsdt_estimatedtestingtime = null;
                
                Long trnclsdt_testingtimeallowed = rs.getLong(TRNCLSDT_TESTINGTIMEALLOWED);
                if(rs.wasNull())
                    trnclsdt_testingtimeallowed = null;
                
                Long trnclsdt_requiredcompletiontime = rs.getLong(TRNCLSDT_REQUIREDCOMPLETIONTIME);
                if(rs.wasNull())
                    trnclsdt_requiredcompletiontime = null;
                
                Long trnclsdt_wes_workeffortscopeid = rs.getLong(TRNCLSDT_WES_WORKEFFORTSCOPEID);
                if(rs.wasNull())
                    trnclsdt_wes_workeffortscopeid = null;
                
                Integer trnclsdt_defaultpercentagetopass = rs.getInt(TRNCLSDT_DEFAULTPERCENTAGETOPASS);
                if(rs.wasNull())
                    trnclsdt_defaultpercentagetopass = null;
                
                Integer trnclsdt_overallquestioncount = rs.getInt(TRNCLSDT_OVERALLQUESTIONCOUNT);
                if(rs.wasNull())
                    trnclsdt_overallquestioncount = null;
                
                Long trnclsdt_testingvaliditytime = rs.getLong(TRNCLSDT_TESTINGVALIDITYTIME);
                if(rs.wasNull())
                    trnclsdt_testingvaliditytime = null;
                
                Long trnclsdt_expiredretentiontime = rs.getLong(TRNCLSDT_EXPIREDRETENTIONTIME);
                if(rs.wasNull())
                    trnclsdt_expiredretentiontime = null;
                
                Boolean trnclsdt_alwaysreassignonexpiration = rs.getInt(TRNCLSDT_ALWAYSREASSIGNONEXPIRATION) == 1;
                if(rs.wasNull())
                    trnclsdt_alwaysreassignonexpiration = null;
                
                Boolean trnclsdt_isdefault = rs.getInt(TRNCLSDT_ISDEFAULT) == 1;
                if(rs.wasNull())
                    trnclsdt_isdefault = null;
                
                Integer trnclsdt_sortorder = rs.getInt(TRNCLSDT_SORTORDER);
                if(rs.wasNull())
                    trnclsdt_sortorder = null;
                
                Long trnclsdt_fromtime = rs.getLong(TRNCLSDT_FROMTIME);
                if(rs.wasNull())
                    trnclsdt_fromtime = null;
                
                Long trnclsdt_thrutime = rs.getLong(TRNCLSDT_THRUTIME);
                if(rs.wasNull())
                    trnclsdt_thrutime = null;
                
                _value = new TrainingClassDetailValue(_pk, new TrainingClassPK(trnclsdt_trncls_trainingclassid), trnclsdt_trainingclassname, trnclsdt_estimatedreadingtime, trnclsdt_readingtimeallowed, trnclsdt_estimatedtestingtime, trnclsdt_testingtimeallowed, trnclsdt_requiredcompletiontime, new WorkEffortScopePK(trnclsdt_wes_workeffortscopeid), trnclsdt_defaultpercentagetopass, trnclsdt_overallquestioncount, trnclsdt_testingvaliditytime, trnclsdt_expiredretentiontime, trnclsdt_alwaysreassignonexpiration, trnclsdt_isdefault, trnclsdt_sortorder, trnclsdt_fromtime, trnclsdt_thrutime);
            } else
                _value = _entity.getTrainingClassDetailValue();
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _value;
    }
    
    public java.util.List<TrainingClassDetail> getEntitiesFromPKs(EntityPermission entityPermission, Collection<TrainingClassDetailPK> pks)
            throws PersistenceDatabaseException {
        java.util.List<TrainingClassDetail> _entities = new ArrayList<>(pks.size());
        
        for(TrainingClassDetailPK _pk: pks) {
            _entities.add(getEntityFromPK(entityPermission, _pk));
        }
        
        return _entities;
    }
    
    public TrainingClassDetail getEntityFromValue(EntityPermission entityPermission, TrainingClassDetailValue value) {
        return getEntityFromPK(entityPermission, value.getPrimaryKey());
    }
    
    public TrainingClassDetail getEntityFromCache(TrainingClassDetailPK pk) {
        TrainingClassDetailValue _value = (TrainingClassDetailValue)session.getValueCache().get(pk);
    
        return _value == null ? null : new TrainingClassDetail(_value, EntityPermission.READ_ONLY);
    }
    
    public TrainingClassDetail getEntityFromPK(EntityPermission entityPermission, TrainingClassDetailPK pk)
            throws PersistenceDatabaseException {
        TrainingClassDetail _entity;
        
        // See if we already have the entity in the session cache
        _entity = (TrainingClassDetail)session.getEntity(pk);
        if(_entity != null) {
            // If the requested permission is READ_WRITE, and the cached permission is
            // READ_ONLY, then pretend that the cached object wasn't found, and create
            // a new entity that is READ_WRITE.
            if(entityPermission.equals(EntityPermission.READ_WRITE)) {
                if(_entity.getEntityPermission().equals(EntityPermission.READ_ONLY))
                    _entity = null;
            }
        }
        
        if(_entity == null && entityPermission.equals(EntityPermission.READ_ONLY)) {
            _entity = getEntityFromCache(pk);
        }
        
        if(_entity == null) {
            PreparedStatement _ps = session.prepareStatement(entityPermission.equals(EntityPermission.READ_ONLY)? SQL_SELECT_READ_ONLY: SQL_SELECT_READ_WRITE);
            long _entityId = pk.getEntityId();
            ResultSet _rs = null;
            
            try {
                _ps.setLong(1, _entityId);
                _rs = _ps.executeQuery();
                if(_rs.next()) {
                    _entity = getEntityFromResultSet(entityPermission, _rs);
                }
            } catch (SQLException se) {
                throw new PersistenceDatabaseException(se);
            } finally {
                if(_rs != null) {
                    try {
                        _rs.close();
                    } catch (SQLException se) {
                        // do nothing
                    }
                }
            }
        }
        
        return _entity;
    }
    
    public Set<TrainingClassDetailPK> getPKsFromQueryAsSet(PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        Set<TrainingClassDetailPK> _pks;
        ResultSet _rs = null;
        
        try {
            if(params.length != 0) {
                Session.setQueryParams(ps, params);
            }
            
            _rs = ps.executeQuery();
            _pks = getPKsFromResultSetAsSet(_rs);
            _rs.close();
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        } finally {
            if(_rs != null) {
                try {
                    _rs.close();
                } catch (SQLException se) {
                    // do nothing
                }
            }
        }
        
        return _pks;
    }
    
    public java.util.List<TrainingClassDetailPK> getPKsFromQueryAsList(PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        java.util.List<TrainingClassDetailPK> _pks;
        ResultSet _rs = null;
        
        try {
            if(params.length != 0) {
                Session.setQueryParams(ps, params);
            }
            
            _rs = ps.executeQuery();
            _pks = getPKsFromResultSetAsList(_rs);
            _rs.close();
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        } finally {
            if(_rs != null) {
                try {
                    _rs.close();
                } catch (SQLException se) {
                    // do nothing
                }
            }
        }
        
        return _pks;
    }
    
    public TrainingClassDetailPK getPKFromQuery(PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        TrainingClassDetailPK _pk = null;
        ResultSet _rs = null;
        
        try {
            if(params.length != 0) {
                Session.setQueryParams(ps, params);
            }
            
            _rs = ps.executeQuery();
            if(_rs.next()) {
                _pk = getPKFromResultSet(_rs);
            }
            _rs.close();
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        } finally {
            if(_rs != null) {
                try {
                    _rs.close();
                } catch (SQLException se) {
                    // do nothing
                }
            }
        }
        
        return _pk;
    }
    
    public java.util.List<TrainingClassDetail> getEntitiesFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(TrainingClassDetailFactory.class, queryMap.get(entityPermission));
        
        return getEntitiesFromQuery(entityPermission, ps, params);
    }
    
    public java.util.List<TrainingClassDetail> getEntitiesFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(TrainingClassDetailFactory.class, queryMap.get(entityPermission));
        
        return getEntitiesFromQuery(entityPermission, ps);
    }
    
    public java.util.List<TrainingClassDetail> getEntitiesFromQuery(EntityPermission entityPermission, PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        java.util.List<TrainingClassDetail> _entities;
        ResultSet _rs = null;
        
        try {
            if(params.length != 0) {
                Session.setQueryParams(ps, params);
            }
            
            _rs = ps.executeQuery();
            _entities = getEntitiesFromResultSet(entityPermission, _rs);
            _rs.close();
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        } finally {
            if(_rs != null) {
                try {
                    _rs.close();
                } catch (SQLException se) {
                    // do nothing
                }
            }
        }
        
        return _entities;
    }
    
    public TrainingClassDetail getEntityFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(TrainingClassDetailFactory.class, queryMap.get(entityPermission));
        
        return getEntityFromQuery(entityPermission, ps, params);
    }
    
    public TrainingClassDetail getEntityFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(TrainingClassDetailFactory.class, queryMap.get(entityPermission));
        
        return getEntityFromQuery(entityPermission, ps);
    }
    
    public TrainingClassDetail getEntityFromQuery(EntityPermission entityPermission, PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        TrainingClassDetail _entity = null;
        ResultSet _rs = null;
        
        try {
            if(params.length != 0) {
                Session.setQueryParams(ps, params);
            }
            
            _rs = ps.executeQuery();
            if(_rs.next()) {
                _entity = getEntityFromResultSet(entityPermission, _rs);
            }
            _rs.close();
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        } finally {
            if(_rs != null) {
                try {
                    _rs.close();
                } catch (SQLException se) {
                    // do nothing
                }
            }
        }
        
        return _entity;
    }
    
    public java.util.List<TrainingClassDetail> getEntitiesFromResultSet(EntityPermission entityPermission, ResultSet rs)
            throws PersistenceDatabaseException {
        java.util.List<TrainingClassDetail> _result = new ArrayList<>();
        
        try {
            while(rs.next()) {
                _result.add(getEntityFromResultSet(entityPermission, rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public TrainingClassDetail getEntityFromResultSet(EntityPermission entityPermission, ResultSet rs)
            throws PersistenceDatabaseException {
        TrainingClassDetail _entity;
        
        try {
            Long trnclsdt_trainingclassdetailid = rs.getLong(TRNCLSDT_TRAININGCLASSDETAILID);
            TrainingClassDetailPK _pk = new TrainingClassDetailPK(trnclsdt_trainingclassdetailid);
            
            // See if we already have the entity in the session cache
            _entity = (TrainingClassDetail)session.getEntity(_pk);
            if(_entity != null) {
                // If the requested permission is READ_WRITE, and the cached permission is
                // READ_ONLY, then pretend that the cached object wasn't found, and create
                // a new entity that is READ_WRITE.
                if(entityPermission.equals(EntityPermission.READ_WRITE)) {
                    if(_entity.getEntityPermission().equals(EntityPermission.READ_ONLY))
                        _entity = null;
                }
            }
            boolean foundInSessionCache = _entity != null;
            
            if(_entity == null && entityPermission.equals(EntityPermission.READ_ONLY)) {
                _entity = getEntityFromCache(_pk);
            }
            
            if(_entity == null) {
                Long trnclsdt_trncls_trainingclassid = rs.getLong(TRNCLSDT_TRNCLS_TRAININGCLASSID);
                if(rs.wasNull())
                    trnclsdt_trncls_trainingclassid = null;
                
                String trnclsdt_trainingclassname = rs.getString(TRNCLSDT_TRAININGCLASSNAME);
                if(rs.wasNull())
                    trnclsdt_trainingclassname = null;
                
                Long trnclsdt_estimatedreadingtime = rs.getLong(TRNCLSDT_ESTIMATEDREADINGTIME);
                if(rs.wasNull())
                    trnclsdt_estimatedreadingtime = null;
                
                Long trnclsdt_readingtimeallowed = rs.getLong(TRNCLSDT_READINGTIMEALLOWED);
                if(rs.wasNull())
                    trnclsdt_readingtimeallowed = null;
                
                Long trnclsdt_estimatedtestingtime = rs.getLong(TRNCLSDT_ESTIMATEDTESTINGTIME);
                if(rs.wasNull())
                    trnclsdt_estimatedtestingtime = null;
                
                Long trnclsdt_testingtimeallowed = rs.getLong(TRNCLSDT_TESTINGTIMEALLOWED);
                if(rs.wasNull())
                    trnclsdt_testingtimeallowed = null;
                
                Long trnclsdt_requiredcompletiontime = rs.getLong(TRNCLSDT_REQUIREDCOMPLETIONTIME);
                if(rs.wasNull())
                    trnclsdt_requiredcompletiontime = null;
                
                Long trnclsdt_wes_workeffortscopeid = rs.getLong(TRNCLSDT_WES_WORKEFFORTSCOPEID);
                if(rs.wasNull())
                    trnclsdt_wes_workeffortscopeid = null;
                
                Integer trnclsdt_defaultpercentagetopass = rs.getInt(TRNCLSDT_DEFAULTPERCENTAGETOPASS);
                if(rs.wasNull())
                    trnclsdt_defaultpercentagetopass = null;
                
                Integer trnclsdt_overallquestioncount = rs.getInt(TRNCLSDT_OVERALLQUESTIONCOUNT);
                if(rs.wasNull())
                    trnclsdt_overallquestioncount = null;
                
                Long trnclsdt_testingvaliditytime = rs.getLong(TRNCLSDT_TESTINGVALIDITYTIME);
                if(rs.wasNull())
                    trnclsdt_testingvaliditytime = null;
                
                Long trnclsdt_expiredretentiontime = rs.getLong(TRNCLSDT_EXPIREDRETENTIONTIME);
                if(rs.wasNull())
                    trnclsdt_expiredretentiontime = null;
                
                Boolean trnclsdt_alwaysreassignonexpiration = rs.getInt(TRNCLSDT_ALWAYSREASSIGNONEXPIRATION) == 1;
                if(rs.wasNull())
                    trnclsdt_alwaysreassignonexpiration = null;
                
                Boolean trnclsdt_isdefault = rs.getInt(TRNCLSDT_ISDEFAULT) == 1;
                if(rs.wasNull())
                    trnclsdt_isdefault = null;
                
                Integer trnclsdt_sortorder = rs.getInt(TRNCLSDT_SORTORDER);
                if(rs.wasNull())
                    trnclsdt_sortorder = null;
                
                Long trnclsdt_fromtime = rs.getLong(TRNCLSDT_FROMTIME);
                if(rs.wasNull())
                    trnclsdt_fromtime = null;
                
                Long trnclsdt_thrutime = rs.getLong(TRNCLSDT_THRUTIME);
                if(rs.wasNull())
                    trnclsdt_thrutime = null;
                
                TrainingClassDetailValue _value = new TrainingClassDetailValue(_pk, trnclsdt_trncls_trainingclassid == null? null: new TrainingClassPK(trnclsdt_trncls_trainingclassid), trnclsdt_trainingclassname, trnclsdt_estimatedreadingtime, trnclsdt_readingtimeallowed, trnclsdt_estimatedtestingtime, trnclsdt_testingtimeallowed, trnclsdt_requiredcompletiontime, trnclsdt_wes_workeffortscopeid == null? null: new WorkEffortScopePK(trnclsdt_wes_workeffortscopeid), trnclsdt_defaultpercentagetopass, trnclsdt_overallquestioncount, trnclsdt_testingvaliditytime, trnclsdt_expiredretentiontime, trnclsdt_alwaysreassignonexpiration, trnclsdt_isdefault, trnclsdt_sortorder, trnclsdt_fromtime, trnclsdt_thrutime);
                _entity = new TrainingClassDetail(_value, entityPermission);
            }
            
            if(!foundInSessionCache) {
                if(entityPermission.equals(EntityPermission.READ_ONLY)) {
                    session.putReadOnlyEntity(_pk, _entity);
                    session.getValueCache().put(_entity.getTrainingClassDetailValue());
                } else {
                    session.putReadWriteEntity(_pk, _entity);
                }
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _entity;
    }
    
    public TrainingClassDetail create(TrainingClass trainingClass, String trainingClassName, Long estimatedReadingTime, Long readingTimeAllowed, Long estimatedTestingTime, Long testingTimeAllowed, Long requiredCompletionTime, WorkEffortScope workEffortScope, Integer defaultPercentageToPass, Integer overallQuestionCount, Long testingValidityTime, Long expiredRetentionTime, Boolean alwaysReassignOnExpiration, Boolean isDefault, Integer sortOrder, Long fromTime, Long thruTime)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        return create(trainingClass == null ? null : trainingClass.getPrimaryKey(), trainingClassName, estimatedReadingTime, readingTimeAllowed, estimatedTestingTime, testingTimeAllowed, requiredCompletionTime, workEffortScope == null ? null : workEffortScope.getPrimaryKey(), defaultPercentageToPass, overallQuestionCount, testingValidityTime, expiredRetentionTime, alwaysReassignOnExpiration, isDefault, sortOrder, fromTime, thruTime);
    }
    
    private void bindForCreate(PreparedStatement _ps, TrainingClassDetailValue _value)
            throws SQLException {
        _ps.setLong(1, _value.getEntityId());
        
        TrainingClassPK trnclsdt_trncls_trainingclassid = _value.getTrainingClassPK();
        if(trnclsdt_trncls_trainingclassid == null)
            _ps.setNull(2, Types.BIGINT);
        else
            _ps.setLong(2, trnclsdt_trncls_trainingclassid.getEntityId());
            
        String trnclsdt_trainingclassname = _value.getTrainingClassName();
        if(trnclsdt_trainingclassname == null)
            _ps.setNull(3, Types.VARCHAR);
        else
            _ps.setString(3, trnclsdt_trainingclassname);
            
        Long trnclsdt_estimatedreadingtime = _value.getEstimatedReadingTime();
        if(trnclsdt_estimatedreadingtime == null)
            _ps.setNull(4, Types.BIGINT);
        else
            _ps.setLong(4, trnclsdt_estimatedreadingtime);
            
        Long trnclsdt_readingtimeallowed = _value.getReadingTimeAllowed();
        if(trnclsdt_readingtimeallowed == null)
            _ps.setNull(5, Types.BIGINT);
        else
            _ps.setLong(5, trnclsdt_readingtimeallowed);
            
        Long trnclsdt_estimatedtestingtime = _value.getEstimatedTestingTime();
        if(trnclsdt_estimatedtestingtime == null)
            _ps.setNull(6, Types.BIGINT);
        else
            _ps.setLong(6, trnclsdt_estimatedtestingtime);
            
        Long trnclsdt_testingtimeallowed = _value.getTestingTimeAllowed();
        if(trnclsdt_testingtimeallowed == null)
            _ps.setNull(7, Types.BIGINT);
        else
            _ps.setLong(7, trnclsdt_testingtimeallowed);
            
        Long trnclsdt_requiredcompletiontime = _value.getRequiredCompletionTime();
        if(trnclsdt_requiredcompletiontime == null)
            _ps.setNull(8, Types.BIGINT);
        else
            _ps.setLong(8, trnclsdt_requiredcompletiontime);
            
        WorkEffortScopePK trnclsdt_wes_workeffortscopeid = _value.getWorkEffortScopePK();
        if(trnclsdt_wes_workeffortscopeid == null)
            _ps.setNull(9, Types.BIGINT);
        else
            _ps.setLong(9, trnclsdt_wes_workeffortscopeid.getEntityId());
            
        Integer trnclsdt_defaultpercentagetopass = _value.getDefaultPercentageToPass();
        if(trnclsdt_defaultpercentagetopass == null)
            _ps.setNull(10, Types.INTEGER);
        else
            _ps.setInt(10, trnclsdt_defaultpercentagetopass);
            
        Integer trnclsdt_overallquestioncount = _value.getOverallQuestionCount();
        if(trnclsdt_overallquestioncount == null)
            _ps.setNull(11, Types.INTEGER);
        else
            _ps.setInt(11, trnclsdt_overallquestioncount);
            
        Long trnclsdt_testingvaliditytime = _value.getTestingValidityTime();
        if(trnclsdt_testingvaliditytime == null)
            _ps.setNull(12, Types.BIGINT);
        else
            _ps.setLong(12, trnclsdt_testingvaliditytime);
            
        Long trnclsdt_expiredretentiontime = _value.getExpiredRetentionTime();
        if(trnclsdt_expiredretentiontime == null)
            _ps.setNull(13, Types.BIGINT);
        else
            _ps.setLong(13, trnclsdt_expiredretentiontime);
            
        Boolean trnclsdt_alwaysreassignonexpiration = _value.getAlwaysReassignOnExpiration();
        if(trnclsdt_alwaysreassignonexpiration == null)
            _ps.setNull(14, Types.BIT);
        else
            _ps.setInt(14, trnclsdt_alwaysreassignonexpiration? 1: 0);
            
        Boolean trnclsdt_isdefault = _value.getIsDefault();
        if(trnclsdt_isdefault == null)
            _ps.setNull(15, Types.BIT);
        else
            _ps.setInt(15, trnclsdt_isdefault? 1: 0);
            
        Integer trnclsdt_sortorder = _value.getSortOrder();
        if(trnclsdt_sortorder == null)
            _ps.setNull(16, Types.INTEGER);
        else
            _ps.setInt(16, trnclsdt_sortorder);
            
        Long trnclsdt_fromtime = _value.getFromTime();
        if(trnclsdt_fromtime == null)
            _ps.setNull(17, Types.BIGINT);
        else
            _ps.setLong(17, trnclsdt_fromtime);
            
        Long trnclsdt_thrutime = _value.getThruTime();
        if(trnclsdt_thrutime == null)
            _ps.setNull(18, Types.BIGINT);
        else
            _ps.setLong(18, trnclsdt_thrutime);
            
    }
    
    public TrainingClassDetail create(TrainingClassPK trainingClassPK, String trainingClassName, Long estimatedReadingTime, Long readingTimeAllowed, Long estimatedTestingTime, Long testingTimeAllowed, Long requiredCompletionTime, WorkEffortScopePK workEffortScopePK, Integer defaultPercentageToPass, Integer overallQuestionCount, Long testingValidityTime, Long expiredRetentionTime, Boolean alwaysReassignOnExpiration, Boolean isDefault, Integer sortOrder, Long fromTime, Long thruTime)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        TrainingClassDetailPK _pk = getNextPK();
        TrainingClassDetailValue _value = new TrainingClassDetailValue(_pk, trainingClassPK, trainingClassName, estimatedReadingTime, readingTimeAllowed, estimatedTestingTime, testingTimeAllowed, requiredCompletionTime, workEffortScopePK, defaultPercentageToPass, overallQuestionCount, testingValidityTime, expiredRetentionTime, alwaysReassignOnExpiration, isDefault, sortOrder, fromTime, thruTime);
        
        PreparedStatement _ps = session.prepareStatement(SQL_INSERT);
        
        try {
            bindForCreate(_ps, _value);
            
            if(PersistenceDebugFlags.CheckEntityInsertRowCount) {
                int _count = _ps.executeUpdate();
                
                if(_count != 1) {
                    throw new PersistenceDatabaseUpdateException("insert failed, _count = " + _count);
                }
            } else {
                 _ps.executeUpdate();
            }
            
            session.getValueCache().put(_value);
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        TrainingClassDetail _entity = new TrainingClassDetail(_value, EntityPermission.READ_ONLY);
        session.putReadOnlyEntity(_pk, _entity);
        
        return _entity;
    }
    
    public void create(Collection<TrainingClassDetailValue> _values)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        int _size = _values.size();
        
        if(_size > 0) {
            PreparedStatement _ps = session.prepareStatement(SQL_INSERT);
            List<TrainingClassDetailValue> _cacheValues = new ArrayList<>(_size);
            
            try {
                for(TrainingClassDetailValue _value : _values) {
                    _value.setEntityId(entityIdGenerator.getNextEntityId());
                    bindForCreate(_ps, _value);
                    
                    _ps.addBatch();
                    
                    _cacheValues.add(_value);
                }
                
                if(PersistenceDebugFlags.CheckEntityInsertRowCount) {
                    int[] _counts = _ps.executeBatch();
                    
                    for(int _countOffset = 0 ; _countOffset < _size ; _countOffset++) {
                        if(_counts[_countOffset] != 1 && _counts[_countOffset] != PreparedStatement.SUCCESS_NO_INFO) {
                            throw new PersistenceDatabaseUpdateException("batch insert failed, _counts[" + _countOffset + "] = " + _counts[_countOffset]);
                        }
                    }
                } else {
                     _ps.executeBatch();
                }
                
                _ps.clearBatch();
            } catch (SQLException se) {
                throw new PersistenceDatabaseException(se);
            }
            
            _cacheValues.forEach((_cacheValue) -> {
                TrainingClassDetail _cacheEntity = new TrainingClassDetail(_cacheValue, EntityPermission.READ_ONLY);
                
                session.putReadOnlyEntity(_cacheValue.getPrimaryKey(), _cacheEntity);
            });
        }
    }
    
    private boolean bindForStore(PreparedStatement _ps, TrainingClassDetailValue _value)
            throws SQLException {
        boolean _hasBeenModified = _value.hasBeenModified();
        
        if(_hasBeenModified) {
            TrainingClassPK trnclsdt_trncls_trainingclassid = _value.getTrainingClassPK();
            if(trnclsdt_trncls_trainingclassid == null)
                _ps.setNull(1, Types.BIGINT);
            else
                _ps.setLong(1, trnclsdt_trncls_trainingclassid.getEntityId());
            
            String trnclsdt_trainingclassname = _value.getTrainingClassName();
            if(trnclsdt_trainingclassname == null)
                _ps.setNull(2, Types.VARCHAR);
            else
                _ps.setString(2, trnclsdt_trainingclassname);
            
            Long trnclsdt_estimatedreadingtime = _value.getEstimatedReadingTime();
            if(trnclsdt_estimatedreadingtime == null)
                _ps.setNull(3, Types.BIGINT);
            else
                _ps.setLong(3, trnclsdt_estimatedreadingtime);
            
            Long trnclsdt_readingtimeallowed = _value.getReadingTimeAllowed();
            if(trnclsdt_readingtimeallowed == null)
                _ps.setNull(4, Types.BIGINT);
            else
                _ps.setLong(4, trnclsdt_readingtimeallowed);
            
            Long trnclsdt_estimatedtestingtime = _value.getEstimatedTestingTime();
            if(trnclsdt_estimatedtestingtime == null)
                _ps.setNull(5, Types.BIGINT);
            else
                _ps.setLong(5, trnclsdt_estimatedtestingtime);
            
            Long trnclsdt_testingtimeallowed = _value.getTestingTimeAllowed();
            if(trnclsdt_testingtimeallowed == null)
                _ps.setNull(6, Types.BIGINT);
            else
                _ps.setLong(6, trnclsdt_testingtimeallowed);
            
            Long trnclsdt_requiredcompletiontime = _value.getRequiredCompletionTime();
            if(trnclsdt_requiredcompletiontime == null)
                _ps.setNull(7, Types.BIGINT);
            else
                _ps.setLong(7, trnclsdt_requiredcompletiontime);
            
            WorkEffortScopePK trnclsdt_wes_workeffortscopeid = _value.getWorkEffortScopePK();
            if(trnclsdt_wes_workeffortscopeid == null)
                _ps.setNull(8, Types.BIGINT);
            else
                _ps.setLong(8, trnclsdt_wes_workeffortscopeid.getEntityId());
            
            Integer trnclsdt_defaultpercentagetopass = _value.getDefaultPercentageToPass();
            if(trnclsdt_defaultpercentagetopass == null)
                _ps.setNull(9, Types.INTEGER);
            else
                _ps.setInt(9, trnclsdt_defaultpercentagetopass);
            
            Integer trnclsdt_overallquestioncount = _value.getOverallQuestionCount();
            if(trnclsdt_overallquestioncount == null)
                _ps.setNull(10, Types.INTEGER);
            else
                _ps.setInt(10, trnclsdt_overallquestioncount);
            
            Long trnclsdt_testingvaliditytime = _value.getTestingValidityTime();
            if(trnclsdt_testingvaliditytime == null)
                _ps.setNull(11, Types.BIGINT);
            else
                _ps.setLong(11, trnclsdt_testingvaliditytime);
            
            Long trnclsdt_expiredretentiontime = _value.getExpiredRetentionTime();
            if(trnclsdt_expiredretentiontime == null)
                _ps.setNull(12, Types.BIGINT);
            else
                _ps.setLong(12, trnclsdt_expiredretentiontime);
            
            Boolean trnclsdt_alwaysreassignonexpiration = _value.getAlwaysReassignOnExpiration();
            if(trnclsdt_alwaysreassignonexpiration == null)
                _ps.setNull(13, Types.BIT);
            else
                _ps.setInt(13, trnclsdt_alwaysreassignonexpiration? 1: 0);
            
            Boolean trnclsdt_isdefault = _value.getIsDefault();
            if(trnclsdt_isdefault == null)
                _ps.setNull(14, Types.BIT);
            else
                _ps.setInt(14, trnclsdt_isdefault? 1: 0);
            
            Integer trnclsdt_sortorder = _value.getSortOrder();
            if(trnclsdt_sortorder == null)
                _ps.setNull(15, Types.INTEGER);
            else
                _ps.setInt(15, trnclsdt_sortorder);
            
            Long trnclsdt_fromtime = _value.getFromTime();
            if(trnclsdt_fromtime == null)
                _ps.setNull(16, Types.BIGINT);
            else
                _ps.setLong(16, trnclsdt_fromtime);
            
            Long trnclsdt_thrutime = _value.getThruTime();
            if(trnclsdt_thrutime == null)
                _ps.setNull(17, Types.BIGINT);
            else
                _ps.setLong(17, trnclsdt_thrutime);
            
            _ps.setLong(18, _value.getPrimaryKey().getEntityId());
            
            _value.clearHasBeenModified();
        }
        
        return _hasBeenModified;
    }
    
    @Override
    public void store(TrainingClassDetail entity)
            throws PersistenceDatabaseException {
        PreparedStatement _ps = session.prepareStatement(SQL_UPDATE);
        
        try {
            TrainingClassDetailValue _value = entity.getTrainingClassDetailValue();
            
            if(bindForStore(_ps, _value)) {
                if(PersistenceDebugFlags.CheckEntityUpdateRowCount) {
                    int _count = _ps.executeUpdate();
                    
                    if(_count != 1) {
                        throw new PersistenceDatabaseUpdateException("update failed, _count = " + _count);
                    }
                } else {
                     _ps.executeUpdate();
                }
                
                session.getValueCache().put(_value);
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
    }
    
    @Override
    public void store(Collection<TrainingClassDetail> entities)
            throws PersistenceDatabaseException {
        if(entities.size() > 0) {
            PreparedStatement _ps = session.prepareStatement(SQL_UPDATE);
            int _modifiedEntities = 0;
            
            try {
                for(TrainingClassDetail entity : entities) {
                    if(bindForStore(_ps, entity.getTrainingClassDetailValue())) {
                        _ps.addBatch();
                        _modifiedEntities++;
                    }
                }
                
                if(_modifiedEntities != 0) {
                    if(PersistenceDebugFlags.CheckEntityUpdateRowCount) {
                        int[] _counts = _ps.executeBatch();
                        
                        for(int _countOffset = 0 ; _countOffset < _modifiedEntities  ; _countOffset++) {
                            if(_counts[_countOffset] != 1 && _counts[_countOffset] != PreparedStatement.SUCCESS_NO_INFO) {
                                throw new PersistenceDatabaseUpdateException("batch update failed, _counts[" + _countOffset + "] = " + _counts[_countOffset]);
                            }
                        }
                    } else {
                         _ps.executeBatch();
                    }
                    
                    _ps.clearBatch();
                    
                    entities.forEach((entity) -> {
                        session.getValueCache().put(entity.getTrainingClassDetailValue());
                    });
                }
            } catch (SQLException se) {
                throw new PersistenceDatabaseException(se);
            }
        }
    }
    
    @Override
    public void remove(TrainingClassDetail entity)
            throws PersistenceDatabaseException {
        remove(entity.getPrimaryKey());
    }
    
    @Override
    public void remove(TrainingClassDetailPK pk)
            throws PersistenceDatabaseException {
        PreparedStatement _ps = session.prepareStatement(SQL_DELETE);
        long _entityId = pk.getEntityId();
        
        try {
            _ps.setLong(1, _entityId);
            
            if(PersistenceDebugFlags.CheckEntityDeleteRowCount) {
                int _count = _ps.executeUpdate();
                
                if(_count != 1) {
                    throw new PersistenceDatabaseUpdateException("remove failed, _count = " + _count);
                }
            } else {
                 _ps.executeUpdate();
            }
            
            session.getValueCache().remove(pk);
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        session.removed(pk, false);
    }
    
    @Override
    public void remove(Collection<TrainingClassDetailPK> pks)
            throws PersistenceDatabaseException {
        if(pks.size() > 0) {
            PreparedStatement _ps = session.prepareStatement(SQL_DELETE);
            int _modifiedEntities = 0;
            
            try {
                for(TrainingClassDetailPK pk : pks) {
                    long _entityId = pk.getEntityId();
                    
                    _ps.setLong(1, _entityId);
                    
                    _ps.addBatch();
                    _modifiedEntities++;
                }
                
                if(_modifiedEntities != 0) {
                    if(PersistenceDebugFlags.CheckEntityDeleteRowCount) {
                        int[] _counts = _ps.executeBatch();
                        
                        for(int _countOffset = 0 ; _countOffset < _modifiedEntities  ; _countOffset++) {
                            if(_counts[_countOffset] != 1 && _counts[_countOffset] != PreparedStatement.SUCCESS_NO_INFO) {
                                throw new PersistenceDatabaseUpdateException("batch remove failed, _counts[" + _countOffset + "] = " + _counts[_countOffset]);
                            }
                        }
                    } else {
                        _ps.executeBatch();
                    }
                    
                    _ps.clearBatch();
                    
                    pks.forEach((pk) -> {
                        session.getValueCache().remove(pk);
                    });
                }
            } catch (SQLException se) {
                throw new PersistenceDatabaseException(se);
            }
            
            pks.forEach((pk) -> {
                session.removed(pk, true);
            });
        }
    }
    
    @Override
    public boolean validPK(TrainingClassDetailPK pk)
            throws PersistenceDatabaseException {
        boolean valid = false;
        PreparedStatement _ps = session.prepareStatement(SQL_VALID);
        ResultSet _rs = null;
        
        try {
            _ps.setLong(1, pk.getEntityId());
            
            _rs = _ps.executeQuery();
            if(_rs.next()) {
                long _count = _rs.getLong(1);
                if(_rs.wasNull())
                    _count = 0;
                
                if(_count == 1)
                    valid = true;
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        } finally {
            if(_rs != null) {
                try {
                    _rs.close();
                } catch (SQLException se) {
                    // do nothing
                }
            }
        }
        
        return valid;
    }
    
}