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 BaseTurbineUserPeer 41 extends BasePeer 42 { 43 44 45 public static final String DATABASE_NAME = "cream"; 46 47 48 public static final String TABLE_NAME = "TURBINE_USER"; 49 50 55 public static MapBuilder getMapBuilder() 56 throws TorqueException 57 { 58 return getMapBuilder(TurbineUserMapBuilder.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 PASSWORD_VALUE; 67 68 public static final String FIRST_NAME; 69 70 public static final String LAST_NAME; 71 72 public static final String EMAIL; 73 74 public static final String CONFIRM_VALUE; 75 76 public static final String MODIFIED; 77 78 public static final String CREATED; 79 80 public static final String LAST_LOGIN; 81 82 public static final String OBJECTDATA; 83 84 static 85 { 86 USER_ID = "TURBINE_USER.USER_ID"; 87 LOGIN_NAME = "TURBINE_USER.LOGIN_NAME"; 88 PASSWORD_VALUE = "TURBINE_USER.PASSWORD_VALUE"; 89 FIRST_NAME = "TURBINE_USER.FIRST_NAME"; 90 LAST_NAME = "TURBINE_USER.LAST_NAME"; 91 EMAIL = "TURBINE_USER.EMAIL"; 92 CONFIRM_VALUE = "TURBINE_USER.CONFIRM_VALUE"; 93 MODIFIED = "TURBINE_USER.MODIFIED"; 94 CREATED = "TURBINE_USER.CREATED"; 95 LAST_LOGIN = "TURBINE_USER.LAST_LOGIN"; 96 OBJECTDATA = "TURBINE_USER.OBJECTDATA"; 97 if (Torque.isInit()) 98 { 99 try 100 { 101 getMapBuilder(TurbineUserMapBuilder.CLASS_NAME); 102 } 103 catch (Exception e) 104 { 105 log.error("Could not initialize Peer", e); 106 } 107 } 108 else 109 { 110 Torque.registerMapBuilder(TurbineUserMapBuilder.CLASS_NAME); 111 } 112 } 113 114 115 public static final int numColumns = 11; 116 117 118 protected static final String CLASSNAME_DEFAULT = 119 "org.campware.cream.om.TurbineUser"; 120 121 122 protected static final Class CLASS_DEFAULT = initClass(CLASSNAME_DEFAULT); 123 124 130 private static Class initClass(String className) 131 { 132 Class c = null; 133 try 134 { 135 c = Class.forName(className); 136 } 137 catch (Throwable t) 138 { 139 log.error("A FATAL ERROR has occurred which should not " 140 + "have happened under any circumstance. Please notify " 141 + "the Torque developers <torque-dev@db.apache.org> " 142 + "and give as many details as possible (including the error " 143 + "stack trace).", t); 144 145 if (t instanceof Error ) 147 { 148 throw (Error ) t.fillInStackTrace(); 149 } 150 } 151 return c; 152 } 153 154 164 public static List resultSet2Objects(java.sql.ResultSet results) 165 throws TorqueException 166 { 167 try 168 { 169 QueryDataSet qds = null; 170 List rows = null; 171 try 172 { 173 qds = new QueryDataSet(results); 174 rows = getSelectResults(qds); 175 } 176 finally 177 { 178 if (qds != null) 179 { 180 qds.close(); 181 } 182 } 183 184 return populateObjects(rows); 185 } 186 catch (SQLException e) 187 { 188 throw new TorqueException(e); 189 } 190 catch (DataSetException e) 191 { 192 throw new TorqueException(e); 193 } 194 } 195 196 197 198 205 public static ObjectKey doInsert(Criteria criteria) 206 throws TorqueException 207 { 208 return BaseTurbineUserPeer 209 .doInsert(criteria, (Connection ) null); 210 } 211 212 222 public static ObjectKey doInsert(Criteria criteria, Connection con) 223 throws TorqueException 224 { 225 226 setDbName(criteria); 227 228 if (con == null) 229 { 230 return BasePeer.doInsert(criteria); 231 } 232 else 233 { 234 return BasePeer.doInsert(criteria, con); 235 } 236 } 237 238 245 public static void addSelectColumns(Criteria criteria) 246 throws TorqueException 247 { 248 criteria.addSelectColumn(USER_ID); 249 criteria.addSelectColumn(LOGIN_NAME); 250 criteria.addSelectColumn(PASSWORD_VALUE); 251 criteria.addSelectColumn(FIRST_NAME); 252 criteria.addSelectColumn(LAST_NAME); 253 criteria.addSelectColumn(EMAIL); 254 criteria.addSelectColumn(CONFIRM_VALUE); 255 criteria.addSelectColumn(MODIFIED); 256 criteria.addSelectColumn(CREATED); 257 criteria.addSelectColumn(LAST_LOGIN); 258 criteria.addSelectColumn(OBJECTDATA); 259 } 260 261 270 public static TurbineUser row2Object(Record row, 271 int offset, 272 Class cls) 273 throws TorqueException 274 { 275 try 276 { 277 TurbineUser obj = (TurbineUser) cls.newInstance(); 278 TurbineUserPeer.populateObject(row, offset, obj); 279 obj.setModified(false); 280 obj.setNew(false); 281 282 return obj; 283 } 284 catch (InstantiationException e) 285 { 286 throw new TorqueException(e); 287 } 288 catch (IllegalAccessException e) 289 { 290 throw new TorqueException(e); 291 } 292 } 293 294 303 public static void populateObject(Record row, 304 int offset, 305 TurbineUser obj) 306 throws TorqueException 307 { 308 try 309 { 310 obj.setUserId(row.getValue(offset + 0).asInt()); 311 obj.setUserName(row.getValue(offset + 1).asString()); 312 obj.setPassword(row.getValue(offset + 2).asString()); 313 obj.setFirstName(row.getValue(offset + 3).asString()); 314 obj.setLastName(row.getValue(offset + 4).asString()); 315 obj.setEmail(row.getValue(offset + 5).asString()); 316 obj.setConfirmed(row.getValue(offset + 6).asString()); 317 obj.setModified(row.getValue(offset + 7).asUtilDate()); 318 obj.setCreateDate(row.getValue(offset + 8).asUtilDate()); 319 obj.setLastLogin(row.getValue(offset + 9).asUtilDate()); 320 obj.setObjectdata(row.getValue(offset + 10).asBytes()); 321 } 322 catch (DataSetException e) 323 { 324 throw new TorqueException(e); 325 } 326 } 327 328 336 public static List doSelect(Criteria criteria) throws TorqueException 337 { 338 return populateObjects(doSelectVillageRecords(criteria)); 339 } 340 341 350 public static List doSelect(Criteria criteria, Connection con) 351 throws TorqueException 352 { 353 return populateObjects(doSelectVillageRecords(criteria, con)); 354 } 355 356 366 public static List doSelectVillageRecords(Criteria criteria) 367 throws TorqueException 368 { 369 return BaseTurbineUserPeer 370 .doSelectVillageRecords(criteria, (Connection ) null); 371 } 372 373 382 public static List doSelectVillageRecords(Criteria criteria, Connection con) 383 throws TorqueException 384 { 385 if (criteria.getSelectColumns().size() == 0) 386 { 387 addSelectColumns(criteria); 388 } 389 390 391 setDbName(criteria); 392 393 if (con == null) 396 { 397 return BasePeer.doSelect(criteria); 398 } 399 else 400 { 401 return BasePeer.doSelect(criteria, con); 402 } 403 } 404 405 412 public static List populateObjects(List records) 413 throws TorqueException 414 { 415 List results = new ArrayList (records.size()); 416 417 for (int i = 0; i < records.size(); i++) 419 { 420 Record row = (Record) records.get(i); 421 results.add(TurbineUserPeer.row2Object(row, 1, 422 TurbineUserPeer.getOMClass())); 423 } 424 return results; 425 } 426 427 428 436 public static Class getOMClass() 437 throws TorqueException 438 { 439 return CLASS_DEFAULT; 440 } 441 442 450 public static void doUpdate(Criteria criteria) throws TorqueException 451 { 452 BaseTurbineUserPeer 453 .doUpdate(criteria, (Connection ) null); 454 } 455 456 467 public static void doUpdate(Criteria criteria, Connection con) 468 throws TorqueException 469 { 470 Criteria selectCriteria = new Criteria(DATABASE_NAME, 2); 471 selectCriteria.put(USER_ID, criteria.remove(USER_ID)); 472 473 setDbName(criteria); 474 475 if (con == null) 476 { 477 BasePeer.doUpdate(selectCriteria, criteria); 478 } 479 else 480 { 481 BasePeer.doUpdate(selectCriteria, criteria, con); 482 } 483 } 484 485 492 public static void doDelete(Criteria criteria) throws TorqueException 493 { 494 TurbineUserPeer 495 .doDelete(criteria, (Connection ) null); 496 } 497 498 508 public static void doDelete(Criteria criteria, Connection con) 509 throws TorqueException 510 { 511 512 setDbName(criteria); 513 514 if (con == null) 515 { 516 BasePeer.doDelete(criteria); 517 } 518 else 519 { 520 BasePeer.doDelete(criteria, con); 521 } 522 } 523 524 530 public static List doSelect(TurbineUser obj) throws TorqueException 531 { 532 return doSelect(buildSelectCriteria(obj)); 533 } 534 535 541 public static void doInsert(TurbineUser obj) throws TorqueException 542 { 543 obj.setPrimaryKey(doInsert(buildCriteria(obj))); 544 obj.setNew(false); 545 obj.setModified(false); 546 } 547 548 553 public static void doUpdate(TurbineUser obj) throws TorqueException 554 { 555 doUpdate(buildCriteria(obj)); 556 obj.setModified(false); 557 } 558 559 564 public static void doDelete(TurbineUser obj) throws TorqueException 565 { 566 doDelete(buildSelectCriteria(obj)); 567 } 568 569 579 public static void doInsert(TurbineUser obj, Connection con) 580 throws TorqueException 581 { 582 obj.setPrimaryKey(doInsert(buildCriteria(obj), con)); 583 obj.setNew(false); 584 obj.setModified(false); 585 } 586 587 597 public static void doUpdate(TurbineUser obj, Connection con) 598 throws TorqueException 599 { 600 doUpdate(buildCriteria(obj), con); 601 obj.setModified(false); 602 } 603 604 614 public static void doDelete(TurbineUser obj, Connection con) 615 throws TorqueException 616 { 617 doDelete(buildSelectCriteria(obj), con); 618 } 619 620 627 public static void doDelete(ObjectKey pk) throws TorqueException 628 { 629 BaseTurbineUserPeer 630 .doDelete(pk, (Connection ) null); 631 } 632 633 643 public static void doDelete(ObjectKey pk, Connection con) 644 throws TorqueException 645 { 646 doDelete(buildCriteria(pk), con); 647 } 648 649 650 public static Criteria buildCriteria( ObjectKey pk ) 651 { 652 Criteria criteria = new Criteria(); 653 criteria.add(USER_ID, pk); 654 return criteria; 655 } 656 657 658 public static Criteria buildCriteria( TurbineUser obj ) 659 { 660 Criteria criteria = new Criteria(DATABASE_NAME); 661 if (!obj.isNew()) 662 criteria.add(USER_ID, obj.getUserId()); 663 criteria.add(LOGIN_NAME, obj.getUserName()); 664 criteria.add(PASSWORD_VALUE, obj.getPassword()); 665 criteria.add(FIRST_NAME, obj.getFirstName()); 666 criteria.add(LAST_NAME, obj.getLastName()); 667 criteria.add(EMAIL, obj.getEmail()); 668 criteria.add(CONFIRM_VALUE, obj.getConfirmed()); 669 criteria.add(MODIFIED, obj.getModified()); 670 criteria.add(CREATED, obj.getCreateDate()); 671 criteria.add(LAST_LOGIN, obj.getLastLogin()); 672 criteria.add(OBJECTDATA, obj.getObjectdata()); 673 return criteria; 674 } 675 676 677 public static Criteria buildSelectCriteria( TurbineUser obj ) 678 { 679 Criteria criteria = new Criteria(DATABASE_NAME); 680 if (!obj.isNew()) 681 criteria.add(USER_ID, obj.getUserId()); 682 criteria.add(LOGIN_NAME, obj.getUserName()); 683 criteria.add(PASSWORD_VALUE, obj.getPassword()); 684 criteria.add(FIRST_NAME, obj.getFirstName()); 685 criteria.add(LAST_NAME, obj.getLastName()); 686 criteria.add(EMAIL, obj.getEmail()); 687 criteria.add(CONFIRM_VALUE, obj.getConfirmed()); 688 criteria.add(MODIFIED, obj.getModified()); 689 criteria.add(CREATED, obj.getCreateDate()); 690 criteria.add(LAST_LOGIN, obj.getLastLogin()); 691 return criteria; 692 } 693 694 695 704 public static TurbineUser retrieveByPK(int pk) 705 throws TorqueException, NoRowsException, TooManyRowsException 706 { 707 return retrieveByPK(SimpleKey.keyFor(pk)); 708 } 709 710 720 public static TurbineUser retrieveByPK(int pk, Connection con) 721 throws TorqueException, NoRowsException, TooManyRowsException 722 { 723 return retrieveByPK(SimpleKey.keyFor(pk), con); 724 } 725 726 735 public static TurbineUser retrieveByPK(ObjectKey pk) 736 throws TorqueException, NoRowsException, TooManyRowsException 737 { 738 Connection db = null; 739 TurbineUser retVal = null; 740 try 741 { 742 db = Torque.getConnection(DATABASE_NAME); 743 retVal = retrieveByPK(pk, db); 744 } 745 finally 746 { 747 Torque.closeConnection(db); 748 } 749 return(retVal); 750 } 751 752 762 public static TurbineUser retrieveByPK(ObjectKey pk, Connection con) 763 throws TorqueException, NoRowsException, TooManyRowsException 764 { 765 Criteria criteria = buildCriteria(pk); 766 List v = doSelect(criteria, con); 767 if (v.size() == 0) 768 { 769 throw new NoRowsException("Failed to select a row."); 770 } 771 else if (v.size() > 1) 772 { 773 throw new TooManyRowsException("Failed to select only one row."); 774 } 775 else 776 { 777 return (TurbineUser)v.get(0); 778 } 779 } 780 781 788 public static List retrieveByPKs(List pks) 789 throws TorqueException 790 { 791 Connection db = null; 792 List retVal = null; 793 try 794 { 795 db = Torque.getConnection(DATABASE_NAME); 796 retVal = retrieveByPKs(pks, db); 797 } 798 finally 799 { 800 Torque.closeConnection(db); 801 } 802 return(retVal); 803 } 804 805 813 public static List retrieveByPKs( List pks, Connection dbcon ) 814 throws TorqueException 815 { 816 List objs = null; 817 if (pks == null || pks.size() == 0) 818 { 819 objs = new LinkedList (); 820 } 821 else 822 { 823 Criteria criteria = new Criteria(); 824 criteria.addIn( USER_ID, pks ); 825 objs = doSelect(criteria, dbcon); 826 } 827 return objs; 828 } 829 830 831 832 833 834 835 836 837 838 839 846 protected static TableMap getTableMap() 847 throws TorqueException 848 { 849 return Torque.getDatabaseMap(DATABASE_NAME).getTable(TABLE_NAME); 850 } 851 852 private static void setDbName(Criteria crit) 853 { 854 if (crit.getDbName() == Torque.getDefaultDB()) 858 { 859 crit.setDbName(DATABASE_NAME); 860 } 861 } 862 } 863
| Popular Tags
|