1 package allinone; 2 3 import com.lutris.appserver.server.sql.*; 4 import com.lutris.util.*; 5 import org.enhydra.dods.*; 6 import java.sql.SQLException ; 7 8 9 import javax.swing.*; 10 import java.util.*; 11 import java.awt.*; 12 import java.awt.event.*; 13 import java.net.*; 14 import java.io.*; 15 import org.apache.log4j.Logger; 16 import org.apache.log4j.xml.DOMConfigurator; 17 import com.lutris.appserver.server.sql.*; 18 import allinone.data.disc.*; 19 import allinone.data.person.*; 20 21 public class MassModification { 22 23 public void runTest(DBTransaction dbTrans) { 24 try { 25 System.err.println("___ - + * startin MassModification * + - ___"); 26 for(int n = 0; n < 30; ++n) { 27 PersonDO person1 = PersonDO.createVirgin(dbTrans); 28 29 person1.setFirstname("Asterix"); 30 person1.setLastname("The Gaul"); 31 person1.setLogin("p1"); 32 person1.setPassword((n>22)?"p1":"."); 33 person1.save(dbTrans); 34 System.err.print("+"); 35 } 36 dbTrans.commit(); 37 PersonDO pDO = null; 38 PersonQuery q = new PersonQuery(dbTrans); 39 45 46 49 System.err.println("commit 'n' release"); 50 51 53 PersonQuery queryU = new PersonQuery(dbTrans); 54 55 PersonUpdate massUpd = new PersonUpdate(queryU); 56 57 System.err.println("made query 'n' massDel"); 58 59 queryU.setQueryFavouredDisc(null); 60 queryU.setQueryLastname("The Gaul"); 61 62 System.err.println("query alone["+ queryU.getQueryBuilder().getSQLwithParms() +"]"); 63 64 massUpd.setFirstname("Obelixa"); 65 massUpd.setFirstname("Obelix"); 66 massUpd.setLastname("of Laetitia"); 67 System.err.println("before save["+ queryU.getQueryBuilder().getSQLwithParms() +"]"); 69 massUpd.save(); 70 System.err.println("after save["+ queryU.getQueryBuilder().getSQLwithParms() +"]"); 71 72 74 PersonQuery queryD = new PersonQuery(dbTrans); 75 PersonDelete massDel = new PersonDelete(queryD); 76 queryD.setQueryPassword("."); 77 massDel.save(); 78 dbTrans.commit(); 79 dbTrans.release(); 80 81 System.err.println("commit 'n' release"); 82 83 dbTrans = DODS.getDatabaseManager().createTransaction(); 84 85 System.err.println("after write["+ queryU.getQueryBuilder().getSQLwithParms() +"]"); 87 q = new PersonQuery(dbTrans); 88 pDO = null; 89 do { 90 pDO = q.getNextDO(); 91 if (null == pDO) 92 break; 93 System.err.println("pDO:"+ pDO +"\t"+ pDO.getFirstname() +", "+ pDO.getFavouredDisc()); 94 pDO.delete(dbTrans); 95 break; 96 } while(true); 97 98 dbTrans.commit(); 99 dbTrans.release(); 100 System.err.println("kraj konac"); 101 }catch (Exception ex){ 102 System.err.println(ex.toString()); 103 ex.printStackTrace(); 104 } 105 } 106 } 107 | Popular Tags |