《精通Hibernate》学习(1) 《精通Hibernate》学习(1)——第一个Hibernate应用

时间  2021-08-15



转自：http://blog.csdn.net/yu422560654/article/details/7028748



《精通Hibernate》学习(1)——第一个Hibernate应用

一、在Java应用中使用Hibernate的步骤

  • 创建Hibernate的配置文件
  • 创建持久化类
  • 创建对象-关系映射文件
  • 通过Hibernate API编写访问数据库的代码

二、Helloapp应用的结构

三、Hibernate的配置文件(hibernate.properties)

[plain] view plain copy print ?
  1. hibernate.dialect=org.hibernate.dialect.MySQLDialect
  2. hibernate.connection.driver_class=com.mysql.jdbc.Driver
  3. hibernate.connection.url=jdbc:mysql://localhost:3306/SAMPLEDB
  4. hibernate.connection.username=root
  5. hibernate.connection.password=1234
  6. hibernate.show_sql=true


四、创建持久化类Customer

  • 持久化类符合JavaBean的规范，包含一些属性，以及与之对应的getXXX()和setXXX()方法。
  • 持久化类有一个id属性，用来惟一标识Customer类的每个对象。在面向对象术语中，这个id属性被称为对象标识符（OID，Object Identifier），通常它都用整数表示
  • Hibernate要求持久化类必须提供一个不带参数的默认构造方法
[java] view plain copy print ?
  1. packagemypack;
  2. importjava.io.Serializable;
  3. importjava.sql.Date;
  4. importjava.sql.Timestamp;
  6. publicclassCustomerimplementsSerializable{
  7. privateLongid;
  8. privateStringname;
  9. privateStringemail;
  10. privateStringpassword;
  11. privateintphone;
  12. privateStringaddress;
  13. privatecharsex;
  14. privatebooleanmarried;
  15. privateStringdescription;
  16. privatebyte[]image;
  17. privateDatebirthday;
  18. privateTimestampregisteredTime;
  20. publicCustomer(){}
  22. publicLonggetId(){
  23. returnid;
  24. }
  26. privatevoidsetId(Longid){
  27. this.id=id;
  28. }
  30. publicStringgetName(){
  31. returnname;
  32. }
  34. publicvoidsetName(Stringname){
  35. this.name=name;
  36. }
  38. publicStringgetEmail(){
  39. returnemail;
  40. }
  42. publicvoidsetEmail(Stringemail){
  43. this.email=email;
  44. }
  46. publicStringgetPassword(){
  47. returnpassword;
  48. }
  50. publicvoidsetPassword(Stringpassword){
  51. this.password=password;
  52. }
  54. publicintgetPhone(){
  55. returnphone;
  56. }
  58. publicvoidsetPhone(intphone){
  59. this.phone=phone;
  60. }
  62. publicStringgetAddress(){
  63. returnaddress;
  64. }
  66. publicvoidsetAddress(Stringaddress){
  67. this.address=address;
  68. }
  69. publicchargetSex(){
  70. returnsex;
  71. }
  73. publicvoidsetSex(charsex){
  74. this.sex=sex;
  75. }
  77. publicbooleanisMarried(){
  78. returnmarried;
  79. }
  81. publicvoidsetMarried(booleanmarried){
  82. this.married=married;
  83. }
  85. publicStringgetDescription(){
  86. returndescription;
  87. }
  89. publicvoidsetDescription(Stringdescription){
  90. this.description=description;
  91. }
  93. publicbyte[]getImage(){
  94. returnthis.image;
  95. }
  97. publicvoidsetImage(byte[]image){
  98. this.image=image;
  99. }
  101. publicDategetBirthday(){
  102. returnthis.birthday;
  103. }
  105. publicvoidsetBirthday(Datebirthday){
  106. this.birthday=birthday;
  107. }
  109. publicTimestampgetRegisteredTime(){
  110. returnthis.registeredTime;
  111. }
  113. publicvoidsetRegisteredTime(TimestampregisteredTime){
  114. this.registeredTime=registeredTime;
  115. }
  117. }

注意：

  • getXXX()和setXXX()方法可以采用任意的访问级别，他的命名规则必须符合特定的命名规则，“get”和“set”后面紧跟属性的名字，并且属性名的首字母为大写，如name属性的get方法为getName()。
  • 如果持久化类的属性为boolean类型，那么它的get方法名可以用get做前缀也可以用is做前缀。

五、创建数据库Schema

