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

/**
 * ContactPostalAddressFactory.java
 */

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

import com.echothree.model.data.contact.common.pk.ContactMechanismPK;
import com.echothree.model.data.party.common.pk.PersonalTitlePK;
import com.echothree.model.data.party.common.pk.NameSuffixPK;
import com.echothree.model.data.geo.common.pk.GeoCodePK;

import com.echothree.model.data.contact.server.entity.ContactMechanism;
import com.echothree.model.data.party.server.entity.PersonalTitle;
import com.echothree.model.data.party.server.entity.NameSuffix;
import com.echothree.model.data.geo.server.entity.GeoCode;

import com.echothree.model.data.contact.common.ContactPostalAddressConstants;
import com.echothree.model.data.contact.common.pk.ContactPostalAddressPK;
import com.echothree.model.data.contact.server.value.ContactPostalAddressValue;
import com.echothree.model.data.contact.server.entity.ContactPostalAddress;
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 ContactPostalAddressFactory
        implements BaseFactory<ContactPostalAddressPK, ContactPostalAddress> {
    
    //final private static Log log = LogFactory.getLog(ContactPostalAddressFactory.class);
    
    final private static String SQL_SELECT_READ_ONLY = "SELECT ctpa_contactpostaladdressid, ctpa_cmch_contactmechanismid, ctpa_pert_personaltitleid, ctpa_firstname, ctpa_firstnamesdx, ctpa_middlename, ctpa_middlenamesdx, ctpa_lastname, ctpa_lastnamesdx, ctpa_nsfx_namesuffixid, ctpa_companyname, ctpa_attention, ctpa_address1, ctpa_address2, ctpa_address3, ctpa_city, ctpa_citygeocodeid, ctpa_countygeocodeid, ctpa_state, ctpa_stategeocodeid, ctpa_postalcode, ctpa_postalcodegeocodeid, ctpa_countrygeocodeid, ctpa_iscommercial, ctpa_fromtime, ctpa_thrutime FROM contactpostaladdresses WHERE ctpa_contactpostaladdressid = ?";
    final private static String SQL_SELECT_READ_WRITE = "SELECT ctpa_contactpostaladdressid, ctpa_cmch_contactmechanismid, ctpa_pert_personaltitleid, ctpa_firstname, ctpa_firstnamesdx, ctpa_middlename, ctpa_middlenamesdx, ctpa_lastname, ctpa_lastnamesdx, ctpa_nsfx_namesuffixid, ctpa_companyname, ctpa_attention, ctpa_address1, ctpa_address2, ctpa_address3, ctpa_city, ctpa_citygeocodeid, ctpa_countygeocodeid, ctpa_state, ctpa_stategeocodeid, ctpa_postalcode, ctpa_postalcodegeocodeid, ctpa_countrygeocodeid, ctpa_iscommercial, ctpa_fromtime, ctpa_thrutime FROM contactpostaladdresses WHERE ctpa_contactpostaladdressid = ? FOR UPDATE";
    final private static String SQL_INSERT = "INSERT INTO contactpostaladdresses (ctpa_contactpostaladdressid, ctpa_cmch_contactmechanismid, ctpa_pert_personaltitleid, ctpa_firstname, ctpa_firstnamesdx, ctpa_middlename, ctpa_middlenamesdx, ctpa_lastname, ctpa_lastnamesdx, ctpa_nsfx_namesuffixid, ctpa_companyname, ctpa_attention, ctpa_address1, ctpa_address2, ctpa_address3, ctpa_city, ctpa_citygeocodeid, ctpa_countygeocodeid, ctpa_state, ctpa_stategeocodeid, ctpa_postalcode, ctpa_postalcodegeocodeid, ctpa_countrygeocodeid, ctpa_iscommercial, ctpa_fromtime, ctpa_thrutime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
    final private static String SQL_UPDATE = "UPDATE contactpostaladdresses SET ctpa_cmch_contactmechanismid = ?, ctpa_pert_personaltitleid = ?, ctpa_firstname = ?, ctpa_firstnamesdx = ?, ctpa_middlename = ?, ctpa_middlenamesdx = ?, ctpa_lastname = ?, ctpa_lastnamesdx = ?, ctpa_nsfx_namesuffixid = ?, ctpa_companyname = ?, ctpa_attention = ?, ctpa_address1 = ?, ctpa_address2 = ?, ctpa_address3 = ?, ctpa_city = ?, ctpa_citygeocodeid = ?, ctpa_countygeocodeid = ?, ctpa_state = ?, ctpa_stategeocodeid = ?, ctpa_postalcode = ?, ctpa_postalcodegeocodeid = ?, ctpa_countrygeocodeid = ?, ctpa_iscommercial = ?, ctpa_fromtime = ?, ctpa_thrutime = ? WHERE ctpa_contactpostaladdressid = ?";
    final private static String SQL_DELETE = "DELETE FROM contactpostaladdresses WHERE ctpa_contactpostaladdressid = ?";
    final private static String SQL_VALID = "SELECT COUNT(*) FROM contactpostaladdresses WHERE ctpa_contactpostaladdressid = ?";
    
    final private static String PK_COLUMN = "ctpa_contactpostaladdressid";
    final private static String ALL_COLUMNS = "ctpa_contactpostaladdressid, ctpa_cmch_contactmechanismid, ctpa_pert_personaltitleid, ctpa_firstname, ctpa_firstnamesdx, ctpa_middlename, ctpa_middlenamesdx, ctpa_lastname, ctpa_lastnamesdx, ctpa_nsfx_namesuffixid, ctpa_companyname, ctpa_attention, ctpa_address1, ctpa_address2, ctpa_address3, ctpa_city, ctpa_citygeocodeid, ctpa_countygeocodeid, ctpa_state, ctpa_stategeocodeid, ctpa_postalcode, ctpa_postalcodegeocodeid, ctpa_countrygeocodeid, ctpa_iscommercial, ctpa_fromtime, ctpa_thrutime";
    final public static String TABLE_NAME = "contactpostaladdresses";
    
    final public static String CTPA_CONTACTPOSTALADDRESSID = "ctpa_contactpostaladdressid";
    final public static String CTPA_CMCH_CONTACTMECHANISMID = "ctpa_cmch_contactmechanismid";
    final public static String CTPA_PERT_PERSONALTITLEID = "ctpa_pert_personaltitleid";
    final public static String CTPA_FIRSTNAME = "ctpa_firstname";
    final public static String CTPA_FIRSTNAMESDX = "ctpa_firstnamesdx";
    final public static String CTPA_MIDDLENAME = "ctpa_middlename";
    final public static String CTPA_MIDDLENAMESDX = "ctpa_middlenamesdx";
    final public static String CTPA_LASTNAME = "ctpa_lastname";
    final public static String CTPA_LASTNAMESDX = "ctpa_lastnamesdx";
    final public static String CTPA_NSFX_NAMESUFFIXID = "ctpa_nsfx_namesuffixid";
    final public static String CTPA_COMPANYNAME = "ctpa_companyname";
    final public static String CTPA_ATTENTION = "ctpa_attention";
    final public static String CTPA_ADDRESS1 = "ctpa_address1";
    final public static String CTPA_ADDRESS2 = "ctpa_address2";
    final public static String CTPA_ADDRESS3 = "ctpa_address3";
    final public static String CTPA_CITY = "ctpa_city";
    final public static String CTPA_CITYGEOCODEID = "ctpa_citygeocodeid";
    final public static String CTPA_COUNTYGEOCODEID = "ctpa_countygeocodeid";
    final public static String CTPA_STATE = "ctpa_state";
    final public static String CTPA_STATEGEOCODEID = "ctpa_stategeocodeid";
    final public static String CTPA_POSTALCODE = "ctpa_postalcode";
    final public static String CTPA_POSTALCODEGEOCODEID = "ctpa_postalcodegeocodeid";
    final public static String CTPA_COUNTRYGEOCODEID = "ctpa_countrygeocodeid";
    final public static String CTPA_ISCOMMERCIAL = "ctpa_iscommercial";
    final public static String CTPA_FROMTIME = "ctpa_fromtime";
    final public static String CTPA_THRUTIME = "ctpa_thrutime";
    
    final private static EntityIdGenerator entityIdGenerator = new EntityIdGenerator(ContactPostalAddressConstants.COMPONENT_VENDOR_NAME, ContactPostalAddressConstants.ENTITY_TYPE_NAME);
    
    /** Creates a new instance of ContactPostalAddressFactory */
    private ContactPostalAddressFactory() {
        super();
    }
    
    private static class ContactPostalAddressFactoryHolder {
        static ContactPostalAddressFactory instance = new ContactPostalAddressFactory();
    }
    
    public static ContactPostalAddressFactory getInstance() {
        return ContactPostalAddressFactoryHolder.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 ContactPostalAddressConstants.COMPONENT_VENDOR_NAME;
    }
    
    @Override
    public String getEntityTypeName() {
        return ContactPostalAddressConstants.ENTITY_TYPE_NAME;
    }
    
    public PreparedStatement prepareStatement(String query) {
        return ThreadSession.currentSession().prepareStatement(ContactPostalAddressFactory.class, query);
    }
    
    public ContactPostalAddressPK getNextPK() {
        return new ContactPostalAddressPK(entityIdGenerator.getNextEntityId());
    }
    
    public Set<ContactPostalAddressPK> getPKsFromResultSetAsSet(ResultSet rs)
            throws PersistenceDatabaseException {
        Set<ContactPostalAddressPK> _result = new HashSet<>();
        
        try {
            while(rs.next()) {
                _result.add(getPKFromResultSet(rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public java.util.List<ContactPostalAddressPK> getPKsFromResultSetAsList(ResultSet rs)
            throws PersistenceDatabaseException {
        java.util.List<ContactPostalAddressPK> _result = new ArrayList<>();
        
        try {
            while(rs.next()) {
                _result.add(getPKFromResultSet(rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public ContactPostalAddressPK getPKFromResultSet(ResultSet rs)
            throws PersistenceDatabaseException {
        ContactPostalAddressPK _result;
        
        try {
            long ctpa_contactpostaladdressid = rs.getLong(CTPA_CONTACTPOSTALADDRESSID);
            Long _entityId = rs.wasNull() ? null : ctpa_contactpostaladdressid;
            
            _result = new ContactPostalAddressPK(_entityId);
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public java.util.List<ContactPostalAddressValue> getValuesFromPKs(Session session, Collection<ContactPostalAddressPK> pks)
            throws PersistenceDatabaseException {
        java.util.List<ContactPostalAddressValue> _values = new ArrayList<>(pks.size());
        
        for(ContactPostalAddressPK _pk: pks) {
            _values.add(getValueFromPK(session, _pk));
        }
        
        return _values;
    }
    
    public ContactPostalAddressValue getValueFromPK(Session session, ContactPostalAddressPK pk)
            throws PersistenceDatabaseException {
        ContactPostalAddressValue _value;
        
        // See if we already have the entity in the session cache
        ContactPostalAddress _entity = (ContactPostalAddress)session.getEntity(pk);
        if(_entity == null)
            _value = getEntityFromPK(session, EntityPermission.READ_ONLY, pk).getContactPostalAddressValue();
        else
            _value = _entity.getContactPostalAddressValue();
        
        return _value;
    }
    
    public java.util.List<ContactPostalAddressValue> getValuesFromResultSet(Session session, ResultSet rs)
            throws PersistenceDatabaseException {
        java.util.List<ContactPostalAddressValue> _result = new ArrayList<>();
        
        try {
            while(rs.next()) {
                _result.add(getValueFromResultSet(session, rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public ContactPostalAddressValue getValueFromResultSet(Session session, ResultSet rs)
            throws PersistenceDatabaseException {
        ContactPostalAddressValue _value;
        
        try {
            Long ctpa_contactpostaladdressid = rs.getLong(CTPA_CONTACTPOSTALADDRESSID);
            ContactPostalAddressPK _pk = new ContactPostalAddressPK(ctpa_contactpostaladdressid);
            
            // See if we already have the entity in the session cache
            ContactPostalAddress _entity = (ContactPostalAddress)session.getEntity(_pk);
            
            if(_entity == null) {
                Long ctpa_cmch_contactmechanismid = rs.getLong(CTPA_CMCH_CONTACTMECHANISMID);
                if(rs.wasNull())
                    ctpa_cmch_contactmechanismid = null;
                
                Long ctpa_pert_personaltitleid = rs.getLong(CTPA_PERT_PERSONALTITLEID);
                if(rs.wasNull())
                    ctpa_pert_personaltitleid = null;
                
                String ctpa_firstname = rs.getString(CTPA_FIRSTNAME);
                if(rs.wasNull())
                    ctpa_firstname = null;
                
                String ctpa_firstnamesdx = rs.getString(CTPA_FIRSTNAMESDX);
                if(rs.wasNull())
                    ctpa_firstnamesdx = null;
                
                String ctpa_middlename = rs.getString(CTPA_MIDDLENAME);
                if(rs.wasNull())
                    ctpa_middlename = null;
                
                String ctpa_middlenamesdx = rs.getString(CTPA_MIDDLENAMESDX);
                if(rs.wasNull())
                    ctpa_middlenamesdx = null;
                
                String ctpa_lastname = rs.getString(CTPA_LASTNAME);
                if(rs.wasNull())
                    ctpa_lastname = null;
                
                String ctpa_lastnamesdx = rs.getString(CTPA_LASTNAMESDX);
                if(rs.wasNull())
                    ctpa_lastnamesdx = null;
                
                Long ctpa_nsfx_namesuffixid = rs.getLong(CTPA_NSFX_NAMESUFFIXID);
                if(rs.wasNull())
                    ctpa_nsfx_namesuffixid = null;
                
                String ctpa_companyname = rs.getString(CTPA_COMPANYNAME);
                if(rs.wasNull())
                    ctpa_companyname = null;
                
                String ctpa_attention = rs.getString(CTPA_ATTENTION);
                if(rs.wasNull())
                    ctpa_attention = null;
                
                String ctpa_address1 = rs.getString(CTPA_ADDRESS1);
                if(rs.wasNull())
                    ctpa_address1 = null;
                
                String ctpa_address2 = rs.getString(CTPA_ADDRESS2);
                if(rs.wasNull())
                    ctpa_address2 = null;
                
                String ctpa_address3 = rs.getString(CTPA_ADDRESS3);
                if(rs.wasNull())
                    ctpa_address3 = null;
                
                String ctpa_city = rs.getString(CTPA_CITY);
                if(rs.wasNull())
                    ctpa_city = null;
                
                Long ctpa_citygeocodeid = rs.getLong(CTPA_CITYGEOCODEID);
                if(rs.wasNull())
                    ctpa_citygeocodeid = null;
                
                Long ctpa_countygeocodeid = rs.getLong(CTPA_COUNTYGEOCODEID);
                if(rs.wasNull())
                    ctpa_countygeocodeid = null;
                
                String ctpa_state = rs.getString(CTPA_STATE);
                if(rs.wasNull())
                    ctpa_state = null;
                
                Long ctpa_stategeocodeid = rs.getLong(CTPA_STATEGEOCODEID);
                if(rs.wasNull())
                    ctpa_stategeocodeid = null;
                
                String ctpa_postalcode = rs.getString(CTPA_POSTALCODE);
                if(rs.wasNull())
                    ctpa_postalcode = null;
                
                Long ctpa_postalcodegeocodeid = rs.getLong(CTPA_POSTALCODEGEOCODEID);
                if(rs.wasNull())
                    ctpa_postalcodegeocodeid = null;
                
                Long ctpa_countrygeocodeid = rs.getLong(CTPA_COUNTRYGEOCODEID);
                if(rs.wasNull())
                    ctpa_countrygeocodeid = null;
                
                Boolean ctpa_iscommercial = rs.getInt(CTPA_ISCOMMERCIAL) == 1;
                if(rs.wasNull())
                    ctpa_iscommercial = null;
                
                Long ctpa_fromtime = rs.getLong(CTPA_FROMTIME);
                if(rs.wasNull())
                    ctpa_fromtime = null;
                
                Long ctpa_thrutime = rs.getLong(CTPA_THRUTIME);
                if(rs.wasNull())
                    ctpa_thrutime = null;
                
                _value = new ContactPostalAddressValue(_pk, new ContactMechanismPK(ctpa_cmch_contactmechanismid), new PersonalTitlePK(ctpa_pert_personaltitleid), ctpa_firstname, ctpa_firstnamesdx, ctpa_middlename, ctpa_middlenamesdx, ctpa_lastname, ctpa_lastnamesdx, new NameSuffixPK(ctpa_nsfx_namesuffixid), ctpa_companyname, ctpa_attention, ctpa_address1, ctpa_address2, ctpa_address3, ctpa_city, new GeoCodePK(ctpa_citygeocodeid), new GeoCodePK(ctpa_countygeocodeid), ctpa_state, new GeoCodePK(ctpa_stategeocodeid), ctpa_postalcode, new GeoCodePK(ctpa_postalcodegeocodeid), new GeoCodePK(ctpa_countrygeocodeid), ctpa_iscommercial, ctpa_fromtime, ctpa_thrutime);
            } else
                _value = _entity.getContactPostalAddressValue();
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _value;
    }
    
    public java.util.List<ContactPostalAddress> getEntitiesFromPKs(EntityPermission entityPermission, Collection<ContactPostalAddressPK> pks)
            throws PersistenceDatabaseException {
        return getEntitiesFromPKs(ThreadSession.currentSession(), entityPermission, pks);
    }
    
    public java.util.List<ContactPostalAddress> getEntitiesFromPKs(Session session, EntityPermission entityPermission, Collection<ContactPostalAddressPK> pks)
            throws PersistenceDatabaseException {
        java.util.List<ContactPostalAddress> _entities = new ArrayList<>(pks.size());
        
        for(ContactPostalAddressPK _pk: pks) {
            _entities.add(getEntityFromPK(session, entityPermission, _pk));
        }
        
        return _entities;
    }
    
    public ContactPostalAddress getEntityFromValue(EntityPermission entityPermission, ContactPostalAddressValue value) {
        return getEntityFromPK(ThreadSession.currentSession(), entityPermission, value.getPrimaryKey());
    }
    
    public ContactPostalAddress getEntityFromValue(Session session, EntityPermission entityPermission, ContactPostalAddressValue value) {
        return getEntityFromPK(session, entityPermission, value.getPrimaryKey());
    }
    
    public ContactPostalAddress getEntityFromPK(EntityPermission entityPermission, ContactPostalAddressPK pk)
            throws PersistenceDatabaseException {
        return getEntityFromPK(ThreadSession.currentSession(), entityPermission, pk);
    }
    
    public ContactPostalAddress getEntityFromCache(Session session, ContactPostalAddressPK pk) {
        ContactPostalAddressValue _value = (ContactPostalAddressValue)session.getValueCache().get(pk);
    
        return _value == null ? null : new ContactPostalAddress(_value, EntityPermission.READ_ONLY);
    }
    
    public ContactPostalAddress getEntityFromPK(Session session, EntityPermission entityPermission, ContactPostalAddressPK pk)
            throws PersistenceDatabaseException {
        ContactPostalAddress _entity;
        
        // See if we already have the entity in the session cache
        _entity = (ContactPostalAddress)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<ContactPostalAddressPK> getPKsFromQueryAsSet(PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        Set<ContactPostalAddressPK> _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<ContactPostalAddressPK> getPKsFromQueryAsList(PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        java.util.List<ContactPostalAddressPK> _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 ContactPostalAddressPK getPKFromQuery(PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        ContactPostalAddressPK _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<ContactPostalAddress> getEntitiesFromQuery(Session session, EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(ContactPostalAddressFactory.class, queryMap.get(entityPermission));
        
        return getEntitiesFromQuery(session, entityPermission, ps, params);
    }
    
    public java.util.List<ContactPostalAddress> getEntitiesFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
            throws PersistenceDatabaseException {
        Session session = ThreadSession.currentSession();
        PreparedStatement ps = session.prepareStatement(ContactPostalAddressFactory.class, queryMap.get(entityPermission));
        
        return getEntitiesFromQuery(session, entityPermission, ps, params);
    }
    
    public java.util.List<ContactPostalAddress> getEntitiesFromQuery(Session session, EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(ContactPostalAddressFactory.class, queryMap.get(entityPermission));
        
        return getEntitiesFromQuery(session, entityPermission, ps);
    }
    
    public java.util.List<ContactPostalAddress> getEntitiesFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
            throws PersistenceDatabaseException {
        Session session = ThreadSession.currentSession();
        PreparedStatement ps = session.prepareStatement(ContactPostalAddressFactory.class, queryMap.get(entityPermission));
        
        return getEntitiesFromQuery(session, entityPermission, ps);
    }
    
    public java.util.List<ContactPostalAddress> getEntitiesFromQuery(EntityPermission entityPermission, PreparedStatement ps)
            throws PersistenceDatabaseException {
        return getEntitiesFromQuery(ThreadSession.currentSession(), entityPermission, ps);
    }
    
    public java.util.List<ContactPostalAddress> getEntitiesFromQuery(EntityPermission entityPermission, PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        return getEntitiesFromQuery(ThreadSession.currentSession(), entityPermission, ps, params);
    }
    
    public java.util.List<ContactPostalAddress> getEntitiesFromQuery(Session session, EntityPermission entityPermission, PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        java.util.List<ContactPostalAddress> _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 ContactPostalAddress getEntityFromQuery(Session session, EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(ContactPostalAddressFactory.class, queryMap.get(entityPermission));
        
        return getEntityFromQuery(session, entityPermission, ps, params);
    }
    
    public ContactPostalAddress getEntityFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
            throws PersistenceDatabaseException {
        Session session = ThreadSession.currentSession();
        PreparedStatement ps = session.prepareStatement(ContactPostalAddressFactory.class, queryMap.get(entityPermission));
        
        return getEntityFromQuery(session, entityPermission, ps, params);
    }
    
    public ContactPostalAddress getEntityFromQuery(Session session, EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
            throws PersistenceDatabaseException {
        PreparedStatement ps = session.prepareStatement(ContactPostalAddressFactory.class, queryMap.get(entityPermission));
        
        return getEntityFromQuery(session, entityPermission, ps);
    }
    
    public ContactPostalAddress getEntityFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
            throws PersistenceDatabaseException {
        Session session = ThreadSession.currentSession();
        PreparedStatement ps = session.prepareStatement(ContactPostalAddressFactory.class, queryMap.get(entityPermission));
        
        return getEntityFromQuery(session, entityPermission, ps);
    }
    
    public ContactPostalAddress getEntityFromQuery(EntityPermission entityPermission, PreparedStatement ps)
            throws PersistenceDatabaseException {
        return getEntityFromQuery(ThreadSession.currentSession(), entityPermission, ps);
    }
    
    public ContactPostalAddress getEntityFromQuery(EntityPermission entityPermission, PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        return getEntityFromQuery(ThreadSession.currentSession(), entityPermission, ps, params);
    }
    
    public ContactPostalAddress getEntityFromQuery(Session session, EntityPermission entityPermission, PreparedStatement ps, final Object... params)
            throws PersistenceDatabaseException {
        ContactPostalAddress _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<ContactPostalAddress> getEntitiesFromResultSet(EntityPermission entityPermission, ResultSet rs)
            throws PersistenceDatabaseException {
        return getEntitiesFromResultSet(ThreadSession.currentSession(), entityPermission, rs);
    }
    
    public java.util.List<ContactPostalAddress> getEntitiesFromResultSet(Session session, EntityPermission entityPermission, ResultSet rs)
            throws PersistenceDatabaseException {
        java.util.List<ContactPostalAddress> _result = new ArrayList<>();
        
        try {
            while(rs.next()) {
                _result.add(getEntityFromResultSet(session, entityPermission, rs));
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _result;
    }
    
    public ContactPostalAddress getEntityFromResultSet(EntityPermission entityPermission, ResultSet rs)
            throws PersistenceDatabaseException {
        return getEntityFromResultSet(ThreadSession.currentSession(), entityPermission, rs);
    }
    
    public ContactPostalAddress getEntityFromResultSet(Session session, EntityPermission entityPermission, ResultSet rs)
            throws PersistenceDatabaseException {
        ContactPostalAddress _entity;
        
        try {
            Long ctpa_contactpostaladdressid = rs.getLong(CTPA_CONTACTPOSTALADDRESSID);
            ContactPostalAddressPK _pk = new ContactPostalAddressPK(ctpa_contactpostaladdressid);
            
            // See if we already have the entity in the session cache
            _entity = (ContactPostalAddress)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 ctpa_cmch_contactmechanismid = rs.getLong(CTPA_CMCH_CONTACTMECHANISMID);
                if(rs.wasNull())
                    ctpa_cmch_contactmechanismid = null;
                
                Long ctpa_pert_personaltitleid = rs.getLong(CTPA_PERT_PERSONALTITLEID);
                if(rs.wasNull())
                    ctpa_pert_personaltitleid = null;
                
                String ctpa_firstname = rs.getString(CTPA_FIRSTNAME);
                if(rs.wasNull())
                    ctpa_firstname = null;
                
                String ctpa_firstnamesdx = rs.getString(CTPA_FIRSTNAMESDX);
                if(rs.wasNull())
                    ctpa_firstnamesdx = null;
                
                String ctpa_middlename = rs.getString(CTPA_MIDDLENAME);
                if(rs.wasNull())
                    ctpa_middlename = null;
                
                String ctpa_middlenamesdx = rs.getString(CTPA_MIDDLENAMESDX);
                if(rs.wasNull())
                    ctpa_middlenamesdx = null;
                
                String ctpa_lastname = rs.getString(CTPA_LASTNAME);
                if(rs.wasNull())
                    ctpa_lastname = null;
                
                String ctpa_lastnamesdx = rs.getString(CTPA_LASTNAMESDX);
                if(rs.wasNull())
                    ctpa_lastnamesdx = null;
                
                Long ctpa_nsfx_namesuffixid = rs.getLong(CTPA_NSFX_NAMESUFFIXID);
                if(rs.wasNull())
                    ctpa_nsfx_namesuffixid = null;
                
                String ctpa_companyname = rs.getString(CTPA_COMPANYNAME);
                if(rs.wasNull())
                    ctpa_companyname = null;
                
                String ctpa_attention = rs.getString(CTPA_ATTENTION);
                if(rs.wasNull())
                    ctpa_attention = null;
                
                String ctpa_address1 = rs.getString(CTPA_ADDRESS1);
                if(rs.wasNull())
                    ctpa_address1 = null;
                
                String ctpa_address2 = rs.getString(CTPA_ADDRESS2);
                if(rs.wasNull())
                    ctpa_address2 = null;
                
                String ctpa_address3 = rs.getString(CTPA_ADDRESS3);
                if(rs.wasNull())
                    ctpa_address3 = null;
                
                String ctpa_city = rs.getString(CTPA_CITY);
                if(rs.wasNull())
                    ctpa_city = null;
                
                Long ctpa_citygeocodeid = rs.getLong(CTPA_CITYGEOCODEID);
                if(rs.wasNull())
                    ctpa_citygeocodeid = null;
                
                Long ctpa_countygeocodeid = rs.getLong(CTPA_COUNTYGEOCODEID);
                if(rs.wasNull())
                    ctpa_countygeocodeid = null;
                
                String ctpa_state = rs.getString(CTPA_STATE);
                if(rs.wasNull())
                    ctpa_state = null;
                
                Long ctpa_stategeocodeid = rs.getLong(CTPA_STATEGEOCODEID);
                if(rs.wasNull())
                    ctpa_stategeocodeid = null;
                
                String ctpa_postalcode = rs.getString(CTPA_POSTALCODE);
                if(rs.wasNull())
                    ctpa_postalcode = null;
                
                Long ctpa_postalcodegeocodeid = rs.getLong(CTPA_POSTALCODEGEOCODEID);
                if(rs.wasNull())
                    ctpa_postalcodegeocodeid = null;
                
                Long ctpa_countrygeocodeid = rs.getLong(CTPA_COUNTRYGEOCODEID);
                if(rs.wasNull())
                    ctpa_countrygeocodeid = null;
                
                Boolean ctpa_iscommercial = rs.getInt(CTPA_ISCOMMERCIAL) == 1;
                if(rs.wasNull())
                    ctpa_iscommercial = null;
                
                Long ctpa_fromtime = rs.getLong(CTPA_FROMTIME);
                if(rs.wasNull())
                    ctpa_fromtime = null;
                
                Long ctpa_thrutime = rs.getLong(CTPA_THRUTIME);
                if(rs.wasNull())
                    ctpa_thrutime = null;
                
                ContactPostalAddressValue _value = new ContactPostalAddressValue(_pk, ctpa_cmch_contactmechanismid == null? null: new ContactMechanismPK(ctpa_cmch_contactmechanismid), ctpa_pert_personaltitleid == null? null: new PersonalTitlePK(ctpa_pert_personaltitleid), ctpa_firstname, ctpa_firstnamesdx, ctpa_middlename, ctpa_middlenamesdx, ctpa_lastname, ctpa_lastnamesdx, ctpa_nsfx_namesuffixid == null? null: new NameSuffixPK(ctpa_nsfx_namesuffixid), ctpa_companyname, ctpa_attention, ctpa_address1, ctpa_address2, ctpa_address3, ctpa_city, ctpa_citygeocodeid == null? null: new GeoCodePK(ctpa_citygeocodeid), ctpa_countygeocodeid == null? null: new GeoCodePK(ctpa_countygeocodeid), ctpa_state, ctpa_stategeocodeid == null? null: new GeoCodePK(ctpa_stategeocodeid), ctpa_postalcode, ctpa_postalcodegeocodeid == null? null: new GeoCodePK(ctpa_postalcodegeocodeid), ctpa_countrygeocodeid == null? null: new GeoCodePK(ctpa_countrygeocodeid), ctpa_iscommercial, ctpa_fromtime, ctpa_thrutime);
                _entity = new ContactPostalAddress(_value, entityPermission);
            }
            
            if(!foundInSessionCache) {
                if(entityPermission.equals(EntityPermission.READ_ONLY)) {
                    session.putReadOnlyEntity(_pk, _entity);
                    session.getValueCache().put(_entity.getContactPostalAddressValue());
                } else {
                    session.putReadWriteEntity(_pk, _entity);
                }
            }
        } catch (SQLException se) {
            throw new PersistenceDatabaseException(se);
        }
        
        return _entity;
    }
    
    public ContactPostalAddress create(Session session, ContactMechanism contactMechanism, PersonalTitle personalTitle, String firstName, String firstNameSdx, String middleName, String middleNameSdx, String lastName, String lastNameSdx, NameSuffix nameSuffix, String companyName, String attention, String address1, String address2, String address3, String city, GeoCode cityGeoCode, GeoCode countyGeoCode, String state, GeoCode stateGeoCode, String postalCode, GeoCode postalCodeGeoCode, GeoCode countryGeoCode, Boolean isCommercial, Long fromTime, Long thruTime)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        return create(session, contactMechanism == null ? null : contactMechanism.getPrimaryKey(), personalTitle == null ? null : personalTitle.getPrimaryKey(), firstName, firstNameSdx, middleName, middleNameSdx, lastName, lastNameSdx, nameSuffix == null ? null : nameSuffix.getPrimaryKey(), companyName, attention, address1, address2, address3, city, cityGeoCode == null ? null : cityGeoCode.getPrimaryKey(), countyGeoCode == null ? null : countyGeoCode.getPrimaryKey(), state, stateGeoCode == null ? null : stateGeoCode.getPrimaryKey(), postalCode, postalCodeGeoCode == null ? null : postalCodeGeoCode.getPrimaryKey(), countryGeoCode == null ? null : countryGeoCode.getPrimaryKey(), isCommercial, fromTime, thruTime);
    }
    
    public ContactPostalAddress create(ContactMechanism contactMechanism, PersonalTitle personalTitle, String firstName, String firstNameSdx, String middleName, String middleNameSdx, String lastName, String lastNameSdx, NameSuffix nameSuffix, String companyName, String attention, String address1, String address2, String address3, String city, GeoCode cityGeoCode, GeoCode countyGeoCode, String state, GeoCode stateGeoCode, String postalCode, GeoCode postalCodeGeoCode, GeoCode countryGeoCode, Boolean isCommercial, Long fromTime, Long thruTime)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        return create(ThreadSession.currentSession(), contactMechanism == null ? null : contactMechanism.getPrimaryKey(), personalTitle == null ? null : personalTitle.getPrimaryKey(), firstName, firstNameSdx, middleName, middleNameSdx, lastName, lastNameSdx, nameSuffix == null ? null : nameSuffix.getPrimaryKey(), companyName, attention, address1, address2, address3, city, cityGeoCode == null ? null : cityGeoCode.getPrimaryKey(), countyGeoCode == null ? null : countyGeoCode.getPrimaryKey(), state, stateGeoCode == null ? null : stateGeoCode.getPrimaryKey(), postalCode, postalCodeGeoCode == null ? null : postalCodeGeoCode.getPrimaryKey(), countryGeoCode == null ? null : countryGeoCode.getPrimaryKey(), isCommercial, fromTime, thruTime);
    }
    
    private void bindForCreate(PreparedStatement _ps, ContactPostalAddressValue _value)
            throws SQLException {
        _ps.setLong(1, _value.getEntityId());
        
        ContactMechanismPK ctpa_cmch_contactmechanismid = _value.getContactMechanismPK();
        if(ctpa_cmch_contactmechanismid == null)
            _ps.setNull(2, Types.BIGINT);
        else
            _ps.setLong(2, ctpa_cmch_contactmechanismid.getEntityId());
            
        PersonalTitlePK ctpa_pert_personaltitleid = _value.getPersonalTitlePK();
        if(ctpa_pert_personaltitleid == null)
            _ps.setNull(3, Types.BIGINT);
        else
            _ps.setLong(3, ctpa_pert_personaltitleid.getEntityId());
            
        String ctpa_firstname = _value.getFirstName();
        if(ctpa_firstname == null)
            _ps.setNull(4, Types.VARCHAR);
        else
            _ps.setString(4, ctpa_firstname);
            
        String ctpa_firstnamesdx = _value.getFirstNameSdx();
        if(ctpa_firstnamesdx == null)
            _ps.setNull(5, Types.VARCHAR);
        else
            _ps.setString(5, ctpa_firstnamesdx);
            
        String ctpa_middlename = _value.getMiddleName();
        if(ctpa_middlename == null)
            _ps.setNull(6, Types.VARCHAR);
        else
            _ps.setString(6, ctpa_middlename);
            
        String ctpa_middlenamesdx = _value.getMiddleNameSdx();
        if(ctpa_middlenamesdx == null)
            _ps.setNull(7, Types.VARCHAR);
        else
            _ps.setString(7, ctpa_middlenamesdx);
            
        String ctpa_lastname = _value.getLastName();
        if(ctpa_lastname == null)
            _ps.setNull(8, Types.VARCHAR);
        else
            _ps.setString(8, ctpa_lastname);
            
        String ctpa_lastnamesdx = _value.getLastNameSdx();
        if(ctpa_lastnamesdx == null)
            _ps.setNull(9, Types.VARCHAR);
        else
            _ps.setString(9, ctpa_lastnamesdx);
            
        NameSuffixPK ctpa_nsfx_namesuffixid = _value.getNameSuffixPK();
        if(ctpa_nsfx_namesuffixid == null)
            _ps.setNull(10, Types.BIGINT);
        else
            _ps.setLong(10, ctpa_nsfx_namesuffixid.getEntityId());
            
        String ctpa_companyname = _value.getCompanyName();
        if(ctpa_companyname == null)
            _ps.setNull(11, Types.VARCHAR);
        else
            _ps.setString(11, ctpa_companyname);
            
        String ctpa_attention = _value.getAttention();
        if(ctpa_attention == null)
            _ps.setNull(12, Types.VARCHAR);
        else
            _ps.setString(12, ctpa_attention);
            
        String ctpa_address1 = _value.getAddress1();
        if(ctpa_address1 == null)
            _ps.setNull(13, Types.VARCHAR);
        else
            _ps.setString(13, ctpa_address1);
            
        String ctpa_address2 = _value.getAddress2();
        if(ctpa_address2 == null)
            _ps.setNull(14, Types.VARCHAR);
        else
            _ps.setString(14, ctpa_address2);
            
        String ctpa_address3 = _value.getAddress3();
        if(ctpa_address3 == null)
            _ps.setNull(15, Types.VARCHAR);
        else
            _ps.setString(15, ctpa_address3);
            
        String ctpa_city = _value.getCity();
        if(ctpa_city == null)
            _ps.setNull(16, Types.VARCHAR);
        else
            _ps.setString(16, ctpa_city);
            
        GeoCodePK ctpa_citygeocodeid = _value.getCityGeoCodePK();
        if(ctpa_citygeocodeid == null)
            _ps.setNull(17, Types.BIGINT);
        else
            _ps.setLong(17, ctpa_citygeocodeid.getEntityId());
            
        GeoCodePK ctpa_countygeocodeid = _value.getCountyGeoCodePK();
        if(ctpa_countygeocodeid == null)
            _ps.setNull(18, Types.BIGINT);
        else
            _ps.setLong(18, ctpa_countygeocodeid.getEntityId());
            
        String ctpa_state = _value.getState();
        if(ctpa_state == null)
            _ps.setNull(19, Types.VARCHAR);
        else
            _ps.setString(19, ctpa_state);
            
        GeoCodePK ctpa_stategeocodeid = _value.getStateGeoCodePK();
        if(ctpa_stategeocodeid == null)
            _ps.setNull(20, Types.BIGINT);
        else
            _ps.setLong(20, ctpa_stategeocodeid.getEntityId());
            
        String ctpa_postalcode = _value.getPostalCode();
        if(ctpa_postalcode == null)
            _ps.setNull(21, Types.VARCHAR);
        else
            _ps.setString(21, ctpa_postalcode);
            
        GeoCodePK ctpa_postalcodegeocodeid = _value.getPostalCodeGeoCodePK();
        if(ctpa_postalcodegeocodeid == null)
            _ps.setNull(22, Types.BIGINT);
        else
            _ps.setLong(22, ctpa_postalcodegeocodeid.getEntityId());
            
        GeoCodePK ctpa_countrygeocodeid = _value.getCountryGeoCodePK();
        if(ctpa_countrygeocodeid == null)
            _ps.setNull(23, Types.BIGINT);
        else
            _ps.setLong(23, ctpa_countrygeocodeid.getEntityId());
            
        Boolean ctpa_iscommercial = _value.getIsCommercial();
        if(ctpa_iscommercial == null)
            _ps.setNull(24, Types.BIT);
        else
            _ps.setInt(24, ctpa_iscommercial? 1: 0);
            
        Long ctpa_fromtime = _value.getFromTime();
        if(ctpa_fromtime == null)
            _ps.setNull(25, Types.BIGINT);
        else
            _ps.setLong(25, ctpa_fromtime);
            
        Long ctpa_thrutime = _value.getThruTime();
        if(ctpa_thrutime == null)
            _ps.setNull(26, Types.BIGINT);
        else
            _ps.setLong(26, ctpa_thrutime);
            
    }
    
    public ContactPostalAddress create(Session session, ContactMechanismPK contactMechanismPK, PersonalTitlePK personalTitlePK, String firstName, String firstNameSdx, String middleName, String middleNameSdx, String lastName, String lastNameSdx, NameSuffixPK nameSuffixPK, String companyName, String attention, String address1, String address2, String address3, String city, GeoCodePK cityGeoCodePK, GeoCodePK countyGeoCodePK, String state, GeoCodePK stateGeoCodePK, String postalCode, GeoCodePK postalCodeGeoCodePK, GeoCodePK countryGeoCodePK, Boolean isCommercial, Long fromTime, Long thruTime)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        ContactPostalAddressPK _pk = getNextPK();
        ContactPostalAddressValue _value = new ContactPostalAddressValue(_pk, contactMechanismPK, personalTitlePK, firstName, firstNameSdx, middleName, middleNameSdx, lastName, lastNameSdx, nameSuffixPK, companyName, attention, address1, address2, address3, city, cityGeoCodePK, countyGeoCodePK, state, stateGeoCodePK, postalCode, postalCodeGeoCodePK, countryGeoCodePK, isCommercial, 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);
        }
        
        ContactPostalAddress _entity = new ContactPostalAddress(_value, EntityPermission.READ_ONLY);
        session.putReadOnlyEntity(_pk, _entity);
        
        return _entity;
    }
    
    public ContactPostalAddress create(ContactMechanismPK contactMechanismPK, PersonalTitlePK personalTitlePK, String firstName, String firstNameSdx, String middleName, String middleNameSdx, String lastName, String lastNameSdx, NameSuffixPK nameSuffixPK, String companyName, String attention, String address1, String address2, String address3, String city, GeoCodePK cityGeoCodePK, GeoCodePK countyGeoCodePK, String state, GeoCodePK stateGeoCodePK, String postalCode, GeoCodePK postalCodeGeoCodePK, GeoCodePK countryGeoCodePK, Boolean isCommercial, Long fromTime, Long thruTime)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        return create(ThreadSession.currentSession(), contactMechanismPK, personalTitlePK, firstName, firstNameSdx, middleName, middleNameSdx, lastName, lastNameSdx, nameSuffixPK, companyName, attention, address1, address2, address3, city, cityGeoCodePK, countyGeoCodePK, state, stateGeoCodePK, postalCode, postalCodeGeoCodePK, countryGeoCodePK, isCommercial, fromTime, thruTime);
    }
    
    public void create(Session session, Collection<ContactPostalAddressValue> _values)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        int _size = _values.size();
        
        if(_size > 0) {
            PreparedStatement _ps = session.prepareStatement(SQL_INSERT);
            List<ContactPostalAddressValue> _cacheValues = new ArrayList<>(_size);
            
            try {
                for(ContactPostalAddressValue _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) -> {
                ContactPostalAddress _cacheEntity = new ContactPostalAddress(_cacheValue, EntityPermission.READ_ONLY);
                
                session.putReadOnlyEntity(_cacheValue.getPrimaryKey(), _cacheEntity);
            });
        }
    }
    
    public void create(Collection<ContactPostalAddressValue> _values)
            throws PersistenceDatabaseException, PersistenceNotNullException {
        create(ThreadSession.currentSession(), _values);
    }
    
    private boolean bindForStore(PreparedStatement _ps, ContactPostalAddressValue _value)
            throws SQLException {
        boolean _hasBeenModified = _value.hasBeenModified();
        
        if(_hasBeenModified) {
            ContactMechanismPK ctpa_cmch_contactmechanismid = _value.getContactMechanismPK();
            if(ctpa_cmch_contactmechanismid == null)
                _ps.setNull(1, Types.BIGINT);
            else
                _ps.setLong(1, ctpa_cmch_contactmechanismid.getEntityId());
            
            PersonalTitlePK ctpa_pert_personaltitleid = _value.getPersonalTitlePK();
            if(ctpa_pert_personaltitleid == null)
                _ps.setNull(2, Types.BIGINT);
            else
                _ps.setLong(2, ctpa_pert_personaltitleid.getEntityId());
            
            String ctpa_firstname = _value.getFirstName();
            if(ctpa_firstname == null)
                _ps.setNull(3, Types.VARCHAR);
            else
                _ps.setString(3, ctpa_firstname);
            
            String ctpa_firstnamesdx = _value.getFirstNameSdx();
            if(ctpa_firstnamesdx == null)
                _ps.setNull(4, Types.VARCHAR);
            else
                _ps.setString(4, ctpa_firstnamesdx);
            
            String ctpa_middlename = _value.getMiddleName();
            if(ctpa_middlename == null)
                _ps.setNull(5, Types.VARCHAR);
            else
                _ps.setString(5, ctpa_middlename);
            
            String ctpa_middlenamesdx = _value.getMiddleNameSdx();
            if(ctpa_middlenamesdx == null)
                _ps.setNull(6, Types.VARCHAR);
            else
                _ps.setString(6, ctpa_middlenamesdx);
            
            String ctpa_lastname = _value.getLastName();
            if(ctpa_lastname == null)
                _ps.setNull(7, Types.VARCHAR);
            else
                _ps.setString(7, ctpa_lastname);
            
            String ctpa_lastnamesdx = _value.getLastNameSdx();
            if(ctpa_lastnamesdx == null)
                _ps.setNull(8, Types.VARCHAR);
            else
                _ps.setString(8, ctpa_lastnamesdx);
            
            NameSuffixPK ctpa_nsfx_namesuffixid = _value.getNameSuffixPK();
            if(ctpa_nsfx_namesuffixid == null)
                _ps.setNull(9, Types.BIGINT);
            else
                _ps.setLong(9, ctpa_nsfx_namesuffixid.getEntityId());
            
            String ctpa_companyname = _value.getCompanyName();
            if(ctpa_companyname == null)
                _ps.setNull(10, Types.VARCHAR);
            else
                _ps.setString(10, ctpa_companyname);
            
            String ctpa_attention = _value.getAttention();
            if(ctpa_attention == null)
                _ps.setNull(11, Types.VARCHAR);
            else
                _ps.setString(11, ctpa_attention);
            
            String ctpa_address1 = _value.getAddress1();
            if(ctpa_address1 == null)
                _ps.setNull(12, Types.VARCHAR);
            else
                _ps.setString(12, ctpa_address1);
            
            String ctpa_address2 = _value.getAddress2();
            if(ctpa_address2 == null)
                _ps.setNull(13, Types.VARCHAR);
            else
                _ps.setString(13, ctpa_address2);
            
            String ctpa_address3 = _value.getAddress3();
            if(ctpa_address3 == null)
                _ps.setNull(14, Types.VARCHAR);
            else
                _ps.setString(14, ctpa_address3);
            
            String ctpa_city = _value.getCity();
            if(ctpa_city == null)
                _ps.setNull(15, Types.VARCHAR);
            else
                _ps.setString(15, ctpa_city);
            
            GeoCodePK ctpa_citygeocodeid = _value.getCityGeoCodePK();
            if(ctpa_citygeocodeid == null)
                _ps.setNull(16, Types.BIGINT);
            else
                _ps.setLong(16, ctpa_citygeocodeid.getEntityId());
            
            GeoCodePK ctpa_countygeocodeid = _value.getCountyGeoCodePK();
            if(ctpa_countygeocodeid == null)
                _ps.setNull(17, Types.BIGINT);
            else
                _ps.setLong(17, ctpa_countygeocodeid.getEntityId());
            
            String ctpa_state = _value.getState();
            if(ctpa_state == null)
                _ps.setNull(18, Types.VARCHAR);
            else
                _ps.setString(18, ctpa_state);
            
            GeoCodePK ctpa_stategeocodeid = _value.getStateGeoCodePK();
            if(ctpa_stategeocodeid == null)
                _ps.setNull(19, Types.BIGINT);
            else
                _ps.setLong(19, ctpa_stategeocodeid.getEntityId());
            
            String ctpa_postalcode = _value.getPostalCode();
            if(ctpa_postalcode == null)
                _ps.setNull(20, Types.VARCHAR);
            else
                _ps.setString(20, ctpa_postalcode);
            
            GeoCodePK ctpa_postalcodegeocodeid = _value.getPostalCodeGeoCodePK();
            if(ctpa_postalcodegeocodeid == null)
                _ps.setNull(21, Types.BIGINT);
            else
                _ps.setLong(21, ctpa_postalcodegeocodeid.getEntityId());
            
            GeoCodePK ctpa_countrygeocodeid = _value.getCountryGeoCodePK();
            if(ctpa_countrygeocodeid == null)
                _ps.setNull(22, Types.BIGINT);
            else
                _ps.setLong(22, ctpa_countrygeocodeid.getEntityId());
            
            Boolean ctpa_iscommercial = _value.getIsCommercial();
            if(ctpa_iscommercial == null)
                _ps.setNull(23, Types.BIT);
            else
                _ps.setInt(23, ctpa_iscommercial? 1: 0);
            
            Long ctpa_fromtime = _value.getFromTime();
            if(ctpa_fromtime == null)
                _ps.setNull(24, Types.BIGINT);
            else
                _ps.setLong(24, ctpa_fromtime);
            
            Long ctpa_thrutime = _value.getThruTime();
            if(ctpa_thrutime == null)
                _ps.setNull(25, Types.BIGINT);
            else
                _ps.setLong(25, ctpa_thrutime);
            
            _ps.setLong(26, _value.getPrimaryKey().getEntityId());
            
            _value.clearHasBeenModified();
        }
        
        return _hasBeenModified;
    }
    
    @Override
    public void store(Session session, ContactPostalAddress entity)
            throws PersistenceDatabaseException {
        PreparedStatement _ps = session.prepareStatement(SQL_UPDATE);
        
        try {
            ContactPostalAddressValue _value = entity.getContactPostalAddressValue();
            
            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<ContactPostalAddress> entities)
            throws PersistenceDatabaseException {
        if(entities.size() > 0) {
            PreparedStatement _ps = session.prepareStatement(SQL_UPDATE);
            int _modifiedEntities = 0;
            
            try {
                for(ContactPostalAddress entity : entities) {
                    if(bindForStore(_ps, entity.getContactPostalAddressValue())) {
                        _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.getContactPostalAddressValue());
                    });
                }
            } catch (SQLException se) {
                throw new PersistenceDatabaseException(se);
            }
        }
    }
    
    @Override
    public void store(Collection<ContactPostalAddress> entities)
            throws PersistenceDatabaseException {
        store(ThreadSession.currentSession(), entities);
    }
    
    @Override
    public void remove(Session session, ContactPostalAddress entity)
            throws PersistenceDatabaseException {
        remove(session, entity.getPrimaryKey());
    }
    
    @Override
    public void remove(Session session, ContactPostalAddressPK 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<ContactPostalAddressPK> pks)
            throws PersistenceDatabaseException {
        if(pks.size() > 0) {
            PreparedStatement _ps = session.prepareStatement(SQL_DELETE);
            int _modifiedEntities = 0;
            
            try {
                for(ContactPostalAddressPK 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<ContactPostalAddressPK> pks)
            throws PersistenceDatabaseException {
        remove(ThreadSession.currentSession(), pks);
    }
    
    @Override
    public boolean validPK(Session session, ContactPostalAddressPK 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;
    }
    
}