Source code

001// --------------------------------------------------------------------------------
002// Copyright 2002-2024 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 * MessageDetailFactory.java
021 */
022
023package com.echothree.model.data.message.server.factory;
024
025import com.echothree.model.data.message.common.pk.MessagePK;
026import com.echothree.model.data.message.common.pk.MessageTypePK;
027
028import com.echothree.model.data.message.server.entity.Message;
029import com.echothree.model.data.message.server.entity.MessageType;
030
031import com.echothree.model.data.message.common.MessageDetailConstants;
032import com.echothree.model.data.message.common.pk.MessageDetailPK;
033import com.echothree.model.data.message.server.value.MessageDetailValue;
034import com.echothree.model.data.message.server.entity.MessageDetail;
035import com.echothree.util.common.exception.PersistenceDatabaseException;
036import com.echothree.util.common.exception.PersistenceDatabaseUpdateException;
037import com.echothree.util.common.exception.PersistenceNotNullException;
038import com.echothree.util.server.persistence.BaseFactory;
039import com.echothree.util.server.persistence.EntityIdGenerator;
040import com.echothree.util.server.persistence.EntityPermission;
041import com.echothree.util.server.persistence.PersistenceDebugFlags;
042import com.echothree.util.server.persistence.Session;
043import com.echothree.util.server.persistence.ThreadSession;
044import java.sql.PreparedStatement;
045import java.sql.ResultSet;
046import java.sql.SQLException;
047import java.sql.Types;
048import java.io.ByteArrayInputStream;
049import java.io.StringReader;
050import java.util.ArrayList;
051import java.util.Collection;
052import java.util.HashSet;
053import java.util.List;
054import java.util.Map;
055import java.util.Set;
056import org.apache.commons.logging.Log;
057import org.apache.commons.logging.LogFactory;
058
059public class MessageDetailFactory
060        implements BaseFactory<MessageDetailPK, MessageDetail> {
061    
062    //final private static Log log = LogFactory.getLog(MessageDetailFactory.class);
063    
064    final private static String SQL_SELECT_READ_ONLY = "SELECT mssgdt_messagedetailid, mssgdt_mssg_messageid, mssgdt_mssgtyp_messagetypeid, mssgdt_messagename, mssgdt_includebydefault, mssgdt_isdefault, mssgdt_sortorder, mssgdt_fromtime, mssgdt_thrutime FROM messagedetails WHERE mssgdt_messagedetailid = ?";
065    final private static String SQL_SELECT_READ_WRITE = "SELECT mssgdt_messagedetailid, mssgdt_mssg_messageid, mssgdt_mssgtyp_messagetypeid, mssgdt_messagename, mssgdt_includebydefault, mssgdt_isdefault, mssgdt_sortorder, mssgdt_fromtime, mssgdt_thrutime FROM messagedetails WHERE mssgdt_messagedetailid = ? FOR UPDATE";
066    final private static String SQL_INSERT = "INSERT INTO messagedetails (mssgdt_messagedetailid, mssgdt_mssg_messageid, mssgdt_mssgtyp_messagetypeid, mssgdt_messagename, mssgdt_includebydefault, mssgdt_isdefault, mssgdt_sortorder, mssgdt_fromtime, mssgdt_thrutime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)";
067    final private static String SQL_UPDATE = "UPDATE messagedetails SET mssgdt_mssg_messageid = ?, mssgdt_mssgtyp_messagetypeid = ?, mssgdt_messagename = ?, mssgdt_includebydefault = ?, mssgdt_isdefault = ?, mssgdt_sortorder = ?, mssgdt_fromtime = ?, mssgdt_thrutime = ? WHERE mssgdt_messagedetailid = ?";
068    final private static String SQL_DELETE = "DELETE FROM messagedetails WHERE mssgdt_messagedetailid = ?";
069    final private static String SQL_VALID = "SELECT COUNT(*) FROM messagedetails WHERE mssgdt_messagedetailid = ?";
070    
071    final private static String PK_COLUMN = "mssgdt_messagedetailid";
072    final private static String ALL_COLUMNS = "mssgdt_messagedetailid, mssgdt_mssg_messageid, mssgdt_mssgtyp_messagetypeid, mssgdt_messagename, mssgdt_includebydefault, mssgdt_isdefault, mssgdt_sortorder, mssgdt_fromtime, mssgdt_thrutime";
073    final public static String TABLE_NAME = "messagedetails";
074    
075    final public static String MSSGDT_MESSAGEDETAILID = "mssgdt_messagedetailid";
076    final public static String MSSGDT_MSSG_MESSAGEID = "mssgdt_mssg_messageid";
077    final public static String MSSGDT_MSSGTYP_MESSAGETYPEID = "mssgdt_mssgtyp_messagetypeid";
078    final public static String MSSGDT_MESSAGENAME = "mssgdt_messagename";
079    final public static String MSSGDT_INCLUDEBYDEFAULT = "mssgdt_includebydefault";
080    final public static String MSSGDT_ISDEFAULT = "mssgdt_isdefault";
081    final public static String MSSGDT_SORTORDER = "mssgdt_sortorder";
082    final public static String MSSGDT_FROMTIME = "mssgdt_fromtime";
083    final public static String MSSGDT_THRUTIME = "mssgdt_thrutime";
084    
085    final private static EntityIdGenerator entityIdGenerator = new EntityIdGenerator(MessageDetailConstants.COMPONENT_VENDOR_NAME, MessageDetailConstants.ENTITY_TYPE_NAME);
086    
087    /** Creates a new instance of MessageDetailFactory */
088    private MessageDetailFactory() {
089        super();
090    }
091    
092    private static class MessageDetailFactoryHolder {
093        static MessageDetailFactory instance = new MessageDetailFactory();
094    }
095    
096    public static MessageDetailFactory getInstance() {
097        return MessageDetailFactoryHolder.instance;
098    }
099    
100    @Override
101    public String getPKColumn() {
102        return PK_COLUMN;
103    }
104    
105    @Override
106    public String getAllColumns() {
107        return ALL_COLUMNS;
108    }
109    
110    @Override
111    public String getTableName() {
112        return TABLE_NAME;
113    }
114    
115    @Override
116    public String getComponentVendorName() {
117        return MessageDetailConstants.COMPONENT_VENDOR_NAME;
118    }
119    
120    @Override
121    public String getEntityTypeName() {
122        return MessageDetailConstants.ENTITY_TYPE_NAME;
123    }
124    
125    public PreparedStatement prepareStatement(String query) {
126        return ThreadSession.currentSession().prepareStatement(MessageDetailFactory.class, query);
127    }
128    
129    public MessageDetailPK getNextPK() {
130        return new MessageDetailPK(entityIdGenerator.getNextEntityId());
131    }
132    
133    public Set<MessageDetailPK> getPKsFromResultSetAsSet(ResultSet rs)
134            throws PersistenceDatabaseException {
135        Set<MessageDetailPK> _result = new HashSet<>();
136        
137        try {
138            while(rs.next()) {
139                _result.add(getPKFromResultSet(rs));
140            }
141        } catch (SQLException se) {
142            throw new PersistenceDatabaseException(se);
143        }
144        
145        return _result;
146    }
147    
148    public java.util.List<MessageDetailPK> getPKsFromResultSetAsList(ResultSet rs)
149            throws PersistenceDatabaseException {
150        java.util.List<MessageDetailPK> _result = new ArrayList<>();
151        
152        try {
153            while(rs.next()) {
154                _result.add(getPKFromResultSet(rs));
155            }
156        } catch (SQLException se) {
157            throw new PersistenceDatabaseException(se);
158        }
159        
160        return _result;
161    }
162    
163    public MessageDetailPK getPKFromResultSet(ResultSet rs)
164            throws PersistenceDatabaseException {
165        MessageDetailPK _result;
166        
167        try {
168            long mssgdt_messagedetailid = rs.getLong(MSSGDT_MESSAGEDETAILID);
169            Long _entityId = rs.wasNull() ? null : mssgdt_messagedetailid;
170            
171            _result = new MessageDetailPK(_entityId);
172        } catch (SQLException se) {
173            throw new PersistenceDatabaseException(se);
174        }
175        
176        return _result;
177    }
178    
179    public java.util.List<MessageDetailValue> getValuesFromPKs(Session session, Collection<MessageDetailPK> pks)
180            throws PersistenceDatabaseException {
181        java.util.List<MessageDetailValue> _values = new ArrayList<>(pks.size());
182        
183        for(MessageDetailPK _pk: pks) {
184            _values.add(getValueFromPK(session, _pk));
185        }
186        
187        return _values;
188    }
189    
190    public MessageDetailValue getValueFromPK(Session session, MessageDetailPK pk)
191            throws PersistenceDatabaseException {
192        MessageDetailValue _value;
193        
194        // See if we already have the entity in the session cache
195        MessageDetail _entity = (MessageDetail)session.getEntity(pk);
196        if(_entity == null)
197            _value = getEntityFromPK(session, EntityPermission.READ_ONLY, pk).getMessageDetailValue();
198        else
199            _value = _entity.getMessageDetailValue();
200        
201        return _value;
202    }
203    
204    public java.util.List<MessageDetailValue> getValuesFromResultSet(Session session, ResultSet rs)
205            throws PersistenceDatabaseException {
206        java.util.List<MessageDetailValue> _result = new ArrayList<>();
207        
208        try {
209            while(rs.next()) {
210                _result.add(getValueFromResultSet(session, rs));
211            }
212        } catch (SQLException se) {
213            throw new PersistenceDatabaseException(se);
214        }
215        
216        return _result;
217    }
218    
219    public MessageDetailValue getValueFromResultSet(Session session, ResultSet rs)
220            throws PersistenceDatabaseException {
221        MessageDetailValue _value;
222        
223        try {
224            Long mssgdt_messagedetailid = rs.getLong(MSSGDT_MESSAGEDETAILID);
225            MessageDetailPK _pk = new MessageDetailPK(mssgdt_messagedetailid);
226            
227            // See if we already have the entity in the session cache
228            MessageDetail _entity = (MessageDetail)session.getEntity(_pk);
229            
230            if(_entity == null) {
231                Long mssgdt_mssg_messageid = rs.getLong(MSSGDT_MSSG_MESSAGEID);
232                if(rs.wasNull())
233                    mssgdt_mssg_messageid = null;
234                
235                Long mssgdt_mssgtyp_messagetypeid = rs.getLong(MSSGDT_MSSGTYP_MESSAGETYPEID);
236                if(rs.wasNull())
237                    mssgdt_mssgtyp_messagetypeid = null;
238                
239                String mssgdt_messagename = rs.getString(MSSGDT_MESSAGENAME);
240                if(rs.wasNull())
241                    mssgdt_messagename = null;
242                
243                Boolean mssgdt_includebydefault = rs.getInt(MSSGDT_INCLUDEBYDEFAULT) == 1;
244                if(rs.wasNull())
245                    mssgdt_includebydefault = null;
246                
247                Boolean mssgdt_isdefault = rs.getInt(MSSGDT_ISDEFAULT) == 1;
248                if(rs.wasNull())
249                    mssgdt_isdefault = null;
250                
251                Integer mssgdt_sortorder = rs.getInt(MSSGDT_SORTORDER);
252                if(rs.wasNull())
253                    mssgdt_sortorder = null;
254                
255                Long mssgdt_fromtime = rs.getLong(MSSGDT_FROMTIME);
256                if(rs.wasNull())
257                    mssgdt_fromtime = null;
258                
259                Long mssgdt_thrutime = rs.getLong(MSSGDT_THRUTIME);
260                if(rs.wasNull())
261                    mssgdt_thrutime = null;
262                
263                _value = new MessageDetailValue(_pk, new MessagePK(mssgdt_mssg_messageid), new MessageTypePK(mssgdt_mssgtyp_messagetypeid), mssgdt_messagename, mssgdt_includebydefault, mssgdt_isdefault, mssgdt_sortorder, mssgdt_fromtime, mssgdt_thrutime);
264            } else
265                _value = _entity.getMessageDetailValue();
266        } catch (SQLException se) {
267            throw new PersistenceDatabaseException(se);
268        }
269        
270        return _value;
271    }
272    
273    public java.util.List<MessageDetail> getEntitiesFromPKs(EntityPermission entityPermission, Collection<MessageDetailPK> pks)
274            throws PersistenceDatabaseException {
275        return getEntitiesFromPKs(ThreadSession.currentSession(), entityPermission, pks);
276    }
277    
278    public java.util.List<MessageDetail> getEntitiesFromPKs(Session session, EntityPermission entityPermission, Collection<MessageDetailPK> pks)
279            throws PersistenceDatabaseException {
280        java.util.List<MessageDetail> _entities = new ArrayList<>(pks.size());
281        
282        for(MessageDetailPK _pk: pks) {
283            _entities.add(getEntityFromPK(session, entityPermission, _pk));
284        }
285        
286        return _entities;
287    }
288    
289    public MessageDetail getEntityFromValue(EntityPermission entityPermission, MessageDetailValue value) {
290        return getEntityFromPK(ThreadSession.currentSession(), entityPermission, value.getPrimaryKey());
291    }
292    
293    public MessageDetail getEntityFromValue(Session session, EntityPermission entityPermission, MessageDetailValue value) {
294        return getEntityFromPK(session, entityPermission, value.getPrimaryKey());
295    }
296    
297    public MessageDetail getEntityFromPK(EntityPermission entityPermission, MessageDetailPK pk)
298            throws PersistenceDatabaseException {
299        return getEntityFromPK(ThreadSession.currentSession(), entityPermission, pk);
300    }
301    
302    public MessageDetail getEntityFromCache(Session session, MessageDetailPK pk) {
303        MessageDetailValue _value = (MessageDetailValue)session.getValueCache().get(pk);
304    
305        return _value == null ? null : new MessageDetail(_value, EntityPermission.READ_ONLY);
306    }
307    
308    public MessageDetail getEntityFromPK(Session session, EntityPermission entityPermission, MessageDetailPK pk)
309            throws PersistenceDatabaseException {
310        MessageDetail _entity;
311        
312        // See if we already have the entity in the session cache
313        _entity = (MessageDetail)session.getEntity(pk);
314        if(_entity != null) {
315            // If the requested permission is READ_WRITE, and the cached permission is
316            // READ_ONLY, then pretend that the cached object wasn't found, and create
317            // a new entity that is READ_WRITE.
318            if(entityPermission.equals(EntityPermission.READ_WRITE)) {
319                if(_entity.getEntityPermission().equals(EntityPermission.READ_ONLY))
320                    _entity = null;
321            }
322        }
323        
324        if(_entity == null && entityPermission.equals(EntityPermission.READ_ONLY)) {
325            _entity = getEntityFromCache(session, pk);
326        }
327        
328        if(_entity == null) {
329            PreparedStatement _ps = session.prepareStatement(entityPermission.equals(EntityPermission.READ_ONLY)? SQL_SELECT_READ_ONLY: SQL_SELECT_READ_WRITE);
330            long _entityId = pk.getEntityId();
331            ResultSet _rs = null;
332            
333            try {
334                _ps.setLong(1, _entityId);
335                _rs = _ps.executeQuery();
336                if(_rs.next()) {
337                    _entity = getEntityFromResultSet(session, entityPermission, _rs);
338                }
339            } catch (SQLException se) {
340                throw new PersistenceDatabaseException(se);
341            } finally {
342                if(_rs != null) {
343                    try {
344                        _rs.close();
345                    } catch (SQLException se) {
346                        // do nothing
347                    }
348                }
349            }
350        }
351        
352        return _entity;
353    }
354    
355    public Set<MessageDetailPK> getPKsFromQueryAsSet(PreparedStatement ps, final Object... params)
356            throws PersistenceDatabaseException {
357        Set<MessageDetailPK> _pks;
358        ResultSet _rs = null;
359        
360        try {
361            if(params.length != 0) {
362                Session.setQueryParams(ps, params);
363            }
364            
365            _rs = ps.executeQuery();
366            _pks = getPKsFromResultSetAsSet(_rs);
367            _rs.close();
368        } catch (SQLException se) {
369            throw new PersistenceDatabaseException(se);
370        } finally {
371            if(_rs != null) {
372                try {
373                    _rs.close();
374                } catch (SQLException se) {
375                    // do nothing
376                }
377            }
378        }
379        
380        return _pks;
381    }
382    
383    public java.util.List<MessageDetailPK> getPKsFromQueryAsList(PreparedStatement ps, final Object... params)
384            throws PersistenceDatabaseException {
385        java.util.List<MessageDetailPK> _pks;
386        ResultSet _rs = null;
387        
388        try {
389            if(params.length != 0) {
390                Session.setQueryParams(ps, params);
391            }
392            
393            _rs = ps.executeQuery();
394            _pks = getPKsFromResultSetAsList(_rs);
395            _rs.close();
396        } catch (SQLException se) {
397            throw new PersistenceDatabaseException(se);
398        } finally {
399            if(_rs != null) {
400                try {
401                    _rs.close();
402                } catch (SQLException se) {
403                    // do nothing
404                }
405            }
406        }
407        
408        return _pks;
409    }
410    
411    public MessageDetailPK getPKFromQuery(PreparedStatement ps, final Object... params)
412            throws PersistenceDatabaseException {
413        MessageDetailPK _pk = null;
414        ResultSet _rs = null;
415        
416        try {
417            if(params.length != 0) {
418                Session.setQueryParams(ps, params);
419            }
420            
421            _rs = ps.executeQuery();
422            if(_rs.next()) {
423                _pk = getPKFromResultSet(_rs);
424            }
425            _rs.close();
426        } catch (SQLException se) {
427            throw new PersistenceDatabaseException(se);
428        } finally {
429            if(_rs != null) {
430                try {
431                    _rs.close();
432                } catch (SQLException se) {
433                    // do nothing
434                }
435            }
436        }
437        
438        return _pk;
439    }
440    
441    public java.util.List<MessageDetail> getEntitiesFromQuery(Session session, EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
442            throws PersistenceDatabaseException {
443        PreparedStatement ps = session.prepareStatement(MessageDetailFactory.class, queryMap.get(entityPermission));
444        
445        return getEntitiesFromQuery(session, entityPermission, ps, params);
446    }
447    
448    public java.util.List<MessageDetail> getEntitiesFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
449            throws PersistenceDatabaseException {
450        Session session = ThreadSession.currentSession();
451        PreparedStatement ps = session.prepareStatement(MessageDetailFactory.class, queryMap.get(entityPermission));
452        
453        return getEntitiesFromQuery(session, entityPermission, ps, params);
454    }
455    
456    public java.util.List<MessageDetail> getEntitiesFromQuery(Session session, EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
457            throws PersistenceDatabaseException {
458        PreparedStatement ps = session.prepareStatement(MessageDetailFactory.class, queryMap.get(entityPermission));
459        
460        return getEntitiesFromQuery(session, entityPermission, ps);
461    }
462    
463    public java.util.List<MessageDetail> getEntitiesFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
464            throws PersistenceDatabaseException {
465        Session session = ThreadSession.currentSession();
466        PreparedStatement ps = session.prepareStatement(MessageDetailFactory.class, queryMap.get(entityPermission));
467        
468        return getEntitiesFromQuery(session, entityPermission, ps);
469    }
470    
471    public java.util.List<MessageDetail> getEntitiesFromQuery(EntityPermission entityPermission, PreparedStatement ps)
472            throws PersistenceDatabaseException {
473        return getEntitiesFromQuery(ThreadSession.currentSession(), entityPermission, ps);
474    }
475    
476    public java.util.List<MessageDetail> getEntitiesFromQuery(EntityPermission entityPermission, PreparedStatement ps, final Object... params)
477            throws PersistenceDatabaseException {
478        return getEntitiesFromQuery(ThreadSession.currentSession(), entityPermission, ps, params);
479    }
480    
481    public java.util.List<MessageDetail> getEntitiesFromQuery(Session session, EntityPermission entityPermission, PreparedStatement ps, final Object... params)
482            throws PersistenceDatabaseException {
483        java.util.List<MessageDetail> _entities;
484        ResultSet _rs = null;
485        
486        try {
487            if(params.length != 0) {
488                Session.setQueryParams(ps, params);
489            }
490            
491            _rs = ps.executeQuery();
492            _entities = getEntitiesFromResultSet(session, entityPermission, _rs);
493            _rs.close();
494        } catch (SQLException se) {
495            throw new PersistenceDatabaseException(se);
496        } finally {
497            if(_rs != null) {
498                try {
499                    _rs.close();
500                } catch (SQLException se) {
501                    // do nothing
502                }
503            }
504        }
505        
506        return _entities;
507    }
508    
509    public MessageDetail getEntityFromQuery(Session session, EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
510            throws PersistenceDatabaseException {
511        PreparedStatement ps = session.prepareStatement(MessageDetailFactory.class, queryMap.get(entityPermission));
512        
513        return getEntityFromQuery(session, entityPermission, ps, params);
514    }
515    
516    public MessageDetail getEntityFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap, final Object... params)
517            throws PersistenceDatabaseException {
518        Session session = ThreadSession.currentSession();
519        PreparedStatement ps = session.prepareStatement(MessageDetailFactory.class, queryMap.get(entityPermission));
520        
521        return getEntityFromQuery(session, entityPermission, ps, params);
522    }
523    
524    public MessageDetail getEntityFromQuery(Session session, EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
525            throws PersistenceDatabaseException {
526        PreparedStatement ps = session.prepareStatement(MessageDetailFactory.class, queryMap.get(entityPermission));
527        
528        return getEntityFromQuery(session, entityPermission, ps);
529    }
530    
531    public MessageDetail getEntityFromQuery(EntityPermission entityPermission, Map<EntityPermission, String>queryMap)
532            throws PersistenceDatabaseException {
533        Session session = ThreadSession.currentSession();
534        PreparedStatement ps = session.prepareStatement(MessageDetailFactory.class, queryMap.get(entityPermission));
535        
536        return getEntityFromQuery(session, entityPermission, ps);
537    }
538    
539    public MessageDetail getEntityFromQuery(EntityPermission entityPermission, PreparedStatement ps)
540            throws PersistenceDatabaseException {
541        return getEntityFromQuery(ThreadSession.currentSession(), entityPermission, ps);
542    }
543    
544    public MessageDetail getEntityFromQuery(EntityPermission entityPermission, PreparedStatement ps, final Object... params)
545            throws PersistenceDatabaseException {
546        return getEntityFromQuery(ThreadSession.currentSession(), entityPermission, ps, params);
547    }
548    
549    public MessageDetail getEntityFromQuery(Session session, EntityPermission entityPermission, PreparedStatement ps, final Object... params)
550            throws PersistenceDatabaseException {
551        MessageDetail _entity = null;
552        ResultSet _rs = null;
553        
554        try {
555            if(params.length != 0) {
556                Session.setQueryParams(ps, params);
557            }
558            
559            _rs = ps.executeQuery();
560            if(_rs.next()) {
561                _entity = getEntityFromResultSet(session, entityPermission, _rs);
562            }
563            _rs.close();
564        } catch (SQLException se) {
565            throw new PersistenceDatabaseException(se);
566        } finally {
567            if(_rs != null) {
568                try {
569                    _rs.close();
570                } catch (SQLException se) {
571                    // do nothing
572                }
573            }
574        }
575        
576        return _entity;
577    }
578    
579    public java.util.List<MessageDetail> getEntitiesFromResultSet(EntityPermission entityPermission, ResultSet rs)
580            throws PersistenceDatabaseException {
581        return getEntitiesFromResultSet(ThreadSession.currentSession(), entityPermission, rs);
582    }
583    
584    public java.util.List<MessageDetail> getEntitiesFromResultSet(Session session, EntityPermission entityPermission, ResultSet rs)
585            throws PersistenceDatabaseException {
586        java.util.List<MessageDetail> _result = new ArrayList<>();
587        
588        try {
589            while(rs.next()) {
590                _result.add(getEntityFromResultSet(session, entityPermission, rs));
591            }
592        } catch (SQLException se) {
593            throw new PersistenceDatabaseException(se);
594        }
595        
596        return _result;
597    }
598    
599    public MessageDetail getEntityFromResultSet(EntityPermission entityPermission, ResultSet rs)
600            throws PersistenceDatabaseException {
601        return getEntityFromResultSet(ThreadSession.currentSession(), entityPermission, rs);
602    }
603    
604    public MessageDetail getEntityFromResultSet(Session session, EntityPermission entityPermission, ResultSet rs)
605            throws PersistenceDatabaseException {
606        MessageDetail _entity;
607        
608        try {
609            Long mssgdt_messagedetailid = rs.getLong(MSSGDT_MESSAGEDETAILID);
610            MessageDetailPK _pk = new MessageDetailPK(mssgdt_messagedetailid);
611            
612            // See if we already have the entity in the session cache
613            _entity = (MessageDetail)session.getEntity(_pk);
614            if(_entity != null) {
615                // If the requested permission is READ_WRITE, and the cached permission is
616                // READ_ONLY, then pretend that the cached object wasn't found, and create
617                // a new entity that is READ_WRITE.
618                if(entityPermission.equals(EntityPermission.READ_WRITE)) {
619                    if(_entity.getEntityPermission().equals(EntityPermission.READ_ONLY))
620                        _entity = null;
621                }
622            }
623            boolean foundInSessionCache = _entity != null;
624            
625            if(_entity == null && entityPermission.equals(EntityPermission.READ_ONLY)) {
626                _entity = getEntityFromCache(session, _pk);
627            }
628            
629            if(_entity == null) {
630                Long mssgdt_mssg_messageid = rs.getLong(MSSGDT_MSSG_MESSAGEID);
631                if(rs.wasNull())
632                    mssgdt_mssg_messageid = null;
633                
634                Long mssgdt_mssgtyp_messagetypeid = rs.getLong(MSSGDT_MSSGTYP_MESSAGETYPEID);
635                if(rs.wasNull())
636                    mssgdt_mssgtyp_messagetypeid = null;
637                
638                String mssgdt_messagename = rs.getString(MSSGDT_MESSAGENAME);
639                if(rs.wasNull())
640                    mssgdt_messagename = null;
641                
642                Boolean mssgdt_includebydefault = rs.getInt(MSSGDT_INCLUDEBYDEFAULT) == 1;
643                if(rs.wasNull())
644                    mssgdt_includebydefault = null;
645                
646                Boolean mssgdt_isdefault = rs.getInt(MSSGDT_ISDEFAULT) == 1;
647                if(rs.wasNull())
648                    mssgdt_isdefault = null;
649                
650                Integer mssgdt_sortorder = rs.getInt(MSSGDT_SORTORDER);
651                if(rs.wasNull())
652                    mssgdt_sortorder = null;
653                
654                Long mssgdt_fromtime = rs.getLong(MSSGDT_FROMTIME);
655                if(rs.wasNull())
656                    mssgdt_fromtime = null;
657                
658                Long mssgdt_thrutime = rs.getLong(MSSGDT_THRUTIME);
659                if(rs.wasNull())
660                    mssgdt_thrutime = null;
661                
662                MessageDetailValue _value = new MessageDetailValue(_pk, mssgdt_mssg_messageid == null? null: new MessagePK(mssgdt_mssg_messageid), mssgdt_mssgtyp_messagetypeid == null? null: new MessageTypePK(mssgdt_mssgtyp_messagetypeid), mssgdt_messagename, mssgdt_includebydefault, mssgdt_isdefault, mssgdt_sortorder, mssgdt_fromtime, mssgdt_thrutime);
663                _entity = new MessageDetail(_value, entityPermission);
664            }
665            
666            if(!foundInSessionCache) {
667                if(entityPermission.equals(EntityPermission.READ_ONLY)) {
668                    session.putReadOnlyEntity(_pk, _entity);
669                    session.getValueCache().put(_entity.getMessageDetailValue());
670                } else {
671                    session.putReadWriteEntity(_pk, _entity);
672                }
673            }
674        } catch (SQLException se) {
675            throw new PersistenceDatabaseException(se);
676        }
677        
678        return _entity;
679    }
680    
681    public MessageDetail create(Session session, Message message, MessageType messageType, String messageName, Boolean includeByDefault, Boolean isDefault, Integer sortOrder, Long fromTime, Long thruTime)
682            throws PersistenceDatabaseException, PersistenceNotNullException {
683        return create(session, message == null ? null : message.getPrimaryKey(), messageType == null ? null : messageType.getPrimaryKey(), messageName, includeByDefault, isDefault, sortOrder, fromTime, thruTime);
684    }
685    
686    public MessageDetail create(Message message, MessageType messageType, String messageName, Boolean includeByDefault, Boolean isDefault, Integer sortOrder, Long fromTime, Long thruTime)
687            throws PersistenceDatabaseException, PersistenceNotNullException {
688        return create(ThreadSession.currentSession(), message == null ? null : message.getPrimaryKey(), messageType == null ? null : messageType.getPrimaryKey(), messageName, includeByDefault, isDefault, sortOrder, fromTime, thruTime);
689    }
690    
691    private void bindForCreate(PreparedStatement _ps, MessageDetailValue _value)
692            throws SQLException {
693        _ps.setLong(1, _value.getEntityId());
694        
695        MessagePK mssgdt_mssg_messageid = _value.getMessagePK();
696        if(mssgdt_mssg_messageid == null)
697            _ps.setNull(2, Types.BIGINT);
698        else
699            _ps.setLong(2, mssgdt_mssg_messageid.getEntityId());
700            
701        MessageTypePK mssgdt_mssgtyp_messagetypeid = _value.getMessageTypePK();
702        if(mssgdt_mssgtyp_messagetypeid == null)
703            _ps.setNull(3, Types.BIGINT);
704        else
705            _ps.setLong(3, mssgdt_mssgtyp_messagetypeid.getEntityId());
706            
707        String mssgdt_messagename = _value.getMessageName();
708        if(mssgdt_messagename == null)
709            _ps.setNull(4, Types.VARCHAR);
710        else
711            _ps.setString(4, mssgdt_messagename);
712            
713        Boolean mssgdt_includebydefault = _value.getIncludeByDefault();
714        if(mssgdt_includebydefault == null)
715            _ps.setNull(5, Types.BIT);
716        else
717            _ps.setInt(5, mssgdt_includebydefault? 1: 0);
718            
719        Boolean mssgdt_isdefault = _value.getIsDefault();
720        if(mssgdt_isdefault == null)
721            _ps.setNull(6, Types.BIT);
722        else
723            _ps.setInt(6, mssgdt_isdefault? 1: 0);
724            
725        Integer mssgdt_sortorder = _value.getSortOrder();
726        if(mssgdt_sortorder == null)
727            _ps.setNull(7, Types.INTEGER);
728        else
729            _ps.setInt(7, mssgdt_sortorder);
730            
731        Long mssgdt_fromtime = _value.getFromTime();
732        if(mssgdt_fromtime == null)
733            _ps.setNull(8, Types.BIGINT);
734        else
735            _ps.setLong(8, mssgdt_fromtime);
736            
737        Long mssgdt_thrutime = _value.getThruTime();
738        if(mssgdt_thrutime == null)
739            _ps.setNull(9, Types.BIGINT);
740        else
741            _ps.setLong(9, mssgdt_thrutime);
742            
743    }
744    
745    public MessageDetail create(Session session, MessagePK messagePK, MessageTypePK messageTypePK, String messageName, Boolean includeByDefault, Boolean isDefault, Integer sortOrder, Long fromTime, Long thruTime)
746            throws PersistenceDatabaseException, PersistenceNotNullException {
747        MessageDetailPK _pk = getNextPK();
748        MessageDetailValue _value = new MessageDetailValue(_pk, messagePK, messageTypePK, messageName, includeByDefault, isDefault, sortOrder, fromTime, thruTime);
749        
750        PreparedStatement _ps = session.prepareStatement(SQL_INSERT);
751        
752        try {
753            bindForCreate(_ps, _value);
754            
755            if(PersistenceDebugFlags.CheckEntityInsertRowCount) {
756                int _count = _ps.executeUpdate();
757                
758                if(_count != 1) {
759                    throw new PersistenceDatabaseUpdateException("insert failed, _count = " + _count);
760                }
761            } else {
762                 _ps.executeUpdate();
763            }
764            
765            session.getValueCache().put(_value);
766        } catch (SQLException se) {
767            throw new PersistenceDatabaseException(se);
768        }
769        
770        MessageDetail _entity = new MessageDetail(_value, EntityPermission.READ_ONLY);
771        session.putReadOnlyEntity(_pk, _entity);
772        
773        return _entity;
774    }
775    
776    public MessageDetail create(MessagePK messagePK, MessageTypePK messageTypePK, String messageName, Boolean includeByDefault, Boolean isDefault, Integer sortOrder, Long fromTime, Long thruTime)
777            throws PersistenceDatabaseException, PersistenceNotNullException {
778        return create(ThreadSession.currentSession(), messagePK, messageTypePK, messageName, includeByDefault, isDefault, sortOrder, fromTime, thruTime);
779    }
780    
781    public void create(Session session, Collection<MessageDetailValue> _values)
782            throws PersistenceDatabaseException, PersistenceNotNullException {
783        int _size = _values.size();
784        
785        if(_size > 0) {
786            PreparedStatement _ps = session.prepareStatement(SQL_INSERT);
787            List<MessageDetailValue> _cacheValues = new ArrayList<>(_size);
788            
789            try {
790                for(MessageDetailValue _value : _values) {
791                    _value.setEntityId(entityIdGenerator.getNextEntityId());
792                    bindForCreate(_ps, _value);
793                    
794                    _ps.addBatch();
795                    
796                    _cacheValues.add(_value);
797                }
798                
799                if(PersistenceDebugFlags.CheckEntityInsertRowCount) {
800                    int[] _counts = _ps.executeBatch();
801                    
802                    for(int _countOffset = 0 ; _countOffset < _size ; _countOffset++) {
803                        if(_counts[_countOffset] != 1 && _counts[_countOffset] != PreparedStatement.SUCCESS_NO_INFO) {
804                            throw new PersistenceDatabaseUpdateException("batch insert failed, _counts[" + _countOffset + "] = " + _counts[_countOffset]);
805                        }
806                    }
807                } else {
808                     _ps.executeBatch();
809                }
810                
811                _ps.clearBatch();
812            } catch (SQLException se) {
813                throw new PersistenceDatabaseException(se);
814            }
815            
816            _cacheValues.forEach((_cacheValue) -> {
817                MessageDetail _cacheEntity = new MessageDetail(_cacheValue, EntityPermission.READ_ONLY);
818                
819                session.putReadOnlyEntity(_cacheValue.getPrimaryKey(), _cacheEntity);
820            });
821        }
822    }
823    
824    public void create(Collection<MessageDetailValue> _values)
825            throws PersistenceDatabaseException, PersistenceNotNullException {
826        create(ThreadSession.currentSession(), _values);
827    }
828    
829    private boolean bindForStore(PreparedStatement _ps, MessageDetailValue _value)
830            throws SQLException {
831        boolean _hasBeenModified = _value.hasBeenModified();
832        
833        if(_hasBeenModified) {
834            MessagePK mssgdt_mssg_messageid = _value.getMessagePK();
835            if(mssgdt_mssg_messageid == null)
836                _ps.setNull(1, Types.BIGINT);
837            else
838                _ps.setLong(1, mssgdt_mssg_messageid.getEntityId());
839            
840            MessageTypePK mssgdt_mssgtyp_messagetypeid = _value.getMessageTypePK();
841            if(mssgdt_mssgtyp_messagetypeid == null)
842                _ps.setNull(2, Types.BIGINT);
843            else
844                _ps.setLong(2, mssgdt_mssgtyp_messagetypeid.getEntityId());
845            
846            String mssgdt_messagename = _value.getMessageName();
847            if(mssgdt_messagename == null)
848                _ps.setNull(3, Types.VARCHAR);
849            else
850                _ps.setString(3, mssgdt_messagename);
851            
852            Boolean mssgdt_includebydefault = _value.getIncludeByDefault();
853            if(mssgdt_includebydefault == null)
854                _ps.setNull(4, Types.BIT);
855            else
856                _ps.setInt(4, mssgdt_includebydefault? 1: 0);
857            
858            Boolean mssgdt_isdefault = _value.getIsDefault();
859            if(mssgdt_isdefault == null)
860                _ps.setNull(5, Types.BIT);
861            else
862                _ps.setInt(5, mssgdt_isdefault? 1: 0);
863            
864            Integer mssgdt_sortorder = _value.getSortOrder();
865            if(mssgdt_sortorder == null)
866                _ps.setNull(6, Types.INTEGER);
867            else
868                _ps.setInt(6, mssgdt_sortorder);
869            
870            Long mssgdt_fromtime = _value.getFromTime();
871            if(mssgdt_fromtime == null)
872                _ps.setNull(7, Types.BIGINT);
873            else
874                _ps.setLong(7, mssgdt_fromtime);
875            
876            Long mssgdt_thrutime = _value.getThruTime();
877            if(mssgdt_thrutime == null)
878                _ps.setNull(8, Types.BIGINT);
879            else
880                _ps.setLong(8, mssgdt_thrutime);
881            
882            _ps.setLong(9, _value.getPrimaryKey().getEntityId());
883            
884            _value.clearHasBeenModified();
885        }
886        
887        return _hasBeenModified;
888    }
889    
890    @Override
891    public void store(Session session, MessageDetail entity)
892            throws PersistenceDatabaseException {
893        PreparedStatement _ps = session.prepareStatement(SQL_UPDATE);
894        
895        try {
896            MessageDetailValue _value = entity.getMessageDetailValue();
897            
898            if(bindForStore(_ps, _value)) {
899                if(PersistenceDebugFlags.CheckEntityUpdateRowCount) {
900                    int _count = _ps.executeUpdate();
901                    
902                    if(_count != 1) {
903                        throw new PersistenceDatabaseUpdateException("update failed, _count = " + _count);
904                    }
905                } else {
906                     _ps.executeUpdate();
907                }
908                
909                session.getValueCache().put(_value);
910            }
911        } catch (SQLException se) {
912            throw new PersistenceDatabaseException(se);
913        }
914    }
915    
916    @Override
917    public void store(Session session, Collection<MessageDetail> entities)
918            throws PersistenceDatabaseException {
919        if(entities.size() > 0) {
920            PreparedStatement _ps = session.prepareStatement(SQL_UPDATE);
921            int _modifiedEntities = 0;
922            
923            try {
924                for(MessageDetail entity : entities) {
925                    if(bindForStore(_ps, entity.getMessageDetailValue())) {
926                        _ps.addBatch();
927                        _modifiedEntities++;
928                    }
929                }
930                
931                if(_modifiedEntities != 0) {
932                    if(PersistenceDebugFlags.CheckEntityUpdateRowCount) {
933                        int[] _counts = _ps.executeBatch();
934                        
935                        for(int _countOffset = 0 ; _countOffset < _modifiedEntities  ; _countOffset++) {
936                            if(_counts[_countOffset] != 1 && _counts[_countOffset] != PreparedStatement.SUCCESS_NO_INFO) {
937                                throw new PersistenceDatabaseUpdateException("batch update failed, _counts[" + _countOffset + "] = " + _counts[_countOffset]);
938                            }
939                        }
940                    } else {
941                         _ps.executeBatch();
942                    }
943                    
944                    _ps.clearBatch();
945                    
946                    entities.forEach((entity) -> {
947                        session.getValueCache().put(entity.getMessageDetailValue());
948                    });
949                }
950            } catch (SQLException se) {
951                throw new PersistenceDatabaseException(se);
952            }
953        }
954    }
955    
956    @Override
957    public void store(Collection<MessageDetail> entities)
958            throws PersistenceDatabaseException {
959        store(ThreadSession.currentSession(), entities);
960    }
961    
962    @Override
963    public void remove(Session session, MessageDetail entity)
964            throws PersistenceDatabaseException {
965        remove(session, entity.getPrimaryKey());
966    }
967    
968    @Override
969    public void remove(Session session, MessageDetailPK pk)
970            throws PersistenceDatabaseException {
971        PreparedStatement _ps = session.prepareStatement(SQL_DELETE);
972        long _entityId = pk.getEntityId();
973        
974        try {
975            _ps.setLong(1, _entityId);
976            
977            if(PersistenceDebugFlags.CheckEntityDeleteRowCount) {
978                int _count = _ps.executeUpdate();
979                
980                if(_count != 1) {
981                    throw new PersistenceDatabaseUpdateException("remove failed, _count = " + _count);
982                }
983            } else {
984                 _ps.executeUpdate();
985            }
986            
987            session.getValueCache().remove(pk);
988        } catch (SQLException se) {
989            throw new PersistenceDatabaseException(se);
990        }
991        
992        session.removed(pk, false);
993    }
994    
995    @Override
996    public void remove(Session session, Collection<MessageDetailPK> pks)
997            throws PersistenceDatabaseException {
998        if(pks.size() > 0) {
999            PreparedStatement _ps = session.prepareStatement(SQL_DELETE);
1000            int _modifiedEntities = 0;
1001            
1002            try {
1003                for(MessageDetailPK pk : pks) {
1004                    long _entityId = pk.getEntityId();
1005                    
1006                    _ps.setLong(1, _entityId);
1007                    
1008                    _ps.addBatch();
1009                    _modifiedEntities++;
1010                }
1011                
1012                if(_modifiedEntities != 0) {
1013                    if(PersistenceDebugFlags.CheckEntityDeleteRowCount) {
1014                        int[] _counts = _ps.executeBatch();
1015                        
1016                        for(int _countOffset = 0 ; _countOffset < _modifiedEntities  ; _countOffset++) {
1017                            if(_counts[_countOffset] != 1 && _counts[_countOffset] != PreparedStatement.SUCCESS_NO_INFO) {
1018                                throw new PersistenceDatabaseUpdateException("batch remove failed, _counts[" + _countOffset + "] = " + _counts[_countOffset]);
1019                            }
1020                        }
1021                    } else {
1022                        _ps.executeBatch();
1023                    }
1024                    
1025                    _ps.clearBatch();
1026                    
1027                    pks.forEach((pk) -> {
1028                        session.getValueCache().remove(pk);
1029                    });
1030                }
1031            } catch (SQLException se) {
1032                throw new PersistenceDatabaseException(se);
1033            }
1034            
1035            pks.forEach((pk) -> {
1036                session.removed(pk, true);
1037            });
1038        }
1039    }
1040    
1041    @Override
1042    public void remove(Collection<MessageDetailPK> pks)
1043            throws PersistenceDatabaseException {
1044        remove(ThreadSession.currentSession(), pks);
1045    }
1046    
1047    @Override
1048    public boolean validPK(Session session, MessageDetailPK pk)
1049            throws PersistenceDatabaseException {
1050        boolean valid = false;
1051        PreparedStatement _ps = session.prepareStatement(SQL_VALID);
1052        ResultSet _rs = null;
1053        
1054        try {
1055            _ps.setLong(1, pk.getEntityId());
1056            
1057            _rs = _ps.executeQuery();
1058            if(_rs.next()) {
1059                long _count = _rs.getLong(1);
1060                if(_rs.wasNull())
1061                    _count = 0;
1062                
1063                if(_count == 1)
1064                    valid = true;
1065            }
1066        } catch (SQLException se) {
1067            throw new PersistenceDatabaseException(se);
1068        } finally {
1069            if(_rs != null) {
1070                try {
1071                    _rs.close();
1072                } catch (SQLException se) {
1073                    // do nothing
1074                }
1075            }
1076        }
1077        
1078        return valid;
1079    }
1080    
1081}