+ Model class
Product.java
package org.sample.model;
import java.math.BigDecimal;
public class Product {
private Integer productId;
private String productName;
private String description;
private Float weight;
private BigDecimal price;
private Integer categoryId;
public Integer getCategoryId() {
return categoryId;
}
public void setCategoryId(Integer categoryId) {
this.categoryId = categoryId;
}
public Integer getProductId() {
return productId;
}
public void setProductId(Integer productId) {
this.productId = productId;
}
public String getProductName() {
return productName;
}
public void setProductName(String productName) {
this.productName = productName;
}
public String getDescription() {
return description;
}
public void setDescription(String description) {
this.description = description;
}
public Float getWeight() {
return weight;
}
public void setWeight(Float weight) {
this.weight = weight;
}
public BigDecimal getPrice() {
return price;
}
public void setPrice(BigDecimal price) {
this.price = price;
}
}
Category.java
package org.sample.model;
public class Category {
private Integer categoryId;
private String categoryName;
public Integer getCategoryId() {
return categoryId;
}
public void setCategoryId(Integer categoryId) {
this.categoryId = categoryId;
}
public String getCategoryName() {
return categoryName;
}
public void setCategoryName(String categoryName) {
this.categoryName = categoryName;
}
}
Product.hbm.xml
version="1.0"?>
hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
package="org.sample.model">
name="Product" table="PRODUCT">
name="productId" column="PRODUCT_ID" type="java.lang.Integer">
class="increment"/>
name="productName" type="java.lang.String" column="PRODUCT_NAME"/> name="description" type="java.lang.String" column="DESCRIPTION"/> name="weight" type="java.lang.Float" column="WEIGHT"/> name="price" type="java.math.BigDecimal" column="PRICE"/> name="categoryId" type="java.lang.Integer" column="CATEGORY_ID"/>
Category.hbm.xml
version="1.0"?>
hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
package="org.sample.model">
name="Category" table="CATEGORY">
name="categoryId" column="CATEGORY_ID" type="java.lang.Integer">
class="increment"/>
name="categoryName" type="java.lang.String" column="CATEGORY_NAME"/>
+ Dao class
ProductDAO.java
package org.sample.dao;
import org.sample.model.Product;
public interface ProductDAO {
public void createProduct(Product product);
public void updateProduct(Product product);
public void deleteProduct(Product product);
public Product getProduct(Integer productId);
public Product[] listAllProduct();
}
CategoryDAO.java
package org.sample.dao;
import org.sample.model.Category;
public interface CategoryDAO {
public void createCategory(Category cat);
public void updateCategory(Category cat);
public void deleteCategory(Category cat);
public Category getCategory(Integer categoryId);
public Category[] getAllCategories();
}
ProductDAOImpl.java
package org.sample.dao.impl;
import org.sample.dao.ProductDAO;
import org.sample.model.Product;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;
public class ProductDAOImpl extends HibernateDaoSupport implements ProductDAO {
public void createProduct(Product product) {
getHibernateTemplate().save(product);
}
@SuppressWarnings("unchecked")
public Product[] listAllProduct() {
Product[] products = new Product[0];
return (Product[]) getHibernateTemplate().find("from Product").toArray(products);
}
public Product getProduct(Integer productId) {
Product pro1 = (Product) getHibernateTemplate().load(Product.class,
productId);
Product pro2 = new Product();
pro2.setProductId(pro1.getProductId());
pro2.setProductName(pro1.getProductName());
pro2.setCategoryId(pro1.getCategoryId());
pro2.setPrice(pro1.getPrice());
pro2.setWeight(pro1.getWeight());
pro2.setDescription(pro1.getDescription());
return pro2;
}
public void updateProduct(Product product) {
getHibernateTemplate().update(product);
}
public void deleteProduct(Product product) {
getHibernateTemplate().delete(product);
}
}
CategoryDAOImpl.java
package org.sample.dao.impl;
import java.util.List;
import org.sample.dao.CategoryDAO;
import org.sample.model.Category;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;
public class CategoryDAOImpl extends HibernateDaoSupport implements CategoryDAO {
public void createCategory(Category cat) {
getHibernateTemplate().save(cat);
}
public void deleteCategory(Category cat) {
getHibernateTemplate().delete(cat);
}
@SuppressWarnings("unchecked")
public Category[] getAllCategories() {
List list = getHibernateTemplate().find("from Category");
Category[] categories = (Category[]) list.toArray();
return categories;
}
public void updateCategory(Category cat) {
getHibernateTemplate().update(cat);
}
public Category getCategory(Integer categoryId) {
Category cat1 = (Category) getHibernateTemplate().get(Category.class,
categoryId);
Category cat2 = new Category();
cat2.setCategoryId(cat1.getCategoryId());
cat2.setCategoryName(cat1.getCategoryName());
return cat2;
}
}
+ Service class (call dao)
ProductService.java
CategoryService.java
ProductServiceImpl.java
CategoryServiceImpl.java
+ applicationContext.xml
beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
id="applicationContext"
class="org.apache.axis2.extensions.spring.receivers.ApplicationContextHolder"/>
id="dataSource"
class="org.springframework.jdbc.datasource.DriverManagerDataSource">
com.mysql.jdbc.Driver
jdbc:mysql://localhost:3306/product_management
root
root
id="hibernateInterceptor"
class="org.springframework.orm.hibernate3.HibernateInterceptor">
bean="sessionFactory"/>
id="sessionFactory"
class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
local="dataSource"/>
org/sample/model/Category.hbm.xml
org/sample/model/Product.hbm.xml
name="hibernateProperties"> org.hibernate.dialect.MySQLDialect
key="hibernate.show_sql">true
id="hibernateTemplate"
class="org.springframework.orm.hibernate3.HibernateTemplate">
bean="sessionFactory"/>
id="productDao" class="org.sample.dao.impl.ProductDAOImpl">
name="hibernateTemplate"> local="hibernateTemplate"/>
id="productServiceTarget"
class="org.sample.service.impl.ProductServiceImpl">
local="productDao"/>
id="productService"
class="org.springframework.aop.framework.ProxyFactoryBean">
local="productServiceTarget"/>
org.sample.service.ProductService
hibernateInterceptor
id="categoryDao" class="org.sample.dao.impl.CategoryDAOImpl">
name="hibernateTemplate"> local="hibernateTemplate"/>
id="categoryServiceTarget"
class="org.sample.service.impl.CategoryServiceImpl">
local="categoryDao"/>
id="categoryService"
class="org.springframework.aop.framework.ProxyFactoryBean">
local="categoryServiceTarget"/>
org.sample.service.CategoryService
hibernateInterceptor
+ services.xml
name="SpringInit" class="org.sample.service.SpringInit">
This web service initializes Spring.
org.sample.service.SpringInit
name="ServiceTCCL">composite name="load-on-startup">true name="springInit">
class="org.apache.axis2.receivers.RawXMLINOutMessageReceiver"/>
name="productService">
org.sample.service.impl.ProductServiceImpl
name="ServiceObjectSupplier"> org.apache.axis2.extensions.spring.receivers.SpringAppContextAwareObjectSupplier
name="SpringBeanName">productService
mep="http://www.w3.org/2004/08/wsdl/in-only"
class="org.apache.axis2.rpc.receivers.RPCInOnlyMessageReceiver"/>
mep="http://www.w3.org/2004/08/wsdl/in-out"
class="org.apache.axis2.rpc.receivers.RPCMessageReceiver"/>
name="categoryService">
org.sample.service.impl.CategoryServiceImpl
name="ServiceObjectSupplier"> org.apache.axis2.extensions.spring.receivers.SpringAppContextAwareObjectSupplier
name="SpringBeanName">categoryService
mep="http://www.w3.org/2004/08/wsdl/in-only"
class="org.apache.axis2.rpc.receivers.RPCInOnlyMessageReceiver"/>
mep="http://www.w3.org/2004/08/wsdl/in-out"
class="org.apache.axis2.rpc.receivers.RPCMessageReceiver"/>
+ Client class
CreateProductSpringClient.java
UpdateProductSpringClient.java
package org.sample.client;
import javax.xml.namespace.QName;
import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.rpc.client.RPCServiceClient;
import org.sample.model.Category;
public class UpdateCategorySpringClient {
public static void main(String[] args) throws AxisFault {
RPCServiceClient serviceClient = new RPCServiceClient();
Options options = serviceClient.getOptions();
EndpointReference targetEPR = new EndpointReference(
"http://127.0.0.1:8989/axis2/services/categoryService");
options.setTo(targetEPR);
// get products
QName opGetCategory = new QName("http://impl.service.sample.org",
"getCategory");
Object[] opGetCategoryArgs = new Object[] { new Integer(4) };
Class[] returnTypes = new Class[] { Category.class };
Object[] response = serviceClient.invokeBlocking(opGetCategory,
opGetCategoryArgs, returnTypes);
Category cat = (Category) response[0];
// Displaying the result
System.out.println("CategoryId : " + cat.getCategoryId());
System.out.println("CategoryName : " + cat.getCategoryName());
// update Product
EndpointReference targetEPR1 = new EndpointReference(
"http://127.0.0.1:8989/axis2/services/categoryService");
options.setTo(targetEPR1);
cat.setCategoryName("Games");
Object[] opGetCategoryArgs1 = new Object[] { cat };
System.out.println("Category id:" + cat.getCategoryId());
QName opGetCategory1 = new QName("http://impl.service.sample.org",
"updateCategory");
serviceClient.invokeRobust(opGetCategory1, opGetCategoryArgs1);
System.out.println("xong roi");
}
}
DeleteProductSpringClient.java
ListProductSpringClient.java
package org.sample.client;
import javax.xml.namespace.QName;
import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.rpc.client.RPCServiceClient;
import org.sample.model.Product;
public class ListProductSpringClient {
public static void main(String[] args) throws AxisFault {
RPCServiceClient serviceClient = new RPCServiceClient();
Options options = serviceClient.getOptions();
EndpointReference targetEPR = new EndpointReference(
"http://127.0.0.1:8989/axis2/services/productService");
options.setTo(targetEPR);
// get products
QName opGetProduct = new QName("http://impl.service.sample.org",
"listAllProduct");
Object[] opGetProductArgs = new Object[] {};
Class[] returnTypes = new Class[] { Product[].class };
Object[] response = serviceClient.invokeBlocking(opGetProduct,
opGetProductArgs, returnTypes);
Product[] products = (Product[]) response[0];
for (int i = 0; i < products.length; i++) {
Product pro = (Product) products[i];
System.out.println("product name:" + pro.getProductName());
}
}
}
+ Library
cglib.jar
common-collection.jar
ehcache.jar
dom4j.jar
jta.jar
hibernate3.jar
mysql-connector.jar
antlr-2.7.5H3.jar
Chú ý: copy tất cả thư mục con của thư mục classes trong thư mục target vào C:\Program Files\Apache Software Foundation\Tomcat 6.0\webapps\axis2\WEB-INF\classes
Tip
+ Lỗi java.lang.IllegalStateException: No valid ObjectCreator found <= thiếu stax-1.2.0.jar file
+ SOAP: nghi thức trao đổi thông tin qua HTTP, SOAP message là XML message
+ JAX-WS là kỹ thuật để xây dựng web service và client giao tiếp qua XML
+ JAX-RPC cung cấp mô hình để phát triển ứng dụng dựa vào SOAP. Lập trình JAX-RPC đơn giản kỹ thuật chạy nghi thức SOAP và cung cấp ánh xạ services giữa Java và WSDL
+ WSDL: file mô tả web service
+ Sử dụng tool java2wsdl để phát sinh wsdl file: java2wsdl -cp . -cn org.sample.service.BusinessService -of BusinessService.wsdl
+ POJO nhấn mạnh đối tượng là đối tượng Java bình thường (hông phải Enterprise JavaBean, nó không cài đặt, kế thừa bất kỳ lớp nào hoặc chứa
annotation) để thiết kế đơn giản hơn, tốt hơn. JavaBean là một POJO có tính chất serializable (cho phép truy cập các thuộc tính private của các đối tượng persistent), có phương thức khởi tạo không tham số, cho phép truy cập các thuộc tính bằng phương thức getter và setter.
(Spring POJO: http://www.onjava.com/pub/a/onjava/2005/06/29/spring-ejb3.html).
Chúc bạn thành công.
DangTrung
