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

/**
 * CarrierServiceOptionFactory.java
 */

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

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

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

import com.echothree.model.data.carrier.common.CarrierServiceOptionConstants;
import com.echothree.model.data.carrier.common.pk.CarrierServiceOptionPK;
import com.echothree.model.data.carrier.server.value.CarrierServiceOptionValue;
import com.echothree.model.data.carrier.server.entity.CarrierServiceOption;
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 CarrierServiceOptionFactory
        implements BaseFactory<CarrierServiceOptionPK, CarrierServiceOption> {
    
    @Inject
    Session session;
    
    //private static final Logger log = LoggerFactory.getLogger(CarrierServiceOptionFactory.class);
    
    final private static String SQL_SELECT_READ_ONLY = "SELECT crrsrvopt_carrierserviceoptionid, crrsrvopt_crrsrv_carrierserviceid, crrsrvopt_crropt_carrieroptionid, crrsrvopt_isrecommended, crrsrvopt_isrequired, crrsrvopt_recommendedgeocodeselectorid, crrsrvopt_requiredgeocodeselectorid, crrsrvopt_recommendeditemselectorid, crrsrvopt_requireditemselectorid, crrsrvopt_recommendedorderselectorid, crrsrvopt_requiredorderselectorid, crrsrvopt_recommendedshipmentselectorid, crrsrvopt_requiredshipmentselectorid, crrsrvopt_fromtime, crrsrvopt_thrutime FROM carrierserviceoptions WHERE crrsrvopt_carrierserviceoptionid = ?";
    final private static String SQL_SELECT_READ_WRITE = "SELECT crrsrvopt_carrierserviceoptionid, crrsrvopt_crrsrv_carrierserviceid, crrsrvopt_crropt_carrieroptionid, crrsrvopt_isrecommended, crrsrvopt_isrequired, crrsrvopt_recommendedgeocodeselectorid, crrsrvopt_requiredgeocodeselectorid, crrsrvopt_recommendeditemselectorid, crrsrvopt_requireditemselectorid, crrsrvopt_recommendedorderselectorid, crrsrvopt_requiredorderselectorid, crrsrvopt_recommendedshipmentselectorid, crrsrvopt_requiredshipmentselectorid, crrsrvopt_fromtime, crrsrvopt_thrutime FROM carrierserviceoptions WHERE crrsrvopt_carrierserviceoptionid = ? FOR UPDATE";
    final private static String SQL_INSERT = "INSERT INTO carrierserviceoptions (crrsrvopt_carrierserviceoptionid, crrsrvopt_crrsrv_carrierserviceid, crrsrvopt_crropt_carrieroptionid, crrsrvopt_isrecommended, crrsrvopt_isrequired, crrsrvopt_recommendedgeocodeselectorid, crrsrvopt_requiredgeocodeselectorid, crrsrvopt_recommendeditemselectorid, crrsrvopt_requireditemselectorid, crrsrvopt_recommendedorderselectorid, crrsrvopt_requiredorderselectorid, crrsrvopt_recommendedshipmentselectorid, crrsrvopt_requiredshipmentselectorid, crrsrvopt_fromtime, crrsrvopt_thrutime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
    final private static String SQL_UPDATE = "UPDATE carrierserviceoptions SET crrsrvopt_crrsrv_carrierserviceid = ?, crrsrvopt_crropt_carrieroptionid = ?, crrsrvopt_isrecommended = ?, crrsrvopt_isrequired = ?, crrsrvopt_recommendedgeocodeselectorid = ?, crrsrvopt_requiredgeocodeselectorid = ?, crrsrvopt_recommendeditemselectorid = ?, crrsrvopt_requireditemselectorid = ?, crrsrvopt_recommendedorderselectorid = ?, crrsrvopt_requiredorderselectorid = ?, crrsrvopt_recommendedshipmentselectorid = ?, crrsrvopt_requiredshipmentselectorid = ?, crrsrvopt_fromtime = ?, crrsrvopt_thrutime = ? WHERE crrsrvopt_carrierserviceoptionid = ?";
    final private static String SQL_DELETE = "DELETE FROM carrierserviceoptions WHERE crrsrvopt_carrierserviceoptionid = ?";
    final private static String SQL_VALID = "SELECT COUNT(*) FROM carrierserviceoptions WHERE crrsrvopt_carrierserviceoptionid = ?";
    
    final private static String PK_COLUMN = "crrsrvopt_carrierserviceoptionid";
    final private static String ALL_COLUMNS = "crrsrvopt_carrierserviceoptionid, crrsrvopt_crrsrv_carrierserviceid, crrsrvopt_crropt_carrieroptionid, crrsrvopt_isrecommended, crrsrvopt_isrequired, crrsrvopt_recommendedgeocodeselectorid, crrsrvopt_requiredgeocodeselectorid, crrsrvopt_recommendeditemselectorid, crrsrvopt_requireditemselectorid, crrsrvopt_recommendedorderselectorid, crrsrvopt_requiredorderselectorid, crrsrvopt_recommendedshipmentselectorid, crrsrvopt_requiredshipmentselectorid, crrsrvopt_fromtime, crrsrvopt_thrutime";
    final public static String TABLE_NAME = "carrierserviceoptions";
    
    final public static String CRRSRVOPT_CARRIERSERVICEOPTIONID = "crrsrvopt_carrierserviceoptionid";
    final public static String CRRSRVOPT_CRRSRV_CARRIERSERVICEID = "crrsrvopt_crrsrv_carrierserviceid";
    final public static String CRRSRVOPT_CRROPT_CARRIEROPTIONID = "crrsrvopt_crropt_carrieroptionid";
    final public static String CRRSRVOPT_ISRECOMMENDED = "crrsrvopt_isrecommended";
    final public static String CRRSRVOPT_ISREQUIRED = "crrsrvopt_isrequired";
    final public static String CRRSRVOPT_RECOMMENDEDGEOCODESELECTORID = "crrsrvopt_recommendedgeocodeselectorid";
    final public static String CRRSRVOPT_REQUIREDGEOCODESELECTORID = "crrsrvopt_requiredgeocodeselectorid";
    final public static String CRRSRVOPT_RECOMMENDEDITEMSELECTORID = "crrsrvopt_recommendeditemselectorid";
    final public static String CRRSRVOPT_REQUIREDITEMSELECTORID = "crrsrvopt_requireditemselectorid";
    final public static String CRRSRVOPT_RECOMMENDEDORDERSELECTORID = "crrsrvopt_recommendedorderselectorid";
    final public static String CRRSRVOPT_REQUIREDORDERSELECTORID = "crrsrvopt_requiredorderselectorid";
    final public static String CRRSRVOPT_RECOMMENDEDSHIPMENTSELECTORID = "crrsrvopt_recommendedshipmentselectorid";
    final public static String CRRSRVOPT_REQUIREDSHIPMENTSELECTORID = "crrsrvopt_requiredshipmentselectorid";
    final public static String CRRSRVOPT_FROMTIME = "crrsrvopt_fromtime";
    final public static String CRRSRVOPT_THRUTIME = "crrsrvopt_thrutime";
    
    final private static EntityIdGenerator entityIdGenerator = new EntityIdGenerator(CarrierServiceOptionConstants.COMPONENT_VENDOR_NAME, CarrierServiceOptionConstants.ENTITY_TYPE_NAME);
    
    /** Creates a new instance of CarrierServiceOptionFactory */
    protected CarrierServiceOptionFactory() {
        super();
    }
    
    public static CarrierServiceOptionFactory getInstance() {
        return CDI.current().select(CarrierServiceOptionFactory.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 CarrierServiceOptionConstants.COMPONENT_VENDOR_NAME;
    }
    
    @Override
    public String getEntityTypeName() {
        return CarrierServiceOptionConstants.ENTITY_TYPE_NAME;
    }
    
    public PreparedStatement prepareStatement(String query) {
        return session.prepareStatement(CarrierServiceOptionFactory.class, query);
    }
    
    public CarrierServiceOptionPK getNextPK() {
        return new CarrierServiceOptionPK(entityIdGenerator.getNextEntityId());
    }
    
    public Set<CarrierServiceOptionPK> getPKsFromResultSetAsSet(ResultSet rs)
            throws PersistenceDatabaseException {
        Set<CarrierServiceOptionPK> _result = new HashSet<>();
        
        try {
            while(rs.next()) {
                _result.add(getPKFromResultSet(rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public java.util.List<CarrierServiceOptionPK> getPKsFromResultSetAsList(ResultSet rs)
            throws PersistenceDatabaseException {
        java.util.List<CarrierServiceOptionPK> _result = new ArrayList<>();
        
        try {
            while(rs.next()) {
                _result.add(getPKFromResultSet(rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public CarrierServiceOptionPK getPKFromResultSet(ResultSet rs)
            throws PersistenceDatabaseException {
        CarrierServiceOptionPK _result;
        
        try {
            long crrsrvopt_carrierserviceoptionid = rs.getLong(CRRSRVOPT_CARRIERSERVICEOPTIONID);
            Long _entityId = rs.wasNull() ? null : crrsrvopt_carrierserviceoptionid;
            
            _result = new CarrierServiceOptionPK(_entityId);
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public java.util.List<CarrierServiceOptionValue> getValuesFromPKs(Collection<CarrierServiceOptionPK> pks)
            throws PersistenceDatabaseException {
        java.util.List<CarrierServiceOptionValue> _values = new ArrayList<>(pks.size());
        
        for(CarrierServiceOptionPK _pk: pks) {
            _values.add(getValueFromPK(_pk));
        }
        
        return _values;
    }
    
    public CarrierServiceOptionValue getValueFromPK(CarrierServiceOptionPK pk)
            throws PersistenceDatabaseException {
        CarrierServiceOptionValue _value;
        
        // See if we already have the entity in the session cache
        CarrierServiceOption _entity = (CarrierServiceOption)session.getEntity(pk);
        if(_entity == null)
            _value = getEntityFromPK(EntityPermission.READ_ONLY, pk).getCarrierServiceOptionValue();
        else
            _value = _entity.getCarrierServiceOptionValue();
        
        return _value;
    }
    
    public java.util.List<CarrierServiceOptionValue> getValuesFromResultSet(ResultSet rs)
            throws PersistenceDatabaseException {
        java.util.List<CarrierServiceOptionValue> _result = new ArrayList<>();
        
        try {
            while(rs.next()) {
                _result.add(getValueFromResultSet(rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public CarrierServiceOptionValue getValueFromResultSet(ResultSet rs)
            throws PersistenceDatabaseException {
        CarrierServiceOptionValue _value;
        
        try {
            Long crrsrvopt_carrierserviceoptionid = rs.getLong(CRRSRVOPT_CARRIERSERVICEOPTIONID);
            CarrierServiceOptionPK _pk = new CarrierServiceOptionPK(crrsrvopt_carrierserviceoptionid);
            
            // See if we already have the entity in the session cache
            CarrierServiceOption _entity = (CarrierServiceOption)session.getEntity(_pk);
            
            if(_entity == null) {
                Long crrsrvopt_crrsrv_carrierserviceid = rs.getLong(CRRSRVOPT_CRRSRV_CARRIERSERVICEID);
                if(rs.wasNull())
                    crrsrvopt_crrsrv_carrierserviceid = null;
                
                Long crrsrvopt_crropt_carrieroptionid = rs.getLong(CRRSRVOPT_CRROPT_CARRIEROPTIONID);
                if(rs.wasNull())
                    crrsrvopt_crropt_carrieroptionid = null;
                
                Boolean crrsrvopt_isrecommended = rs.getInt(CRRSRVOPT_ISRECOMMENDED) == 1;
                if(rs.wasNull())
                    crrsrvopt_isrecommended = null;
                
                Boolean crrsrvopt_isrequired = rs.getInt(CRRSRVOPT_ISREQUIRED) == 1;
                if(rs.wasNull())
                    crrsrvopt_isrequired = null;
                
                Long crrsrvopt_recommendedgeocodeselectorid = rs.getLong(CRRSRVOPT_RECOMMENDEDGEOCODESELECTORID);
                if(rs.wasNull())
                    crrsrvopt_recommendedgeocodeselectorid = null;
                
                Long crrsrvopt_requiredgeocodeselectorid = rs.getLong(CRRSRVOPT_REQUIREDGEOCODESELECTORID);
                if(rs.wasNull())
                    crrsrvopt_requiredgeocodeselectorid = null;
                
                Long crrsrvopt_recommendeditemselectorid = rs.getLong(CRRSRVOPT_RECOMMENDEDITEMSELECTORID);
                if(rs.wasNull())
                    crrsrvopt_recommendeditemselectorid = null;
                
                Long crrsrvopt_requireditemselectorid = rs.getLong(CRRSRVOPT_REQUIREDITEMSELECTORID);
                if(rs.wasNull())
                    crrsrvopt_requireditemselectorid = null;
                
                Long crrsrvopt_recommendedorderselectorid = rs.getLong(CRRSRVOPT_RECOMMENDEDORDERSELECTORID);
                if(rs.wasNull())
                    crrsrvopt_recommendedorderselectorid = null;
                
                Long crrsrvopt_requiredorderselectorid = rs.getLong(CRRSRVOPT_REQUIREDORDERSELECTORID);
                if(rs.wasNull())
                    crrsrvopt_requiredorderselectorid = null;
                
                Long crrsrvopt_recommendedshipmentselectorid = rs.getLong(CRRSRVOPT_RECOMMENDEDSHIPMENTSELECTORID);
                if(rs.wasNull())
                    crrsrvopt_recommendedshipmentselectorid = null;
                
                Long crrsrvopt_requiredshipmentselectorid = rs.getLong(CRRSRVOPT_REQUIREDSHIPMENTSELECTORID);
                if(rs.wasNull())
                    crrsrvopt_requiredshipmentselectorid = null;
                
                Long crrsrvopt_fromtime = rs.getLong(CRRSRVOPT_FROMTIME);
                if(rs.wasNull())
                    crrsrvopt_fromtime = null;
                
                Long crrsrvopt_thrutime = rs.getLong(CRRSRVOPT_THRUTIME);
                if(rs.wasNull())
                    crrsrvopt_thrutime = null;
                
                _value = new CarrierServiceOptionValue(_pk, new CarrierServicePK(crrsrvopt_crrsrv_carrierserviceid), new CarrierOptionPK(crrsrvopt_crropt_carrieroptionid), crrsrvopt_isrecommended, crrsrvopt_isrequired, new SelectorPK(crrsrvopt_recommendedgeocodeselectorid), new SelectorPK(crrsrvopt_requiredgeocodeselectorid), new SelectorPK(crrsrvopt_recommendeditemselectorid), new SelectorPK(crrsrvopt_requireditemselectorid), new SelectorPK(crrsrvopt_recommendedorderselectorid), new SelectorPK(crrsrvopt_requiredorderselectorid), new SelectorPK(crrsrvopt_recommendedshipmentselectorid), new SelectorPK(crrsrvopt_requiredshipmentselectorid), crrsrvopt_fromtime, crrsrvopt_thrutime);
            } else
                _value = _entity.getCarrierServiceOptionValue();
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _value;
    }
    
    public java.util.List<CarrierServiceOption> getEntitiesFromPKs(EntityPermission entityPermission, Collection<CarrierServiceOptionPK> pks)
            throws PersistenceDatabaseException {
        java.util.List<CarrierServiceOption> _entities = new ArrayList<>(pks.size());
        
        for(CarrierServiceOptionPK _pk: pks) {
            _entities.add(getEntityFromPK(entityPermission, _pk));
        }
        
        return _entities;
    }
    
    public CarrierServiceOption getEntityFromValue(EntityPermission entityPermission, CarrierServiceOptionValue value) {
        return getEntityFromPK(entityPermission, value.getPrimaryKey());
    }
    
    public CarrierServiceOption getEntityFromCache(CarrierServiceOptionPK pk) {
        CarrierServiceOptionValue _value = (CarrierServiceOptionValue)session.getValueCache().get(pk);
    
        return _value == null ? null : new CarrierServiceOption(_value, EntityPermission.READ_ONLY);
    }
    
    public CarrierServiceOption getEntityFromPK(EntityPermission entityPermission, CarrierServiceOptionPK pk)
            throws PersistenceDatabaseException {
        CarrierServiceOption _entity;
        
        // See if we already have the entity in the session cache
        _entity = (CarrierServiceOption)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<CarrierServiceOptionPK> getPKsFromQueryAsSet(PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        Set<CarrierServiceOptionPK> _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<CarrierServiceOptionPK> getPKsFromQueryAsList(PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        java.util.List<CarrierServiceOptionPK> _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 CarrierServiceOptionPK getPKFromQuery(PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        CarrierServiceOptionPK _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<CarrierServiceOption> getEntitiesFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(CarrierServiceOptionFactory.class, queryMap.get(entityPermission));
        
        return getEntitiesFromQuery(entityPermission, ps, params);
    }
    
    public java.util.List<CarrierServiceOption> getEntitiesFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(CarrierServiceOptionFactory.class, queryMap.get(entityPermission));
        
        return getEntitiesFromQuery(entityPermission, ps);
    }
    
    public java.util.List<CarrierServiceOption> getEntitiesFromQuery(EntityPermission entityPermission, PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        java.util.List<CarrierServiceOption> _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 CarrierServiceOption getEntityFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(CarrierServiceOptionFactory.class, queryMap.get(entityPermission));
        
        return getEntityFromQuery(entityPermission, ps, params);
    }
    
    public CarrierServiceOption getEntityFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(CarrierServiceOptionFactory.class, queryMap.get(entityPermission));
        
        return getEntityFromQuery(entityPermission, ps);
    }
    
    public CarrierServiceOption getEntityFromQuery(EntityPermission entityPermission, PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        CarrierServiceOption _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<CarrierServiceOption> getEntitiesFromResultSet(EntityPermission entityPermission, ResultSet rs)
            throws PersistenceDatabaseException {
        java.util.List<CarrierServiceOption> _result = new ArrayList<>();
        
        try {
            while(rs.next()) {
                _result.add(getEntityFromResultSet(entityPermission, rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public CarrierServiceOption getEntityFromResultSet(EntityPermission entityPermission, ResultSet rs)
            throws PersistenceDatabaseException {
        CarrierServiceOption _entity;
        
        try {
            Long crrsrvopt_carrierserviceoptionid = rs.getLong(CRRSRVOPT_CARRIERSERVICEOPTIONID);
            CarrierServiceOptionPK _pk = new CarrierServiceOptionPK(crrsrvopt_carrierserviceoptionid);
            
            // See if we already have the entity in the session cache
            _entity = (CarrierServiceOption)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 crrsrvopt_crrsrv_carrierserviceid = rs.getLong(CRRSRVOPT_CRRSRV_CARRIERSERVICEID);
                if(rs.wasNull())
                    crrsrvopt_crrsrv_carrierserviceid = null;
                
                Long crrsrvopt_crropt_carrieroptionid = rs.getLong(CRRSRVOPT_CRROPT_CARRIEROPTIONID);
                if(rs.wasNull())
                    crrsrvopt_crropt_carrieroptionid = null;
                
                Boolean crrsrvopt_isrecommended = rs.getInt(CRRSRVOPT_ISRECOMMENDED) == 1;
                if(rs.wasNull())
                    crrsrvopt_isrecommended = null;
                
                Boolean crrsrvopt_isrequired = rs.getInt(CRRSRVOPT_ISREQUIRED) == 1;
                if(rs.wasNull())
                    crrsrvopt_isrequired = null;
                
                Long crrsrvopt_recommendedgeocodeselectorid = rs.getLong(CRRSRVOPT_RECOMMENDEDGEOCODESELECTORID);
                if(rs.wasNull())
                    crrsrvopt_recommendedgeocodeselectorid = null;
                
                Long crrsrvopt_requiredgeocodeselectorid = rs.getLong(CRRSRVOPT_REQUIREDGEOCODESELECTORID);
                if(rs.wasNull())
                    crrsrvopt_requiredgeocodeselectorid = null;
                
                Long crrsrvopt_recommendeditemselectorid = rs.getLong(CRRSRVOPT_RECOMMENDEDITEMSELECTORID);
                if(rs.wasNull())
                    crrsrvopt_recommendeditemselectorid = null;
                
                Long crrsrvopt_requireditemselectorid = rs.getLong(CRRSRVOPT_REQUIREDITEMSELECTORID);
                if(rs.wasNull())
                    crrsrvopt_requireditemselectorid = null;
                
                Long crrsrvopt_recommendedorderselectorid = rs.getLong(CRRSRVOPT_RECOMMENDEDORDERSELECTORID);
                if(rs.wasNull())
                    crrsrvopt_recommendedorderselectorid = null;
                
                Long crrsrvopt_requiredorderselectorid = rs.getLong(CRRSRVOPT_REQUIREDORDERSELECTORID);
                if(rs.wasNull())
                    crrsrvopt_requiredorderselectorid = null;
                
                Long crrsrvopt_recommendedshipmentselectorid = rs.getLong(CRRSRVOPT_RECOMMENDEDSHIPMENTSELECTORID);
                if(rs.wasNull())
                    crrsrvopt_recommendedshipmentselectorid = null;
                
                Long crrsrvopt_requiredshipmentselectorid = rs.getLong(CRRSRVOPT_REQUIREDSHIPMENTSELECTORID);
                if(rs.wasNull())
                    crrsrvopt_requiredshipmentselectorid = null;
                
                Long crrsrvopt_fromtime = rs.getLong(CRRSRVOPT_FROMTIME);
                if(rs.wasNull())
                    crrsrvopt_fromtime = null;
                
                Long crrsrvopt_thrutime = rs.getLong(CRRSRVOPT_THRUTIME);
                if(rs.wasNull())
                    crrsrvopt_thrutime = null;
                
                CarrierServiceOptionValue _value = new CarrierServiceOptionValue(_pk, crrsrvopt_crrsrv_carrierserviceid == null? null: new CarrierServicePK(crrsrvopt_crrsrv_carrierserviceid), crrsrvopt_crropt_carrieroptionid == null? null: new CarrierOptionPK(crrsrvopt_crropt_carrieroptionid), crrsrvopt_isrecommended, crrsrvopt_isrequired, crrsrvopt_recommendedgeocodeselectorid == null? null: new SelectorPK(crrsrvopt_recommendedgeocodeselectorid), crrsrvopt_requiredgeocodeselectorid == null? null: new SelectorPK(crrsrvopt_requiredgeocodeselectorid), crrsrvopt_recommendeditemselectorid == null? null: new SelectorPK(crrsrvopt_recommendeditemselectorid), crrsrvopt_requireditemselectorid == null? null: new SelectorPK(crrsrvopt_requireditemselectorid), crrsrvopt_recommendedorderselectorid == null? null: new SelectorPK(crrsrvopt_recommendedorderselectorid), crrsrvopt_requiredorderselectorid == null? null: new SelectorPK(crrsrvopt_requiredorderselectorid), crrsrvopt_recommendedshipmentselectorid == null? null: new SelectorPK(crrsrvopt_recommendedshipmentselectorid), crrsrvopt_requiredshipmentselectorid == null? null: new SelectorPK(crrsrvopt_requiredshipmentselectorid), crrsrvopt_fromtime, crrsrvopt_thrutime);
                _entity = new CarrierServiceOption(_value, entityPermission);
            }
            
            if(!foundInSessionCache) {
                if(entityPermission.equals(EntityPermission.READ_ONLY)) {
                    session.putReadOnlyEntity(_pk, _entity);
                    session.getValueCache().put(_entity.getCarrierServiceOptionValue());
                } else {
                    session.putReadWriteEntity(_pk, _entity);
                }
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _entity;
    }
    
    public CarrierServiceOption create(CarrierService carrierService, CarrierOption carrierOption, Boolean isRecommended, Boolean isRequired, Selector recommendedGeoCodeSelector, Selector requiredGeoCodeSelector, Selector recommendedItemSelector, Selector requiredItemSelector, Selector recommendedOrderSelector, Selector requiredOrderSelector, Selector recommendedShipmentSelector, Selector requiredShipmentSelector, Long fromTime, Long thruTime)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        return create(carrierService == null ? null : carrierService.getPrimaryKey(), carrierOption == null ? null : carrierOption.getPrimaryKey(), 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(), fromTime, thruTime);
    }
    
    private void bindForCreate(PreparedStatement _ps, CarrierServiceOptionValue _value)
            throws SQLException {
        _ps.setLong(1, _value.getEntityId());
        
        CarrierServicePK crrsrvopt_crrsrv_carrierserviceid = _value.getCarrierServicePK();
        if(crrsrvopt_crrsrv_carrierserviceid == null)
            _ps.setNull(2, Types.BIGINT);
        else
            _ps.setLong(2, crrsrvopt_crrsrv_carrierserviceid.getEntityId());
            
        CarrierOptionPK crrsrvopt_crropt_carrieroptionid = _value.getCarrierOptionPK();
        if(crrsrvopt_crropt_carrieroptionid == null)
            _ps.setNull(3, Types.BIGINT);
        else
            _ps.setLong(3, crrsrvopt_crropt_carrieroptionid.getEntityId());
            
        Boolean crrsrvopt_isrecommended = _value.getIsRecommended();
        if(crrsrvopt_isrecommended == null)
            _ps.setNull(4, Types.BIT);
        else
            _ps.setInt(4, crrsrvopt_isrecommended? 1: 0);
            
        Boolean crrsrvopt_isrequired = _value.getIsRequired();
        if(crrsrvopt_isrequired == null)
            _ps.setNull(5, Types.BIT);
        else
            _ps.setInt(5, crrsrvopt_isrequired? 1: 0);
            
        SelectorPK crrsrvopt_recommendedgeocodeselectorid = _value.getRecommendedGeoCodeSelectorPK();
        if(crrsrvopt_recommendedgeocodeselectorid == null)
            _ps.setNull(6, Types.BIGINT);
        else
            _ps.setLong(6, crrsrvopt_recommendedgeocodeselectorid.getEntityId());
            
        SelectorPK crrsrvopt_requiredgeocodeselectorid = _value.getRequiredGeoCodeSelectorPK();
        if(crrsrvopt_requiredgeocodeselectorid == null)
            _ps.setNull(7, Types.BIGINT);
        else
            _ps.setLong(7, crrsrvopt_requiredgeocodeselectorid.getEntityId());
            
        SelectorPK crrsrvopt_recommendeditemselectorid = _value.getRecommendedItemSelectorPK();
        if(crrsrvopt_recommendeditemselectorid == null)
            _ps.setNull(8, Types.BIGINT);
        else
            _ps.setLong(8, crrsrvopt_recommendeditemselectorid.getEntityId());
            
        SelectorPK crrsrvopt_requireditemselectorid = _value.getRequiredItemSelectorPK();
        if(crrsrvopt_requireditemselectorid == null)
            _ps.setNull(9, Types.BIGINT);
        else
            _ps.setLong(9, crrsrvopt_requireditemselectorid.getEntityId());
            
        SelectorPK crrsrvopt_recommendedorderselectorid = _value.getRecommendedOrderSelectorPK();
        if(crrsrvopt_recommendedorderselectorid == null)
            _ps.setNull(10, Types.BIGINT);
        else
            _ps.setLong(10, crrsrvopt_recommendedorderselectorid.getEntityId());
            
        SelectorPK crrsrvopt_requiredorderselectorid = _value.getRequiredOrderSelectorPK();
        if(crrsrvopt_requiredorderselectorid == null)
            _ps.setNull(11, Types.BIGINT);
        else
            _ps.setLong(11, crrsrvopt_requiredorderselectorid.getEntityId());
            
        SelectorPK crrsrvopt_recommendedshipmentselectorid = _value.getRecommendedShipmentSelectorPK();
        if(crrsrvopt_recommendedshipmentselectorid == null)
            _ps.setNull(12, Types.BIGINT);
        else
            _ps.setLong(12, crrsrvopt_recommendedshipmentselectorid.getEntityId());
            
        SelectorPK crrsrvopt_requiredshipmentselectorid = _value.getRequiredShipmentSelectorPK();
        if(crrsrvopt_requiredshipmentselectorid == null)
            _ps.setNull(13, Types.BIGINT);
        else
            _ps.setLong(13, crrsrvopt_requiredshipmentselectorid.getEntityId());
            
        Long crrsrvopt_fromtime = _value.getFromTime();
        if(crrsrvopt_fromtime == null)
            _ps.setNull(14, Types.BIGINT);
        else
            _ps.setLong(14, crrsrvopt_fromtime);
            
        Long crrsrvopt_thrutime = _value.getThruTime();
        if(crrsrvopt_thrutime == null)
            _ps.setNull(15, Types.BIGINT);
        else
            _ps.setLong(15, crrsrvopt_thrutime);
            
    }
    
    public CarrierServiceOption create(CarrierServicePK carrierServicePK, CarrierOptionPK carrierOptionPK, Boolean isRecommended, Boolean isRequired, SelectorPK recommendedGeoCodeSelectorPK, SelectorPK requiredGeoCodeSelectorPK, SelectorPK recommendedItemSelectorPK, SelectorPK requiredItemSelectorPK, SelectorPK recommendedOrderSelectorPK, SelectorPK requiredOrderSelectorPK, SelectorPK recommendedShipmentSelectorPK, SelectorPK requiredShipmentSelectorPK, Long fromTime, Long thruTime)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        CarrierServiceOptionPK _pk = getNextPK();
        CarrierServiceOptionValue _value = new CarrierServiceOptionValue(_pk, carrierServicePK, carrierOptionPK, isRecommended, isRequired, recommendedGeoCodeSelectorPK, requiredGeoCodeSelectorPK, recommendedItemSelectorPK, requiredItemSelectorPK, recommendedOrderSelectorPK, requiredOrderSelectorPK, recommendedShipmentSelectorPK, requiredShipmentSelectorPK, 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);
        }
        
        CarrierServiceOption _entity = new CarrierServiceOption(_value, EntityPermission.READ_ONLY);
        session.putReadOnlyEntity(_pk, _entity);
        
        return _entity;
    }
    
    public void create(Collection<CarrierServiceOptionValue> _values)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        int _size = _values.size();
        
        if(_size > 0) {
            PreparedStatement _ps = session.prepareStatement(SQL_INSERT);
            List<CarrierServiceOptionValue> _cacheValues = new ArrayList<>(_size);
            
            try {
                for(CarrierServiceOptionValue _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) -> {
                CarrierServiceOption _cacheEntity = new CarrierServiceOption(_cacheValue, EntityPermission.READ_ONLY);
                
                session.putReadOnlyEntity(_cacheValue.getPrimaryKey(), _cacheEntity);
            });
        }
    }
    
    private boolean bindForStore(PreparedStatement _ps, CarrierServiceOptionValue _value)
            throws SQLException {
        boolean _hasBeenModified = _value.hasBeenModified();
        
        if(_hasBeenModified) {
            CarrierServicePK crrsrvopt_crrsrv_carrierserviceid = _value.getCarrierServicePK();
            if(crrsrvopt_crrsrv_carrierserviceid == null)
                _ps.setNull(1, Types.BIGINT);
            else
                _ps.setLong(1, crrsrvopt_crrsrv_carrierserviceid.getEntityId());
            
            CarrierOptionPK crrsrvopt_crropt_carrieroptionid = _value.getCarrierOptionPK();
            if(crrsrvopt_crropt_carrieroptionid == null)
                _ps.setNull(2, Types.BIGINT);
            else
                _ps.setLong(2, crrsrvopt_crropt_carrieroptionid.getEntityId());
            
            Boolean crrsrvopt_isrecommended = _value.getIsRecommended();
            if(crrsrvopt_isrecommended == null)
                _ps.setNull(3, Types.BIT);
            else
                _ps.setInt(3, crrsrvopt_isrecommended? 1: 0);
            
            Boolean crrsrvopt_isrequired = _value.getIsRequired();
            if(crrsrvopt_isrequired == null)
                _ps.setNull(4, Types.BIT);
            else
                _ps.setInt(4, crrsrvopt_isrequired? 1: 0);
            
            SelectorPK crrsrvopt_recommendedgeocodeselectorid = _value.getRecommendedGeoCodeSelectorPK();
            if(crrsrvopt_recommendedgeocodeselectorid == null)
                _ps.setNull(5, Types.BIGINT);
            else
                _ps.setLong(5, crrsrvopt_recommendedgeocodeselectorid.getEntityId());
            
            SelectorPK crrsrvopt_requiredgeocodeselectorid = _value.getRequiredGeoCodeSelectorPK();
            if(crrsrvopt_requiredgeocodeselectorid == null)
                _ps.setNull(6, Types.BIGINT);
            else
                _ps.setLong(6, crrsrvopt_requiredgeocodeselectorid.getEntityId());
            
            SelectorPK crrsrvopt_recommendeditemselectorid = _value.getRecommendedItemSelectorPK();
            if(crrsrvopt_recommendeditemselectorid == null)
                _ps.setNull(7, Types.BIGINT);
            else
                _ps.setLong(7, crrsrvopt_recommendeditemselectorid.getEntityId());
            
            SelectorPK crrsrvopt_requireditemselectorid = _value.getRequiredItemSelectorPK();
            if(crrsrvopt_requireditemselectorid == null)
                _ps.setNull(8, Types.BIGINT);
            else
                _ps.setLong(8, crrsrvopt_requireditemselectorid.getEntityId());
            
            SelectorPK crrsrvopt_recommendedorderselectorid = _value.getRecommendedOrderSelectorPK();
            if(crrsrvopt_recommendedorderselectorid == null)
                _ps.setNull(9, Types.BIGINT);
            else
                _ps.setLong(9, crrsrvopt_recommendedorderselectorid.getEntityId());
            
            SelectorPK crrsrvopt_requiredorderselectorid = _value.getRequiredOrderSelectorPK();
            if(crrsrvopt_requiredorderselectorid == null)
                _ps.setNull(10, Types.BIGINT);
            else
                _ps.setLong(10, crrsrvopt_requiredorderselectorid.getEntityId());
            
            SelectorPK crrsrvopt_recommendedshipmentselectorid = _value.getRecommendedShipmentSelectorPK();
            if(crrsrvopt_recommendedshipmentselectorid == null)
                _ps.setNull(11, Types.BIGINT);
            else
                _ps.setLong(11, crrsrvopt_recommendedshipmentselectorid.getEntityId());
            
            SelectorPK crrsrvopt_requiredshipmentselectorid = _value.getRequiredShipmentSelectorPK();
            if(crrsrvopt_requiredshipmentselectorid == null)
                _ps.setNull(12, Types.BIGINT);
            else
                _ps.setLong(12, crrsrvopt_requiredshipmentselectorid.getEntityId());
            
            Long crrsrvopt_fromtime = _value.getFromTime();
            if(crrsrvopt_fromtime == null)
                _ps.setNull(13, Types.BIGINT);
            else
                _ps.setLong(13, crrsrvopt_fromtime);
            
            Long crrsrvopt_thrutime = _value.getThruTime();
            if(crrsrvopt_thrutime == null)
                _ps.setNull(14, Types.BIGINT);
            else
                _ps.setLong(14, crrsrvopt_thrutime);
            
            _ps.setLong(15, _value.getPrimaryKey().getEntityId());
            
            _value.clearHasBeenModified();
        }
        
        return _hasBeenModified;
    }
    
    @Override
    public void store(CarrierServiceOption entity)
            throws PersistenceDatabaseException {
        PreparedStatement _ps = session.prepareStatement(SQL_UPDATE);
        
        try {
            CarrierServiceOptionValue _value = entity.getCarrierServiceOptionValue();
            
            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<CarrierServiceOption> entities)
            throws PersistenceDatabaseException {
        if(entities.size() > 0) {
            PreparedStatement _ps = session.prepareStatement(SQL_UPDATE);
            int _modifiedEntities = 0;
            
            try {
                for(CarrierServiceOption entity : entities) {
                    if(bindForStore(_ps, entity.getCarrierServiceOptionValue())) {
                        _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.getCarrierServiceOptionValue());
                    });
                }
            } catch (SQLException se) {
                throw new PersistenceDatabaseException(se);
            }
        }
    }
    
    @Override
    public void remove(CarrierServiceOption entity)
            throws PersistenceDatabaseException {
        remove(entity.getPrimaryKey());
    }
    
    @Override
    public void remove(CarrierServiceOptionPK 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<CarrierServiceOptionPK> pks)
            throws PersistenceDatabaseException {
        if(pks.size() > 0) {
            PreparedStatement _ps = session.prepareStatement(SQL_DELETE);
            int _modifiedEntities = 0;
            
            try {
                for(CarrierServiceOptionPK 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(CarrierServiceOptionPK 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;
    }
    
}