Employee.java
package hibernatepack.samples;
public class Employee {
private int empid;
private String empname;
private double salary;
public int getEmpid() {
return empid;
}
public void setEmpid(int empid) {
this.empid = empid;
}
public String getEmpname() {
return empname;
}
public void setEmpname(String empname) {
this.empname = empname;
}
public double getSalary() {
return salary;
}
public void setSalary(double salary) {
this.salary = salary;
}
}
Employee.hbm.xml <?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="hibernatepack.samples.Employee" table="HBEmployeeDetails" >
<id name= "empid" column="EmpNo" />
<property name= "empname" column = "EmpName" />
<property name="salary" column="Salary" />
</class>
</hibernate-mapping>
oracleconfig.cfg.xml <?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>
<property name="hibernate.dialect">org.hibernate.dialect.OracleDialect</property>
<property name="hibernate.connection.driver_class">oracle.jdbc.OracleDriver</property>
<property name="hibernate.connection.url">jdbc:oracle:thin:@10.154.117.76:1521:oracle</property>
<property name="hibernate.connection.username">user</property>
<property name="hibernate.connection.password">password</property>
<property name="hibernate.hbm2ddl.auto">create</property>
<property name="hibernate.show_sql">true</property>
<mapping resource="Employee.hbm.xml" />
</session-factory>
</hibernate-configuration>
derbiconfig.cfg.xml
<?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>
<property name="hibernate.dialect">org.hibernate.dialect.DerbyDialect</property>
<property name="hibernate.connection.driver_class">org.apache.derby.jdbc.ClientDriver</property>
<property name="hibernate.connection.url">jdbc:derby://localhost:1527/HibernateDB</property>
<property name="hibernate.connection.username">user</property>
<property name="hibernate.connection.password">pwd</property>
<property name="hibernate.show_sql">true</property>
<property name="hibernate.hbm2ddl.auto">create</property>
<mapping resource="Employee.hbm.xml"/>
</session-factory>
</hibernate-configuration>
IEmployeeDAO.java
package hibernatepack.samples;
import java.util.List;
public interface IEmployeeDAO {
public void findAllEmployees();
public void insertEmployee(Employee e);
}
EmloyeeDaoImpl.java
public class EmployeeDaoImpl implements IEmployeeDAO {
SessionFactory sessionFactory1 = new Configuration().configure("oracleconfig.cfg.xml").buildSessionFactory();
SessionFactory sessionFactory2 = new Configuration().configure("derbyconfig.cfg.xml").buildSessionFactory();
Session session = null;
Transaction transaction = null;
public void findAllEmployees() {
ArrayList empList = new ArrayList();
try {
session = sessionFactory1.openSession();
transaction = session.beginTransaction();
transaction.begin();
Criteria crit = session.createCriteria(Employee.class);
empList = (ArrayList) crit.list();
System.out.println("Records from Oracle Database");
for (Employee emp : empList) {
System.out.println(emp.getEmpid() + " " + emp.getEmpname() + " " + emp.getSalary());
}
session.close();
session = sessionFactory2.openSession();
Criteria crit1 = session.createCriteria(Employee.class);
empList = (ArrayList) crit1.list();
System.out.println("Records from Derby Database");
for (Employee emp : empList) {
System.out.println(emp.getEmpid() + " " + emp.getEmpname() + " " + emp.getSalary());
}
session.close();
} catch (Exception he) {
he.printStackTrace();
}
}
public void insertEmployee(Employee e) {
try {
session = sessionFactory1.openSession();
transaction = session.beginTransaction();
transaction.begin();
session.save(e);
transaction.commit();
session.close();
session = sessionFactory2.openSession();
transaction = session.beginTransaction();
transaction.begin();
session.save(e);
transaction.commit();
session.close();
} catch (HibernateException he) {
he.printStackTrace();
}
}
}
No comments:
Post a Comment