This article describes the method of Hibernate to add data in batches. Share it for your reference, as follows:
1. Hibernate_016_BatchAddData program directory structure:
2. The jar package introduced in the lib directory:
3. MedicineDao.java source code:
package com.xqh.dao;import java.util.List;import org.hibernate.Session;import com.xqh.model.Medicine;import com.xqh.util.HibernateUtil;/** * Drug database operation class* */public class MedicineDao { /** * Batch saving of drugs* * @param ms * List collection*/ public void saveMedicines(List<Medicine> ms) { Session session = null; if (ms != null && ms.size() > 0) { try { session = HibernateUtil.getSession(); // Get Session session.beginTransaction(); // Turn on things Medicine medicine = null; // Create a drug object// Loop the drug object for (int i = 0; i < ms.size(); i++) { medicine = (Medicine) ms.get(i); // Get the drug session.save(medicine); // Save the drug object// The batch of inserted objects is immediately written to the database and free memory if (i % 10 == 0) { session.flush(); session.clear(); } } session.getTransaction().commit(); // Submit things} catch (Exception e) { e.printStackTrace(); // Print error message session.getTransaction().rollback(); // An error will roll back the thing} finally { HibernateUtil.closeSession(session); // Close Session } } }}4. Medicine.java source code:
package com.xqh.model;/** * Drug persistence class*/public class Medicine { private Integer id; //id number private String name; //drug name private double price; //price private String factoryAdd; //factory address 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 source code:
<?xml version="1.0"?><!DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN" "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd"><hibernate-mapping> <class name="com.xqh.model.Medicine" table="tb_medicine_batch"> <id name="id"> <generator/> </id> <property name="name" not-null="true" length="200" /> <property name="price" not-null="true"/> <property name="factoryAdd" length="200"/> </class></hibernate-mapping>
6.SaveMedicine.java source code:
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 { // Drug name String names[] = request.getParameterValues("name"); // Price String prices[] = request.getParameterValues("price"); // Factory address String adds[] = request.getParameterValues("factoryAdd"); // Validity judgment if(names != null && prices != null && adds != null){ if(names.length == prices.length && names.length == adds.length){ // Instantiate a List collection List<Medicine> ms = new ArrayList<Medicine>(); Medicine m = null; // Drug object// Instantiate the drug object in turn and add it to the collection for (int i = 0; i < names.length; i++) { m = new Medicine(); // Instantiate the drug // Assign the attribute m.setName(names[i]); m.setPrice(Double.parseDouble(prices[i])); m.setFactoryAdd(adds[i]); m.add(m); // Add to the set} // Instantiate the MedicineDao object MedicineDao dao = new MedicineDao(); dao.saveMedicines(ms); // Batch save the drug request.setAttribute("info", "Drug information is saved successfully!!!"); } } // Forward(request, response); }}7. CharacterEncodingFilter.java source code:
/* * 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;/** * Character encoding filter*/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 source code:
package com.xqh.util;import org.hibernate.HibernateException;import org.hibernate.Session;import org.hibernate.SessionFactory;import org.hibernate.cfg.Configuration;/** * Hibernate initialization class, used to obtain Session, SessionFactory and close Session */public class HibernateUtil { // SessionFactory object private static SessionFactory factory = null; // Static block static { try { // Load Hibernate configuration file Configuration cfg = new Configuration().configure(); // Instantiate SessionFactory factory = cfg.buildSessionFactory(); } catch (HibernateException e) { e.printStackTrace(); } } /** * Get Session object* @return Session object*/ public static Session getSession() { // If SessionFacroty is not empty, enable Session Session session = (factory != null) ? factory.openSession() : null; return session; } /** * Get SessionFactory object* @return SessionFactory object*/ public static SessionFactory getSessionFactory() { return factory; } /** * Close Session * @param session object*/ public static void closeSession(Session session) { if (session != null) { if (session.isOpen()) { session.close(); // Close Session } } }}9.hibernate.cfg.xml source code:
<?xml version='1.0' encoding='UTF-8'?><!DOCTYPE hibernate-configuration PUBLIC "-//Hibernate/Hibernate Configuration DTD 3.0//EN" "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd"><hibernate-configuration> <session-factory> <!-- Dialect--> <property name="dialect">org.hibernate.dialect.MySQLDialect</property> <!-- Database Connection--> <property name="connection.url">jdbc:mysql://localhost:3306/learn</property> <!-- Database connection username--> <property name="connection.username">root</property> <!-- Database connection password--> <property name="connection.password">1120</property> <!-- Database driver--> <property name="connection.driver_class">com.mysql.jdbc.Driver</property> <!-- Print SQL statement--> <property name="show_sql">true</property> <!-- Automatic table creation--> <property name="hibernate.hbm2ddl.auto">update</property> <!-- Mapping file--> <mapping resource="com/xqh/model/Medicine.hbm.xml"/> </session-factory></hibernate-configuration>
10.log4j.properties source code:
### direct log messages to stdout ###log4j.appender.stdout=org.apache.log4j.ConsoleAppenderlog4j.appender.stdout.Target=System.outlog4j.appender.stdout.layout=org.apache.log4j.PatternLayoutlog4j.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=trace11.index.jsp source code:
<%@ page language="java" contentType="text/html" pageEncoding="GBK"%><!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"><html> <head> <title>Batch Add Drug Information</title> <style type="text/css">td { background: #EBEBEB; font-family: Verdana; font-size: 12px; background-color: #EBEBEB; color: black; line-height: 20px; height: 30px;}</style> <script type="text/javascript"> function add(){ var a = document.getElementById("a"); var b = document.getElementById("b"); b.innerHTML += a.innerHTML; } function reduce() { var a = document.getElementById("a"); var b = document.getElementById("b"); var stra = a.innerHTML; var strb = b.innerHTML; b.innerHTML = strb.substring(0, strb.length - stra.length); } function save(formName){ for(i=0;i<formName.length;i++){ if(formName.elements[i].value==""){ alert("Please fill in the full information!"); return false; } } } </script> </head> <body onload="add()"> <form action="SaveMedicine" method="post" onsubmit="return save(this);"> <table align="center" cellpadding="3" cellpacing="1" > <tr> <td align="center"> <br> <h1> Batch Add Drug Information</h1> </td> </tr> <tr> <td> <div id="b"></div> </td> </td> </tr> <tr> <td> <input type="button" value="Add a line" onclick="add()"> <input type="button" value="Reduce()"> <input type="submit" value="Batch Add to Database"> </td> </tr> </table> </form> <div id="a" style="display: none"> <table align="center"> <tr> <td> Name: </td> <td> <input type="text" name="name" size="13"> </td> <td> Unit price: </td> <td> <input type="text" name="price" size="13"> </td> <td> Factory address: </td> <td> <input type="text" name="factoryAdd" size="30"> </td> </tr> </table> </div> </body></html>12.result.jsp source code:
<%@ page language="java" contentType="text/html" pageEncoding="GBK"%><!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"><html> <head> <title>Result Information</title> <!-- <link rel="stylesheet" type="text/css" href="styles.css"> --> </head> <body> <div align="center"> <font color="red" size="12px;" style="font-weight: bold;"> ${info} </font> <br><br><br><br><br> <a href="index.jsp">Return</a> </div> </body></html>13. Data table tb_medicine_batch structure:
14. Screenshot of program operation results:
I hope that the description in this article will be helpful to everyone's Java programming based on the Hibernate framework.