من کاری ندارم اون هندی عقب مونده چی کار کرده این کاری که من می گم بکنی حله. ولی بازم می گم کلی concept هست که باید بری خودت بخونی و جریانش رو در بیاری
طرف client. برای خودت یک project جدا درست کن توی NETBEANS یا هرجا که بلدی اصلا توی kate خوبه؟
package myclient;
import java.util.Properties;
import javax.naming.Context;
import javax.naming.InitialContext;
import myejb.MySessionRemote;
import mypersistence.Person;
/**
*
* @author root
*/
public class Main {
private Properties prop;
private Context ctx;
private MySessionRemote sr;
public Main() {
}
private Context getContext() {
try {
if (this.ctx == null) {
prop = new Properties();
prop.setProperty("java.naming.factory.initial", "com.sun.enterprise.naming.SerialInitContextFactory");
prop.setProperty("java.naming.factory.url.pkgs", "com.sun.enterprise.naming");
prop.setProperty("java.naming.factory.state", "com.sun.corba.ee.impl.presentation.rmi.JNDIStateFa ctoryImpl");
prop.setProperty("org.omg.CORBA.ORBInitialHost", "192.168.1.2");
prop.setProperty("org.omg.CORBA.ORBInitialPort", "3700");
ctx = new InitialContext(prop);
}
} catch (Exception ex) {
ex.printStackTrace();
}
return ctx;
}
public void save() {
Person person = new Person();
person.setName("babak");
person.setFamily("azarmi");
try {
sr = (MySessionRemote) getContext().lookup("myejb.MySessionRemote");
sr.savePerson(person);
} catch (Exception ex) {
ex.printStackTrace();
}
}
public void show() {
try {
sr = (MySessionRemote) getContext().lookup("myejb.MySessionRemote");
Person p =sr.getPerson("babak");
System.out.println(p.getId());
System.out.println(p.getName());
System.out.println(p.getFamily());
} catch (Exception ex) {
ex.printStackTrace();
}
}
public static void main(String[] args) {
Main m = new Main();
m.save();
m.show();
}
}
به package ها هم دقت کن. نکته اساسی اینکه که باید در قسمت client توی classpath ی که داره حتما jar فایل ejbی که بعد می سازیم تعریف شده باشه . اینها رو فکر کنم که دیگه خودت استاد شدی.
اما در قسمت سروری.
نکته هایی که باید رعایت کنی یا من رعایت کردم و تو باید بدونی اینکه یک من از hibernate استفاده نه toplink. دوم اینکه تمام بار کنترل transaction ها رو روی container نزاشتم بلکه خودم handle کردم و تو توی کد خواهی دید. پس به قسمت persistence.xml خیلی دقت کن بابا که چه جوری تنظیم کردم. اون کتابی که بهت معرفی کردم اگر خونده باشی خواهی دید ما برای کنترل transaction ها هم می تونیم بندازیم گردن container که من موافقه این کار هستم درصد خطا می یاد پایین و هم می تونی خودت transaction ها رو باز وبسته کنی که اینجا من بهت گفتم اینطوری رفتار کردم که درکل این کار بهتره برای اینکه همه چیز دسته خودته. یک پروژه دیگه باز می کنی بعد کد ها رو اضافه می کنی. بعد jar فایل درست می کنی بعد jar فایل رو به classpath ی توی clientهست اضافه می کنی بعد deploy می کنی.
کلاس Person.java
/*
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/
package mypersistence;
import java.io.Serializable;
import javax.persistence.Basic;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import javax.persistence.Table;
/**
*
* @author root
*/
@Entity
@Table(name = "test")
//@NamedQueries({@NamedQuery(name = "Test.findAll", query = "SELECT t FROM Test t")})
public class Person implements Serializable {
private static final long serialVersionUID = 1L;
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
@Basic(optional = false)
@Column(name = "id")
private Integer id;
@Basic(optional = false)
@Column(name = "name")
private String name;
@Basic(optional = false)
@Column(name = "family")
private String family;
public Person() {
}
public Person(Integer id) {
this.id = id;
}
public Person(Integer id, String name, String family) {
this.id = id;
this.name = name;
this.family = family;
}
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 String getFamily() {
return family;
}
public void setFamily(String family) {
this.family = family;
}
@Override
public int hashCode() {
int hash = 0;
hash += (id != null ? id.hashCode() : 0);
return hash;
}
@Override
public boolean equals(Object object) {
// TODO: Warning - this method won't work in the case the id fields are not set
if (!(object instanceof Person)) {
return false;
}
Person other = (Person) object;
if ((this.id == null && other.id != null) || (this.id != null && !this.id.equals(other.id))) {
return false;
}
return true;
}
@Override
public String toString() {
return "mypersistence.Test[id=" + id + "]";
}
}
همانطور که می بینی من یک table دارم توی دیتا بیسم به نام test که اینجا map شده. یک id بیشتر ندارم.
نکته من از dataabase mysql استفاده کردم. نکته بعدی جدول نرمال هست ولی منطقی نیست و یعنی می بینی که می تونی n تا اسم تکراری بدی ولی در query زده شده فقط منتظر یک record هستی. خودت دقت کن. من کد table رو هم بهت می دم.
اما در قسمت session ها من فقط bean رو برات می فرسم خود برعکسش interface رو بساز دیگه. jar فایلهای hibernate رو هم netbeans داره به این projectet اضافه کن.
/*
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/
package myejb;
import javax.ejb.Stateless;
import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
import javax.persistence.Persistence;
import javax.persistence.Query;
import mypersistence.Person;
/**
*
* @author root
*/
@Stateless
public class MySessionBean implements MySessionRemote {
private EntityManagerFactory emf;
private EntityManager em;
private EntityManager getEM() {
if (emf == null || em == null) {
emf = Persistence.createEntityManagerFactory("test");
em = emf.createEntityManager();
}
return em;
}
public void savePerson(Person person) {
try {
getEM().getTransaction().begin();
//
getEM().persist(person);
//
getEM().getTransaction().commit();
} catch (Exception ex) {
if (getEM().getTransaction().isActive()) {
getEM().getTransaction().rollback();
}
ex.printStackTrace();
} finally {
try {
getEM().clear();
} catch (Exception e) {
e.printStackTrace();
}
}
}
public Person getPerson(String name) {
String q = "SELECT p FROM Person p WHERE p.name = :name";
Query query = null;
Person person = new Person();
try {
getEM().getTransaction().begin();
//
query = getEM().createQuery(q);
query.setParameter("name", name);
person = (Person) query.getSingleResult();
//
getEM().getTransaction().commit();
} catch (Exception ex) {
if (getEM().getTransaction().isActive()) {
getEM().getTransaction().rollback();
}
ex.printStackTrace();
} finally {
try {
getEM().clear();
} catch (Exception e) {
e.printStackTrace();
}
}
return person;
}
public void removePerson(String name) {
throw new UnsupportedOperationException("Not supported yet.");
}
}
بازم می گم به نام پروژه و package ها خوب دقت کن. اما قسمت آخر persistence.xml هست که چون من دستی دارم کنترل می کنم خوب نگاه کن ببین چی کار کردم.
persistence.xml
<?xml version="1.0" encoding="UTF-8"?>
<persistence version="1.0" xmlns="http://java.sun.com/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd">
<persistence-unit name="test" >
<provider>org.hibernate.ejb.HibernatePersistence</provider>
<!--<jta-data-source>test</jta-data-source>-->
<class>mypersistence.Person</class>
<properties>
<property name="hibernate.show_sql" value="true"/>
<property name="hibernate.connection.driver_class" value="com.mysql.jdbc.Driver"/>
<property name="hibernate.connection.password" value="babak"/>
<property name="hibernate.connection.url" value="jdbc:mysql://localhost/test"/>
<property name="hibernate.connection.username" value="root"/>
</properties>
</persistence-unit>
</persistence>
بقیشم گیر کردی بپرس منظورم توی اجراش نیست توی فهمشه
کد table
CREATE TABLE `test`.`test` (
`id` int(11) NOT NULL auto_increment,
`name` varchar(200) NOT NULL,
`family` varchar(200) NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=MyISAM AUTO_INCREMENT=7 DEFAULT CHARSET=latin1