Hibernate实现批量添加数据的方法

这篇文章主要介绍了Hibernate实现批量添加数据的方法,详细分析了基于Hibernate执行批量添加操作的具体步骤与相关实现代码,需要的朋友可以参考下

本文实例讲述了Hibernate实现批量添加数据的方法。分享给大家供大家参考,具体如下:

1.Hibernate_016_BatchAddData程序目录结构:

2.lib目录下所引入的jar包:

3.MedicineDao.java源代码:

 package com.xqh.dao; import java.util.List; import org.hibernate.Session; import com.xqh.model.Medicine; import com.xqh.util.HibernateUtil; /** * 药品数据库操作类 * */ public class MedicineDao { /** * 批量保存药品 * * @param ms *      List集合 */ public void saveMedicines(List ms) { Session session = null; if (ms != null && ms.size() > 0) { try { session = HibernateUtil.getSession(); // 获取Session session.beginTransaction(); // 开启事物 Medicine medicine = null; // 创建药品对象 // 循环获取药品对象 for (int i = 0; i 

4.Medicine.java源代码:

 package com.xqh.model; /** * 药品持久化类 */ public class Medicine { private Integer id;       //id号 private String name;      //药品名称 private double price;      //价格 private String factoryAdd;   //出厂地址 public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public double getPrice() { return price; } public void setPrice(double price) { this.price = price; } public String getFactoryAdd() { return factoryAdd; } public void setFactoryAdd(String factoryAdd) { this.factoryAdd = factoryAdd; } } 

5.Medicine.hbm.xml源代码:

     

6.SaveMedicine.java源代码:

 package com.xqh.servlet; import java.io.IOException; import java.util.ArrayList; import java.util.List; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import com.xqh.dao.MedicineDao; import com.xqh.model.Medicine; public class SaveMedicine extends HttpServlet { private static final long serialVersionUID = 3743334039515411666L; public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { // 药品名称 String names[] = request.getParameterValues("name"); // 价格 String prices[] = request.getParameterValues("price"); // 出厂地址 String adds[] = request.getParameterValues("factoryAdd"); // 有效性判断 if(names != null && prices != null && adds != null){ if(names.length == prices.length && names.length == adds.length){ // 实例化一个List集合 List ms = new ArrayList(); Medicine m = null; // 药品对象 // 依次实例化药品对象并添加到集合中 for (int i = 0; i 

7.CharacterEncodingFilter.java源代码:

 /* * To change this template, choose Tools | Templates * and open the template in the editor. */ package com.xqh.util; import java.io.IOException; import javax.servlet.Filter; import javax.servlet.FilterChain; import javax.servlet.FilterConfig; import javax.servlet.ServletException; import javax.servlet.ServletRequest; import javax.servlet.ServletResponse; /** * 字符编码过滤器 */ public class CharacterEncodingFilter implements Filter{ protected String encoding = null; protected FilterConfig filterConfig = null; public void init(FilterConfig filterConfig) throws ServletException { this.filterConfig = filterConfig; this.encoding = filterConfig.getInitParameter("encoding"); } public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException { if (encoding != null) { request.setCharacterEncoding(encoding); response.setContentType("text/html; charset="+encoding); } chain.doFilter(request, response); } public void destroy() { this.encoding = null; this.filterConfig = null; } } 

8.HibernateUtil.java源代码:

 package com.xqh.util; import org.hibernate.HibernateException; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.cfg.Configuration; /** * Hibernate初始化类,用于获取Session、SessionFactory 及关闭Session */ public class HibernateUtil { // SessionFactory对象 private static SessionFactory factory = null; // 静态块 static { try { // 加载Hibernate配置文件 Configuration cfg = new Configuration().configure(); // 实例化SessionFactory factory = cfg.buildSessionFactory(); } catch (HibernateException e) { e.printStackTrace(); } } /** * 获取Session对象 * @return Session对象 */ public static Session getSession() { //如果SessionFacroty不为空,则开启Session Session session = (factory != null) ? factory.openSession() : null; return session; } /** * 获取SessionFactory对象 * @return SessionFactory对象 */ public static SessionFactory getSessionFactory() { return factory; } /** * 关闭Session * @param session对象 */ public static void closeSession(Session session) { if (session != null) { if (session.isOpen()) { session.close(); // 关闭Session } } } } 

9.hibernate.cfg.xml源代码:

    org.hibernate.dialect.MySQLDialectjdbc:mysql://localhost:3306/learnroot1120com.mysql.jdbc.Drivertrueupdate

10.log4j.properties源代码:

 ### direct log messages to stdout ### log4j.appender.stdout=org.apache.log4j.ConsoleAppender log4j.appender.stdout.Target=System.out log4j.appender.stdout.layout=org.apache.log4j.PatternLayout log4j.appender.stdout.layout.ConversionPattern=%d{ABSOLUTE} %5p %c{1}:%L - %m%n ### direct messages to file hibernate.log ### #log4j.appender.file=org.apache.log4j.FileAppender #log4j.appender.file.File=hibernate.log #log4j.appender.file.layout=org.apache.log4j.PatternLayout #log4j.appender.file.layout.ConversionPattern=%d{ABSOLUTE} %5p %c{1}:%L - %m%n ### set log levels - for more verbose logging change 'info' to 'debug' ### log4j.rootLogger=warn, stdout #log4j.logger.org.hibernate=info #log4j.logger.org.hibernate=debug ### log HQL query parser activity #log4j.logger.org.hibernate.hql.ast.AST=debug ### log just the SQL #log4j.logger.org.hibernate.SQL=debug ### log JDBC bind parameters ### #log4j.logger.org.hibernate.type=info #log4j.logger.org.hibernate.type=debug ### log schema export/update ### #log4j.logger.org.hibernate.tool.hbm2ddl=debug ### log HQL parse trees #log4j.logger.org.hibernate.hql=debug ### log cache activity ### #log4j.logger.org.hibernate.cache=debug ### log transaction activity #log4j.logger.org.hibernate.transaction=debug ### log JDBC resource acquisition #log4j.logger.org.hibernate.jdbc=debug ### enable the following line if you want to track down connection ### ### leakages when using DriverManagerConnectionProvider ### #log4j.logger.org.hibernate.connection.DriverManagerConnectionProvider=trace 

11.index.jsp源代码:

 <%@ page language="java" contentType="text/html" pageEncoding="GBK"%>  批量添加药品信息 

批量添加药品信息

12.result.jsp源代码:

 <%@ page language="java" contentType="text/html" pageEncoding="GBK"%>  结果信息 
${info}



返回

13.数据表tb_medicine_batch结构:

14.程序运行结果截图:

希望本文所述对大家基于Hibernate框架的Java程序设计有所帮助。

以上就是Hibernate实现批量添加数据的方法的详细内容,更多请关注0133技术站其它相关文章!

赞(0) 打赏
未经允许不得转载:0133技术站首页 » Java