// --------------------------------------------------------------------------------
// Copyright 2002-2024 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
// --------------------------------------------------------------------------------

/**
 * ShipmentDetailFactory.java
 */

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

import com.echothree.model.data.shipment.common.pk.ShipmentPK;
import com.echothree.model.data.shipment.common.pk.ShipmentTypePK;
import com.echothree.model.data.party.common.pk.PartyPK;
import com.echothree.model.data.contact.common.pk.PartyContactMechanismPK;
import com.echothree.model.data.shipping.common.pk.ShippingMethodPK;

import com.echothree.model.data.shipment.server.entity.Shipment;
import com.echothree.model.data.shipment.server.entity.ShipmentType;
import com.echothree.model.data.party.server.entity.Party;
import com.echothree.model.data.contact.server.entity.PartyContactMechanism;
import com.echothree.model.data.shipping.server.entity.ShippingMethod;

import com.echothree.model.data.shipment.common.ShipmentDetailConstants;
import com.echothree.model.data.shipment.common.pk.ShipmentDetailPK;
import com.echothree.model.data.shipment.server.value.ShipmentDetailValue;
import com.echothree.model.data.shipment.server.entity.ShipmentDetail;
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 com.echothree.util.server.persistence.ThreadSession;
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 org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

public class ShipmentDetailFactory
        implements BaseFactory<ShipmentDetailPK, ShipmentDetail> {
    
    //final private static Log log = LogFactory.getLog(ShipmentDetailFactory.class);
    
    final private static String SQL_SELECT_READ_ONLY = "SELECT shpdt_shipmentdetailid, shpdt_shp_shipmentid, shpdt_shptyp_shipmenttypeid, shpdt_shipmentname, shpdt_originpartyid, shpdt_originwarehousepartyid, shpdt_originpartycontactmechanismid, shpdt_destinationpartyid, shpdt_destinationwarehousepartyid, shpdt_destinationpartycontactmechanismid, shpdt_shm_shippingmethodid, shpdt_fromtime, shpdt_thrutime FROM shipmentdetails WHERE shpdt_shipmentdetailid = ?";
    final private static String SQL_SELECT_READ_WRITE = "SELECT shpdt_shipmentdetailid, shpdt_shp_shipmentid, shpdt_shptyp_shipmenttypeid, shpdt_shipmentname, shpdt_originpartyid, shpdt_originwarehousepartyid, shpdt_originpartycontactmechanismid, shpdt_destinationpartyid, shpdt_destinationwarehousepartyid, shpdt_destinationpartycontactmechanismid, shpdt_shm_shippingmethodid, shpdt_fromtime, shpdt_thrutime FROM shipmentdetails WHERE shpdt_shipmentdetailid = ? FOR UPDATE";
    final private static String SQL_INSERT = "INSERT INTO shipmentdetails (shpdt_shipmentdetailid, shpdt_shp_shipmentid, shpdt_shptyp_shipmenttypeid, shpdt_shipmentname, shpdt_originpartyid, shpdt_originwarehousepartyid, shpdt_originpartycontactmechanismid, shpdt_destinationpartyid, shpdt_destinationwarehousepartyid, shpdt_destinationpartycontactmechanismid, shpdt_shm_shippingmethodid, shpdt_fromtime, shpdt_thrutime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
    final private static String SQL_UPDATE = "UPDATE shipmentdetails SET shpdt_shp_shipmentid = ?, shpdt_shptyp_shipmenttypeid = ?, shpdt_shipmentname = ?, shpdt_originpartyid = ?, shpdt_originwarehousepartyid = ?, shpdt_originpartycontactmechanismid = ?, shpdt_destinationpartyid = ?, shpdt_destinationwarehousepartyid = ?, shpdt_destinationpartycontactmechanismid = ?, shpdt_shm_shippingmethodid = ?, shpdt_fromtime = ?, shpdt_thrutime = ? WHERE shpdt_shipmentdetailid = ?";
    final private static String SQL_DELETE = "DELETE FROM shipmentdetails WHERE shpdt_shipmentdetailid = ?";
    final private static String SQL_VALID = "SELECT COUNT(*) FROM shipmentdetails WHERE shpdt_shipmentdetailid = ?";
    
    final private static String PK_COLUMN = "shpdt_shipmentdetailid";
    final private static String ALL_COLUMNS = "shpdt_shipmentdetailid, shpdt_shp_shipmentid, shpdt_shptyp_shipmenttypeid, shpdt_shipmentname, shpdt_originpartyid, shpdt_originwarehousepartyid, shpdt_originpartycontactmechanismid, shpdt_destinationpartyid, shpdt_destinationwarehousepartyid, shpdt_destinationpartycontactmechanismid, shpdt_shm_shippingmethodid, shpdt_fromtime, shpdt_thrutime";
    final public static String TABLE_NAME = "shipmentdetails";
    
    final public static String SHPDT_SHIPMENTDETAILID = "shpdt_shipmentdetailid";
    final public static String SHPDT_SHP_SHIPMENTID = "shpdt_shp_shipmentid";
    final public static String SHPDT_SHPTYP_SHIPMENTTYPEID = "shpdt_shptyp_shipmenttypeid";
    final public static String SHPDT_SHIPMENTNAME = "shpdt_shipmentname";
    final public static String SHPDT_ORIGINPARTYID = "shpdt_originpartyid";
    final public static String SHPDT_ORIGINWAREHOUSEPARTYID = "shpdt_originwarehousepartyid";
    final public static String SHPDT_ORIGINPARTYCONTACTMECHANISMID = "shpdt_originpartycontactmechanismid";
    final public static String SHPDT_DESTINATIONPARTYID = "shpdt_destinationpartyid";
    final public static String SHPDT_DESTINATIONWAREHOUSEPARTYID = "shpdt_destinationwarehousepartyid";
    final public static String SHPDT_DESTINATIONPARTYCONTACTMECHANISMID = "shpdt_destinationpartycontactmechanismid";
    final public static String SHPDT_SHM_SHIPPINGMETHODID = "shpdt_shm_shippingmethodid";
    final public static String SHPDT_FROMTIME = "shpdt_fromtime";
    final public static String SHPDT_THRUTIME = "shpdt_thrutime";
    
    final private static EntityIdGenerator entityIdGenerator = new EntityIdGenerator(ShipmentDetailConstants.COMPONENT_VENDOR_NAME, ShipmentDetailConstants.ENTITY_TYPE_NAME);
    
    /** Creates a new instance of ShipmentDetailFactory */
    private ShipmentDetailFactory() {
        super();
    }
    
    private static class ShipmentDetailFactoryHolder {
        static ShipmentDetailFactory instance = new ShipmentDetailFactory();
    }
    
    public static ShipmentDetailFactory getInstance() {
        return ShipmentDetailFactoryHolder.instance;
    }
    
    @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 ShipmentDetailConstants.COMPONENT_VENDOR_NAME;
    }
    
    @Override
    public String getEntityTypeName() {
        return ShipmentDetailConstants.ENTITY_TYPE_NAME;
    }
    
    public PreparedStatement prepareStatement(String query) {
        return ThreadSession.currentSession().prepareStatement(ShipmentDetailFactory.class, query);
    }
    
    public ShipmentDetailPK getNextPK() {
        return new ShipmentDetailPK(entityIdGenerator.getNextEntityId());
    }
    
    public Set<ShipmentDetailPK> getPKsFromResultSetAsSet(ResultSet rs)
            throws PersistenceDatabaseException {
        Set<ShipmentDetailPK> _result = new HashSet<>();
        
        try {
            while(rs.next()) {
                _result.add(getPKFromResultSet(rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public java.util.List<ShipmentDetailPK> getPKsFromResultSetAsList(ResultSet rs)
            throws PersistenceDatabaseException {
        java.util.List<ShipmentDetailPK> _result = new ArrayList<>();
        
        try {
            while(rs.next()) {
                _result.add(getPKFromResultSet(rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public ShipmentDetailPK getPKFromResultSet(ResultSet rs)
            throws PersistenceDatabaseException {
        ShipmentDetailPK _result;
        
        try {
            long shpdt_shipmentdetailid = rs.getLong(SHPDT_SHIPMENTDETAILID);
            Long _entityId = rs.wasNull() ? null : shpdt_shipmentdetailid;
            
            _result = new ShipmentDetailPK(_entityId);
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public java.util.List<ShipmentDetailValue> getValuesFromPKs(Session session, Collection<ShipmentDetailPK> pks)
            throws PersistenceDatabaseException {
        java.util.List<ShipmentDetailValue> _values = new ArrayList<>(pks.size());
        
        for(ShipmentDetailPK _pk: pks) {
            _values.add(getValueFromPK(session, _pk));
        }
        
        return _values;
    }
    
    public ShipmentDetailValue getValueFromPK(Session session, ShipmentDetailPK pk)
            throws PersistenceDatabaseException {
        ShipmentDetailValue _value;
        
        // See if we already have the entity in the session cache
        ShipmentDetail _entity = (ShipmentDetail)session.getEntity(pk);
        if(_entity == null)
            _value = getEntityFromPK(session, EntityPermission.READ_ONLY, pk).getShipmentDetailValue();
        else
            _value = _entity.getShipmentDetailValue();
        
        return _value;
    }
    
    public java.util.List<ShipmentDetailValue> getValuesFromResultSet(Session session, ResultSet rs)
            throws PersistenceDatabaseException {
        java.util.List<ShipmentDetailValue> _result = new ArrayList<>();
        
        try {
            while(rs.next()) {
                _result.add(getValueFromResultSet(session, rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public ShipmentDetailValue getValueFromResultSet(Session session, ResultSet rs)
            throws PersistenceDatabaseException {
        ShipmentDetailValue _value;
        
        try {
            Long shpdt_shipmentdetailid = rs.getLong(SHPDT_SHIPMENTDETAILID);
            ShipmentDetailPK _pk = new ShipmentDetailPK(shpdt_shipmentdetailid);
            
            // See if we already have the entity in the session cache
            ShipmentDetail _entity = (ShipmentDetail)session.getEntity(_pk);
            
            if(_entity == null) {
                Long shpdt_shp_shipmentid = rs.getLong(SHPDT_SHP_SHIPMENTID);
                if(rs.wasNull())
                    shpdt_shp_shipmentid = null;
                
                Long shpdt_shptyp_shipmenttypeid = rs.getLong(SHPDT_SHPTYP_SHIPMENTTYPEID);
                if(rs.wasNull())
                    shpdt_shptyp_shipmenttypeid = null;
                
                String shpdt_shipmentname = rs.getString(SHPDT_SHIPMENTNAME);
                if(rs.wasNull())
                    shpdt_shipmentname = null;
                
                Long shpdt_originpartyid = rs.getLong(SHPDT_ORIGINPARTYID);
                if(rs.wasNull())
                    shpdt_originpartyid = null;
                
                Long shpdt_originwarehousepartyid = rs.getLong(SHPDT_ORIGINWAREHOUSEPARTYID);
                if(rs.wasNull())
                    shpdt_originwarehousepartyid = null;
                
                Long shpdt_originpartycontactmechanismid = rs.getLong(SHPDT_ORIGINPARTYCONTACTMECHANISMID);
                if(rs.wasNull())
                    shpdt_originpartycontactmechanismid = null;
                
                Long shpdt_destinationpartyid = rs.getLong(SHPDT_DESTINATIONPARTYID);
                if(rs.wasNull())
                    shpdt_destinationpartyid = null;
                
                Long shpdt_destinationwarehousepartyid = rs.getLong(SHPDT_DESTINATIONWAREHOUSEPARTYID);
                if(rs.wasNull())
                    shpdt_destinationwarehousepartyid = null;
                
                Long shpdt_destinationpartycontactmechanismid = rs.getLong(SHPDT_DESTINATIONPARTYCONTACTMECHANISMID);
                if(rs.wasNull())
                    shpdt_destinationpartycontactmechanismid = null;
                
                Long shpdt_shm_shippingmethodid = rs.getLong(SHPDT_SHM_SHIPPINGMETHODID);
                if(rs.wasNull())
                    shpdt_shm_shippingmethodid = null;
                
                Long shpdt_fromtime = rs.getLong(SHPDT_FROMTIME);
                if(rs.wasNull())
                    shpdt_fromtime = null;
                
                Long shpdt_thrutime = rs.getLong(SHPDT_THRUTIME);
                if(rs.wasNull())
                    shpdt_thrutime = null;
                
                _value = new ShipmentDetailValue(_pk, new ShipmentPK(shpdt_shp_shipmentid), new ShipmentTypePK(shpdt_shptyp_shipmenttypeid), shpdt_shipmentname, new PartyPK(shpdt_originpartyid), new PartyPK(shpdt_originwarehousepartyid), new PartyContactMechanismPK(shpdt_originpartycontactmechanismid), new PartyPK(shpdt_destinationpartyid), new PartyPK(shpdt_destinationwarehousepartyid), new PartyContactMechanismPK(shpdt_destinationpartycontactmechanismid), new ShippingMethodPK(shpdt_shm_shippingmethodid), shpdt_fromtime, shpdt_thrutime);
            } else
                _value = _entity.getShipmentDetailValue();
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _value;
    }
    
    public java.util.List<ShipmentDetail> getEntitiesFromPKs(EntityPermission entityPermission, Collection<ShipmentDetailPK> pks)
            throws PersistenceDatabaseException {
        return getEntitiesFromPKs(ThreadSession.currentSession(), entityPermission, pks);
    }
    
    public java.util.List<ShipmentDetail> getEntitiesFromPKs(Session session, EntityPermission entityPermission, Collection<ShipmentDetailPK> pks)
            throws PersistenceDatabaseException {
        java.util.List<ShipmentDetail> _entities = new ArrayList<>(pks.size());
        
        for(ShipmentDetailPK _pk: pks) {
            _entities.add(getEntityFromPK(session, entityPermission, _pk));
        }
        
        return _entities;
    }
    
    public ShipmentDetail getEntityFromValue(EntityPermission entityPermission, ShipmentDetailValue value) {
        return getEntityFromPK(ThreadSession.currentSession(), entityPermission, value.getPrimaryKey());
    }
    
    public ShipmentDetail getEntityFromValue(Session session, EntityPermission entityPermission, ShipmentDetailValue value) {
        return getEntityFromPK(session, entityPermission, value.getPrimaryKey());
    }
    
    public ShipmentDetail getEntityFromPK(EntityPermission entityPermission, ShipmentDetailPK pk)
            throws PersistenceDatabaseException {
        return getEntityFromPK(ThreadSession.currentSession(), entityPermission, pk);
    }
    
    public ShipmentDetail getEntityFromCache(Session session, ShipmentDetailPK pk) {
        ShipmentDetailValue _value = (ShipmentDetailValue)session.getValueCache().get(pk);
    
        return _value == null ? null : new ShipmentDetail(_value, EntityPermission.READ_ONLY);
    }
    
    public ShipmentDetail getEntityFromPK(Session session, EntityPermission entityPermission, ShipmentDetailPK pk)
            throws PersistenceDatabaseException {
        ShipmentDetail _entity;
        
        // See if we already have the entity in the session cache
        _entity = (ShipmentDetail)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(session, 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(session, 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<ShipmentDetailPK> getPKsFromQueryAsSet(PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        Set<ShipmentDetailPK> _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<ShipmentDetailPK> getPKsFromQueryAsList(PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        java.util.List<ShipmentDetailPK> _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 ShipmentDetailPK getPKFromQuery(PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        ShipmentDetailPK _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<ShipmentDetail> getEntitiesFromQuery(Session session, EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(ShipmentDetailFactory.class, queryMap.get(entityPermission));
        
        return getEntitiesFromQuery(session, entityPermission, ps, params);
    }
    
    public java.util.List<ShipmentDetail> getEntitiesFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
            throws PersistenceDatabaseException {
        Session session = ThreadSession.currentSession();
        PreparedStatement ps = session.prepareStatement(ShipmentDetailFactory.class, queryMap.get(entityPermission));
        
        return getEntitiesFromQuery(session, entityPermission, ps, params);
    }
    
    public java.util.List<ShipmentDetail> getEntitiesFromQuery(Session session, EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(ShipmentDetailFactory.class, queryMap.get(entityPermission));
        
        return getEntitiesFromQuery(session, entityPermission, ps);
    }
    
    public java.util.List<ShipmentDetail> getEntitiesFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
            throws PersistenceDatabaseException {
        Session session = ThreadSession.currentSession();
        PreparedStatement ps = session.prepareStatement(ShipmentDetailFactory.class, queryMap.get(entityPermission));
        
        return getEntitiesFromQuery(session, entityPermission, ps);
    }
    
    public java.util.List<ShipmentDetail> getEntitiesFromQuery(EntityPermission entityPermission, PreparedStatement ps)
            throws PersistenceDatabaseException {
        return getEntitiesFromQuery(ThreadSession.currentSession(), entityPermission, ps);
    }
    
    public java.util.List<ShipmentDetail> getEntitiesFromQuery(EntityPermission entityPermission, PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        return getEntitiesFromQuery(ThreadSession.currentSession(), entityPermission, ps, params);
    }
    
    public java.util.List<ShipmentDetail> getEntitiesFromQuery(Session session, EntityPermission entityPermission, PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        java.util.List<ShipmentDetail> _entities;
        ResultSet _rs = null;
        
        try {
            if(params.length != 0) {
                Session.setQueryParams(ps, params);
            }
            
            _rs = ps.executeQuery();
            _entities = getEntitiesFromResultSet(session, 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 ShipmentDetail getEntityFromQuery(Session session, EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(ShipmentDetailFactory.class, queryMap.get(entityPermission));
        
        return getEntityFromQuery(session, entityPermission, ps, params);
    }
    
    public ShipmentDetail getEntityFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
            throws PersistenceDatabaseException {
        Session session = ThreadSession.currentSession();
        PreparedStatement ps = session.prepareStatement(ShipmentDetailFactory.class, queryMap.get(entityPermission));
        
        return getEntityFromQuery(session, entityPermission, ps, params);
    }
    
    public ShipmentDetail getEntityFromQuery(Session session, EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(ShipmentDetailFactory.class, queryMap.get(entityPermission));
        
        return getEntityFromQuery(session, entityPermission, ps);
    }
    
    public ShipmentDetail getEntityFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
            throws PersistenceDatabaseException {
        Session session = ThreadSession.currentSession();
        PreparedStatement ps = session.prepareStatement(ShipmentDetailFactory.class, queryMap.get(entityPermission));
        
        return getEntityFromQuery(session, entityPermission, ps);
    }
    
    public ShipmentDetail getEntityFromQuery(EntityPermission entityPermission, PreparedStatement ps)
            throws PersistenceDatabaseException {
        return getEntityFromQuery(ThreadSession.currentSession(), entityPermission, ps);
    }
    
    public ShipmentDetail getEntityFromQuery(EntityPermission entityPermission, PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        return getEntityFromQuery(ThreadSession.currentSession(), entityPermission, ps, params);
    }
    
    public ShipmentDetail getEntityFromQuery(Session session, EntityPermission entityPermission, PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        ShipmentDetail _entity = null;
        ResultSet _rs = null;
        
        try {
            if(params.length != 0) {
                Session.setQueryParams(ps, params);
            }
            
            _rs = ps.executeQuery();
            if(_rs.next()) {
                _entity = getEntityFromResultSet(session, 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<ShipmentDetail> getEntitiesFromResultSet(EntityPermission entityPermission, ResultSet rs)
            throws PersistenceDatabaseException {
        return getEntitiesFromResultSet(ThreadSession.currentSession(), entityPermission, rs);
    }
    
    public java.util.List<ShipmentDetail> getEntitiesFromResultSet(Session session, EntityPermission entityPermission, ResultSet rs)
            throws PersistenceDatabaseException {
        java.util.List<ShipmentDetail> _result = new ArrayList<>();
        
        try {
            while(rs.next()) {
                _result.add(getEntityFromResultSet(session, entityPermission, rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public ShipmentDetail getEntityFromResultSet(EntityPermission entityPermission, ResultSet rs)
            throws PersistenceDatabaseException {
        return getEntityFromResultSet(ThreadSession.currentSession(), entityPermission, rs);
    }
    
    public ShipmentDetail getEntityFromResultSet(Session session, EntityPermission entityPermission, ResultSet rs)
            throws PersistenceDatabaseException {
        ShipmentDetail _entity;
        
        try {
            Long shpdt_shipmentdetailid = rs.getLong(SHPDT_SHIPMENTDETAILID);
            ShipmentDetailPK _pk = new ShipmentDetailPK(shpdt_shipmentdetailid);
            
            // See if we already have the entity in the session cache
            _entity = (ShipmentDetail)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(session, _pk);
            }
            
            if(_entity == null) {
                Long shpdt_shp_shipmentid = rs.getLong(SHPDT_SHP_SHIPMENTID);
                if(rs.wasNull())
                    shpdt_shp_shipmentid = null;
                
                Long shpdt_shptyp_shipmenttypeid = rs.getLong(SHPDT_SHPTYP_SHIPMENTTYPEID);
                if(rs.wasNull())
                    shpdt_shptyp_shipmenttypeid = null;
                
                String shpdt_shipmentname = rs.getString(SHPDT_SHIPMENTNAME);
                if(rs.wasNull())
                    shpdt_shipmentname = null;
                
                Long shpdt_originpartyid = rs.getLong(SHPDT_ORIGINPARTYID);
                if(rs.wasNull())
                    shpdt_originpartyid = null;
                
                Long shpdt_originwarehousepartyid = rs.getLong(SHPDT_ORIGINWAREHOUSEPARTYID);
                if(rs.wasNull())
                    shpdt_originwarehousepartyid = null;
                
                Long shpdt_originpartycontactmechanismid = rs.getLong(SHPDT_ORIGINPARTYCONTACTMECHANISMID);
                if(rs.wasNull())
                    shpdt_originpartycontactmechanismid = null;
                
                Long shpdt_destinationpartyid = rs.getLong(SHPDT_DESTINATIONPARTYID);
                if(rs.wasNull())
                    shpdt_destinationpartyid = null;
                
                Long shpdt_destinationwarehousepartyid = rs.getLong(SHPDT_DESTINATIONWAREHOUSEPARTYID);
                if(rs.wasNull())
                    shpdt_destinationwarehousepartyid = null;
                
                Long shpdt_destinationpartycontactmechanismid = rs.getLong(SHPDT_DESTINATIONPARTYCONTACTMECHANISMID);
                if(rs.wasNull())
                    shpdt_destinationpartycontactmechanismid = null;
                
                Long shpdt_shm_shippingmethodid = rs.getLong(SHPDT_SHM_SHIPPINGMETHODID);
                if(rs.wasNull())
                    shpdt_shm_shippingmethodid = null;
                
                Long shpdt_fromtime = rs.getLong(SHPDT_FROMTIME);
                if(rs.wasNull())
                    shpdt_fromtime = null;
                
                Long shpdt_thrutime = rs.getLong(SHPDT_THRUTIME);
                if(rs.wasNull())
                    shpdt_thrutime = null;
                
                ShipmentDetailValue _value = new ShipmentDetailValue(_pk, shpdt_shp_shipmentid == null? null: new ShipmentPK(shpdt_shp_shipmentid), shpdt_shptyp_shipmenttypeid == null? null: new ShipmentTypePK(shpdt_shptyp_shipmenttypeid), shpdt_shipmentname, shpdt_originpartyid == null? null: new PartyPK(shpdt_originpartyid), shpdt_originwarehousepartyid == null? null: new PartyPK(shpdt_originwarehousepartyid), shpdt_originpartycontactmechanismid == null? null: new PartyContactMechanismPK(shpdt_originpartycontactmechanismid), shpdt_destinationpartyid == null? null: new PartyPK(shpdt_destinationpartyid), shpdt_destinationwarehousepartyid == null? null: new PartyPK(shpdt_destinationwarehousepartyid), shpdt_destinationpartycontactmechanismid == null? null: new PartyContactMechanismPK(shpdt_destinationpartycontactmechanismid), shpdt_shm_shippingmethodid == null? null: new ShippingMethodPK(shpdt_shm_shippingmethodid), shpdt_fromtime, shpdt_thrutime);
                _entity = new ShipmentDetail(_value, entityPermission);
            }
            
            if(!foundInSessionCache) {
                if(entityPermission.equals(EntityPermission.READ_ONLY)) {
                    session.putReadOnlyEntity(_pk, _entity);
                    session.getValueCache().put(_entity.getShipmentDetailValue());
                } else {
                    session.putReadWriteEntity(_pk, _entity);
                }
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _entity;
    }
    
    public ShipmentDetail create(Session session, Shipment shipment, ShipmentType shipmentType, String shipmentName, Party originParty, Party originWarehouseParty, PartyContactMechanism originPartyContactMechanism, Party destinationParty, Party destinationWarehouseParty, PartyContactMechanism destinationPartyContactMechanism, ShippingMethod shippingMethod, Long fromTime, Long thruTime)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        return create(session, shipment == null ? null : shipment.getPrimaryKey(), shipmentType == null ? null : shipmentType.getPrimaryKey(), shipmentName, originParty == null ? null : originParty.getPrimaryKey(), originWarehouseParty == null ? null : originWarehouseParty.getPrimaryKey(), originPartyContactMechanism == null ? null : originPartyContactMechanism.getPrimaryKey(), destinationParty == null ? null : destinationParty.getPrimaryKey(), destinationWarehouseParty == null ? null : destinationWarehouseParty.getPrimaryKey(), destinationPartyContactMechanism == null ? null : destinationPartyContactMechanism.getPrimaryKey(), shippingMethod == null ? null : shippingMethod.getPrimaryKey(), fromTime, thruTime);
    }
    
    public ShipmentDetail create(Shipment shipment, ShipmentType shipmentType, String shipmentName, Party originParty, Party originWarehouseParty, PartyContactMechanism originPartyContactMechanism, Party destinationParty, Party destinationWarehouseParty, PartyContactMechanism destinationPartyContactMechanism, ShippingMethod shippingMethod, Long fromTime, Long thruTime)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        return create(ThreadSession.currentSession(), shipment == null ? null : shipment.getPrimaryKey(), shipmentType == null ? null : shipmentType.getPrimaryKey(), shipmentName, originParty == null ? null : originParty.getPrimaryKey(), originWarehouseParty == null ? null : originWarehouseParty.getPrimaryKey(), originPartyContactMechanism == null ? null : originPartyContactMechanism.getPrimaryKey(), destinationParty == null ? null : destinationParty.getPrimaryKey(), destinationWarehouseParty == null ? null : destinationWarehouseParty.getPrimaryKey(), destinationPartyContactMechanism == null ? null : destinationPartyContactMechanism.getPrimaryKey(), shippingMethod == null ? null : shippingMethod.getPrimaryKey(), fromTime, thruTime);
    }
    
    private void bindForCreate(PreparedStatement _ps, ShipmentDetailValue _value)
            throws SQLException {
        _ps.setLong(1, _value.getEntityId());
        
        ShipmentPK shpdt_shp_shipmentid = _value.getShipmentPK();
        if(shpdt_shp_shipmentid == null)
            _ps.setNull(2, Types.BIGINT);
        else
            _ps.setLong(2, shpdt_shp_shipmentid.getEntityId());
            
        ShipmentTypePK shpdt_shptyp_shipmenttypeid = _value.getShipmentTypePK();
        if(shpdt_shptyp_shipmenttypeid == null)
            _ps.setNull(3, Types.BIGINT);
        else
            _ps.setLong(3, shpdt_shptyp_shipmenttypeid.getEntityId());
            
        String shpdt_shipmentname = _value.getShipmentName();
        if(shpdt_shipmentname == null)
            _ps.setNull(4, Types.VARCHAR);
        else
            _ps.setString(4, shpdt_shipmentname);
            
        PartyPK shpdt_originpartyid = _value.getOriginPartyPK();
        if(shpdt_originpartyid == null)
            _ps.setNull(5, Types.BIGINT);
        else
            _ps.setLong(5, shpdt_originpartyid.getEntityId());
            
        PartyPK shpdt_originwarehousepartyid = _value.getOriginWarehousePartyPK();
        if(shpdt_originwarehousepartyid == null)
            _ps.setNull(6, Types.BIGINT);
        else
            _ps.setLong(6, shpdt_originwarehousepartyid.getEntityId());
            
        PartyContactMechanismPK shpdt_originpartycontactmechanismid = _value.getOriginPartyContactMechanismPK();
        if(shpdt_originpartycontactmechanismid == null)
            _ps.setNull(7, Types.BIGINT);
        else
            _ps.setLong(7, shpdt_originpartycontactmechanismid.getEntityId());
            
        PartyPK shpdt_destinationpartyid = _value.getDestinationPartyPK();
        if(shpdt_destinationpartyid == null)
            _ps.setNull(8, Types.BIGINT);
        else
            _ps.setLong(8, shpdt_destinationpartyid.getEntityId());
            
        PartyPK shpdt_destinationwarehousepartyid = _value.getDestinationWarehousePartyPK();
        if(shpdt_destinationwarehousepartyid == null)
            _ps.setNull(9, Types.BIGINT);
        else
            _ps.setLong(9, shpdt_destinationwarehousepartyid.getEntityId());
            
        PartyContactMechanismPK shpdt_destinationpartycontactmechanismid = _value.getDestinationPartyContactMechanismPK();
        if(shpdt_destinationpartycontactmechanismid == null)
            _ps.setNull(10, Types.BIGINT);
        else
            _ps.setLong(10, shpdt_destinationpartycontactmechanismid.getEntityId());
            
        ShippingMethodPK shpdt_shm_shippingmethodid = _value.getShippingMethodPK();
        if(shpdt_shm_shippingmethodid == null)
            _ps.setNull(11, Types.BIGINT);
        else
            _ps.setLong(11, shpdt_shm_shippingmethodid.getEntityId());
            
        Long shpdt_fromtime = _value.getFromTime();
        if(shpdt_fromtime == null)
            _ps.setNull(12, Types.BIGINT);
        else
            _ps.setLong(12, shpdt_fromtime);
            
        Long shpdt_thrutime = _value.getThruTime();
        if(shpdt_thrutime == null)
            _ps.setNull(13, Types.BIGINT);
        else
            _ps.setLong(13, shpdt_thrutime);
            
    }
    
    public ShipmentDetail create(Session session, ShipmentPK shipmentPK, ShipmentTypePK shipmentTypePK, String shipmentName, PartyPK originPartyPK, PartyPK originWarehousePartyPK, PartyContactMechanismPK originPartyContactMechanismPK, PartyPK destinationPartyPK, PartyPK destinationWarehousePartyPK, PartyContactMechanismPK destinationPartyContactMechanismPK, ShippingMethodPK shippingMethodPK, Long fromTime, Long thruTime)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        ShipmentDetailPK _pk = getNextPK();
        ShipmentDetailValue _value = new ShipmentDetailValue(_pk, shipmentPK, shipmentTypePK, shipmentName, originPartyPK, originWarehousePartyPK, originPartyContactMechanismPK, destinationPartyPK, destinationWarehousePartyPK, destinationPartyContactMechanismPK, shippingMethodPK, 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);
        }
        
        ShipmentDetail _entity = new ShipmentDetail(_value, EntityPermission.READ_ONLY);
        session.putReadOnlyEntity(_pk, _entity);
        
        return _entity;
    }
    
    public ShipmentDetail create(ShipmentPK shipmentPK, ShipmentTypePK shipmentTypePK, String shipmentName, PartyPK originPartyPK, PartyPK originWarehousePartyPK, PartyContactMechanismPK originPartyContactMechanismPK, PartyPK destinationPartyPK, PartyPK destinationWarehousePartyPK, PartyContactMechanismPK destinationPartyContactMechanismPK, ShippingMethodPK shippingMethodPK, Long fromTime, Long thruTime)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        return create(ThreadSession.currentSession(), shipmentPK, shipmentTypePK, shipmentName, originPartyPK, originWarehousePartyPK, originPartyContactMechanismPK, destinationPartyPK, destinationWarehousePartyPK, destinationPartyContactMechanismPK, shippingMethodPK, fromTime, thruTime);
    }
    
    public void create(Session session, Collection<ShipmentDetailValue> _values)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        int _size = _values.size();
        
        if(_size > 0) {
            PreparedStatement _ps = session.prepareStatement(SQL_INSERT);
            List<ShipmentDetailValue> _cacheValues = new ArrayList<>(_size);
            
            try {
                for(ShipmentDetailValue _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) -> {
                ShipmentDetail _cacheEntity = new ShipmentDetail(_cacheValue, EntityPermission.READ_ONLY);
                
                session.putReadOnlyEntity(_cacheValue.getPrimaryKey(), _cacheEntity);
            });
        }
    }
    
    public void create(Collection<ShipmentDetailValue> _values)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        create(ThreadSession.currentSession(), _values);
    }
    
    private boolean bindForStore(PreparedStatement _ps, ShipmentDetailValue _value)
            throws SQLException {
        boolean _hasBeenModified = _value.hasBeenModified();
        
        if(_hasBeenModified) {
            ShipmentPK shpdt_shp_shipmentid = _value.getShipmentPK();
            if(shpdt_shp_shipmentid == null)
                _ps.setNull(1, Types.BIGINT);
            else
                _ps.setLong(1, shpdt_shp_shipmentid.getEntityId());
            
            ShipmentTypePK shpdt_shptyp_shipmenttypeid = _value.getShipmentTypePK();
            if(shpdt_shptyp_shipmenttypeid == null)
                _ps.setNull(2, Types.BIGINT);
            else
                _ps.setLong(2, shpdt_shptyp_shipmenttypeid.getEntityId());
            
            String shpdt_shipmentname = _value.getShipmentName();
            if(shpdt_shipmentname == null)
                _ps.setNull(3, Types.VARCHAR);
            else
                _ps.setString(3, shpdt_shipmentname);
            
            PartyPK shpdt_originpartyid = _value.getOriginPartyPK();
            if(shpdt_originpartyid == null)
                _ps.setNull(4, Types.BIGINT);
            else
                _ps.setLong(4, shpdt_originpartyid.getEntityId());
            
            PartyPK shpdt_originwarehousepartyid = _value.getOriginWarehousePartyPK();
            if(shpdt_originwarehousepartyid == null)
                _ps.setNull(5, Types.BIGINT);
            else
                _ps.setLong(5, shpdt_originwarehousepartyid.getEntityId());
            
            PartyContactMechanismPK shpdt_originpartycontactmechanismid = _value.getOriginPartyContactMechanismPK();
            if(shpdt_originpartycontactmechanismid == null)
                _ps.setNull(6, Types.BIGINT);
            else
                _ps.setLong(6, shpdt_originpartycontactmechanismid.getEntityId());
            
            PartyPK shpdt_destinationpartyid = _value.getDestinationPartyPK();
            if(shpdt_destinationpartyid == null)
                _ps.setNull(7, Types.BIGINT);
            else
                _ps.setLong(7, shpdt_destinationpartyid.getEntityId());
            
            PartyPK shpdt_destinationwarehousepartyid = _value.getDestinationWarehousePartyPK();
            if(shpdt_destinationwarehousepartyid == null)
                _ps.setNull(8, Types.BIGINT);
            else
                _ps.setLong(8, shpdt_destinationwarehousepartyid.getEntityId());
            
            PartyContactMechanismPK shpdt_destinationpartycontactmechanismid = _value.getDestinationPartyContactMechanismPK();
            if(shpdt_destinationpartycontactmechanismid == null)
                _ps.setNull(9, Types.BIGINT);
            else
                _ps.setLong(9, shpdt_destinationpartycontactmechanismid.getEntityId());
            
            ShippingMethodPK shpdt_shm_shippingmethodid = _value.getShippingMethodPK();
            if(shpdt_shm_shippingmethodid == null)
                _ps.setNull(10, Types.BIGINT);
            else
                _ps.setLong(10, shpdt_shm_shippingmethodid.getEntityId());
            
            Long shpdt_fromtime = _value.getFromTime();
            if(shpdt_fromtime == null)
                _ps.setNull(11, Types.BIGINT);
            else
                _ps.setLong(11, shpdt_fromtime);
            
            Long shpdt_thrutime = _value.getThruTime();
            if(shpdt_thrutime == null)
                _ps.setNull(12, Types.BIGINT);
            else
                _ps.setLong(12, shpdt_thrutime);
            
            _ps.setLong(13, _value.getPrimaryKey().getEntityId());
            
            _value.clearHasBeenModified();
        }
        
        return _hasBeenModified;
    }
    
    @Override
    public void store(Session session, ShipmentDetail entity)
            throws PersistenceDatabaseException {
        PreparedStatement _ps = session.prepareStatement(SQL_UPDATE);
        
        try {
            ShipmentDetailValue _value = entity.getShipmentDetailValue();
            
            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(Session session, Collection<ShipmentDetail> entities)
            throws PersistenceDatabaseException {
        if(entities.size() > 0) {
            PreparedStatement _ps = session.prepareStatement(SQL_UPDATE);
            int _modifiedEntities = 0;
            
            try {
                for(ShipmentDetail entity : entities) {
                    if(bindForStore(_ps, entity.getShipmentDetailValue())) {
                        _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.getShipmentDetailValue());
                    });
                }
            } catch (SQLException se) {
                throw new PersistenceDatabaseException(se);
            }
        }
    }
    
    @Override
    public void store(Collection<ShipmentDetail> entities)
            throws PersistenceDatabaseException {
        store(ThreadSession.currentSession(), entities);
    }
    
    @Override
    public void remove(Session session, ShipmentDetail entity)
            throws PersistenceDatabaseException {
        remove(session, entity.getPrimaryKey());
    }
    
    @Override
    public void remove(Session session, ShipmentDetailPK 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(Session session, Collection<ShipmentDetailPK> pks)
            throws PersistenceDatabaseException {
        if(pks.size() > 0) {
            PreparedStatement _ps = session.prepareStatement(SQL_DELETE);
            int _modifiedEntities = 0;
            
            try {
                for(ShipmentDetailPK 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 void remove(Collection<ShipmentDetailPK> pks)
            throws PersistenceDatabaseException {
        remove(ThreadSession.currentSession(), pks);
    }
    
    @Override
    public boolean validPK(Session session, ShipmentDetailPK 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;
    }
    
}