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