事务的例子.doc

事务操作的例子一、创建数据表drop sequence person_seq;CREATE SEQUENCE person_seq INCREMENT BY 1 START WITH 10000 NOMAXVALUE NOCYCLE CACHE 10;drop table PERSONS;create table PERSONS( ID NUMBER not null, NAME VARCHAR2(50), AGE NUMBER, SEX VARCHAR2(50), constraint ID primary key (ID);insert into persons(ID, Name,Age,Sex) values( person_seq.nextval, zhangsan, 32,male);insert into persons(ID, Name,Age,Sex) values( person_seq.nextval, lisi, 32,male);insert into persons(ID, Name,Age,Sex) values( person_seq.nextval, wangwu, 32,male);二、设计对象类/*01*/package ;/*02*/*03*/import java.io.*;/*04*/import javax.persistence.*;/*05*/*06*/Entity/*07*/Table(name = PERSONS)/*08*/SequenceGenerator(name=mysequ,/*09*/ sequenceName=person_seq)/*10*/public class Person implements Serializable /*11*/*12*/ Id/*13*/ GeneratedValue(strategy=GenerationType.SEQUENCE,/*14*/ generator=mysequ)/*15*/ Column(name = ID, nullable = false)/*16*/ private Integer id;/*17*/*18*/ Column(name = NAME)/*19*/ private String name;/*20*/*21*/ Column(name = AGE)/*22*/ private Integer age;/*23*/*24*/ Column(name = SEX)/*25*/ private String sex;/*26*/ /*27*/ public Person() /*28*/ public Person(Integer id) /*29*/ this.id = id;/*30*/ /*31*/*32*/ public Integer getId() /*33*/ return this.id;/*34*/ /*35*/ public void setId(Integer id) /*36*/ this.id = id;/*37*/ /*38*/*39*/ public String getName() /*40*/ return ;/*41*/ /*42*/ public void setName(String name) /*43*/ = name;/*44*/ /*45*/*46*/ public Integer getAge() /*47*/ return this.age;/*48*/ /*49*/ public void setAge(Integer age) /*50*/ this.age = age;/*51*/ /*52*/ /*53*/ public String getSex() /*54*/ return this.sex;/*55*/ /*56*/ public void setSex(String sex) /*57*/ this.sex = sex;/*58*/ /*59*/三、容器管理的事务的例子/*01*/package ;/*02*/*03*/import javax.persistence.*;/*04*/import java.util.*;/*05*/import javax.ejb.*;/*06*/import bits.db.*;/*07*/*08*/Stateless/*09*/public class PersonManager implements IPersonAdmin/*10*/*11*/ PersistenceContext(unitName=mydb) /*12*/ private EntityManager manager;/*13*/ EJB(mappedName=MySession/remote)/*14*/ private IPersonAdmin mytools;/*15*/ public List QueryAll()/*16*/ /*17*/ Query q=manager.createQuery(from Person c);/*18*/ List results=q.getResultList();/*19*/ List result=(List)results;/*20*/ return result;/*21*/ /*22*/ public void createPerson(Person p) /*23*/ /*24*/ Person pobj=new Person(); /*25*/ pobj.setName(zhanghao); /*26*/ pobj.setAge(new Integer(32); /*27*/ pobj.setSex(male); /*28*/ manager.persist(pobj);/*29*/ mytools.createPerson(p);/*30*/ manager.persist(null);/*31*/ /*32*/四、Bean管理的事务的例子/*01*/package ;/*02*/*03*/import javax.persistence.*;/*04*/import java.util.*;/*05*/import javax.ejb.*;/*06*/import javax.annotation.*;/*07*/import bits.db.*;/*08*/import javax.transaction.*;/*09*/*10*/Stateless/*11*/TransactionManagement(TransactionManagementType.BEAN)/*12*/public class PersonManager implements IPersonAdmin/*13*/*14*/ Resource /*15*/ private EJBContext ctx;/*16*/ Resource/*17*/ private UserTransaction ut;/*18*/ PersistenceContext(unitName=mydb) /*19*/ private EntityManager manager;/*20*/ EJB(mappedName=MySession/remote)/*21*/ private IPersonAdmin mytools;/*22*/ public List QueryAll()/*23*/ /*24*/ List results=null;/*25*/ UserTransaction ut1=ctx.getUserTransaction();/*26*/ try/*27*/ ut1.begin();/*28*/ Query q=manager.createQuery(from Person c);/*29*/ results=q.getResultList();/*30*/ mit();/*31*/ /*32*/ catch(Exception ex)/*33*/ /*34*/ try/*35*/ ut1.rollback(); catch(Exception ex1)/*36*/ /*37*/ List result=(List)results;/*38*/ return result;/*39*/ /*40*/ public void createPerson(Person p) /*41*/ /*42*/ try/*43*/ /*44*/ ut.begin();/*45*/ Person pobj=new Person(); /*46*/ pobj.setName(zhanghao); /*47*/ pobj.setAge(new Integer(32); /*48*/ pobj.setSex(male); /*49*/ manager.persist(pob