[sql] view plain copy print ?
  1. dropdatabaseifexistsSAMPLEDB;
  2. createdatabaseSAMPLEDB;
  3. useSAMPLEDB;
  5. createtableCUSTOMERS(
  6. IDbigintnotnullprimarykey,
  7. NAMEvarchar(15)notnull,
  8. EMAILvarchar(128)notnull,
  9. PASSWORDvarchar(8)notnull,
  10. PHONEint,
  11. ADDRESSvarchar(255),
  12. SEXchar(1),
  13. IS_MARRIEDbit,
  14. DESCRIPTIONtext,
  15. IMAGEblob,
  16. BIRTHDAYdate,
  17. REGISTERED_TIMEtimestamp
  18. );


六、创建对象-关系映射文件Customer.hbm.xml
[html] view plain copy print ?
  1. <?xmlversion="1.0"?>
  2. <!DOCTYPEhibernate-mappingPUBLIC"-//Hibernate/HibernateMappingDTD3.0//EN""http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
  4. <hibernate-mapping>
  5. <classname="mypack.Customer"table="CUSTOMERS">
  6. <idname="id"column="ID"type="long">
  7. <generatorclass="increment"/>
  8. </id>
  9. <propertyname="name"column="NAME"type="string"not-null="true"/>
  10. <propertyname="email"column="EMAIL"type="string"not-null="true"/>
  11. <propertyname="password"column="PASSWORD"type="string"not-null="true"/>
  12. <propertyname="phone"column="PHONE"type="int"/>
  13. <propertyname="address"column="ADDRESS"type="string"/>
  14. <propertyname="sex"column="SEX"type="character"/>
  15. <propertyname="married"column="IS_MARRIED"type="boolean"/>
  16. <propertyname="description"column="DESCRIPTION"type="text"/>
  17. <propertyname="image"column="IMAGE"type="binary"/>
  18. <propertyname="birthday"column="BIRTHDAY"type="date"/>
  19. <propertyname="registeredTime"column="REGISTERED_TIME"type="timestamp"/>
  20. </class>
  21. </hibernate-mapping>

  • <id>元素映射OID

<generator>子元素用来设定标识符生成器。Hibernate提供了提供了多种内置的实现。

  • <property>元素映射值类型属性
name属性：指定持久化类的属性的名字。
column属性：指定与类的属性映射的表的字段名。
type属性：指定Hibernate映射类型。Hibernate映射类型是Java类型与SQL类型的桥梁。

采用XML文件来配置对象-关系映射的优点：
  • Hibernate既不会渗透到上层域模型中，也不会渗透到下层数据模型中。
  • 软件开发人员可以独立设计域模型，不必强迫遵守任何规范。
  • 数据库设计人员可以独立设计数据模型，不必强迫遵守任何规范。
  • 对象-关系映射不依赖于任何程序代码，如果需要修改对象-关系映射，只需修改XML文件，不需要修改任何程序，提高了软件的灵活性，并且使维护更加方便。

七、创建BusinessService类

