KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > polepos > teams > prevayler > melbourne > MelbournePrevaylerDriver


1 /*
2 This file is part of the PolePosition database benchmark
3 http://www.polepos.org
4
5 This program is free software; you can redistribute it and/or
6 modify it under the terms of the GNU General Public License
7 as published by the Free Software Foundation; either version 2
8 of the License, or (at your option) any later version.
9
10 This program is distributed in the hope that it will be useful,
11 but WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 GNU General Public License for more details.
14
15 You should have received a copy of the GNU General Public
16 License along with this program; if not, write to the Free
17 Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
18 MA 02111-1307, USA. */
19
20 package org.polepos.teams.prevayler.melbourne;
21
22 import java.util.*;
23
24 import org.polepos.circuits.melbourne.*;
25 import org.polepos.data.*;
26 import org.polepos.teams.prevayler.*;
27
28
29 public class MelbournePrevaylerDriver extends PrevaylerDriver implements MelbourneDriver, Checksum {
30
31     private final MelbourneSystem _melbourne = (MelbourneSystem)_prevayler.prevalentSystem();
32
33     public void write() {
34         int objectsToWrite= setup().getObjectCount();
35         int commitInterval= setup().getCommitInterval();
36         
37         while (objectsToWrite > 0) {
38             int objectsToWriteNow = objectsToWrite < commitInterval
39                 ? objectsToWrite
40                 : commitInterval;
41             _prevayler.execute(new ObjectCreationTransaction(objectsToWriteNow));
42             objectsToWrite -= commitInterval;
43         }
44     }
45     
46     public void read() {
47         Iterator pilots = _melbourne.pilots().iterator();
48         while (pilots.hasNext()) {
49             Pilot p = (Pilot)pilots.next();
50         }
51     }
52     
53     public void read_hot() {
54         read();
55     }
56     
57     public void delete() {
58         int objectsToDelete = setup().getObjectCount();
59         int commitInterval = setup().getCommitInterval();
60         
61         while (objectsToDelete > 0) {
62             int objectsToDeleteNow = objectsToDelete < commitInterval
63                 ? objectsToDelete
64                 : commitInterval;
65             _prevayler.execute(new DeletionTransaction(objectsToDeleteNow));
66             objectsToDelete -= commitInterval;
67         }
68     }
69
70     protected Object JavaDoc prevalentSystem() {
71         return new MelbourneSystem(this);
72     }
73
74     public void add(int i) {
75         addToCheckSum(i);
76     }
77
78
79     
80 }
81
Popular Tags