1 package org.campware.cream.om; 2 3 import java.math.BigDecimal ; 4 import java.sql.Connection ; 5 import java.sql.SQLException ; 6 import java.util.ArrayList ; 7 import java.util.Date ; 8 import java.util.Iterator ; 9 import java.util.LinkedList ; 10 import java.util.List ; 11 12 import org.apache.torque.NoRowsException; 13 import org.apache.torque.TooManyRowsException; 14 import org.apache.torque.Torque; 15 import org.apache.torque.TorqueException; 16 import org.apache.torque.map.MapBuilder; 17 import org.apache.torque.map.TableMap; 18 import org.apache.torque.om.DateKey; 19 import org.apache.torque.om.NumberKey; 20 import org.apache.torque.om.StringKey; 21 import org.apache.torque.om.ObjectKey; 22 import org.apache.torque.om.SimpleKey; 23 import org.apache.torque.util.BasePeer; 24 import org.apache.torque.util.Criteria; 25 26 import com.workingdogs.village.DataSetException; 27 import com.workingdogs.village.QueryDataSet; 28 import com.workingdogs.village.Record; 29 30 import org.campware.cream.om.map.*; 32 33 34 40 public abstract class BaseCreamUserPeer 41 extends BasePeer 42 { 43 44 45 public static final String DATABASE_NAME = "cream"; 46 47 48 public static final String TABLE_NAME = "CREAM_USER"; 49 50 55 public static MapBuilder getMapBuilder() 56 throws TorqueException 57 { 58 return getMapBuilder(CreamUserMapBuilder.CLASS_NAME); 59 } 60 61 62 public static final String USER_ID; 63 64 public static final String LOGIN_NAME; 65 66 public static final String WELCOME; 67 68 public static final String DEFAULT_LIST; 69 70 public static final String INBOX_FID; 71 72 public static final String OUTBOX_FID; 73 74 public static final String NEWS_SUBS_FID; 75 76 public static final String NEWSLETTER_FID; 77 78 public static final String ONLINE_SUBS_FID; 79 80 public static final String PRINT_SUBS_FID; 81 82 public static final String SERVICE_FID; 83 84 public static final String SHIPMENT_FID; 85 86 public static final String PAYMENT_FID; 87 88 public static final String SORDER_FID; 89 90 public static final String PROJECT_FID; 91 92 public static final String CUSTOMER_FID; 93 94 public static final String PRODUCT_FID; 95 96 static 97 { 98 USER_ID = "CREAM_USER.USER_ID"; 99 LOGIN_NAME = "CREAM_USER.LOGIN_NAME"; 100 WELCOME = "CREAM_USER.WELCOME"; 101 DEFAULT_LIST = "CREAM_USER.DEFAULT_LIST"; 102 INBOX_FID = "CREAM_USER.INBOX_FID"; 103 OUTBOX_FID = "CREAM_USER.OUTBOX_FID"; 104 NEWS_SUBS_FID = "CREAM_USER.NEWS_SUBS_FID"; 105 NEWSLETTER_FID = "CREAM_USER.NEWSLETTER_FID"; 106 ONLINE_SUBS_FID = "CREAM_USER.ONLINE_SUBS_FID"; 107 PRINT_SUBS_FID = "CREAM_USER.PRINT_SUBS_FID"; 108 SERVICE_FID = "CREAM_USER.SERVICE_FID"; 109 SHIPMENT_FID = "CREAM_USER.SHIPMENT_FID"; 110 PAYMENT_FID = "CREAM_USER.PAYMENT_FID"; 111 SORDER_FID = "CREAM_USER.SORDER_FID"; 112 PROJECT_FID = "CREAM_USER.PROJECT_FID"; 113 CUSTOMER_FID = "CREAM_USER.CUSTOMER_FID"; 114 PRODUCT_FID = "CREAM_USER.PRODUCT_FID"; 115 if (Torque.isInit()) 116 { 117 try 118 { 119 getMapBuilder(CreamUserMapBuilder.CLASS_NAME); 120 } 121 catch (Exception e) 122 { 123 log.error("Could not initialize Peer", e); 124 } 125 } 126 else 127 { 128 Torque.registerMapBuilder(CreamUserMapBuilder.CLASS_NAME); 129 } 130 } 131 132 133 public static final int numColumns = 17; 134 135 136 protected static final String CLASSNAME_DEFAULT = 137 "org.campware.cream.om.CreamUser"; 138 139 140 protected static final Class CLASS_DEFAULT = initClass(CLASSNAME_DEFAULT); 141 142 148 private static Class initClass(String className) 149 { 150 Class c = null; 151 try 152 { 153 c = Class.forName(className); 154 } 155 catch (Throwable t) 156 { 157 log.error("A FATAL ERROR has occurred which should not " 158 + "have happened under any circumstance. Please notify " 159 + "the Torque developers <torque-dev@db.apache.org> " 160 + "and give as many details as possible (including the error " 161 + "stack trace).", t); 162 163 if (t instanceof Error ) 165 { 166 throw (Error ) t.fillInStackTrace(); 167 } 168 } 169 return c; 170 } 171 172 182 public static List resultSet2Objects(java.sql.ResultSet results) 183 throws TorqueException 184 { 185 try 186 { 187 QueryDataSet qds = null; 188 List rows = null; 189 try 190 { 191 qds = new QueryDataSet(results); 192 rows = getSelectResults(qds); 193 } 194 finally 195 { 196 if (qds != null) 197 { 198 qds.close(); 199 } 200 } 201 202 return populateObjects(rows); 203 } 204 catch (SQLException e) 205 { 206 throw new TorqueException(e); 207 } 208 catch (DataSetException e) 209 { 210 throw new TorqueException(e); 211 } 212 } 213 214 215 216 223 public static ObjectKey doInsert(Criteria criteria) 224 throws TorqueException 225 { 226 return BaseCreamUserPeer 227 .doInsert(criteria, (Connection ) null); 228 } 229 230 240 public static ObjectKey doInsert(Criteria criteria, Connection con) 241 throws TorqueException 242 { 243 244 setDbName(criteria); 245 246 if (con == null) 247 { 248 return BasePeer.doInsert(criteria); 249 } 250 else 251 { 252 return BasePeer.doInsert(criteria, con); 253 } 254 } 255 256 263 public static void addSelectColumns(Criteria criteria) 264 throws TorqueException 265 { 266 criteria.addSelectColumn(USER_ID); 267 criteria.addSelectColumn(LOGIN_NAME); 268 criteria.addSelectColumn(WELCOME); 269 criteria.addSelectColumn(DEFAULT_LIST); 270 criteria.addSelectColumn(INBOX_FID); 271 criteria.addSelectColumn(OUTBOX_FID); 272 criteria.addSelectColumn(NEWS_SUBS_FID); 273 criteria.addSelectColumn(NEWSLETTER_FID); 274 criteria.addSelectColumn(ONLINE_SUBS_FID); 275 criteria.addSelectColumn(PRINT_SUBS_FID); 276 criteria.addSelectColumn(SERVICE_FID); 277 criteria.addSelectColumn(SHIPMENT_FID); 278 criteria.addSelectColumn(PAYMENT_FID); 279 criteria.addSelectColumn(SORDER_FID); 280 criteria.addSelectColumn(PROJECT_FID); 281 criteria.addSelectColumn(CUSTOMER_FID); 282 criteria.addSelectColumn(PRODUCT_FID); 283 } 284 285 294 public static CreamUser row2Object(Record row, 295 int offset, 296 Class cls) 297 throws TorqueException 298 { 299 try 300 { 301 CreamUser obj = (CreamUser) cls.newInstance(); 302 CreamUserPeer.populateObject(row, offset, obj); 303 obj.setModified(false); 304 obj.setNew(false); 305 306 return obj; 307 } 308 catch (InstantiationException e) 309 { 310 throw new TorqueException(e); 311 } 312 catch (IllegalAccessException e) 313 { 314 throw new TorqueException(e); 315 } 316 } 317 318 327 public static void populateObject(Record row, 328 int offset, 329 CreamUser obj) 330 throws TorqueException 331 { 332 try 333 { 334 obj.setUserId(row.getValue(offset + 0).asInt()); 335 obj.setUserName(row.getValue(offset + 1).asString()); 336 obj.setWelcome(row.getValue(offset + 2).asString()); 337 obj.setDefaultList(row.getValue(offset + 3).asInt()); 338 obj.setInboxFid(row.getValue(offset + 4).asInt()); 339 obj.setOutboxFid(row.getValue(offset + 5).asInt()); 340 obj.setNewsSubsFid(row.getValue(offset + 6).asInt()); 341 obj.setNewsletterFid(row.getValue(offset + 7).asInt()); 342 obj.setOnlineSubsFid(row.getValue(offset + 8).asInt()); 343 obj.setPrintSubsFid(row.getValue(offset + 9).asInt()); 344 obj.setServiceFid(row.getValue(offset + 10).asInt()); 345 obj.setShipmentFid(row.getValue(offset + 11).asInt()); 346 obj.setPaymentFid(row.getValue(offset + 12).asInt()); 347 obj.setSorderFid(row.getValue(offset + 13).asInt()); 348 obj.setProjectFid(row.getValue(offset + 14).asInt()); 349 obj.setCustomerFid(row.getValue(offset + 15).asInt()); 350 obj.setProductFid(row.getValue(offset + 16).asInt()); 351 } 352 catch (DataSetException e) 353 { 354 throw new TorqueException(e); 355 } 356 } 357 358 366 public static List doSelect(Criteria criteria) throws TorqueException 367 { 368 return populateObjects(doSelectVillageRecords(criteria)); 369 } 370 371 380 public static List doSelect(Criteria criteria, Connection con) 381 throws TorqueException 382 { 383 return populateObjects(doSelectVillageRecords(criteria, con)); 384 } 385 386 396 public static List doSelectVillageRecords(Criteria criteria) 397 throws TorqueException 398 { 399 return BaseCreamUserPeer 400 .doSelectVillageRecords(criteria, (Connection ) null); 401 } 402 403 412 public static List doSelectVillageRecords(Criteria criteria, Connection con) 413 throws TorqueException 414 { 415 if (criteria.getSelectColumns().size() == 0) 416 { 417 addSelectColumns(criteria); 418 } 419 420 421 setDbName(criteria); 422 423 if (con == null) 426 { 427 return BasePeer.doSelect(criteria); 428 } 429 else 430 { 431 return BasePeer.doSelect(criteria, con); 432 } 433 } 434 435 442 public static List populateObjects(List records) 443 throws TorqueException 444 { 445 List results = new ArrayList (records.size()); 446 447 for (int i = 0; i < records.size(); i++) 449 { 450 Record row = (Record) records.get(i); 451 results.add(CreamUserPeer.row2Object(row, 1, 452 CreamUserPeer.getOMClass())); 453 } 454 return results; 455 } 456 457 458 466 public static Class getOMClass() 467 throws TorqueException 468 { 469 return CLASS_DEFAULT; 470 } 471 472 480 public static void doUpdate(Criteria criteria) throws TorqueException 481 { 482 BaseCreamUserPeer 483 .doUpdate(criteria, (Connection ) null); 484 } 485 486 497 public static void doUpdate(Criteria criteria, Connection con) 498 throws TorqueException 499 { 500 Criteria selectCriteria = new Criteria(DATABASE_NAME, 2); 501 selectCriteria.put(USER_ID, criteria.remove(USER_ID)); 502 503 setDbName(criteria); 504 505 if (con == null) 506 { 507 BasePeer.doUpdate(selectCriteria, criteria); 508 } 509 else 510 { 511 BasePeer.doUpdate(selectCriteria, criteria, con); 512 } 513 } 514 515 522 public static void doDelete(Criteria criteria) throws TorqueException 523 { 524 CreamUserPeer 525 .doDelete(criteria, (Connection ) null); 526 } 527 528 538 public static void doDelete(Criteria criteria, Connection con) 539 throws TorqueException 540 { 541 542 setDbName(criteria); 543 544 if (con == null) 545 { 546 BasePeer.doDelete(criteria); 547 } 548 else 549 { 550 BasePeer.doDelete(criteria, con); 551 } 552 } 553 554 560 public static List doSelect(CreamUser obj) throws TorqueException 561 { 562 return doSelect(buildSelectCriteria(obj)); 563 } 564 565 571 public static void doInsert(CreamUser obj) throws TorqueException 572 { 573 doInsert(buildCriteria(obj)); 574 obj.setNew(false); 575 obj.setModified(false); 576 } 577 578 583 public static void doUpdate(CreamUser obj) throws TorqueException 584 { 585 doUpdate(buildCriteria(obj)); 586 obj.setModified(false); 587 } 588 589 594 public static void doDelete(CreamUser obj) throws TorqueException 595 { 596 doDelete(buildSelectCriteria(obj)); 597 } 598 599 609 public static void doInsert(CreamUser obj, Connection con) 610 throws TorqueException 611 { 612 doInsert(buildCriteria(obj), con); 613 obj.setNew(false); 614 obj.setModified(false); 615 } 616 617 627 public static void doUpdate(CreamUser obj, Connection con) 628 throws TorqueException 629 { 630 doUpdate(buildCriteria(obj), con); 631 obj.setModified(false); 632 } 633 634 644 public static void doDelete(CreamUser obj, Connection con) 645 throws TorqueException 646 { 647 doDelete(buildSelectCriteria(obj), con); 648 } 649 650 657 public static void doDelete(ObjectKey pk) throws TorqueException 658 { 659 BaseCreamUserPeer 660 .doDelete(pk, (Connection ) null); 661 } 662 663 673 public static void doDelete(ObjectKey pk, Connection con) 674 throws TorqueException 675 { 676 doDelete(buildCriteria(pk), con); 677 } 678 679 680 public static Criteria buildCriteria( ObjectKey pk ) 681 { 682 Criteria criteria = new Criteria(); 683 criteria.add(USER_ID, pk); 684 return criteria; 685 } 686 687 688 public static Criteria buildCriteria( CreamUser obj ) 689 { 690 Criteria criteria = new Criteria(DATABASE_NAME); 691 criteria.add(USER_ID, obj.getUserId()); 692 criteria.add(LOGIN_NAME, obj.getUserName()); 693 criteria.add(WELCOME, obj.getWelcome()); 694 criteria.add(DEFAULT_LIST, obj.getDefaultList()); 695 criteria.add(INBOX_FID, obj.getInboxFid()); 696 criteria.add(OUTBOX_FID, obj.getOutboxFid()); 697 criteria.add(NEWS_SUBS_FID, obj.getNewsSubsFid()); 698 criteria.add(NEWSLETTER_FID, obj.getNewsletterFid()); 699 criteria.add(ONLINE_SUBS_FID, obj.getOnlineSubsFid()); 700 criteria.add(PRINT_SUBS_FID, obj.getPrintSubsFid()); 701 criteria.add(SERVICE_FID, obj.getServiceFid()); 702 criteria.add(SHIPMENT_FID, obj.getShipmentFid()); 703 criteria.add(PAYMENT_FID, obj.getPaymentFid()); 704 criteria.add(SORDER_FID, obj.getSorderFid()); 705 criteria.add(PROJECT_FID, obj.getProjectFid()); 706 criteria.add(CUSTOMER_FID, obj.getCustomerFid()); 707 criteria.add(PRODUCT_FID, obj.getProductFid()); 708 return criteria; 709 } 710 711 712 public static Criteria buildSelectCriteria( CreamUser obj ) 713 { 714 Criteria criteria = new Criteria(DATABASE_NAME); 715 criteria.add(USER_ID, obj.getUserId()); 716 criteria.add(LOGIN_NAME, obj.getUserName()); 717 criteria.add(WELCOME, obj.getWelcome()); 718 criteria.add(DEFAULT_LIST, obj.getDefaultList()); 719 criteria.add(INBOX_FID, obj.getInboxFid()); 720 criteria.add(OUTBOX_FID, obj.getOutboxFid()); 721 criteria.add(NEWS_SUBS_FID, obj.getNewsSubsFid()); 722 criteria.add(NEWSLETTER_FID, obj.getNewsletterFid()); 723 criteria.add(ONLINE_SUBS_FID, obj.getOnlineSubsFid()); 724 criteria.add(PRINT_SUBS_FID, obj.getPrintSubsFid()); 725 criteria.add(SERVICE_FID, obj.getServiceFid()); 726 criteria.add(SHIPMENT_FID, obj.getShipmentFid()); 727 criteria.add(PAYMENT_FID, obj.getPaymentFid()); 728 criteria.add(SORDER_FID, obj.getSorderFid()); 729 criteria.add(PROJECT_FID, obj.getProjectFid()); 730 criteria.add(CUSTOMER_FID, obj.getCustomerFid()); 731 criteria.add(PRODUCT_FID, obj.getProductFid()); 732 return criteria; 733 } 734 735 736 745 public static CreamUser retrieveByPK(int pk) 746 throws TorqueException, NoRowsException, TooManyRowsException 747 { 748 return retrieveByPK(SimpleKey.keyFor(pk)); 749 } 750 751 761 public static CreamUser retrieveByPK(int pk, Connection con) 762 throws TorqueException, NoRowsException, TooManyRowsException 763 { 764 return retrieveByPK(SimpleKey.keyFor(pk), con); 765 } 766 767 776 public static CreamUser retrieveByPK(ObjectKey pk) 777 throws TorqueException, NoRowsException, TooManyRowsException 778 { 779 Connection db = null; 780 CreamUser retVal = null; 781 try 782 { 783 db = Torque.getConnection(DATABASE_NAME); 784 retVal = retrieveByPK(pk, db); 785 } 786 finally 787 { 788 Torque.closeConnection(db); 789 } 790 return(retVal); 791 } 792 793 803 public static CreamUser retrieveByPK(ObjectKey pk, Connection con) 804 throws TorqueException, NoRowsException, TooManyRowsException 805 { 806 Criteria criteria = buildCriteria(pk); 807 List v = doSelect(criteria, con); 808 if (v.size() == 0) 809 { 810 throw new NoRowsException("Failed to select a row."); 811 } 812 else if (v.size() > 1) 813 { 814 throw new TooManyRowsException("Failed to select only one row."); 815 } 816 else 817 { 818 return (CreamUser)v.get(0); 819 } 820 } 821 822 829 public static List retrieveByPKs(List pks) 830 throws TorqueException 831 { 832 Connection db = null; 833 List retVal = null; 834 try 835 { 836 db = Torque.getConnection(DATABASE_NAME); 837 retVal = retrieveByPKs(pks, db); 838 } 839 finally 840 { 841 Torque.closeConnection(db); 842 } 843 return(retVal); 844 } 845 846 854 public static List retrieveByPKs( List pks, Connection dbcon ) 855 throws TorqueException 856 { 857 List objs = null; 858 if (pks == null || pks.size() == 0) 859 { 860 objs = new LinkedList (); 861 } 862 else 863 { 864 Criteria criteria = new Criteria(); 865 criteria.addIn( USER_ID, pks ); 866 objs = doSelect(criteria, dbcon); 867 } 868 return objs; 869 } 870 871 872 873 874 875 876 877 878 879 880 887 protected static TableMap getTableMap() 888 throws TorqueException 889 { 890 return Torque.getDatabaseMap(DATABASE_NAME).getTable(TABLE_NAME); 891 } 892 893 private static void setDbName(Criteria crit) 894 { 895 if (crit.getDbName() == Torque.getDefaultDB()) 899 { 900 crit.setDbName(DATABASE_NAME); 901 } 902 } 903 } 904
| Popular Tags
|