[java] view plain copy print ?
  1. packagemypack;
  3. importjavax.servlet.*;
  4. importorg.hibernate.*;
  5. importorg.hibernate.cfg.Configuration;
  6. importjava.io.*;
  7. importjava.sql.Date;
  8. importjava.sql.Timestamp;
  9. importjava.util.*;
  11. publicclassBusinessService{
  12. publicstaticSessionFactorysessionFactory;
  14. /**初始化Hibernate，创建SessionFactory实例*/
  15. static{
  16. try{
  17. //根据默认位置的Hibernate配置文件的配置信息，创建一个Configuration实例
  18. Configurationconfig=newConfiguration();
  19. //加载Customer类的对象-关系映射文件
  20. config.addClass(Customer.class);
  21. //创建SessionFactory实例*/
  22. sessionFactory=config.buildSessionFactory();
  23. }catch(RuntimeExceptione){e.printStackTrace();throwe;}
  24. }
  26. /**查询所有的Customer对象，然后调用printCustomer()方法打印Customer对象信息*/
  27. publicvoidfindAllCustomers(ServletContextcontext,PrintWriterout)throwsException{
  28. Sessionsession=sessionFactory.openSession();//创建一个会话
  29. Transactiontx=null;
  30. try{
  31. tx=session.beginTransaction();//开始一个事务
  32. Queryquery=session.createQuery("fromCustomerascorderbyc.nameasc");
  33. Listcustomers=query.list();
  34. for(Iteratorit=customers.iterator();it.hasNext();){
  35. printCustomer(context,out,(Customer)it.next());
  36. }
  38. tx.commit();//提交事务
  40. }catch(RuntimeExceptione){
  41. if(tx!=null){
  42. tx.rollback();
  43. }
  44. throwe;
  45. }finally{
  46. session.close();
  47. }
  48. }
  50. /**持久化一个Customer对象*/
  51. publicvoidsaveCustomer(Customercustomer){
  52. Sessionsession=sessionFactory.openSession();
  53. Transactiontx=null;
  54. try{
  55. tx=session.beginTransaction();
  56. session.save(customer);
  57. tx.commit();
  59. }catch(RuntimeExceptione){
  60. if(tx!=null){
  61. tx.rollback();
  62. }
  63. throwe;
  64. }finally{
  65. session.close();
  66. }
  67. }
  69. /**按照OID加载一个Customer对象，然后修改它的属性*/
  70. publicvoidloadAndUpdateCustomer(Longcustomer_id,Stringaddress){
  71. Sessionsession=sessionFactory.openSession();
  72. Transactiontx=null;
  73. try{
  74. tx=session.beginTransaction();
  76. Customerc=(Customer)session.get(Customer.class,customer_id);
  77. c.setAddress(address);
  78. tx.commit();
  80. }catch(RuntimeExceptione){
  81. if(tx!=null){
  82. tx.rollback();
  83. }
  84. throwe;
  85. }finally{
  86. session.close();
  87. }
  88. }
  90. /**删除Customer对象*/
  91. publicvoiddeleteCustomer(Customercustomer){
  92. Sessionsession=sessionFactory.openSession();
  93. Transactiontx=null;
  94. try{
  95. tx=session.beginTransaction();
  96. session.delete(customer);
  97. tx.commit();
  99. }catch(RuntimeExceptione){
  100. if(tx!=null){
  101. tx.rollback();
  102. }
  103. throwe;
  104. }finally{
  105. session.close();
  106. }
  107. }
  109. /**选择向控制台还是Web网页输出Customer对象的信息*/
  110. privatevoidprintCustomer(ServletContextcontext,PrintWriterout,Customercustomer)throwsException{
  111. if(context!=null)
  112. printCustomerInWeb(context,out,customer);
  113. else
  114. printCustomer(out,customer);
  115. }
  117. /**把Customer对象的信息输出到控制台，如DOS控制台*/
  118. privatevoidprintCustomer(PrintWriterout,Customercustomer)throwsException{
  119. byte[]buffer=customer.getImage();
  120. FileOutputStreamfout=newFileOutputStream("photo_copy.gif");
  121. fout.write(buffer);
  122. fout.close();
  124. out.println("------以下是"+customer.getName()+"的个人信息------");
  125. out.println("ID:"+customer.getId());
  126. out.println("口令:"+customer.getPassword());
  127. out.println("E-Mail:"+customer.getEmail());
  128. out.println("电话:"+customer.getPhone());
  129. out.println("地址:"+customer.getAddress());
  130. Stringsex=customer.getSex()=='M'?"男":"女";
  131. out.println("性别:"+sex);
  132. StringmarriedStatus=customer.isMarried()?"已婚":"未婚";
  133. out.println("婚姻状况:"+marriedStatus);
  134. out.println("生日:"+customer.getBirthday());
  135. out.println("注册时间:"+customer.getRegisteredTime());
  136. out.println("自我介绍:"+customer.getDescription());
  138. }
  140. /**把Customer对象的信息输出到动态网页*/
  141. privatevoidprintCustomerInWeb(ServletContextcontext,PrintWriterout,Customercustomer)throwsException{
  142. //保存照片
  143. byte[]buffer=customer.getImage();
  144. Stringpath=context.getRealPath("/");
  145. FileOutputStreamfout=newFileOutputStream(path+"photo_copy.gif");
  146. fout.write(buffer);
  147. fout.close();
  149. out.println("------以下是"+customer.getName()+"的个人信息------"+"<br>");
  150. out.println("ID:"+customer.getId()+"<br>");
  151. out.println("口令:"+customer.getPassword()+"<br>");
  152. out.println("E-Mail:"+customer.getEmail()+"<br>");
  153. out.println("电话:"+customer.getPhone()+"<br>");
  154. out.println("地址:"+customer.getAddress()+"<br>");
  155. Stringsex=customer.getSex()=='M'?"男":"女";
  156. out.println("性别:"+sex+"<br>");
  157. StringmarriedStatus=customer.isMarried()?"已婚":"未婚";
  158. out.println("婚姻状况:"+marriedStatus+"<br>");
  159. out.println("生日:"+customer.getBirthday()+"<br>");
  160. out.println("注册时间:"+customer.getRegisteredTime()+"<br>");
  161. out.println("自我介绍:"+customer.getDescription()+"<br>");
  162. out.println("<imgsrc='photo_copy.gif'border=0><p>");
  163. }
  164. publicvoidtest(ServletContextcontext,PrintWriterout)throwsException{
  166. Customercustomer=newCustomer();
  167. customer.setName("Tom");
  168. customer.setEmail("[email protected]");
  169. customer.setPassword("1234");
  170. customer.setPhone(55556666);
  171. customer.setAddress("Shanghai");
  172. customer.setSex('M');
  173. customer.setDescription("Iamveryhonest.");
  175. //设置Customer对象的image属性，它是字节数组，存放photo.gif文件中的二进制数据
  176. //photo.gif文件和BusinessService.class文件位于同一个目录下
  177. InputStreamin=this.getClass().getResourceAsStream("photo.gif");
  178. byte[]buffer=newbyte[in.available()];
  179. in.read(buffer);
  180. customer.setImage(buffer);
  181. //设置Customer对象的birthday属性，它是java.sql.Date类型
  182. customer.setBirthday(Date.valueOf("1980-05-06"));
  184. saveCustomer(customer);
  186. findAllCustomers(context,out);
  187. loadAndUpdateCustomer(customer.getId(),"Beijing");
  188. findAllCustomers(context,out);
  189. deleteCustomer(customer);
  190. }
  192. publicstaticvoidmain(Stringargs[])throwsException{
  193. newBusinessService().test(null,newPrintWriter(System.out,true));
  194. sessionFactory.close();
  195. }
  196. }

  • saveCustomer()方法
