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 < ms.size(); i++) {

medicine = (Medicine) ms.get(i); // 获取药品

session.save(medicine); // 保存药品对象

// 批插入的对象立即写入数据库并释放内存

if (i % 10 == 0) {

session.flush();

session.clear();

}

}

session.getTransaction().commit(); // 提交事物

} catch (Exception e) {

e.printStackTrace(); // 打印错误信息

session.getTransaction().rollback(); // 出错将回滚事物

} finally {

HibernateUtil.closeSession(session); // 关闭Session

}

}

}

}

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源代码：

"-//Hibernate/Hibernate Mapping DTD 3.0//EN"

"http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">

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");

// 价格

StrxnSWRLbPFTing 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 < names.length; i++) {

m = new Medicine(); // 实例化药品

// 对属性赋值

m.setName(names[i]);

m.setPrice(Double.parseDouble(prices[i]));

m.setFactoryAdd(adds[i]);

ms.add(m); // 添加到集合中

}

// 实例化MedicineDao对象

MedicineDao dao = new MedicineDao();

dao.saveMedicines(ms); // 批量保存药品

request.setAttribute("info", "药品信息保存成功！！！");

}

}

// 转发到result.jsp页面

request.getRequestDispatcher("result.jsp").forward(request, response);

}

}

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源代码：

"-//Hibernate/Hibernate Configuration DTD 3.0//EN"

"http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">

org.hibernate.dialect.mysqlDialect

jdbc:mysql://localhost:3306/learn

root

1120

com.mysql.jdbc.Driver

true

update

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"%>

onsubmit="return save(this);">

width="600">

批量添加药品信息

名称：

单价：

厂址：

12.result.jsp源代码：

<%@ page language="java" contentType="text/html" pageEncoding="GBK"%>

${info}

返回

13.数据表tb_medicine_batch结构：

14.程序运行结果截图：

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

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。