[Cyberaide-svn] SF.net SVN: cyberaide:[1906] code/trunk/shell-cli/src/main/java/org/ cyberaide/queu
Status: Planning
Brought to you by:
laszewsk
From: <ys...@us...> - 2010-05-29 03:03:56
|
Revision: 1906 http://cyberaide.svn.sourceforge.net/cyberaide/?rev=1906&view=rev Author: ysm906 Date: 2010-05-29 03:03:50 +0000 (Sat, 29 May 2010) Log Message: ----------- Modified Paths: -------------- code/trunk/shell-cli/src/main/java/org/cyberaide/queue/TaskPool.java Modified: code/trunk/shell-cli/src/main/java/org/cyberaide/queue/TaskPool.java =================================================================== --- code/trunk/shell-cli/src/main/java/org/cyberaide/queue/TaskPool.java 2010-05-28 03:37:52 UTC (rev 1905) +++ code/trunk/shell-cli/src/main/java/org/cyberaide/queue/TaskPool.java 2010-05-29 03:03:50 UTC (rev 1906) @@ -8,18 +8,22 @@ import org.cyberaide.core.CoGObject; import org.apache.log4j.Logger; + import org.hibernate.SessionFactory; import org.hibernate.Session; import org.hibernate.cfg.Configuration; +import org.hibernate.Query; /** * TaskPool class */ public class TaskPool implements Pool { - private Logger log = Logger.getLogger(this.getClass()); // is this correct? + private Logger log = Logger.getLogger(this.getClass()); private String id; private Policy policy; private List<CoGObject> tasks; + private static final SessionFactory sessionFactory + = new Configuration().configure().buildSessionFactory(); /** * constructor @@ -30,10 +34,9 @@ this.policy = policy; } - private void test(){ - SessionFactory sessionFactory = - new Configuration().configure().buildSessionFactory(); + private void testInsert(){ Session session = sessionFactory.getCurrentSession(); + try{ session.beginTransaction(); Task task = new Task(); @@ -48,6 +51,20 @@ } } + private void testDelete(){ + Session session = sessionFactory.openSession(); + try{ + Query delete = session.createQuery("delete from Task task where task.id = 2"); + int row = delete.executeUpdate(); + session.getTransaction().commit(); +System.out.println("deleted row = "+row); + }catch(RuntimeException e){ + e.printStackTrace(); + }finally{ + session.close(); + } + } + public void query(String function, String attribute, String value){ } @@ -82,7 +99,8 @@ tasks.add(task); log.info("Task "+jobId+" has been submitted to Task Pool."); -test(); +testInsert(); +testDelete(); } /** This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site. |