该方法调用Session的save()方法，把Customer对象持久化到数据库中。
[java] view plain copy print ?
  1. tx=session.beginTransaction();
  3. session.save(customer);
  5. tx.commit();

当运行session.save()方法时，Hibernate执行以下SQL语句：
[sql] view plain copy print ?
  1. insertintoCUSTOMERS(ID,NAME,EMAIL,PASSWORD,PHONE,ADDRESS,SEX,
  3. IS_MARRIED,DESCRIPTION,IMAGE,BIRTHDAY,REGISTERED_TIME)
  5. values(1,'Tom','[email protected]','1234',55556666,'Shanghai','M',0,'Iamveryhonest.',☺,'1980-05-06',null)

在test()方法中并没有设置Customer对象的id属性，Hibernate会根据映射文件的配置，采用increment标识符生成器自动以递增的方式为OID赋值。在Customer.hbm.xml文件中相关的映射代码如下：
[html] view plain copy print ?
  1. <idname="id"column="ID"type="long">
  3. <generatorclass="increment"/>
  5. </id>
  • findAllCustomers()方法
该方法通过Query接口查询所有的Customer对象。
[java] view plain copy print ?
  1. tx=session.beginTransaction();//开始一个事务
  3. Queryquery=session.createQuery("fromCustomerascorderbyc.nameasc");
  5. Listcustomers=query.list();
  7. for(Iteratorit=customers.iterator();it.hasNext();){
  9. printCustomer(context,out,(Customer)it.next());
  11. }
  13. tx.commit();//提交事务

Session的createQuery()方法的参数“from Customer as c order by c.name asc”使用的是Hibernate查询语言。运行Query.list()方法时， Hibernate执行以下SQL语句：
[sql] view plain copy print ?
  1. select*fromCUSTOMERSorderbyNAMEasc;
  • loadAndUpdateCustomer ()方法
该方法调用Session的get()方法，加载Customer对象，然后再修改Customer对象的属性。
[java] view plain copy print ?
  1. tx=session.beginTransaction();
  3. Customerc=(Customer)session.get(Customer.class,customer_id);
  5. c.setAddress(address);//修改内存中Customer对象的address属性
  7. tx.commit();
以上代码先调用Session的get()方法，它按照参数指定的OID从数据库中检索出匹配的Customer对象，Hibernate会执行以下SQL语句：
[sql] view plain copy print ?
  1. select*fromCUSTOMERSwhereID=1;

loadAndUpdateCustomer()方法接着修改Customer对象的address属性。那么，Hibernate会不会同步更新数据库中相应的CUSTOMERS表的记录呢？答案是肯定的。Hibernate采用脏检查机制，按照内存中的Customer对象的状态的变化，来同步更新数据库中相关的数据，Hibernate会执行以下SQL语句：
[sql] view plain copy print ?
  1. updateCUSTOMERSsetNAME="Tom",EMAIL="[email protected]"…ADDRESS="Beijing"…
  3. whereID=1;

尽管只有Customer对象的address属性发生了变化，但是Hibernate执行的update语句中会包含所有的字段。

  • deleteCustomer()方法
该方法调用Session的delete()方法，删除特定的Customer对象：
[java] view plain copy print ?
  1. tx=session.beginTransaction();
  3. session.delete(customer);
  5. tx.commit();

