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

/**
 * 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 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 ShipmentDetailFactory
        implements BaseFactory<ShipmentDetailPK, ShipmentDetail> {
    
    @Inject
    Session session;
    
    //private static final Logger log = LoggerFactory.getLogger(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 */
    protected ShipmentDetailFactory() {
        super();
    }
    
    public static ShipmentDetailFactory getInstance() {
        return CDI.current().select(ShipmentDetailFactory.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 ShipmentDetailConstants.COMPONENT_VENDOR_NAME;
    }
    
    @Override
    public String getEntityTypeName() {
        return ShipmentDetailConstants.ENTITY_TYPE_NAME;
    }
    
    public PreparedStatement prepareStatement(String query) {
        return session.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(Collection<ShipmentDetailPK> pks)
            throws PersistenceDatabaseException {
        java.util.List<ShipmentDetailValue> _values = new ArrayList<>(pks.size());
        
        for(ShipmentDetailPK _pk: pks) {
            _values.add(getValueFromPK(_pk));
        }
        
        return _values;
    }
    
    public ShipmentDetailValue getValueFromPK(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(EntityPermission.READ_ONLY, pk).getShipmentDetailValue();
        else
            _value = _entity.getShipmentDetailValue();
        
        return _value;
    }
    
    public java.util.List<ShipmentDetailValue> getValuesFromResultSet(ResultSet rs)
            throws PersistenceDatabaseException {
        java.util.List<ShipmentDetailValue> _result = new ArrayList<>();
        
        try {
            while(rs.next()) {
                _result.add(getValueFromResultSet(rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public ShipmentDetailValue getValueFromResultSet(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 {
        java.util.List<ShipmentDetail> _entities = new ArrayList<>(pks.size());
        
        for(ShipmentDetailPK _pk: pks) {
            _entities.add(getEntityFromPK(entityPermission, _pk));
        }
        
        return _entities;
    }
    
    public ShipmentDetail getEntityFromValue(EntityPermission entityPermission, ShipmentDetailValue value) {
        return getEntityFromPK(entityPermission, value.getPrimaryKey());
    }
    
    public ShipmentDetail getEntityFromCache(ShipmentDetailPK pk) {
        ShipmentDetailValue _value = (ShipmentDetailValue)session.getValueCache().get(pk);
    
        return _value == null ? null : new ShipmentDetail(_value, EntityPermission.READ_ONLY);
    }
    
    public ShipmentDetail getEntityFromPK(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(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<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(EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(ShipmentDetailFactory.class, queryMap.get(entityPermission));
        
        return getEntitiesFromQuery(entityPermission, ps, params);
    }
    
    public java.util.List<ShipmentDetail> getEntitiesFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(ShipmentDetailFactory.class, queryMap.get(entityPermission));
        
        return getEntitiesFromQuery(entityPermission, ps);
    }
    
    public java.util.List<ShipmentDetail> getEntitiesFromQuery(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(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(EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(ShipmentDetailFactory.class, queryMap.get(entityPermission));
        
        return getEntityFromQuery(entityPermission, ps, params);
    }
    
    public ShipmentDetail getEntityFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(ShipmentDetailFactory.class, queryMap.get(entityPermission));
        
        return getEntityFromQuery(entityPermission, ps);
    }
    
    public ShipmentDetail getEntityFromQuery(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(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 {
        java.util.List<ShipmentDetail> _result = new ArrayList<>();
        
        try {
            while(rs.next()) {
                _result.add(getEntityFromResultSet(entityPermission, rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public ShipmentDetail getEntityFromResultSet(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(_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(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(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(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 void create(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);
            });
        }
    }
    
    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(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(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 remove(ShipmentDetail entity)
            throws PersistenceDatabaseException {
        remove(entity.getPrimaryKey());
    }
    
    @Override
    public void remove(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(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 boolean validPK(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;
    }
    
}