Source code

001// --------------------------------------------------------------------------------
002// Copyright 2002-2026 Echo Three, LLC
003//
004// Licensed under the Apache License, Version 2.0 (the "License");
005// you may not use this file except in compliance with the License.
006// You may obtain a copy of the License at
007//
008//     http://www.apache.org/licenses/LICENSE-2.0
009//
010// Unless required by applicable law or agreed to in writing, software
011// distributed under the License is distributed on an "AS IS" BASIS,
012// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
013// See the License for the specific language governing permissions and
014// limitations under the License.
015// --------------------------------------------------------------------------------
016// Generated File -- DO NOT EDIT BY HAND
017// --------------------------------------------------------------------------------
018
019/**
020 * ContentWebAddressFactory.java
021 */
022
023package com.echothree.model.data.content.server.factory;
024
025import com.echothree.model.data.content.common.pk.ContentWebAddressDetailPK;
026
027import com.echothree.model.data.content.server.entity.ContentWebAddressDetail;
028
029import com.echothree.model.data.content.common.ContentWebAddressConstants;
030import com.echothree.model.data.content.common.pk.ContentWebAddressPK;
031import com.echothree.model.data.content.server.value.ContentWebAddressValue;
032import com.echothree.model.data.content.server.entity.ContentWebAddress;
033import com.echothree.util.common.exception.PersistenceDatabaseException;
034import com.echothree.util.common.exception.PersistenceDatabaseUpdateException;
035import com.echothree.util.common.exception.PersistenceNotNullException;
036import com.echothree.util.server.persistence.BaseFactory;
037import com.echothree.util.server.persistence.EntityIdGenerator;
038import com.echothree.util.server.persistence.EntityPermission;
039import com.echothree.util.server.persistence.PersistenceDebugFlags;
040import com.echothree.util.server.persistence.Session;
041import java.sql.PreparedStatement;
042import java.sql.ResultSet;
043import java.sql.SQLException;
044import java.sql.Types;
045import java.io.ByteArrayInputStream;
046import java.io.StringReader;
047import java.util.ArrayList;
048import java.util.Collection;
049import java.util.HashSet;
050import java.util.List;
051import java.util.Map;
052import java.util.Set;
053import javax.enterprise.context.ApplicationScoped;
054import javax.enterprise.inject.spi.CDI;
055import javax.inject.Inject;
056import org.jooq.ResultQuery;
057import org.slf4j.Logger;
058import org.slf4j.LoggerFactory;
059
060@ApplicationScoped
061public class ContentWebAddressFactory
062        implements BaseFactory<ContentWebAddressPK, ContentWebAddress> {
063    
064    @Inject
065    Session session;
066    
067    //private static final Logger log = LoggerFactory.getLogger(ContentWebAddressFactory.class);
068    
069    final private static String SQL_SELECT_READ_ONLY = "SELECT cntwa_contentwebaddressid, cntwa_activedetailid, cntwa_lastdetailid FROM contentwebaddresses WHERE cntwa_contentwebaddressid = ?";
070    final private static String SQL_SELECT_READ_WRITE = "SELECT cntwa_contentwebaddressid, cntwa_activedetailid, cntwa_lastdetailid FROM contentwebaddresses WHERE cntwa_contentwebaddressid = ? FOR UPDATE";
071    final private static String SQL_INSERT = "INSERT INTO contentwebaddresses (cntwa_contentwebaddressid, cntwa_activedetailid, cntwa_lastdetailid) VALUES (?, ?, ?)";
072    final private static String SQL_UPDATE = "UPDATE contentwebaddresses SET cntwa_activedetailid = ?, cntwa_lastdetailid = ? WHERE cntwa_contentwebaddressid = ?";
073    final private static String SQL_DELETE = "DELETE FROM contentwebaddresses WHERE cntwa_contentwebaddressid = ?";
074    final private static String SQL_VALID = "SELECT COUNT(*) FROM contentwebaddresses WHERE cntwa_contentwebaddressid = ?";
075    
076    final private static String PK_COLUMN = "cntwa_contentwebaddressid";
077    final private static String ALL_COLUMNS = "cntwa_contentwebaddressid, cntwa_activedetailid, cntwa_lastdetailid";
078    final public static String TABLE_NAME = "contentwebaddresses";
079    
080    final public static String CNTWA_CONTENTWEBADDRESSID = "cntwa_contentwebaddressid";
081    final public static String CNTWA_ACTIVEDETAILID = "cntwa_activedetailid";
082    final public static String CNTWA_LASTDETAILID = "cntwa_lastdetailid";
083    
084    final private static EntityIdGenerator entityIdGenerator = new EntityIdGenerator(ContentWebAddressConstants.COMPONENT_VENDOR_NAME, ContentWebAddressConstants.ENTITY_TYPE_NAME);
085    
086    /** Creates a new instance of ContentWebAddressFactory */
087    protected ContentWebAddressFactory() {
088        super();
089    }
090    
091    public static ContentWebAddressFactory getInstance() {
092        return CDI.current().select(ContentWebAddressFactory.class).get();
093    }
094    
095    @Override
096    public String getPKColumn() {
097        return PK_COLUMN;
098    }
099    
100    @Override
101    public String getAllColumns() {
102        return ALL_COLUMNS;
103    }
104    
105    @Override
106    public String getTableName() {
107        return TABLE_NAME;
108    }
109    
110    @Override
111    public String getComponentVendorName() {
112        return ContentWebAddressConstants.COMPONENT_VENDOR_NAME;
113    }
114    
115    @Override
116    public String getEntityTypeName() {
117        return ContentWebAddressConstants.ENTITY_TYPE_NAME;
118    }
119    
120    public PreparedStatement prepareStatement(String query) {
121        return session.prepareStatement(ContentWebAddressFactory.class, query);
122    }
123    
124    public ContentWebAddressPK getNextPK() {
125        return new ContentWebAddressPK(entityIdGenerator.getNextEntityId());
126    }
127    
128    public Set<ContentWebAddressPK> getPKsFromResultSetAsSet(ResultSet rs)
129            throws PersistenceDatabaseException {
130        Set<ContentWebAddressPK> _result = new HashSet<>();
131        
132        try {
133            while(rs.next()) {
134                _result.add(getPKFromResultSet(rs));
135            }
136        } catch (SQLException se) {
137            throw new PersistenceDatabaseException(se);
138        }
139        
140        return _result;
141    }
142    
143    public java.util.List<ContentWebAddressPK> getPKsFromResultSetAsList(ResultSet rs)
144            throws PersistenceDatabaseException {
145        java.util.List<ContentWebAddressPK> _result = new ArrayList<>();
146        
147        try {
148            while(rs.next()) {
149                _result.add(getPKFromResultSet(rs));
150            }
151        } catch (SQLException se) {
152            throw new PersistenceDatabaseException(se);
153        }
154        
155        return _result;
156    }
157    
158    public ContentWebAddressPK getPKFromResultSet(ResultSet rs)
159            throws PersistenceDatabaseException {
160        ContentWebAddressPK _result;
161        
162        try {
163            long cntwa_contentwebaddressid = rs.getLong(CNTWA_CONTENTWEBADDRESSID);
164            Long _entityId = rs.wasNull() ? null : cntwa_contentwebaddressid;
165            
166            _result = new ContentWebAddressPK(_entityId);
167        } catch (SQLException se) {
168            throw new PersistenceDatabaseException(se);
169        }
170        
171        return _result;
172    }
173    
174    public java.util.List<ContentWebAddressValue> getValuesFromPKs(Collection<ContentWebAddressPK> pks)
175            throws PersistenceDatabaseException {
176        java.util.List<ContentWebAddressValue> _values = new ArrayList<>(pks.size());
177        
178        for(ContentWebAddressPK _pk: pks) {
179            _values.add(getValueFromPK(_pk));
180        }
181        
182        return _values;
183    }
184    
185    public ContentWebAddressValue getValueFromPK(ContentWebAddressPK pk)
186            throws PersistenceDatabaseException {
187        ContentWebAddressValue _value;
188        
189        // See if we already have the entity in the session cache
190        ContentWebAddress _entity = (ContentWebAddress)session.getEntity(pk);
191        if(_entity == null)
192            _value = getEntityFromPK(EntityPermission.READ_ONLY, pk).getContentWebAddressValue();
193        else
194            _value = _entity.getContentWebAddressValue();
195        
196        return _value;
197    }
198    
199    public java.util.List<ContentWebAddressValue> getValuesFromResultSet(ResultSet rs)
200            throws PersistenceDatabaseException {
201        java.util.List<ContentWebAddressValue> _result = new ArrayList<>();
202        
203        try {
204            while(rs.next()) {
205                _result.add(getValueFromResultSet(rs));
206            }
207        } catch (SQLException se) {
208            throw new PersistenceDatabaseException(se);
209        }
210        
211        return _result;
212    }
213    
214    public ContentWebAddressValue getValueFromResultSet(ResultSet rs)
215            throws PersistenceDatabaseException {
216        ContentWebAddressValue _value;
217        
218        try {
219            Long cntwa_contentwebaddressid = rs.getLong(CNTWA_CONTENTWEBADDRESSID);
220            ContentWebAddressPK _pk = new ContentWebAddressPK(cntwa_contentwebaddressid);
221            
222            // See if we already have the entity in the session cache
223            ContentWebAddress _entity = (ContentWebAddress)session.getEntity(_pk);
224            
225            if(_entity == null) {
226                Long cntwa_activedetailid = rs.getLong(CNTWA_ACTIVEDETAILID);
227                if(rs.wasNull())
228                    cntwa_activedetailid = null;
229                
230                Long cntwa_lastdetailid = rs.getLong(CNTWA_LASTDETAILID);
231                if(rs.wasNull())
232                    cntwa_lastdetailid = null;
233                
234                _value = new ContentWebAddressValue(_pk, new ContentWebAddressDetailPK(cntwa_activedetailid), new ContentWebAddressDetailPK(cntwa_lastdetailid));
235            } else
236                _value = _entity.getContentWebAddressValue();
237        } catch (SQLException se) {
238            throw new PersistenceDatabaseException(se);
239        }
240        
241        return _value;
242    }
243    
244    public java.util.List<ContentWebAddress> getEntitiesFromPKs(EntityPermission entityPermission, Collection<ContentWebAddressPK> pks)
245            throws PersistenceDatabaseException {
246        java.util.List<ContentWebAddress> _entities = new ArrayList<>(pks.size());
247        
248        for(ContentWebAddressPK _pk: pks) {
249            _entities.add(getEntityFromPK(entityPermission, _pk));
250        }
251        
252        return _entities;
253    }
254    
255    public ContentWebAddress getEntityFromValue(EntityPermission entityPermission, ContentWebAddressValue value) {
256        return getEntityFromPK(entityPermission, value.getPrimaryKey());
257    }
258    
259    public ContentWebAddress getEntityFromCache(ContentWebAddressPK pk) {
260        ContentWebAddressValue _value = (ContentWebAddressValue)session.getValueCache().get(pk);
261    
262        return _value == null ? null : new ContentWebAddress(_value, EntityPermission.READ_ONLY);
263    }
264    
265    public ContentWebAddress getEntityFromPK(EntityPermission entityPermission, ContentWebAddressPK pk)
266            throws PersistenceDatabaseException {
267        ContentWebAddress _entity;
268        
269        // See if we already have the entity in the session cache
270        _entity = (ContentWebAddress)session.getEntity(pk);
271        if(_entity != null) {
272            // If the requested permission is READ_WRITE, and the cached permission is
273            // READ_ONLY, then pretend that the cached object wasn't found, and create
274            // a new entity that is READ_WRITE.
275            if(entityPermission.equals(EntityPermission.READ_WRITE)) {
276                if(_entity.getEntityPermission().equals(EntityPermission.READ_ONLY))
277                    _entity = null;
278            }
279        }
280        
281        if(_entity == null && entityPermission.equals(EntityPermission.READ_ONLY)) {
282            _entity = getEntityFromCache(pk);
283        }
284        
285        if(_entity == null) {
286            PreparedStatement _ps = session.prepareStatement(entityPermission.equals(EntityPermission.READ_ONLY)? SQL_SELECT_READ_ONLY: SQL_SELECT_READ_WRITE);
287            long _entityId = pk.getEntityId();
288            ResultSet _rs = null;
289            
290            try {
291                _ps.setLong(1, _entityId);
292                _rs = _ps.executeQuery();
293                if(_rs.next()) {
294                    _entity = getEntityFromResultSet(entityPermission, _rs);
295                }
296            } catch (SQLException se) {
297                throw new PersistenceDatabaseException(se);
298            } finally {
299                if(_rs != null) {
300                    try {
301                        _rs.close();
302                    } catch (SQLException se) {
303                        // do nothing
304                    }
305                }
306            }
307        }
308        
309        return _entity;
310    }
311    
312    public Set<ContentWebAddressPK> getPKsFromQueryAsSet(PreparedStatement ps, final Object... params)
313            throws PersistenceDatabaseException {
314        Set<ContentWebAddressPK> _pks;
315        ResultSet _rs = null;
316        
317        try {
318            if(params.length != 0) {
319                Session.setQueryParams(ps, params);
320            }
321            
322            _rs = ps.executeQuery();
323            _pks = getPKsFromResultSetAsSet(_rs);
324            _rs.close();
325        } catch (SQLException se) {
326            throw new PersistenceDatabaseException(se);
327        } finally {
328            if(_rs != null) {
329                try {
330                    _rs.close();
331                } catch (SQLException se) {
332                    // do nothing
333                }
334            }
335        }
336        
337        return _pks;
338    }
339    
340    public java.util.List<ContentWebAddressPK> getPKsFromQueryAsList(PreparedStatement ps, final Object... params)
341            throws PersistenceDatabaseException {
342        java.util.List<ContentWebAddressPK> _pks;
343        ResultSet _rs = null;
344        
345        try {
346            if(params.length != 0) {
347                Session.setQueryParams(ps, params);
348            }
349            
350            _rs = ps.executeQuery();
351            _pks = getPKsFromResultSetAsList(_rs);
352            _rs.close();
353        } catch (SQLException se) {
354            throw new PersistenceDatabaseException(se);
355        } finally {
356            if(_rs != null) {
357                try {
358                    _rs.close();
359                } catch (SQLException se) {
360                    // do nothing
361                }
362            }
363        }
364        
365        return _pks;
366    }
367    
368    public ContentWebAddressPK getPKFromQuery(PreparedStatement ps, final Object... params)
369            throws PersistenceDatabaseException {
370        ContentWebAddressPK _pk = null;
371        ResultSet _rs = null;
372        
373        try {
374            if(params.length != 0) {
375                Session.setQueryParams(ps, params);
376            }
377            
378            _rs = ps.executeQuery();
379            if(_rs.next()) {
380                _pk = getPKFromResultSet(_rs);
381            }
382            _rs.close();
383        } catch (SQLException se) {
384            throw new PersistenceDatabaseException(se);
385        } finally {
386            if(_rs != null) {
387                try {
388                    _rs.close();
389                } catch (SQLException se) {
390                    // do nothing
391                }
392            }
393        }
394        
395        return _pk;
396    }
397    
398    public java.util.List<ContentWebAddress> getEntitiesFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
399            throws PersistenceDatabaseException {
400        PreparedStatement ps = session.prepareStatement(ContentWebAddressFactory.class, queryMap.get(entityPermission));
401        
402        return getEntitiesFromQuery(entityPermission, ps, params);
403    }
404    
405    public java.util.List<ContentWebAddress> getEntitiesFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
406            throws PersistenceDatabaseException {
407        PreparedStatement ps = session.prepareStatement(ContentWebAddressFactory.class, queryMap.get(entityPermission));
408        
409        return getEntitiesFromQuery(entityPermission, ps);
410    }
411    
412    public java.util.List<ContentWebAddress> getEntitiesFromQuery(EntityPermission entityPermission, ResultQuery<?> query)
413            throws PersistenceDatabaseException {
414        PreparedStatement ps = session.prepareStatement(ContentWebAddressFactory.class, query.getSQL());
415        
416        return getEntitiesFromQuery(entityPermission, ps, query.getBindValues().toArray());
417    }
418    
419    public java.util.List<ContentWebAddress> getEntitiesFromQuery(EntityPermission entityPermission, PreparedStatement ps, final Object... params)
420            throws PersistenceDatabaseException {
421        java.util.List<ContentWebAddress> _entities;
422        ResultSet _rs = null;
423        
424        try {
425            if(params.length != 0) {
426                Session.setQueryParams(ps, params);
427            }
428            
429            _rs = ps.executeQuery();
430            _entities = getEntitiesFromResultSet(entityPermission, _rs);
431            _rs.close();
432        } catch (SQLException se) {
433            throw new PersistenceDatabaseException(se);
434        } finally {
435            if(_rs != null) {
436                try {
437                    _rs.close();
438                } catch (SQLException se) {
439                    // do nothing
440                }
441            }
442        }
443        
444        return _entities;
445    }
446    
447    public ContentWebAddress getEntityFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
448            throws PersistenceDatabaseException {
449        PreparedStatement ps = session.prepareStatement(ContentWebAddressFactory.class, queryMap.get(entityPermission));
450        
451        return getEntityFromQuery(entityPermission, ps, params);
452    }
453    
454    public ContentWebAddress getEntityFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
455            throws PersistenceDatabaseException {
456        PreparedStatement ps = session.prepareStatement(ContentWebAddressFactory.class, queryMap.get(entityPermission));
457        
458        return getEntityFromQuery(entityPermission, ps);
459    }
460    
461    public ContentWebAddress getEntityFromQuery(EntityPermission entityPermission, ResultQuery<?> query)
462            throws PersistenceDatabaseException {
463        PreparedStatement ps = session.prepareStatement(ContentWebAddressFactory.class, query.getSQL());
464        
465        return getEntityFromQuery(entityPermission, ps, query.getBindValues().toArray());
466    }
467    
468    public ContentWebAddress getEntityFromQuery(EntityPermission entityPermission, PreparedStatement ps, final Object... params)
469            throws PersistenceDatabaseException {
470        ContentWebAddress _entity = null;
471        ResultSet _rs = null;
472        
473        try {
474            if(params.length != 0) {
475                Session.setQueryParams(ps, params);
476            }
477            
478            _rs = ps.executeQuery();
479            if(_rs.next()) {
480                _entity = getEntityFromResultSet(entityPermission, _rs);
481            }
482            _rs.close();
483        } catch (SQLException se) {
484            throw new PersistenceDatabaseException(se);
485        } finally {
486            if(_rs != null) {
487                try {
488                    _rs.close();
489                } catch (SQLException se) {
490                    // do nothing
491                }
492            }
493        }
494        
495        return _entity;
496    }
497    
498    public java.util.List<ContentWebAddress> getEntitiesFromResultSet(EntityPermission entityPermission, ResultSet rs)
499            throws PersistenceDatabaseException {
500        java.util.List<ContentWebAddress> _result = new ArrayList<>();
501        
502        try {
503            while(rs.next()) {
504                _result.add(getEntityFromResultSet(entityPermission, rs));
505            }
506        } catch (SQLException se) {
507            throw new PersistenceDatabaseException(se);
508        }
509        
510        return _result;
511    }
512    
513    public ContentWebAddress getEntityFromResultSet(EntityPermission entityPermission, ResultSet rs)
514            throws PersistenceDatabaseException {
515        ContentWebAddress _entity;
516        
517        try {
518            Long cntwa_contentwebaddressid = rs.getLong(CNTWA_CONTENTWEBADDRESSID);
519            ContentWebAddressPK _pk = new ContentWebAddressPK(cntwa_contentwebaddressid);
520            
521            // See if we already have the entity in the session cache
522            _entity = (ContentWebAddress)session.getEntity(_pk);
523            if(_entity != null) {
524                // If the requested permission is READ_WRITE, and the cached permission is
525                // READ_ONLY, then pretend that the cached object wasn't found, and create
526                // a new entity that is READ_WRITE.
527                if(entityPermission.equals(EntityPermission.READ_WRITE)) {
528                    if(_entity.getEntityPermission().equals(EntityPermission.READ_ONLY))
529                        _entity = null;
530                }
531            }
532            boolean foundInSessionCache = _entity != null;
533            
534            if(_entity == null && entityPermission.equals(EntityPermission.READ_ONLY)) {
535                _entity = getEntityFromCache(_pk);
536            }
537            
538            if(_entity == null) {
539                Long cntwa_activedetailid = rs.getLong(CNTWA_ACTIVEDETAILID);
540                if(rs.wasNull())
541                    cntwa_activedetailid = null;
542                
543                Long cntwa_lastdetailid = rs.getLong(CNTWA_LASTDETAILID);
544                if(rs.wasNull())
545                    cntwa_lastdetailid = null;
546                
547                ContentWebAddressValue _value = new ContentWebAddressValue(_pk, cntwa_activedetailid == null? null: new ContentWebAddressDetailPK(cntwa_activedetailid), cntwa_lastdetailid == null? null: new ContentWebAddressDetailPK(cntwa_lastdetailid));
548                _entity = new ContentWebAddress(_value, entityPermission);
549            }
550            
551            if(!foundInSessionCache) {
552                if(entityPermission.equals(EntityPermission.READ_ONLY)) {
553                    session.putReadOnlyEntity(_pk, _entity);
554                    session.getValueCache().put(_entity.getContentWebAddressValue());
555                } else {
556                    session.putReadWriteEntity(_pk, _entity);
557                }
558            }
559        } catch (SQLException se) {
560            throw new PersistenceDatabaseException(se);
561        }
562        
563        return _entity;
564    }
565    
566    public ContentWebAddress create()
567            throws PersistenceDatabaseException, PersistenceNotNullException {
568        return create((ContentWebAddressDetailPK)null, (ContentWebAddressDetailPK)null);
569    }
570    public ContentWebAddress create(ContentWebAddressDetail activeDetail, ContentWebAddressDetail lastDetail)
571            throws PersistenceDatabaseException, PersistenceNotNullException {
572        return create(activeDetail == null ? null : activeDetail.getPrimaryKey(), lastDetail == null ? null : lastDetail.getPrimaryKey());
573    }
574    
575    private void bindForCreate(PreparedStatement _ps, ContentWebAddressValue _value)
576            throws SQLException {
577        _ps.setLong(1, _value.getEntityId());
578        
579        ContentWebAddressDetailPK cntwa_activedetailid = _value.getActiveDetailPK();
580        if(cntwa_activedetailid == null)
581            _ps.setNull(2, Types.BIGINT);
582        else
583            _ps.setLong(2, cntwa_activedetailid.getEntityId());
584            
585        ContentWebAddressDetailPK cntwa_lastdetailid = _value.getLastDetailPK();
586        if(cntwa_lastdetailid == null)
587            _ps.setNull(3, Types.BIGINT);
588        else
589            _ps.setLong(3, cntwa_lastdetailid.getEntityId());
590            
591    }
592    
593    public ContentWebAddress create(ContentWebAddressDetailPK activeDetailPK, ContentWebAddressDetailPK lastDetailPK)
594            throws PersistenceDatabaseException, PersistenceNotNullException {
595        ContentWebAddressPK _pk = getNextPK();
596        ContentWebAddressValue _value = new ContentWebAddressValue(_pk, activeDetailPK, lastDetailPK);
597        
598        PreparedStatement _ps = session.prepareStatement(SQL_INSERT);
599        
600        try {
601            bindForCreate(_ps, _value);
602            
603            if(PersistenceDebugFlags.CheckEntityInsertRowCount) {
604                int _count = _ps.executeUpdate();
605                
606                if(_count != 1) {
607                    throw new PersistenceDatabaseUpdateException("insert failed, _count = " + _count);
608                }
609            } else {
610                 _ps.executeUpdate();
611            }
612            
613            session.getValueCache().put(_value);
614        } catch (SQLException se) {
615            throw new PersistenceDatabaseException(se);
616        }
617        
618        ContentWebAddress _entity = new ContentWebAddress(_value, EntityPermission.READ_ONLY);
619        session.putReadOnlyEntity(_pk, _entity);
620        
621        return _entity;
622    }
623    
624    public void create(Collection<ContentWebAddressValue> _values)
625            throws PersistenceDatabaseException, PersistenceNotNullException {
626        int _size = _values.size();
627        
628        if(_size > 0) {
629            PreparedStatement _ps = session.prepareStatement(SQL_INSERT);
630            List<ContentWebAddressValue> _cacheValues = new ArrayList<>(_size);
631            
632            try {
633                for(ContentWebAddressValue _value : _values) {
634                    _value.setEntityId(entityIdGenerator.getNextEntityId());
635                    bindForCreate(_ps, _value);
636                    
637                    _ps.addBatch();
638                    
639                    _cacheValues.add(_value);
640                }
641                
642                if(PersistenceDebugFlags.CheckEntityInsertRowCount) {
643                    int[] _counts = _ps.executeBatch();
644                    
645                    for(int _countOffset = 0 ; _countOffset < _size ; _countOffset++) {
646                        if(_counts[_countOffset] != 1 && _counts[_countOffset] != PreparedStatement.SUCCESS_NO_INFO) {
647                            throw new PersistenceDatabaseUpdateException("batch insert failed, _counts[" + _countOffset + "] = " + _counts[_countOffset]);
648                        }
649                    }
650                } else {
651                     _ps.executeBatch();
652                }
653                
654                _ps.clearBatch();
655            } catch (SQLException se) {
656                throw new PersistenceDatabaseException(se);
657            }
658            
659            _cacheValues.forEach((_cacheValue) -> {
660                ContentWebAddress _cacheEntity = new ContentWebAddress(_cacheValue, EntityPermission.READ_ONLY);
661                
662                session.putReadOnlyEntity(_cacheValue.getPrimaryKey(), _cacheEntity);
663            });
664        }
665    }
666    
667    private boolean bindForStore(PreparedStatement _ps, ContentWebAddressValue _value)
668            throws SQLException {
669        boolean _hasBeenModified = _value.hasBeenModified();
670        
671        if(_hasBeenModified) {
672            ContentWebAddressDetailPK cntwa_activedetailid = _value.getActiveDetailPK();
673            if(cntwa_activedetailid == null)
674                _ps.setNull(1, Types.BIGINT);
675            else
676                _ps.setLong(1, cntwa_activedetailid.getEntityId());
677            
678            ContentWebAddressDetailPK cntwa_lastdetailid = _value.getLastDetailPK();
679            if(cntwa_lastdetailid == null)
680                _ps.setNull(2, Types.BIGINT);
681            else
682                _ps.setLong(2, cntwa_lastdetailid.getEntityId());
683            
684            _ps.setLong(3, _value.getPrimaryKey().getEntityId());
685            
686            _value.clearHasBeenModified();
687        }
688        
689        return _hasBeenModified;
690    }
691    
692    @Override
693    public void store(ContentWebAddress entity)
694            throws PersistenceDatabaseException {
695        PreparedStatement _ps = session.prepareStatement(SQL_UPDATE);
696        
697        try {
698            ContentWebAddressValue _value = entity.getContentWebAddressValue();
699            
700            if(bindForStore(_ps, _value)) {
701                if(PersistenceDebugFlags.CheckEntityUpdateRowCount) {
702                    int _count = _ps.executeUpdate();
703                    
704                    if(_count != 1) {
705                        throw new PersistenceDatabaseUpdateException("update failed, _count = " + _count);
706                    }
707                } else {
708                     _ps.executeUpdate();
709                }
710                
711                session.getValueCache().put(_value);
712            }
713        } catch (SQLException se) {
714            throw new PersistenceDatabaseException(se);
715        }
716    }
717    
718    @Override
719    public void store(Collection<ContentWebAddress> entities)
720            throws PersistenceDatabaseException {
721        if(entities.size() > 0) {
722            PreparedStatement _ps = session.prepareStatement(SQL_UPDATE);
723            int _modifiedEntities = 0;
724            
725            try {
726                for(ContentWebAddress entity : entities) {
727                    if(bindForStore(_ps, entity.getContentWebAddressValue())) {
728                        _ps.addBatch();
729                        _modifiedEntities++;
730                    }
731                }
732                
733                if(_modifiedEntities != 0) {
734                    if(PersistenceDebugFlags.CheckEntityUpdateRowCount) {
735                        int[] _counts = _ps.executeBatch();
736                        
737                        for(int _countOffset = 0 ; _countOffset < _modifiedEntities  ; _countOffset++) {
738                            if(_counts[_countOffset] != 1 && _counts[_countOffset] != PreparedStatement.SUCCESS_NO_INFO) {
739                                throw new PersistenceDatabaseUpdateException("batch update failed, _counts[" + _countOffset + "] = " + _counts[_countOffset]);
740                            }
741                        }
742                    } else {
743                         _ps.executeBatch();
744                    }
745                    
746                    _ps.clearBatch();
747                    
748                    entities.forEach((entity) -> {
749                        session.getValueCache().put(entity.getContentWebAddressValue());
750                    });
751                }
752            } catch (SQLException se) {
753                throw new PersistenceDatabaseException(se);
754            }
755        }
756    }
757    
758    @Override
759    public void remove(ContentWebAddress entity)
760            throws PersistenceDatabaseException {
761        remove(entity.getPrimaryKey());
762    }
763    
764    @Override
765    public void remove(ContentWebAddressPK pk)
766            throws PersistenceDatabaseException {
767        PreparedStatement _ps = session.prepareStatement(SQL_DELETE);
768        long _entityId = pk.getEntityId();
769        
770        try {
771            _ps.setLong(1, _entityId);
772            
773            if(PersistenceDebugFlags.CheckEntityDeleteRowCount) {
774                int _count = _ps.executeUpdate();
775                
776                if(_count != 1) {
777                    throw new PersistenceDatabaseUpdateException("remove failed, _count = " + _count);
778                }
779            } else {
780                 _ps.executeUpdate();
781            }
782            
783            session.getValueCache().remove(pk);
784        } catch (SQLException se) {
785            throw new PersistenceDatabaseException(se);
786        }
787        
788        session.removed(pk, false);
789    }
790    
791    @Override
792    public void remove(Collection<ContentWebAddressPK> pks)
793            throws PersistenceDatabaseException {
794        if(pks.size() > 0) {
795            PreparedStatement _ps = session.prepareStatement(SQL_DELETE);
796            int _modifiedEntities = 0;
797            
798            try {
799                for(ContentWebAddressPK pk : pks) {
800                    long _entityId = pk.getEntityId();
801                    
802                    _ps.setLong(1, _entityId);
803                    
804                    _ps.addBatch();
805                    _modifiedEntities++;
806                }
807                
808                if(_modifiedEntities != 0) {
809                    if(PersistenceDebugFlags.CheckEntityDeleteRowCount) {
810                        int[] _counts = _ps.executeBatch();
811                        
812                        for(int _countOffset = 0 ; _countOffset < _modifiedEntities  ; _countOffset++) {
813                            if(_counts[_countOffset] != 1 && _counts[_countOffset] != PreparedStatement.SUCCESS_NO_INFO) {
814                                throw new PersistenceDatabaseUpdateException("batch remove failed, _counts[" + _countOffset + "] = " + _counts[_countOffset]);
815                            }
816                        }
817                    } else {
818                        _ps.executeBatch();
819                    }
820                    
821                    _ps.clearBatch();
822                    
823                    pks.forEach((pk) -> {
824                        session.getValueCache().remove(pk);
825                    });
826                }
827            } catch (SQLException se) {
828                throw new PersistenceDatabaseException(se);
829            }
830            
831            pks.forEach((pk) -> {
832                session.removed(pk, true);
833            });
834        }
835    }
836    
837    @Override
838    public boolean validPK(ContentWebAddressPK pk)
839            throws PersistenceDatabaseException {
840        boolean valid = false;
841        PreparedStatement _ps = session.prepareStatement(SQL_VALID);
842        ResultSet _rs = null;
843        
844        try {
845            _ps.setLong(1, pk.getEntityId());
846            
847            _rs = _ps.executeQuery();
848            if(_rs.next()) {
849                long _count = _rs.getLong(1);
850                if(_rs.wasNull())
851                    _count = 0;
852                
853                if(_count == 1)
854                    valid = true;
855            }
856        } catch (SQLException se) {
857            throw new PersistenceDatabaseException(se);
858        } finally {
859            if(_rs != null) {
860                try {
861                    _rs.close();
862                } catch (SQLException se) {
863                    // do nothing
864                }
865            }
866        }
867        
868        return valid;
869    }
870    
871}