运行session.delete()方法时，Hibernate根据Customer对象的OID，执行以下SQL delete语句：
[sql] view plain copy print ?
  1. deletefromCUSTOMERSwhereID=1;

八、效果图







一、在Java应用中使用Hibernate的步骤

  • 创建Hibernate的配置文件
  • 创建持久化类
  • 创建对象-关系映射文件
  • 通过Hibernate API编写访问数据库的代码

二、Helloapp应用的结构

三、Hibernate的配置文件(hibernate.properties)

[plain] view plain copy print ?
  1. hibernate.dialect=org.hibernate.dialect.MySQLDialect
  2. hibernate.connection.driver_class=com.mysql.jdbc.Driver
  3. hibernate.connection.url=jdbc:mysql://localhost:3306/SAMPLEDB
  4. hibernate.connection.username=root
  5. hibernate.connection.password=1234
  6. hibernate.show_sql=true


四、创建持久化类Customer

  • 持久化类符合JavaBean的规范，包含一些属性，以及与之对应的getXXX()和setXXX()方法。
  • 持久化类有一个id属性，用来惟一标识Customer类的每个对象。在面向对象术语中，这个id属性被称为对象标识符（OID，Object Identifier），通常它都用整数表示
  • Hibernate要求持久化类必须提供一个不带参数的默认构造方法
[java] view plain copy print ?
  1. packagemypack;
  2. importjava.io.Serializable;
  3. importjava.sql.Date;
  4. importjava.sql.Timestamp;
  6. publicclassCustomerimplementsSerializable{
  7. privateLongid;
  8. privateStringname;
  9. privateStringemail;
  10. privateStringpassword;
  11. privateintphone;
  12. privateStringaddress;
  13. privatecharsex;
  14. privatebooleanmarried;
  15. privateStringdescription;
  16. privatebyte[]image;
  17. privateDatebirthday;
  18. privateTimestampregisteredTime;
  20. publicCustomer(){}
  22. publicLonggetId(){
  23. returnid;
  24. }
  26. privatevoidsetId(Longid){
  27. this.id=id;
  28. }
  30. publicStringgetName(){
  31. returnname;
  32. }
  34. publicvoidsetName(Stringname){
  35. this.name=name;
  36. }
  38. publicStringgetEmail(){
  39. returnemail;
  40. }
  42. publicvoidsetEmail(Stringemail){
  43. this.email=email;
  44. }
  46. publicStringgetPassword(){
  47. returnpassword;
  48. }
  50. publicvoidsetPassword(Stringpassword){
  51. this.password=password;
  52. }
  54. publicintgetPhone(){
  55. returnphone;
  56. }
  58. publicvoidsetPhone(intphone){
  59. this.phone=phone;
  60. }
  62. publicStringgetAddress(){
  63. returnaddress;
  64. }
  66. publicvoidsetAddress(Stringaddress){
  67. this.address=address;
  68. }
  69. publicchargetSex(){
  70. returnsex;
  71. }
  73. publicvoidsetSex(charsex){
  74. this.sex=sex;
  75. }
  77. publicbooleanisMarried(){
  78. returnmarried;
  79. }
  81. publicvoidsetMarried(booleanmarried){
  82. this.married=married;
  83. }
  85. publicStringgetDescription(){
  86. returndescription;
  87. }
  89. publicvoidsetDescription(Stringdescription){
  90. this.description=description;
  91. }
  93. publicbyte[]getImage(){
  94. returnthis.image;
  95. }
  97. publicvoidsetImage(byte[]image){
  98. this.image=image;
  99. }
  101. publicDategetBirthday(){
  102. returnthis.birthday;
  103. }
  105. publicvoidsetBirthday(Datebirthday){
  106. this.birthday=birthday;
  107. }
  109. publicTimestampgetRegisteredTime(){
  110. returnthis.registeredTime;
  111. }
  113. publicvoidsetRegisteredTime(TimestampregisteredTime){
  114. this.registeredTime=registeredTime;
  115. }
  117. }

注意：

  • getXXX()和setXXX()方法可以采用任意的访问级别，他的命名规则必须符合特定的命名规则，“get”和“set”后面紧跟属性的名字，并且属性名的首字母为大写，如name属性的get方法为getName()。
  • 如果持久化类的属性为boolean类型，那么它的get方法名可以用get做前缀也可以用is做前缀。

五、创建数据库Schema

[sql] view plain copy print ?
  1. dropdatabaseifexistsSAMPLEDB;
  2. createdatabaseSAMPLEDB;
  3. useSAMPLEDB;
  5. createtableCUSTOMERS(
  6. IDbigintnotnullprimarykey,
  7. NAMEvarchar(15)notnull,
  8. EMAILvarchar(128)notnull,
  9. PASSWORDvarchar(8)notnull,
  10. PHONEint,
  11. ADDRESSvarchar(255),
  12. SEXchar(1),
  13. IS_MARRIEDbit,
  14. DESCRIPTIONtext,
  15. IMAGEblob,
  16. BIRTHDAYdate,
  17. REGISTERED_TIMEtimestamp
  18. );


