001: package allinone;
002:
003: import com.lutris.appserver.server.sql.*;
004: import com.lutris.util.*;
005: import org.enhydra.dods.*;
006: import java.sql.SQLException;
007:
008: import javax.swing.*;
009: import java.util.*;
010: import java.awt.*;
011: import java.awt.event.*;
012: import java.net.*;
013: import java.io.*;
014: import org.apache.log4j.Logger;
015: import org.apache.log4j.xml.DOMConfigurator;
016: import com.lutris.appserver.server.sql.*;
017: import allinone.data.disc.*;
018: import allinone.data.person.*;
019:
020: public class MassModification {
021:
022: public void runTest(DBTransaction dbTrans) {
023: try {
024: System.err
025: .println("___ - + * startin MassModification * + - ___");
026: for (int n = 0; n < 30; ++n) {
027: PersonDO person1 = PersonDO.createVirgin(dbTrans);
028:
029: person1.setFirstname("Asterix");
030: person1.setLastname("The Gaul");
031: person1.setLogin("p1");
032: person1.setPassword((n > 22) ? "p1" : ".");
033: person1.save(dbTrans);
034: System.err.print("+");
035: }
036: dbTrans.commit();
037: PersonDO pDO = null;
038: PersonQuery q = new PersonQuery(dbTrans);
039: /*
040: do {
041: pDO = q.getNextDO();
042: System.err.println("pDO:"+ pDO);
043: } while(false);//(null != pDO);
044: */
045:
046: //dbTrans.commit();
047: //dbTrans.release();
048: System.err.println("commit 'n' release");
049:
050: //dbTrans = DODS.getDatabaseManager().createTransaction();
051:
052: PersonQuery queryU = new PersonQuery(dbTrans);
053:
054: PersonUpdate massUpd = new PersonUpdate(queryU);
055:
056: System.err.println("made query 'n' massDel");
057:
058: queryU.setQueryFavouredDisc(null);
059: queryU.setQueryLastname("The Gaul");
060:
061: System.err.println("query alone["
062: + queryU.getQueryBuilder().getSQLwithParms() + "]");
063:
064: massUpd.setFirstname("Obelixa");
065: massUpd.setFirstname("Obelix");
066: massUpd.setLastname("of Laetitia");
067: // massUpd.setFavouredDisc(null);
068: System.err.println("before save["
069: + queryU.getQueryBuilder().getSQLwithParms() + "]");
070: massUpd.save();
071: System.err.println("after save["
072: + queryU.getQueryBuilder().getSQLwithParms() + "]");
073:
074: //dbTrans.commit();
075:
076: PersonQuery queryD = new PersonQuery(dbTrans);
077: PersonDelete massDel = new PersonDelete(queryD);
078: queryD.setQueryPassword(".");
079: massDel.save();
080: dbTrans.commit();
081: dbTrans.release();
082:
083: System.err.println("commit 'n' release");
084:
085: dbTrans = DODS.getDatabaseManager().createTransaction();
086: /**/
087: //dbTrans.write();
088: System.err.println("after write["
089: + queryU.getQueryBuilder().getSQLwithParms() + "]");
090: q = new PersonQuery(dbTrans);
091: pDO = null;
092: do {
093: pDO = q.getNextDO();
094: if (null == pDO)
095: break;
096: System.err.println("pDO:" + pDO + "\t"
097: + pDO.getFirstname() + ", "
098: + pDO.getFavouredDisc());
099: pDO.delete(dbTrans);
100: break;
101: } while (true);
102: /**/
103: dbTrans.commit();
104: dbTrans.release();
105: System.err.println("kraj konac");
106: } catch (Exception ex) {
107: System.err.println(ex.toString());
108: ex.printStackTrace();
109: }
110: }
111: }
|