1 21 package com.db4o.test.legacy.soda.engines.db4o; 22 23 import java.io.*; 24 25 import com.db4o.*; 26 import com.db4o.foundation.*; 27 import com.db4o.query.*; 28 import com.db4o.test.legacy.soda.*; 29 30 public class STDb4oClientServer implements STEngine { 31 32 private static final int PORT = 4044; 33 private static final String HOST = "localhost"; 34 private static final String FILE = "sodacs.yap"; 35 private static final String USER = "S.O.D.A."; 36 private static final String PASS = "rocks"; 37 38 private static final boolean IN_PROCESS_SERVER = true; 39 40 private com.db4o.ObjectServer server; 41 private com.db4o.ObjectContainer con; 42 43 52 public static void main(String [] args) { 53 new File(FILE).delete(); 54 ObjectServer server = Db4o.openServer(FILE, PORT); 55 server.grantAccess(USER, PASS); 56 server.ext().configure().messageLevel(-1); 57 } 58 59 public void reset() { 60 new File(FILE).delete(); 61 } 62 63 public Query query() { 64 return con.query(); 65 } 66 67 public void open() { 68 Db4o.configure().messageLevel(-1); 69 70 if (IN_PROCESS_SERVER) { 71 server = Db4o.openServer(FILE, PORT); 72 server.grantAccess(USER, PASS); 73 Cool.sleepIgnoringInterruption(3000); 75 } 76 try { 77 con = Db4o.openClient(HOST, PORT, USER, PASS); 78 } catch (Exception e) { 79 e.printStackTrace(); 80 } 81 } 82 83 public void close() { 84 con.close(); 85 if (IN_PROCESS_SERVER) { 86 server.close(); 87 } 88 } 89 90 public void store(Object obj) { 91 con.set(obj); 92 } 93 94 public void commit(){ 95 con.commit(); 96 } 97 98 public void delete(Object obj){ 99 con.delete(obj); 100 } 101 } 102 | Popular Tags |