六、创建对象-关系映射文件Customer.hbm.xml
[html] view plain copy print ?
  1. <?xmlversion="1.0"?>
  2. <!DOCTYPEhibernate-mappingPUBLIC"-//Hibernate/HibernateMappingDTD3.0//EN""http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
  4. <hibernate-mapping>
  5. <classname="mypack.Customer"table="CUSTOMERS">
  6. <idname="id"column="ID"type="long">
  7. <generatorclass="increment"/>
  8. </id>
  9. <propertyname="name"column="NAME"type="string"not-null="true"/>
  10. <propertyname="email"column="EMAIL"type="string"not-null="true"/>
  11. <propertyname="password"column="PASSWORD"type="string"not-null="true"/>
  12. <propertyname="phone"column="PHONE"type="int"/>
  13. <propertyname="address"column="ADDRESS"type="string"/>
  14. <propertyname="sex"column="SEX"type="character"/>
  15. <propertyname="married"column="IS_MARRIED"type="boolean"/>
  16. <propertyname="description"column="DESCRIPTION"type="text"/>
  17. <propertyname="image"column="IMAGE"type="binary"/>
  18. <propertyname="birthday"column="BIRTHDAY"type="date"/>
  19. <propertyname="registeredTime"column="REGISTERED_TIME"type="timestamp"/>
  20. </class>
  21. </hibernate-mapping>

  • <id>元素映射OID

<generator>子元素用来设定标识符生成器。Hibernate提供了提供了多种内置的实现。

  • <property>元素映射值类型属性
name属性：指定持久化类的属性的名字。
column属性：指定与类的属性映射的表的字段名。
type属性：指定Hibernate映射类型。Hibernate映射类型是Java类型与SQL类型的桥梁。

采用XML文件来配置对象-关系映射的优点：
  • Hibernate既不会渗透到上层域模型中，也不会渗透到下层数据模型中。
  • 软件开发人员可以独立设计域模型，不必强迫遵守任何规范。
  • 数据库设计人员可以独立设计数据模型，不必强迫遵守任何规范。
  • 对象-关系映射不依赖于任何程序代码，如果需要修改对象-关系映射，只需修改XML文件，不需要修改任何程序，提高了软件的灵活性，并且使维护更加方便。

七、创建BusinessService类

