package point; import java.util.Date; import javax.persistence.EntityManager; import javax.persistence.EntityManagerFactory; import javax.persistence.FlushModeType; import javax.persistence.Query; public class TestObjectDB { private int deviceCount = 0; private EntityManagerFactory emf = null; private EntityManager em = null; private int threadCount; private int mod; TestObjectDB(int threadCount, int mod, int size, EntityManagerFactory emf) { this.threadCount = threadCount; this.mod = mod; this.deviceCount = size; this.emf = emf; init(); } private void init() { logger("Initing..."); em = emf.createEntityManager(); } public void close() { logger("Closing..."); if (em.isOpen()) { em.close(); } } public void run() { logger("Running..."); addData(); info(); deleteData(); info(); } private String[] generateAttributes(long deviceId) { int columnCount = 3; String[] attributes = new String[columnCount]; for (int i=0; i