JPA EJB3 – ví dụ mối quan hệ giữa các bảng trong CSDL

Trong ví dụ này, tôi sẽ hướng dẫn các bạn tạo 1 EJB thao tác trên nhiều bảng CSDL và giữa các bảng này có mối quan hệ với nhau.
1. Tạo Database:

Hệ cơ sở dữ liệu ở đây tôi sử dụng dùng MS SQL Server 2005. Database có tên BookMS với các bảng và mối quan hệ của chúng được cho như hình sau:

Đây là script sinh ra database này:

SET ANSI_NULLS ON GO SET QUOTED_IDENTIFIER ON GO IF NOT EXISTS (SELECT * FROM sys.objects WHERE object_id = OBJECT_ID(N'[dbo].[BookType]’) AND type in (N’U’)) BEGIN CREATE TABLE [dbo].[BookType]( [typeID] [int] NOT NULL, [typeName] [nvarchar](250) NOT NULL, CONSTRAINT [PK_BookType] PRIMARY KEY CLUSTERED ( [typeID] ASC )WITH (IGNORE_DUP_KEY = OFF) ON [PRIMARY] ) ON [PRIMARY] END GO SET ANSI_NULLS ON GO SET QUOTED_IDENTIFIER ON GO IF NOT EXISTS (SELECT * FROM sys.objects WHERE object_id = OBJECT_ID(N'[dbo].[Publisher]’) AND type in (N’U’)) BEGIN CREATE TABLE [dbo].[Publisher]( [pubID] [int] NOT NULL, [pubName] [nvarchar](150) NOT NULL, CONSTRAINT [PK_Publisher] PRIMARY KEY CLUSTERED ( [pubID] ASC )WITH (IGNORE_DUP_KEY = OFF) ON [PRIMARY] ) ON [PRIMARY] END GO SET ANSI_NULLS ON GO SET QUOTED_IDENTIFIER ON GO IF NOT EXISTS (SELECT * FROM sys.objects WHERE object_id = OBJECT_ID(N'[dbo].[Book]’) AND type in (N’U’)) BEGIN CREATE TABLE [dbo].[Book]( [ISBN] [bigint] NOT NULL, [bookTiitle] [nvarchar](250) NOT NULL, [authorName] [nvarchar](250) NOT NULL, [pubID] [int] NOT NULL, [typeID] [int] NOT NULL, [shortDesc] [ntext] NOT NULL, CONSTRAINT [PK_Book] PRIMARY KEY CLUSTERED ( [ISBN] ASC )WITH (IGNORE_DUP_KEY = OFF) ON [PRIMARY] ) ON [PRIMARY] TEXTIMAGE_ON [PRIMARY] END GO IF NOT EXISTS (SELECT * FROM sys.foreign_keys WHERE object_id = OBJECT_ID(N'[dbo].[FK_Book_BookType]’) AND parent_object_id = OBJECT_ID(N'[dbo].[Book]’)) ALTER TABLE [dbo].[Book]  WITH CHECK ADD  CONSTRAINT [FK_Book_BookType] FOREIGN KEY([typeID]) REFERENCES [dbo].[BookType] ([typeID]) GO IF NOT EXISTS (SELECT * FROM sys.foreign_keys WHERE object_id = OBJECT_ID(N'[dbo].[FK_Book_Publisher]’) AND parent_object_id = OBJECT_ID(N'[dbo].[Book]’)) ALTER TABLE [dbo].[Book]  WITH CHECK ADD  CONSTRAINT [FK_Book_Publisher] FOREIGN KEY([pubID]) REFERENCES [dbo].[Publisher] ([pubID]) GO IF NOT EXISTS (SELECT * FROM sys.foreign_keys WHERE object_id = OBJECT_ID(N'[dbo].[FK1FAF0945FA8708]’) AND parent_object_id = OBJECT_ID(N'[dbo].[Book]’)) ALTER TABLE [dbo].[Book]  WITH CHECK ADD  CONSTRAINT [FK1FAF0945FA8708] FOREIGN KEY([typeID]) REFERENCES [dbo].[BookType] ([typeID]) GO IF NOT EXISTS (SELECT * FROM sys.foreign_keys WHERE object_id = OBJECT_ID(N'[dbo].[FK1FAF098EFB6544]’) AND parent_object_id = OBJECT_ID(N'[dbo].[Book]’)) ALTER TABLE [dbo].[Book]  WITH CHECK ADD  CONSTRAINT [FK1FAF098EFB6544] FOREIGN KEY([pubID]) REFERENCES [dbo].[Publisher] ([pubID])

Tôi sử dụng Eclipse ganymede (3.4) để thực hiện ví dụ này.

2. Cấu hình Data Management

Bạn phải cấu hình kết nối đến CSDL trong Eclipse. Điều này bắt buộc bạn phải có JDBC driver của MS SQLServer. Bạn có thể download tại http://www.microsoft.com. Sau khi download xong, bạn giải nén ra 1 thư mục nào đó và ghi nhớ lại thư mục này, đặc biệt là file sqljdbc.jar

Trong eclipse, bạn vào menu Window->Reference, chọn mục “Data Management->Connectivity->Driver Definition” như hình

Nhấn nút Add để thêm, cửa sổ sau xuất hiện

Ở lớp Jar List, nhấn nút Add Jars/Zip… rồi chọn file jar sqljdbc.jar

Ở lớp Properties, gõ database name, gõ username, password. lưu ý phải có password. Bạn nên tạo 1 user name khác trong sqlserver với 1 pass và cấp quyền cho nó chứ không dùng sa!!!

Nhấn OK, bạn đã có 1 Driver Definition.

3. Tạo EJB Project

Trong Eclipse, bạn vào menu File->New->EJB Project. Đặt tên là BookMS_JPA. Nhấn nút Modify trong mục Configuration và nhớ chọn mục “Java Persistence 1.0“.

Nhấn Next 2 lần và chọn lựa các tùy chọn như hình sau

Nhấn Finish để kết thúc việc tạo EJB Project

4. Sinh ra các Entities (Entity-Bean)

Nhấn chuột phải lên project của chúng ta, chọn “JPA Tools->Generate Entities”

Nhấn Next

Nhấn Finish để kết thúc.

Bạn sẽ gặp 1 số lỗi khi xem code được phát sinh. Bạn phải fix nó bằng cách thay đổi perspective thành JPA (vào menu WIndow->Open Perspective ->Others, chọn JPA nhấn OK).

Ở góc dưới bên phải của perspective này bạn chọn tab JPA Details, thay đổi Schema thành schema mà bạn config (ở đây là dbo) như hình,

Sau đó lưu lại, các lỗi đã được fix.

Cấu hình persistence

Mở file Persistence.xml trong mục META-INF, thay đổi nội dung như sau

<?xml version=”1.0″ encoding=”UTF-8″?> <persistence version=”1.0″ xmlns=”http://java.sun.com/xml/ns/persistence&#8221; xmlns:xsi=”http://www.w3.org/2001/XMLSchema-instance&#8221; xsi:schemaLocation=”http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd”&gt; <persistence-unit name=”EbookMS_JPA”> <jta-data-source>java:/BOOKMSSQLDS</jta-data-source> <properties> <property name=”hibernate.dialect” value=”org.hibernate.dialect.SQLServerDialect” /> <property name=”hibernate.hbm2ddl.auto” value=”update” /> </properties> </persistence-unit> </persistence>

trong đó <jta-data-source>java:/BOOKMSSQLDS</jta-data-source> là datasource bạn cấu hình trong jboss (thay đổi nội dung file mssql-ds.xml trong %JBOSS_HOME%\server\default\deploy\, thêm vào phân đoạn

<local-tx-datasource> <jndi-name>BOOKMSSQLDS</jndi-name> <connection-url> jdbc:sqlserver://localhost:1433;databaseName=BookMS </connection-url> <driver-class> com.microsoft.sqlserver.jdbc.SQLServerDriver </driver-class> <user-name>sa</user-name> <password></password> <metadata> <type-mapping>MS SQLSERVER2000</type-mapping> </metadata> </local-tx-datasource>

).

5. Tạo Session-Bean

Tạo package vovanhai.wordpress.sessionbean, ta sẽ viết các session bean trong package này.

Với Entity Publisher, ta sẽ tạo session bean như sau:

Tạo interface PublisherDAO.java với nội dung như sau

package vovanhai.wordpress.jpa; import java.util.Collection; import javax.ejb.Remote; @Remote public interface PublisherDAO { public void addPublisher(Publisher pub); public Publisher findPublisherByID(int id); public Collection<Publisher>getAllPublishers(); public void removePublisher(Publisher pub); }

Tạo bean PublisherDAOBean.java có nội dung sau

package vovanhai.wordpress.jpa; import java.util.Collection; import javax.ejb.Stateless; import javax.persistence.EntityManager; import javax.persistence.PersistenceContext; @Stateless public class PublisherDAOBean implements PublisherDAO{ @PersistenceContext (name=”FirstJPAProject”) private EntityManager entityManager; @Override public void addPublisher(Publisher pub) { entityManager.persist(pub); } @Override public Publisher findPublisherByID(int id) { return entityManager.find(Publisher.class, id); } @SuppressWarnings(“all”) @Override public Collection<Publisher> getAllPublishers() { return entityManager.createQuery(“from Publisher p”).getResultList(); } @Override public void removePublisher(Publisher pub) { entityManager.remove(pub); }

Tương tự ta tạo các sessonbean cho Book và Booktype entities

BookTypeDAO.java

package vovanhai.wordpress.jpa; import java.util.Collection; import javax.ejb.Remote; @Remote public interface BookTypeDAO { public void addBookType(Booktype type); public Booktype findBookTypeByID(int id); public Collection<Booktype>getAllBookTypes(); }

BookTypeDAOBea.java

package vovanhai.wordpress.jpa; import java.util.Collection; import javax.ejb.Stateless; import javax.persistence.EntityManager; import javax.persistence.PersistenceContext; @Stateless public class BookTypeDAOBean implements BookTypeDAO { @PersistenceContext (name=”FirstJPAProject”) private EntityManager entityManager; @Override public void addBookType(Booktype type) { entityManager.persist(type); } @Override public Booktype findBookTypeByID(int id) { return entityManager.find(Booktype.class,id); } @SuppressWarnings(“all”) @Override public Collection<Booktype> getAllBookTypes() { return entityManager.createQuery(“from Booktype bt”).getResultList(); } }

BookDAO.java

package vovanhai.wordpress.jpa; import java.util.Collection; import javax.ejb.Remote; @Remote public interface BookDAO { public void addBook(Book book); public Book findBookByISBN(long isbn); public Collection<Book>getAllBooks(); }

BookDAOBean.java

package vovanhai.wordpress.jpa; import java.util.Collection; import javax.ejb.Stateless; import javax.persistence.EntityManager; import javax.persistence.PersistenceContext; @Stateless public class BookDAOBean implements BookDAO { @PersistenceContext (name=”FirstJPAProject”) private EntityManager entityManager; @Override public void addBook(Book book) { entityManager.persist(book); } @Override public Book findBookByISBN(long isbn) { return entityManager.find(Book.class, isbn); } @SuppressWarnings(“all”) @Override public Collection<Book> getAllBooks() { return (Collection<Book>)(entityManager.createQuery(“from Book c”).getResultList()); } }

7. Tạo client để thử

package vovanhai.wordpress.jpa; import java.util.Set; import javax.naming.InitialContext; public class Client { public static void main(String[] args) { try { System.setProperty(“java.naming.factory.initial”,”org.jnp.interfaces.NamingContextFactory”); System.setProperty( “java.naming.provider.url”, “localhost:1099”); System.setProperty( “java.naming.factory.url.pkgs”, “org.jboss.naming” ); InitialContext context=new InitialContext(); BookDAO dao=(BookDAO)context.lookup(“BookDAOBean/remote”); BookTypeDAO btdao=(BookTypeDAO)context.lookup(“BookTypeDAOBean/remote”); PublisherDAO pubdao=(PublisherDAO)context.lookup(“PublisherDAOBean/remote”); Book b=new Book(); b.setIsbn(3634646L); b.setBooktiitle(“Học java bằng ví dụ”); b.setAuthorname(“Nguyễn Văn tèo”); b.setShortdesc(“Shordescription of this book”); Publisher pub=pubdao.findPublisherByID(1); b.setPubid(pub); Booktype type=btdao.findBookTypeByID(3); b.setTypeid(type); dao.addBook(b); System.out.println(“Insert “+b.getBooktiitle()+” completed…”); //Search Book found=dao.findBookByISBN(78354328); System.out.println(“Search: “+found.getBooktiitle()); System.out.print(“====================List books by Publisher:”); System.out.println(pub.getPubname()+”=================”); Set<Book> cols=pub.getBookCollection(); for(Book b1:cols) System.out.println(b1); System.out.print(“====================List books by type:”); System.out.println(type.getTypename()+”====================”); Set<Book>bookbytype=type.getBookCollection(); for(Book bb:bookbytype) System.out.println(bb); } catch (Exception e) { e.printStackTrace(); } } }

Kết quả hiển thị như sau:

Insert Học java bằng ví dụ completed… Search: JavaServer Faces ====================List books by Publisher:Deiteil================= Tomorow Never Die Chuyện tình Học java bằng ví dụ Tomorow Never Die ====================List books by type:Text Book==================== JavaServer Faces Học java bằng ví dụ Mastering JavaServer Faces

Chúc các bạn thành công!