[java] view plain copy print ?
  1. packagemypack;
  3. importjavax.servlet.*;
  4. importorg.hibernate.*;
  5. importorg.hibernate.cfg.Configuration;
  6. importjava.io.*;
  7. importjava.sql.Date;
  8. importjava.sql.Timestamp;
  9. importjava.util.*;
  11. publicclassBusinessService{
  12. publicstaticSessionFactorysessionFactory;
  14. /**初始化Hibernate，创建SessionFactory实例*/
  15. static{
  16. try{
  17. //根据默认位置的Hibernate配置文件的配置信息，创建一个Configuration实例
  18. Configurationconfig=newConfiguration();
  19. //加载Customer类的对象-关系映射文件
  20. config.addClass(Customer.class);
  21. //创建SessionFactory实例*/
  22. sessionFactory=config.buildSessionFactory();
  23. }catch(RuntimeExceptione){e.printStackTrace();throwe;}
  24. }
  26. /**查询所有的Customer对象，然后调用printCustomer()方法打印Customer对象信息*/
  27. publicvoidfindAllCustomers(ServletContextcontext,PrintWriterout)throwsException{
  28. Sessionsession=sessionFactory.openSession();//创建一个会话
  29. Transactiontx=null;
  30. try{
  31. tx=session.beginTransaction();//开始一个事务
  32. Queryquery=session.createQuery("fromCustomerascorderbyc.nameasc");
  33. Listcustomers=query.list();
  34. for(Iteratorit=customers.iterator();it.hasNext();){
  35. printCustomer(context,out,(Customer)it.next());
  36. }
  38. tx.commit();//提交事务
  40. }catch(RuntimeExceptione){
  41. if(tx!=null){
  42. tx.rollback();
  43. }
  44. throwe;
  45. }finally{
  46. session.close();
  47. }
  48. }
  50. /**持久化一个Customer对象*/
  51. publicvoidsaveCustomer(Customercustomer){
  52. Sessionsession=sessionFactory.openSession();
  53. Transactiontx=null;
  54. try{
  55. tx=session.beginTransaction();
  56. session.save(customer);
  57. tx.commit();
  59. }catch(RuntimeExceptione){
  60. if(tx!=null){
  61. tx.rollback();
  62. }
  63. throwe;
  64. }finally{
  65. session.close();
  66. }
  67. }
  69. /**按照OID加载一个Customer对象，然后修改它的属性*/
  70. publicvoidloadAndUpdateCustomer(Longcustomer_id,Stringaddress){
  71. Sessionsession=sessionFactory.openSession();
  72. Transactiontx=null;
  73. try{
  74. tx=session.beginTransaction();
  76. Customerc=(Customer)session.get(Customer.class,customer_id);
  77. c.setAddress(address);
  78. tx.commit();
  80. }catch(RuntimeExceptione){
  81. if(tx!=null){
  82. tx.rollback();
  83. }
  84. throwe;
  85. }finally{
  86. session.close();
  87. }
  88. }
  90. /**删除Customer对象*/
  91. publicvoiddeleteCustomer(Customercustomer){
  92. Sessionsession=sessionFactory.openSession();
  93. Transactiontx=null;
  94. try{
  95. tx=session.beginTransaction();
  96. session.delete(customer);
  97. tx.commit();
  99. }catch(RuntimeExceptione){
  100. if(tx!=null){
  101. tx.rollback();
  102. }
  103. throwe;
  104. }finally{
  105. session.close();
  106. }
  107. }
  109. /**选择向控制台还是Web网页输出Customer对象的信息*/
  110. privatevoidprintCustomer(ServletContextcontext,PrintWriterout,Customercustomer)throwsException{
  111. if(context!=null)
  112. printCustomerInWeb(context,out,customer);
  113. else
  114. printCustomer(out,customer);
  115. }
  117. /**把Customer对象的信息输出到控制台，如DOS控制台*/
  118. privatevoidprintCustomer(PrintWriterout,Customercustomer)throwsException{
  119. byte[]buffer=customer.getImage();
  120. FileOutputStreamfout=newFileOutputStream("photo_copy.gif");
  121. fout.write(buffer);
  122. fout.close();
  124. out.println("------以下是"+customer.getName()+"的个人信息------");
  125. out.println("ID:"+customer.getId());
  126. out.println("口令:"+customer.getPassword());
  127. out.println("E-Mail:"+customer.getEmail());
  128. out.println("电话:"+customer.getPhone());
  129. out.println("地址:"+customer.getAddress());
  130. Stringsex=customer.getSex()=='M'?"男":"女";
  131. out.println("性别:"+sex);
  132. StringmarriedStatus=customer.isMarried()?"已婚":"未婚";
  133. out.println("婚姻状况:"+marriedStatus);
  134. out.println("生日:"+customer.getBirthday());
  135. out.println("注册时间:"+customer.getRegisteredTime());
  136. out.println("自我介绍:"+customer.getDescription());
  138. }
  140. /**把Customer对象的信息输出到动态网页*/
  141. privatevoidprintCustomerInWeb(ServletContextcontext,PrintWriterout,Customercustomer)throwsException{
  142. //保存照片
  143. byte[]buffer=customer.getImage();
  144. Stringpath=context.getRealPath("/");
  145. FileOutputStreamfout=newFileOutputStream(path+"photo_copy.gif");
  146. fout.write(buffer);
  147. fout.close();
  149. out.println("------以下是"+customer.getName()+"的个人信息------"+"<br>");
  150. out.println("ID:"+customer.getId()+"<br>");
  151. out.println("口令:"+customer.getPassword()+"<br>");
  152. out.println("E-Mail:"+customer.getEmail()+"<br>");
  153. out.println("电话:"+customer.getPhone()+"<br>");
  154. out.println("地址:"+customer.getAddress()+"<br>");
  155. Stringsex=customer.getSex()=='M'?"男":"女";
  156. out.println("性别:"+sex+"<br>");
  157. StringmarriedStatus=customer.isMarried()?"已婚":"未婚";
  158. out.println("婚姻状况:"+marriedStatus+"<br>");
  159. out.println("生日:"+customer.getBirthday()+"<br>");
  160. out.println("注册时间:"+customer.getRegisteredTime()+"<br>");
  161. out.println("自我介绍:"+customer.getDescription()+"<br>");
  162. out.println("<imgsrc='photo_copy.gif'border=0><p>");
  163. }
  164. publicvoidtest(ServletContextcontext,PrintWriterout)throwsException{
  166. Customercustomer=newCustomer();
  167. customer.setName("Tom");
  168. customer.setEmail("[email protected]");
  169. customer.setPassword("1234");
  170. customer.setPhone(55556666);
  171. customer.setAddress("Shanghai");
  172. customer.setSex('M');
  173. customer.setDescription("Iamveryhonest.");
  175. //设置Customer对象的image属性，它是字节数组，存放photo.gif文件中的二进制数据
  176. //photo.gif文件和BusinessService.class文件位于同一个目录下
  177. InputStreamin=this.getClass().getResourceAsStream("photo.gif");
  178. byte[]buffer=newbyte[in.available()];
  179. in.read(buffer);
  180. customer.setImage(buffer);
  181. //设置Customer对象的birthday属性，它是java.sql.Date类型
  182. customer.setBirthday(Date.valueOf("1980-05-06"));
  184. saveCustomer(customer);
  186. findAllCustomers(context,out);
  187. loadAndUpdateCustomer(customer.getId(),"Beijing");
  188. findAllCustomers(context,out);
  189. deleteCustomer(customer);
  190. }
  192. publicstaticvoidmain(Stringargs[])throwsException{
  193. newBusinessService().test(null,newPrintWriter(System.out,true));
  194. sessionFactory.close();
  195. }
  196. }

  • saveCustomer()方法
