The hibernate.cfg.xml and hibernate.reveng.xml are in default package under the Source Package.
The Employee.hbm.xml, Employee.java & ManageEmployee.java are in the firstproject package under Source Package.
The Employee.hbm.xml code is as follows:<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN" "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
<hibernate-mapping>
<class name="Employee" table="employee">
<meta attribute="class-description"> This class contains the employee detail. </meta>
<id name="id" type="int" column="id">
<generator class="native"/>
</id>
<property name="firstName" column="first_name" type="string"/>
<property name="lastName" column="last_name" type="string"/>
<property name="salary" column="salary" type="int"/>
</class>
</hibernate-mapping>
The Employee.java code is as follows:package firstproject;
public class Employee
{
private int id;
private String firstName;
private String lastName;
private int salary;
public Employee() {}
public Employee(String fname, String lname, int salary)
{
this.firstName = fname;
this.lastName = lname;
this.salary = salary;
}
public int getId()
{
return id;
}
public void setId( int id )
{
this.id = id;
}
public String getFirstName()
{
return firstName;
}
public void setFirstName( String first_name )
{
this.firstName = first_name;
}
public String getLastName()
{
return lastName;
}
public void setLastName( String last_name )
{
this.lastName = last_name;
}
public int getSalary()
{
return salary;
}
public void setSalary( int salary )
{
this.salary = salary;
}
}
The ManageEmployee code is as follows:package firstproject;
import java.util.List;
import java.util.Date;
import java.util.Iterator;
import org.hibernate.HibernateException;
import org.hibernate.Session;
import org.hibernate.Transaction;
import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;
public class ManageEmployee
{
public static SessionFactory factory;
public static void main(String[] args)
{
try{
factory = new Configuration().configure().buildSessionFactory();
}catch (Throwable ex)
{
System.err.println("Failed to create sessionFactory object." + ex);
throw new ExceptionInInitializerError(ex);
}
ManageEmployee ME = new ManageEmployee();
/* Add few employee records in database */
Integer empID1 = ME.addEmployee("Zara", "Ali", 1000);
Integer empID2 = ME.addEmployee("Daisy", "Das", 5000);
Integer empID3 = ME.addEmployee("John", "Paul", 10000);
/* List down all the employees */
ME.listEmployees();
/* Update employee's records */
ME.updateEmployee(empID1, 5000);
ME.deleteEmployee(empID2);
/* List down new list of the employees */
ME.listEmployees();
}
/* Method to CREATE an employee in the database */
public Integer addEmployee(String fname, String lname, int salary)
{
Session session = factory.openSession();
Transaction tx = null;
Integer employeeID = null;
try{
tx = session.beginTransaction();
Employee employee = new Employee(fname, lname, salary);
employeeID = (Integer) session.save(employee);
tx.commit();
}catch (HibernateException e)
{
if (tx!=null) tx.rollback();
e.printStackTrace();
}finally
{
session.close();
}
return employeeID;
}
/* Method to READ all the employees */
public void listEmployees( )
{
Session session = factory.openSession();
Transaction tx = null;
try{
tx = session.beginTransaction();
List employ = session.createQuery("FROM Employee").list();
for (Iterator iterator =
employ.iterator(); iterator.hasNext();){
Employee employee = (Employee) iterator.next();
System.out.print("First Name: " + employee.getFirstName());
System.out.print(" Last Name: " + employee.getLastName());
System.out.println(" Salary: " + employee.getSalary());
}
tx.commit();
}catch (HibernateException e) {
if (tx!=null) tx.rollback();
e.printStackTrace();
}finally {
session.close();
}
}
/* Method to UPDATE salary for an employee */
public void updateEmployee(Integer EmployeeID,int salary )
{
Session session = factory.openSession();
Transaction tx = null;
try
{
tx = session.beginTransaction();
Employee employee =(Employee)session.get(Employee.class, EmployeeID);
employee.setSalary( salary );
session.update(employee);
tx.commit();
}catch (HibernateException e)
{
if (tx!=null) tx.rollback();
e.printStackTrace();
}finally
{
session.close();
}
}
/* Method to DELETE an employee from the records */
public void deleteEmployee(Integer EmployeeID){
Session session = factory.openSession();
Transaction tx = null;
try{
tx = session.beginTransaction();
Employee employee =(Employee)session.get(Employee.class, EmployeeID);
session.delete(employee);
tx.commit();
}catch (HibernateException e) {
if (tx!=null) tx.rollback();
e.printStackTrace();
}finally {
session.close();
}
}
}
Login
FAQ
Search
