// --------------------------------------------------------------------------------
// 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
// --------------------------------------------------------------------------------

/**
 * CarrierOptionDetailFactory.java
 */

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

import com.echothree.model.data.carrier.common.pk.CarrierOptionPK;
import com.echothree.model.data.party.common.pk.PartyPK;
import com.echothree.model.data.selector.common.pk.SelectorPK;

import com.echothree.model.data.carrier.server.entity.CarrierOption;
import com.echothree.model.data.party.server.entity.Party;
import com.echothree.model.data.selector.server.entity.Selector;

import com.echothree.model.data.carrier.common.CarrierOptionDetailConstants;
import com.echothree.model.data.carrier.common.pk.CarrierOptionDetailPK;
import com.echothree.model.data.carrier.server.value.CarrierOptionDetailValue;
import com.echothree.model.data.carrier.server.entity.CarrierOptionDetail;
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 CarrierOptionDetailFactory
        implements BaseFactory<CarrierOptionDetailPK, CarrierOptionDetail> {
    
    @Inject
    Session session;
    
    //private static final Logger log = LoggerFactory.getLogger(CarrierOptionDetailFactory.class);
    
    final private static String SQL_SELECT_READ_ONLY = "SELECT crroptdt_carrieroptiondetailid, crroptdt_crropt_carrieroptionid, crroptdt_carrierpartyid, crroptdt_carrieroptionname, crroptdt_isrecommended, crroptdt_isrequired, crroptdt_recommendedgeocodeselectorid, crroptdt_requiredgeocodeselectorid, crroptdt_recommendeditemselectorid, crroptdt_requireditemselectorid, crroptdt_recommendedorderselectorid, crroptdt_requiredorderselectorid, crroptdt_recommendedshipmentselectorid, crroptdt_requiredshipmentselectorid, crroptdt_isdefault, crroptdt_sortorder, crroptdt_fromtime, crroptdt_thrutime FROM carrieroptiondetails WHERE crroptdt_carrieroptiondetailid = ?";
    final private static String SQL_SELECT_READ_WRITE = "SELECT crroptdt_carrieroptiondetailid, crroptdt_crropt_carrieroptionid, crroptdt_carrierpartyid, crroptdt_carrieroptionname, crroptdt_isrecommended, crroptdt_isrequired, crroptdt_recommendedgeocodeselectorid, crroptdt_requiredgeocodeselectorid, crroptdt_recommendeditemselectorid, crroptdt_requireditemselectorid, crroptdt_recommendedorderselectorid, crroptdt_requiredorderselectorid, crroptdt_recommendedshipmentselectorid, crroptdt_requiredshipmentselectorid, crroptdt_isdefault, crroptdt_sortorder, crroptdt_fromtime, crroptdt_thrutime FROM carrieroptiondetails WHERE crroptdt_carrieroptiondetailid = ? FOR UPDATE";
    final private static String SQL_INSERT = "INSERT INTO carrieroptiondetails (crroptdt_carrieroptiondetailid, crroptdt_crropt_carrieroptionid, crroptdt_carrierpartyid, crroptdt_carrieroptionname, crroptdt_isrecommended, crroptdt_isrequired, crroptdt_recommendedgeocodeselectorid, crroptdt_requiredgeocodeselectorid, crroptdt_recommendeditemselectorid, crroptdt_requireditemselectorid, crroptdt_recommendedorderselectorid, crroptdt_requiredorderselectorid, crroptdt_recommendedshipmentselectorid, crroptdt_requiredshipmentselectorid, crroptdt_isdefault, crroptdt_sortorder, crroptdt_fromtime, crroptdt_thrutime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
    final private static String SQL_UPDATE = "UPDATE carrieroptiondetails SET crroptdt_crropt_carrieroptionid = ?, crroptdt_carrierpartyid = ?, crroptdt_carrieroptionname = ?, crroptdt_isrecommended = ?, crroptdt_isrequired = ?, crroptdt_recommendedgeocodeselectorid = ?, crroptdt_requiredgeocodeselectorid = ?, crroptdt_recommendeditemselectorid = ?, crroptdt_requireditemselectorid = ?, crroptdt_recommendedorderselectorid = ?, crroptdt_requiredorderselectorid = ?, crroptdt_recommendedshipmentselectorid = ?, crroptdt_requiredshipmentselectorid = ?, crroptdt_isdefault = ?, crroptdt_sortorder = ?, crroptdt_fromtime = ?, crroptdt_thrutime = ? WHERE crroptdt_carrieroptiondetailid = ?";
    final private static String SQL_DELETE = "DELETE FROM carrieroptiondetails WHERE crroptdt_carrieroptiondetailid = ?";
    final private static String SQL_VALID = "SELECT COUNT(*) FROM carrieroptiondetails WHERE crroptdt_carrieroptiondetailid = ?";
    
    final private static String PK_COLUMN = "crroptdt_carrieroptiondetailid";
    final private static String ALL_COLUMNS = "crroptdt_carrieroptiondetailid, crroptdt_crropt_carrieroptionid, crroptdt_carrierpartyid, crroptdt_carrieroptionname, crroptdt_isrecommended, crroptdt_isrequired, crroptdt_recommendedgeocodeselectorid, crroptdt_requiredgeocodeselectorid, crroptdt_recommendeditemselectorid, crroptdt_requireditemselectorid, crroptdt_recommendedorderselectorid, crroptdt_requiredorderselectorid, crroptdt_recommendedshipmentselectorid, crroptdt_requiredshipmentselectorid, crroptdt_isdefault, crroptdt_sortorder, crroptdt_fromtime, crroptdt_thrutime";
    final public static String TABLE_NAME = "carrieroptiondetails";
    
    final public static String CRROPTDT_CARRIEROPTIONDETAILID = "crroptdt_carrieroptiondetailid";
    final public static String CRROPTDT_CRROPT_CARRIEROPTIONID = "crroptdt_crropt_carrieroptionid";
    final public static String CRROPTDT_CARRIERPARTYID = "crroptdt_carrierpartyid";
    final public static String CRROPTDT_CARRIEROPTIONNAME = "crroptdt_carrieroptionname";
    final public static String CRROPTDT_ISRECOMMENDED = "crroptdt_isrecommended";
    final public static String CRROPTDT_ISREQUIRED = "crroptdt_isrequired";
    final public static String CRROPTDT_RECOMMENDEDGEOCODESELECTORID = "crroptdt_recommendedgeocodeselectorid";
    final public static String CRROPTDT_REQUIREDGEOCODESELECTORID = "crroptdt_requiredgeocodeselectorid";
    final public static String CRROPTDT_RECOMMENDEDITEMSELECTORID = "crroptdt_recommendeditemselectorid";
    final public static String CRROPTDT_REQUIREDITEMSELECTORID = "crroptdt_requireditemselectorid";
    final public static String CRROPTDT_RECOMMENDEDORDERSELECTORID = "crroptdt_recommendedorderselectorid";
    final public static String CRROPTDT_REQUIREDORDERSELECTORID = "crroptdt_requiredorderselectorid";
    final public static String CRROPTDT_RECOMMENDEDSHIPMENTSELECTORID = "crroptdt_recommendedshipmentselectorid";
    final public static String CRROPTDT_REQUIREDSHIPMENTSELECTORID = "crroptdt_requiredshipmentselectorid";
    final public static String CRROPTDT_ISDEFAULT = "crroptdt_isdefault";
    final public static String CRROPTDT_SORTORDER = "crroptdt_sortorder";
    final public static String CRROPTDT_FROMTIME = "crroptdt_fromtime";
    final public static String CRROPTDT_THRUTIME = "crroptdt_thrutime";
    
    final private static EntityIdGenerator entityIdGenerator = new EntityIdGenerator(CarrierOptionDetailConstants.COMPONENT_VENDOR_NAME, CarrierOptionDetailConstants.ENTITY_TYPE_NAME);
    
    /** Creates a new instance of CarrierOptionDetailFactory */
    protected CarrierOptionDetailFactory() {
        super();
    }
    
    public static CarrierOptionDetailFactory getInstance() {
        return CDI.current().select(CarrierOptionDetailFactory.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 CarrierOptionDetailConstants.COMPONENT_VENDOR_NAME;
    }
    
    @Override
    public String getEntityTypeName() {
        return CarrierOptionDetailConstants.ENTITY_TYPE_NAME;
    }
    
    public PreparedStatement prepareStatement(String query) {
        return session.prepareStatement(CarrierOptionDetailFactory.class, query);
    }
    
    public CarrierOptionDetailPK getNextPK() {
        return new CarrierOptionDetailPK(entityIdGenerator.getNextEntityId());
    }
    
    public Set<CarrierOptionDetailPK> getPKsFromResultSetAsSet(ResultSet rs)
            throws PersistenceDatabaseException {
        Set<CarrierOptionDetailPK> _result = new HashSet<>();
        
        try {
            while(rs.next()) {
                _result.add(getPKFromResultSet(rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public java.util.List<CarrierOptionDetailPK> getPKsFromResultSetAsList(ResultSet rs)
            throws PersistenceDatabaseException {
        java.util.List<CarrierOptionDetailPK> _result = new ArrayList<>();
        
        try {
            while(rs.next()) {
                _result.add(getPKFromResultSet(rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public CarrierOptionDetailPK getPKFromResultSet(ResultSet rs)
            throws PersistenceDatabaseException {
        CarrierOptionDetailPK _result;
        
        try {
            long crroptdt_carrieroptiondetailid = rs.getLong(CRROPTDT_CARRIEROPTIONDETAILID);
            Long _entityId = rs.wasNull() ? null : crroptdt_carrieroptiondetailid;
            
            _result = new CarrierOptionDetailPK(_entityId);
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public java.util.List<CarrierOptionDetailValue> getValuesFromPKs(Collection<CarrierOptionDetailPK> pks)
            throws PersistenceDatabaseException {
        java.util.List<CarrierOptionDetailValue> _values = new ArrayList<>(pks.size());
        
        for(CarrierOptionDetailPK _pk: pks) {
            _values.add(getValueFromPK(_pk));
        }
        
        return _values;
    }
    
    public CarrierOptionDetailValue getValueFromPK(CarrierOptionDetailPK pk)
            throws PersistenceDatabaseException {
        CarrierOptionDetailValue _value;
        
        // See if we already have the entity in the session cache
        CarrierOptionDetail _entity = (CarrierOptionDetail)session.getEntity(pk);
        if(_entity == null)
            _value = getEntityFromPK(EntityPermission.READ_ONLY, pk).getCarrierOptionDetailValue();
        else
            _value = _entity.getCarrierOptionDetailValue();
        
        return _value;
    }
    
    public java.util.List<CarrierOptionDetailValue> getValuesFromResultSet(ResultSet rs)
            throws PersistenceDatabaseException {
        java.util.List<CarrierOptionDetailValue> _result = new ArrayList<>();
        
        try {
            while(rs.next()) {
                _result.add(getValueFromResultSet(rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public CarrierOptionDetailValue getValueFromResultSet(ResultSet rs)
            throws PersistenceDatabaseException {
        CarrierOptionDetailValue _value;
        
        try {
            Long crroptdt_carrieroptiondetailid = rs.getLong(CRROPTDT_CARRIEROPTIONDETAILID);
            CarrierOptionDetailPK _pk = new CarrierOptionDetailPK(crroptdt_carrieroptiondetailid);
            
            // See if we already have the entity in the session cache
            CarrierOptionDetail _entity = (CarrierOptionDetail)session.getEntity(_pk);
            
            if(_entity == null) {
                Long crroptdt_crropt_carrieroptionid = rs.getLong(CRROPTDT_CRROPT_CARRIEROPTIONID);
                if(rs.wasNull())
                    crroptdt_crropt_carrieroptionid = null;
                
                Long crroptdt_carrierpartyid = rs.getLong(CRROPTDT_CARRIERPARTYID);
                if(rs.wasNull())
                    crroptdt_carrierpartyid = null;
                
                String crroptdt_carrieroptionname = rs.getString(CRROPTDT_CARRIEROPTIONNAME);
                if(rs.wasNull())
                    crroptdt_carrieroptionname = null;
                
                Boolean crroptdt_isrecommended = rs.getInt(CRROPTDT_ISRECOMMENDED) == 1;
                if(rs.wasNull())
                    crroptdt_isrecommended = null;
                
                Boolean crroptdt_isrequired = rs.getInt(CRROPTDT_ISREQUIRED) == 1;
                if(rs.wasNull())
                    crroptdt_isrequired = null;
                
                Long crroptdt_recommendedgeocodeselectorid = rs.getLong(CRROPTDT_RECOMMENDEDGEOCODESELECTORID);
                if(rs.wasNull())
                    crroptdt_recommendedgeocodeselectorid = null;
                
                Long crroptdt_requiredgeocodeselectorid = rs.getLong(CRROPTDT_REQUIREDGEOCODESELECTORID);
                if(rs.wasNull())
                    crroptdt_requiredgeocodeselectorid = null;
                
                Long crroptdt_recommendeditemselectorid = rs.getLong(CRROPTDT_RECOMMENDEDITEMSELECTORID);
                if(rs.wasNull())
                    crroptdt_recommendeditemselectorid = null;
                
                Long crroptdt_requireditemselectorid = rs.getLong(CRROPTDT_REQUIREDITEMSELECTORID);
                if(rs.wasNull())
                    crroptdt_requireditemselectorid = null;
                
                Long crroptdt_recommendedorderselectorid = rs.getLong(CRROPTDT_RECOMMENDEDORDERSELECTORID);
                if(rs.wasNull())
                    crroptdt_recommendedorderselectorid = null;
                
                Long crroptdt_requiredorderselectorid = rs.getLong(CRROPTDT_REQUIREDORDERSELECTORID);
                if(rs.wasNull())
                    crroptdt_requiredorderselectorid = null;
                
                Long crroptdt_recommendedshipmentselectorid = rs.getLong(CRROPTDT_RECOMMENDEDSHIPMENTSELECTORID);
                if(rs.wasNull())
                    crroptdt_recommendedshipmentselectorid = null;
                
                Long crroptdt_requiredshipmentselectorid = rs.getLong(CRROPTDT_REQUIREDSHIPMENTSELECTORID);
                if(rs.wasNull())
                    crroptdt_requiredshipmentselectorid = null;
                
                Boolean crroptdt_isdefault = rs.getInt(CRROPTDT_ISDEFAULT) == 1;
                if(rs.wasNull())
                    crroptdt_isdefault = null;
                
                Integer crroptdt_sortorder = rs.getInt(CRROPTDT_SORTORDER);
                if(rs.wasNull())
                    crroptdt_sortorder = null;
                
                Long crroptdt_fromtime = rs.getLong(CRROPTDT_FROMTIME);
                if(rs.wasNull())
                    crroptdt_fromtime = null;
                
                Long crroptdt_thrutime = rs.getLong(CRROPTDT_THRUTIME);
                if(rs.wasNull())
                    crroptdt_thrutime = null;
                
                _value = new CarrierOptionDetailValue(_pk, new CarrierOptionPK(crroptdt_crropt_carrieroptionid), new PartyPK(crroptdt_carrierpartyid), crroptdt_carrieroptionname, crroptdt_isrecommended, crroptdt_isrequired, new SelectorPK(crroptdt_recommendedgeocodeselectorid), new SelectorPK(crroptdt_requiredgeocodeselectorid), new SelectorPK(crroptdt_recommendeditemselectorid), new SelectorPK(crroptdt_requireditemselectorid), new SelectorPK(crroptdt_recommendedorderselectorid), new SelectorPK(crroptdt_requiredorderselectorid), new SelectorPK(crroptdt_recommendedshipmentselectorid), new SelectorPK(crroptdt_requiredshipmentselectorid), crroptdt_isdefault, crroptdt_sortorder, crroptdt_fromtime, crroptdt_thrutime);
            } else
                _value = _entity.getCarrierOptionDetailValue();
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _value;
    }
    
    public java.util.List<CarrierOptionDetail> getEntitiesFromPKs(EntityPermission entityPermission, Collection<CarrierOptionDetailPK> pks)
            throws PersistenceDatabaseException {
        java.util.List<CarrierOptionDetail> _entities = new ArrayList<>(pks.size());
        
        for(CarrierOptionDetailPK _pk: pks) {
            _entities.add(getEntityFromPK(entityPermission, _pk));
        }
        
        return _entities;
    }
    
    public CarrierOptionDetail getEntityFromValue(EntityPermission entityPermission, CarrierOptionDetailValue value) {
        return getEntityFromPK(entityPermission, value.getPrimaryKey());
    }
    
    public CarrierOptionDetail getEntityFromCache(CarrierOptionDetailPK pk) {
        CarrierOptionDetailValue _value = (CarrierOptionDetailValue)session.getValueCache().get(pk);
    
        return _value == null ? null : new CarrierOptionDetail(_value, EntityPermission.READ_ONLY);
    }
    
    public CarrierOptionDetail getEntityFromPK(EntityPermission entityPermission, CarrierOptionDetailPK pk)
            throws PersistenceDatabaseException {
        CarrierOptionDetail _entity;
        
        // See if we already have the entity in the session cache
        _entity = (CarrierOptionDetail)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<CarrierOptionDetailPK> getPKsFromQueryAsSet(PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        Set<CarrierOptionDetailPK> _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<CarrierOptionDetailPK> getPKsFromQueryAsList(PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        java.util.List<CarrierOptionDetailPK> _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 CarrierOptionDetailPK getPKFromQuery(PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        CarrierOptionDetailPK _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<CarrierOptionDetail> getEntitiesFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(CarrierOptionDetailFactory.class, queryMap.get(entityPermission));
        
        return getEntitiesFromQuery(entityPermission, ps, params);
    }
    
    public java.util.List<CarrierOptionDetail> getEntitiesFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(CarrierOptionDetailFactory.class, queryMap.get(entityPermission));
        
        return getEntitiesFromQuery(entityPermission, ps);
    }
    
    public java.util.List<CarrierOptionDetail> getEntitiesFromQuery(EntityPermission entityPermission, PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        java.util.List<CarrierOptionDetail> _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 CarrierOptionDetail getEntityFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(CarrierOptionDetailFactory.class, queryMap.get(entityPermission));
        
        return getEntityFromQuery(entityPermission, ps, params);
    }
    
    public CarrierOptionDetail getEntityFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(CarrierOptionDetailFactory.class, queryMap.get(entityPermission));
        
        return getEntityFromQuery(entityPermission, ps);
    }
    
    public CarrierOptionDetail getEntityFromQuery(EntityPermission entityPermission, PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        CarrierOptionDetail _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<CarrierOptionDetail> getEntitiesFromResultSet(EntityPermission entityPermission, ResultSet rs)
            throws PersistenceDatabaseException {
        java.util.List<CarrierOptionDetail> _result = new ArrayList<>();
        
        try {
            while(rs.next()) {
                _result.add(getEntityFromResultSet(entityPermission, rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public CarrierOptionDetail getEntityFromResultSet(EntityPermission entityPermission, ResultSet rs)
            throws PersistenceDatabaseException {
        CarrierOptionDetail _entity;
        
        try {
            Long crroptdt_carrieroptiondetailid = rs.getLong(CRROPTDT_CARRIEROPTIONDETAILID);
            CarrierOptionDetailPK _pk = new CarrierOptionDetailPK(crroptdt_carrieroptiondetailid);
            
            // See if we already have the entity in the session cache
            _entity = (CarrierOptionDetail)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 crroptdt_crropt_carrieroptionid = rs.getLong(CRROPTDT_CRROPT_CARRIEROPTIONID);
                if(rs.wasNull())
                    crroptdt_crropt_carrieroptionid = null;
                
                Long crroptdt_carrierpartyid = rs.getLong(CRROPTDT_CARRIERPARTYID);
                if(rs.wasNull())
                    crroptdt_carrierpartyid = null;
                
                String crroptdt_carrieroptionname = rs.getString(CRROPTDT_CARRIEROPTIONNAME);
                if(rs.wasNull())
                    crroptdt_carrieroptionname = null;
                
                Boolean crroptdt_isrecommended = rs.getInt(CRROPTDT_ISRECOMMENDED) == 1;
                if(rs.wasNull())
                    crroptdt_isrecommended = null;
                
                Boolean crroptdt_isrequired = rs.getInt(CRROPTDT_ISREQUIRED) == 1;
                if(rs.wasNull())
                    crroptdt_isrequired = null;
                
                Long crroptdt_recommendedgeocodeselectorid = rs.getLong(CRROPTDT_RECOMMENDEDGEOCODESELECTORID);
                if(rs.wasNull())
                    crroptdt_recommendedgeocodeselectorid = null;
                
                Long crroptdt_requiredgeocodeselectorid = rs.getLong(CRROPTDT_REQUIREDGEOCODESELECTORID);
                if(rs.wasNull())
                    crroptdt_requiredgeocodeselectorid = null;
                
                Long crroptdt_recommendeditemselectorid = rs.getLong(CRROPTDT_RECOMMENDEDITEMSELECTORID);
                if(rs.wasNull())
                    crroptdt_recommendeditemselectorid = null;
                
                Long crroptdt_requireditemselectorid = rs.getLong(CRROPTDT_REQUIREDITEMSELECTORID);
                if(rs.wasNull())
                    crroptdt_requireditemselectorid = null;
                
                Long crroptdt_recommendedorderselectorid = rs.getLong(CRROPTDT_RECOMMENDEDORDERSELECTORID);
                if(rs.wasNull())
                    crroptdt_recommendedorderselectorid = null;
                
                Long crroptdt_requiredorderselectorid = rs.getLong(CRROPTDT_REQUIREDORDERSELECTORID);
                if(rs.wasNull())
                    crroptdt_requiredorderselectorid = null;
                
                Long crroptdt_recommendedshipmentselectorid = rs.getLong(CRROPTDT_RECOMMENDEDSHIPMENTSELECTORID);
                if(rs.wasNull())
                    crroptdt_recommendedshipmentselectorid = null;
                
                Long crroptdt_requiredshipmentselectorid = rs.getLong(CRROPTDT_REQUIREDSHIPMENTSELECTORID);
                if(rs.wasNull())
                    crroptdt_requiredshipmentselectorid = null;
                
                Boolean crroptdt_isdefault = rs.getInt(CRROPTDT_ISDEFAULT) == 1;
                if(rs.wasNull())
                    crroptdt_isdefault = null;
                
                Integer crroptdt_sortorder = rs.getInt(CRROPTDT_SORTORDER);
                if(rs.wasNull())
                    crroptdt_sortorder = null;
                
                Long crroptdt_fromtime = rs.getLong(CRROPTDT_FROMTIME);
                if(rs.wasNull())
                    crroptdt_fromtime = null;
                
                Long crroptdt_thrutime = rs.getLong(CRROPTDT_THRUTIME);
                if(rs.wasNull())
                    crroptdt_thrutime = null;
                
                CarrierOptionDetailValue _value = new CarrierOptionDetailValue(_pk, crroptdt_crropt_carrieroptionid == null? null: new CarrierOptionPK(crroptdt_crropt_carrieroptionid), crroptdt_carrierpartyid == null? null: new PartyPK(crroptdt_carrierpartyid), crroptdt_carrieroptionname, crroptdt_isrecommended, crroptdt_isrequired, crroptdt_recommendedgeocodeselectorid == null? null: new SelectorPK(crroptdt_recommendedgeocodeselectorid), crroptdt_requiredgeocodeselectorid == null? null: new SelectorPK(crroptdt_requiredgeocodeselectorid), crroptdt_recommendeditemselectorid == null? null: new SelectorPK(crroptdt_recommendeditemselectorid), crroptdt_requireditemselectorid == null? null: new SelectorPK(crroptdt_requireditemselectorid), crroptdt_recommendedorderselectorid == null? null: new SelectorPK(crroptdt_recommendedorderselectorid), crroptdt_requiredorderselectorid == null? null: new SelectorPK(crroptdt_requiredorderselectorid), crroptdt_recommendedshipmentselectorid == null? null: new SelectorPK(crroptdt_recommendedshipmentselectorid), crroptdt_requiredshipmentselectorid == null? null: new SelectorPK(crroptdt_requiredshipmentselectorid), crroptdt_isdefault, crroptdt_sortorder, crroptdt_fromtime, crroptdt_thrutime);
                _entity = new CarrierOptionDetail(_value, entityPermission);
            }
            
            if(!foundInSessionCache) {
                if(entityPermission.equals(EntityPermission.READ_ONLY)) {
                    session.putReadOnlyEntity(_pk, _entity);
                    session.getValueCache().put(_entity.getCarrierOptionDetailValue());
                } else {
                    session.putReadWriteEntity(_pk, _entity);
                }
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _entity;
    }
    
    public CarrierOptionDetail create(CarrierOption carrierOption, Party carrierParty, String carrierOptionName, Boolean isRecommended, Boolean isRequired, Selector recommendedGeoCodeSelector, Selector requiredGeoCodeSelector, Selector recommendedItemSelector, Selector requiredItemSelector, Selector recommendedOrderSelector, Selector requiredOrderSelector, Selector recommendedShipmentSelector, Selector requiredShipmentSelector, Boolean isDefault, Integer sortOrder, Long fromTime, Long thruTime)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        return create(carrierOption == null ? null : carrierOption.getPrimaryKey(), carrierParty == null ? null : carrierParty.getPrimaryKey(), carrierOptionName, isRecommended, isRequired, recommendedGeoCodeSelector == null ? null : recommendedGeoCodeSelector.getPrimaryKey(), requiredGeoCodeSelector == null ? null : requiredGeoCodeSelector.getPrimaryKey(), recommendedItemSelector == null ? null : recommendedItemSelector.getPrimaryKey(), requiredItemSelector == null ? null : requiredItemSelector.getPrimaryKey(), recommendedOrderSelector == null ? null : recommendedOrderSelector.getPrimaryKey(), requiredOrderSelector == null ? null : requiredOrderSelector.getPrimaryKey(), recommendedShipmentSelector == null ? null : recommendedShipmentSelector.getPrimaryKey(), requiredShipmentSelector == null ? null : requiredShipmentSelector.getPrimaryKey(), isDefault, sortOrder, fromTime, thruTime);
    }
    
    private void bindForCreate(PreparedStatement _ps, CarrierOptionDetailValue _value)
            throws SQLException {
        _ps.setLong(1, _value.getEntityId());
        
        CarrierOptionPK crroptdt_crropt_carrieroptionid = _value.getCarrierOptionPK();
        if(crroptdt_crropt_carrieroptionid == null)
            _ps.setNull(2, Types.BIGINT);
        else
            _ps.setLong(2, crroptdt_crropt_carrieroptionid.getEntityId());
            
        PartyPK crroptdt_carrierpartyid = _value.getCarrierPartyPK();
        if(crroptdt_carrierpartyid == null)
            _ps.setNull(3, Types.BIGINT);
        else
            _ps.setLong(3, crroptdt_carrierpartyid.getEntityId());
            
        String crroptdt_carrieroptionname = _value.getCarrierOptionName();
        if(crroptdt_carrieroptionname == null)
            _ps.setNull(4, Types.VARCHAR);
        else
            _ps.setString(4, crroptdt_carrieroptionname);
            
        Boolean crroptdt_isrecommended = _value.getIsRecommended();
        if(crroptdt_isrecommended == null)
            _ps.setNull(5, Types.BIT);
        else
            _ps.setInt(5, crroptdt_isrecommended? 1: 0);
            
        Boolean crroptdt_isrequired = _value.getIsRequired();
        if(crroptdt_isrequired == null)
            _ps.setNull(6, Types.BIT);
        else
            _ps.setInt(6, crroptdt_isrequired? 1: 0);
            
        SelectorPK crroptdt_recommendedgeocodeselectorid = _value.getRecommendedGeoCodeSelectorPK();
        if(crroptdt_recommendedgeocodeselectorid == null)
            _ps.setNull(7, Types.BIGINT);
        else
            _ps.setLong(7, crroptdt_recommendedgeocodeselectorid.getEntityId());
            
        SelectorPK crroptdt_requiredgeocodeselectorid = _value.getRequiredGeoCodeSelectorPK();
        if(crroptdt_requiredgeocodeselectorid == null)
            _ps.setNull(8, Types.BIGINT);
        else
            _ps.setLong(8, crroptdt_requiredgeocodeselectorid.getEntityId());
            
        SelectorPK crroptdt_recommendeditemselectorid = _value.getRecommendedItemSelectorPK();
        if(crroptdt_recommendeditemselectorid == null)
            _ps.setNull(9, Types.BIGINT);
        else
            _ps.setLong(9, crroptdt_recommendeditemselectorid.getEntityId());
            
        SelectorPK crroptdt_requireditemselectorid = _value.getRequiredItemSelectorPK();
        if(crroptdt_requireditemselectorid == null)
            _ps.setNull(10, Types.BIGINT);
        else
            _ps.setLong(10, crroptdt_requireditemselectorid.getEntityId());
            
        SelectorPK crroptdt_recommendedorderselectorid = _value.getRecommendedOrderSelectorPK();
        if(crroptdt_recommendedorderselectorid == null)
            _ps.setNull(11, Types.BIGINT);
        else
            _ps.setLong(11, crroptdt_recommendedorderselectorid.getEntityId());
            
        SelectorPK crroptdt_requiredorderselectorid = _value.getRequiredOrderSelectorPK();
        if(crroptdt_requiredorderselectorid == null)
            _ps.setNull(12, Types.BIGINT);
        else
            _ps.setLong(12, crroptdt_requiredorderselectorid.getEntityId());
            
        SelectorPK crroptdt_recommendedshipmentselectorid = _value.getRecommendedShipmentSelectorPK();
        if(crroptdt_recommendedshipmentselectorid == null)
            _ps.setNull(13, Types.BIGINT);
        else
            _ps.setLong(13, crroptdt_recommendedshipmentselectorid.getEntityId());
            
        SelectorPK crroptdt_requiredshipmentselectorid = _value.getRequiredShipmentSelectorPK();
        if(crroptdt_requiredshipmentselectorid == null)
            _ps.setNull(14, Types.BIGINT);
        else
            _ps.setLong(14, crroptdt_requiredshipmentselectorid.getEntityId());
            
        Boolean crroptdt_isdefault = _value.getIsDefault();
        if(crroptdt_isdefault == null)
            _ps.setNull(15, Types.BIT);
        else
            _ps.setInt(15, crroptdt_isdefault? 1: 0);
            
        Integer crroptdt_sortorder = _value.getSortOrder();
        if(crroptdt_sortorder == null)
            _ps.setNull(16, Types.INTEGER);
        else
            _ps.setInt(16, crroptdt_sortorder);
            
        Long crroptdt_fromtime = _value.getFromTime();
        if(crroptdt_fromtime == null)
            _ps.setNull(17, Types.BIGINT);
        else
            _ps.setLong(17, crroptdt_fromtime);
            
        Long crroptdt_thrutime = _value.getThruTime();
        if(crroptdt_thrutime == null)
            _ps.setNull(18, Types.BIGINT);
        else
            _ps.setLong(18, crroptdt_thrutime);
            
    }
    
    public CarrierOptionDetail create(CarrierOptionPK carrierOptionPK, PartyPK carrierPartyPK, String carrierOptionName, Boolean isRecommended, Boolean isRequired, SelectorPK recommendedGeoCodeSelectorPK, SelectorPK requiredGeoCodeSelectorPK, SelectorPK recommendedItemSelectorPK, SelectorPK requiredItemSelectorPK, SelectorPK recommendedOrderSelectorPK, SelectorPK requiredOrderSelectorPK, SelectorPK recommendedShipmentSelectorPK, SelectorPK requiredShipmentSelectorPK, Boolean isDefault, Integer sortOrder, Long fromTime, Long thruTime)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        CarrierOptionDetailPK _pk = getNextPK();
        CarrierOptionDetailValue _value = new CarrierOptionDetailValue(_pk, carrierOptionPK, carrierPartyPK, carrierOptionName, isRecommended, isRequired, recommendedGeoCodeSelectorPK, requiredGeoCodeSelectorPK, recommendedItemSelectorPK, requiredItemSelectorPK, recommendedOrderSelectorPK, requiredOrderSelectorPK, recommendedShipmentSelectorPK, requiredShipmentSelectorPK, 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);
        }
        
        CarrierOptionDetail _entity = new CarrierOptionDetail(_value, EntityPermission.READ_ONLY);
        session.putReadOnlyEntity(_pk, _entity);
        
        return _entity;
    }
    
    public void create(Collection<CarrierOptionDetailValue> _values)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        int _size = _values.size();
        
        if(_size > 0) {
            PreparedStatement _ps = session.prepareStatement(SQL_INSERT);
            List<CarrierOptionDetailValue> _cacheValues = new ArrayList<>(_size);
            
            try {
                for(CarrierOptionDetailValue _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) -> {
                CarrierOptionDetail _cacheEntity = new CarrierOptionDetail(_cacheValue, EntityPermission.READ_ONLY);
                
                session.putReadOnlyEntity(_cacheValue.getPrimaryKey(), _cacheEntity);
            });
        }
    }
    
    private boolean bindForStore(PreparedStatement _ps, CarrierOptionDetailValue _value)
            throws SQLException {
        boolean _hasBeenModified = _value.hasBeenModified();
        
        if(_hasBeenModified) {
            CarrierOptionPK crroptdt_crropt_carrieroptionid = _value.getCarrierOptionPK();
            if(crroptdt_crropt_carrieroptionid == null)
                _ps.setNull(1, Types.BIGINT);
            else
                _ps.setLong(1, crroptdt_crropt_carrieroptionid.getEntityId());
            
            PartyPK crroptdt_carrierpartyid = _value.getCarrierPartyPK();
            if(crroptdt_carrierpartyid == null)
                _ps.setNull(2, Types.BIGINT);
            else
                _ps.setLong(2, crroptdt_carrierpartyid.getEntityId());
            
            String crroptdt_carrieroptionname = _value.getCarrierOptionName();
            if(crroptdt_carrieroptionname == null)
                _ps.setNull(3, Types.VARCHAR);
            else
                _ps.setString(3, crroptdt_carrieroptionname);
            
            Boolean crroptdt_isrecommended = _value.getIsRecommended();
            if(crroptdt_isrecommended == null)
                _ps.setNull(4, Types.BIT);
            else
                _ps.setInt(4, crroptdt_isrecommended? 1: 0);
            
            Boolean crroptdt_isrequired = _value.getIsRequired();
            if(crroptdt_isrequired == null)
                _ps.setNull(5, Types.BIT);
            else
                _ps.setInt(5, crroptdt_isrequired? 1: 0);
            
            SelectorPK crroptdt_recommendedgeocodeselectorid = _value.getRecommendedGeoCodeSelectorPK();
            if(crroptdt_recommendedgeocodeselectorid == null)
                _ps.setNull(6, Types.BIGINT);
            else
                _ps.setLong(6, crroptdt_recommendedgeocodeselectorid.getEntityId());
            
            SelectorPK crroptdt_requiredgeocodeselectorid = _value.getRequiredGeoCodeSelectorPK();
            if(crroptdt_requiredgeocodeselectorid == null)
                _ps.setNull(7, Types.BIGINT);
            else
                _ps.setLong(7, crroptdt_requiredgeocodeselectorid.getEntityId());
            
            SelectorPK crroptdt_recommendeditemselectorid = _value.getRecommendedItemSelectorPK();
            if(crroptdt_recommendeditemselectorid == null)
                _ps.setNull(8, Types.BIGINT);
            else
                _ps.setLong(8, crroptdt_recommendeditemselectorid.getEntityId());
            
            SelectorPK crroptdt_requireditemselectorid = _value.getRequiredItemSelectorPK();
            if(crroptdt_requireditemselectorid == null)
                _ps.setNull(9, Types.BIGINT);
            else
                _ps.setLong(9, crroptdt_requireditemselectorid.getEntityId());
            
            SelectorPK crroptdt_recommendedorderselectorid = _value.getRecommendedOrderSelectorPK();
            if(crroptdt_recommendedorderselectorid == null)
                _ps.setNull(10, Types.BIGINT);
            else
                _ps.setLong(10, crroptdt_recommendedorderselectorid.getEntityId());
            
            SelectorPK crroptdt_requiredorderselectorid = _value.getRequiredOrderSelectorPK();
            if(crroptdt_requiredorderselectorid == null)
                _ps.setNull(11, Types.BIGINT);
            else
                _ps.setLong(11, crroptdt_requiredorderselectorid.getEntityId());
            
            SelectorPK crroptdt_recommendedshipmentselectorid = _value.getRecommendedShipmentSelectorPK();
            if(crroptdt_recommendedshipmentselectorid == null)
                _ps.setNull(12, Types.BIGINT);
            else
                _ps.setLong(12, crroptdt_recommendedshipmentselectorid.getEntityId());
            
            SelectorPK crroptdt_requiredshipmentselectorid = _value.getRequiredShipmentSelectorPK();
            if(crroptdt_requiredshipmentselectorid == null)
                _ps.setNull(13, Types.BIGINT);
            else
                _ps.setLong(13, crroptdt_requiredshipmentselectorid.getEntityId());
            
            Boolean crroptdt_isdefault = _value.getIsDefault();
            if(crroptdt_isdefault == null)
                _ps.setNull(14, Types.BIT);
            else
                _ps.setInt(14, crroptdt_isdefault? 1: 0);
            
            Integer crroptdt_sortorder = _value.getSortOrder();
            if(crroptdt_sortorder == null)
                _ps.setNull(15, Types.INTEGER);
            else
                _ps.setInt(15, crroptdt_sortorder);
            
            Long crroptdt_fromtime = _value.getFromTime();
            if(crroptdt_fromtime == null)
                _ps.setNull(16, Types.BIGINT);
            else
                _ps.setLong(16, crroptdt_fromtime);
            
            Long crroptdt_thrutime = _value.getThruTime();
            if(crroptdt_thrutime == null)
                _ps.setNull(17, Types.BIGINT);
            else
                _ps.setLong(17, crroptdt_thrutime);
            
            _ps.setLong(18, _value.getPrimaryKey().getEntityId());
            
            _value.clearHasBeenModified();
        }
        
        return _hasBeenModified;
    }
    
    @Override
    public void store(CarrierOptionDetail entity)
            throws PersistenceDatabaseException {
        PreparedStatement _ps = session.prepareStatement(SQL_UPDATE);
        
        try {
            CarrierOptionDetailValue _value = entity.getCarrierOptionDetailValue();
            
            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<CarrierOptionDetail> entities)
            throws PersistenceDatabaseException {
        if(entities.size() > 0) {
            PreparedStatement _ps = session.prepareStatement(SQL_UPDATE);
            int _modifiedEntities = 0;
            
            try {
                for(CarrierOptionDetail entity : entities) {
                    if(bindForStore(_ps, entity.getCarrierOptionDetailValue())) {
                        _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.getCarrierOptionDetailValue());
                    });
                }
            } catch (SQLException se) {
                throw new PersistenceDatabaseException(se);
            }
        }
    }
    
    @Override
    public void remove(CarrierOptionDetail entity)
            throws PersistenceDatabaseException {
        remove(entity.getPrimaryKey());
    }
    
    @Override
    public void remove(CarrierOptionDetailPK 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<CarrierOptionDetailPK> pks)
            throws PersistenceDatabaseException {
        if(pks.size() > 0) {
            PreparedStatement _ps = session.prepareStatement(SQL_DELETE);
            int _modifiedEntities = 0;
            
            try {
                for(CarrierOptionDetailPK 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(CarrierOptionDetailPK 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;
    }
    
}