该方法调用Session的save()方法，把Customer对象持久化到数据库中。
[java] view plain copy print ?
  1. tx=session.beginTransaction();
  3. session.save(customer);
  5. tx.commit();

当运行session.save()方法时，Hibernate执行以下SQL语句：
[sql] view plain copy print ?
  1. insertintoCUSTOMERS(ID,NAME,EMAIL,PASSWORD,PHONE,ADDRESS,SEX,
  3. IS_MARRIED,DESCRIPTION,IMAGE,BIRTHDAY,REGISTERED_TIME)
  5. values(1,'Tom','[email protected]','1234',55556666,'Shanghai','M',0,'Iamveryhonest.',☺,'1980-05-06',null)

在test()方法中并没有设置Customer对象的id属性，Hibernate会根据映射文件的配置，采用increment标识符生成器自动以递增的方式为OID赋值。在Customer.hbm.xml文件中相关的映射代码如下：
[html] view plain copy print ?
  1. <idname="id"column="ID"type="long">
  3. <generatorclass="increment"/>
  5. </id>
  • findAllCustomers()方法
该方法通过Query接口查询所有的Customer对象。
[java] view plain copy print ?
  1. tx=session.beginTransaction();//开始一个事务
  3. Queryquery=session.createQuery("fromCustomerascorderbyc.nameasc");
  5. Listcustomers=query.list();
  7. for(Iteratorit=customers.iterator();it.hasNext();){
  9. printCustomer(context,out,(Customer)it.next());
  11. }
  13. tx.commit();//提交事务

Session的createQuery()方法的参数“from Customer as c order by c.name asc”使用的是Hibernate查询语言。运行Query.list()方法时， Hibernate执行以下SQL语句：
[sql] view plain copy print ?
  1. select*fromCUSTOMERSorderbyNAMEasc;
  • loadAndUpdateCustomer ()方法
该方法调用Session的get()方法，加载Customer对象，然后再修改Customer对象的属性。
[java] view plain copy print ?
  1. tx=session.beginTransaction();
  3. Customerc=(Customer)session.get(Customer.class,customer_id);
  5. c.setAddress(address);//修改内存中Customer对象的address属性
  7. tx.commit();
以上代码先调用Session的get()方法，它按照参数指定的OID从数据库中检索出匹配的Customer对象，Hibernate会执行以下SQL语句：
[sql] view plain copy print ?
  1. select*fromCUSTOMERSwhereID=1;

loadAndUpdateCustomer()方法接着修改Customer对象的address属性。那么，Hibernate会不会同步更新数据库中相应的CUSTOMERS表的记录呢？答案是肯定的。Hibernate采用脏检查机制，按照内存中的Customer对象的状态的变化，来同步更新数据库中相关的数据，Hibernate会执行以下SQL语句：
[sql] view plain copy print ?
  1. updateCUSTOMERSsetNAME="Tom",EMAIL="[email protected]"…ADDRESS="Beijing"…
  3. whereID=1;

尽管只有Customer对象的address属性发生了变化，但是Hibernate执行的update语句中会包含所有的字段。

  • deleteCustomer()方法
该方法调用Session的delete()方法，删除特定的Customer对象：
[java] view plain copy print ?
  1. tx=session.beginTransaction();
  3. session.delete(customer);
  5. tx.commit();

运行session.delete()方法时，Hibernate根据Customer对象的OID，执行以下SQL delete语句：
[sql] view plain copy print ?
  1. deletefromCUSTOMERSwhereID=1;

八、效果图

联系我们 沪ICP备13005482号-10