KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > polepos > teams > jdo > BarcelonaJdo


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.jdo;
21
22 import java.util.*;
23
24 import javax.jdo.*;
25
26 import org.polepos.circuits.barcelona.*;
27 import org.polepos.teams.jdo.data.*;
28
29
30
31 public class BarcelonaJdo extends JdoDriver implements BarcelonaDriver{
32     
33     public void write(){
34         int count = setup().getObjectCount();
35         begin();
36         for (int i = 1; i<= count; i++) {
37             JB4 b4 = new JB4();
38             b4.setAll(i);
39             store(b4);
40         }
41         commit();
42     }
43     
44     public void read(){
45         readExtent(JB4.class);
46     }
47     
48     public void query(){
49         int count = setup().getSelectCount();
50         String JavaDoc filter = "this.b2 == param";
51         for (int i = 1; i <= count; i++) {
52             Query query = db().newQuery(JB4.class, filter);
53             query.declareParameters("int param");
54             doQuery(query, i);
55         }
56     }
57     
58     public void delete(){
59         begin();
60         Extent extent = db().getExtent(JB4.class, false);
61         Iterator it = extent.iterator();
62         while(it.hasNext()){
63             db().deletePersistent(it.next());
64             addToCheckSum(5);
65         }
66         extent.closeAll();
67         commit();
68     }
69
70 }
71
Popular Tags