用axis开发java web service中关于服务返回复杂类型的问题

0 0

用axis开发java web service中关于服务返回复杂类型的问题5

我是个初学者。我做了一个简单的例子，遇到点问题，希望大家可以帮忙看看
      首先这里是个pojo类，名字为Product.java
public class Product {
private String pid;
private String pname;
private double price;
private int cnt;
private String ext;

public int getCnt() {
    return cnt;
}
public void setCnt(int cnt) {
    this.cnt = cnt;
}
public String getExt() {
    return ext;
}
public void setExt(String ext) {
    this.ext = ext;
}
public String getPid() {
    return pid;
}
public void setPid(String pid) {
    this.pid = pid;
}
public String getPname() {
    return pname;
}
public void setPname(String pname) {
    this.pname = pname;
}
public double getPrice() {
    return price;
}
public void setPrice(double price) {
    this.price = price;
}
}
接着我做了一个数据库连接的文件,,名字为：DBAccess.java
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DBAccess {
private static Connection _conn = null;

public static Connection getConn() {
    try {
      Class.forName("oracle.jdbc.driver.OracleDriver");
      _conn = DriverManager.getConnection(
          "jdbc:oracle:thin:@127.0.0.1:1521:ICSS", "PRODUCT", "icss");
    } catch (Exception e) {
      e.printStackTrace();
    }
    return _conn;
}

public static void closeConn(Statement stmt, ResultSet rs, Connection conn) {
    try {
      if (rs != null) {
        rs.close();
      }
    } catch (Exception e) {
      e.printStackTrace();
    }
    try {
      if (stmt != null) {
        stmt.close();
      }
    } catch (SQLException e) {
      e.printStackTrace();
    }
    try {
      if (conn != null) {
        conn.close();
      }
    } catch (SQLException e) {
      e.printStackTrace();
    }
}

public static void closeConn() {
    try {
      if (_conn == null || _conn.isClosed()) {
        return;
      } else {
        _conn.close();
      }
    } catch (SQLException e) {
      e.printStackTrace();
    }
}

public void execUpdate() {
}

public ResultSet exceQuery(String sql) {
    ResultSet rs = null;
    try {
      if (_conn.isClosed()) {
        System.out.println("Conn is closed!!");
      }
      Statement stmt = _conn.createStatement();
      rs = stmt.executeQuery(sql);
    } catch (SQLException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    }
    return rs;
}
}
接着我又做了一个接口：Productoption.java
import java.util.ArrayList;

public interface Productoption {
public ArrayList getAllProducts(); } //里面有一个返回为ArrayList的方法

将这几个文件通过MyEclipse+Tomcat发布之后，进入发布后classes所在的文件夹：我的是C:\Program Files\Apache Software Foundation\Tomcat 5.5\webapps\SimpleExample\WEB-INF\classes
在cmd中输入命令：C:\Program Files\Apache Software Foundation\Tomcat 5.5\webapps\SimpleExample\WEB-INF\classes> java org.apache.axis.wsdl.Java2WSDL -o mb.wsdl -l "http://localhost:80/axis/services/Productoption" -n "urn:Productoption" -p"com.icss.oa.opt" "urn:Produtoption" com.icss.oa.opt.Productoption
生成了mb.wsdl文件，接着在输入命令： java org.apache.axis.wsdl.WSDL2Java -o . -d Session -s -S true -Nurn:Productoption com.icss.oa.opt mb.wsdl
生成了许多的.java文件，
最后就是在ProductoptionSoapBindingImpl.java中添加业务代码了，也就是说具体实现上面接口中的getAllProducts()方法了，可是在这里就有问题了

这里是ProductoptionSoapBindingImpl.java的代码
public class ProductoptionSoapBindingImpl implements com.icss.oa.opt.Productoption{

    public java.lang.Object[] getAllProducts() throws java.rmi.RemoteException {
    return null;
    }

}
这里返回类型怎么成了java.lang.Object[]而我的业务代码应该是
import ....这里也要倒入一些包
public class ProductoptionSoapBindingImpl implements com.icss.oa.opt.Productoption{

    public java.lang.Object[] getAllProducts() throws java.rmi.RemoteException {
    Connection conn = null;
          Statement stmt = null;
          ResultSet rs = null;
    conn = DBAccess.getConn();
//上面主要负责数据库的连接
    String sql ="select * from product";

    ArrayList<Product> proList = new ArrayList<Product>();

    try {
      stmt = conn.createStatement();
      rs = stmt.executeQuery(sql);

      Product product;

      while(rs.next()){
        product = new Product();

        product.setPid(rs.getString(1));
        product.setPname(rs.getString(2));
        product.setPrice(rs.getDouble(3));
        product.setCnt(rs.getInt(4));
        product.setExt(rs.getString(5));

        proList.add(product);
      }
    } catch (SQLException e) {
      e.printStackTrace();
    }finally{
      DBAccess.closeConn(stmt,rs,conn);
    }

    return proList;//这里肯定是错误的，可是我确实想让他返回一个ArrayList类型啊，要不然在调用的时候怎么办，如下面我写的test.java来测试这个web 服务
}

    }

}
test.java文件
import .....//这里要倒入一些包
public class test {
public static void main(String args[]) throws ServiceException, MalformedURLException, RemoteException{
       ProductoptionService s = new ProductoptionServiceLocator();
       Productoption opt = s.getProductoption();
       //这里我想用ArrayList因为只有这样才能取出数据库的东西啊
       ArrayList list = opt.getAllProducts();
        for (int i = 0; i < list.size(); i++){
                 Product product = (Product) list.get(i);

               System.out.println("pid is" +product.getPid());
        System.out.println("cnt is" +product.getCnt());
        System.out.println("ext is" +product.getExt());
        System.out.println("pname is" +product.getPname());
        System.out.println("price is" +product.getPrice());


}
}
}
请问各位大侠，这里怎么修改才可以解决这个问题啊；

问题补充：
谢谢您，不过我也试了toArray了，只是以前没用过toArray，可能有点不对，这里是我重新写的关于上面ProductoptionSoapBindingImpl.java
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;

import com.icss.oa.entity.Product;
public class ProductoptionSoapBindingImpl implements com.icss.oa.opt.Productoption{
    public java.lang.Object[] getAllProducts() throws java.rmi.RemoteException {
    Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
conn = DBAccess.getConn();
    String sql ="select * from product";

    ArrayList<Product> proList = new ArrayList<Product>();

    try {
      stmt = conn.createStatement();
      rs = stmt.executeQuery(sql);

      Product product;

      while(rs.next()){
        product = new Product();

        product.setPid(rs.getString(1));
        product.setPname(rs.getString(2));
        product.setPrice(rs.getDouble(3));
        product.setCnt(rs.getInt(4));
        product.setExt(rs.getString(5));

        proList.add(product);
      }
    } catch (SQLException e) {
      e.printStackTrace();
    }finally{
      DBAccess.closeConn(stmt,rs,conn);
    }
   java.lang.Object[] pro = null;
    pro = (proList).toArray(pro);
    return pro; //这里是使用了toArray
}

}
接着我又修改了test.java文件
具体如下：
import java.net.MalformedURLException;
import java.rmi.RemoteException;
import java.util.ArrayList;

import javax.xml.rpc.ServiceException;

import com.icss.oa.entity.*;
import com.icss.oa.opt.*;

public class test {
public static void main(String args[]) throws ServiceException, MalformedURLException, RemoteException{
       ProductoptionService s = new ProductoptionServiceLocator();
       Productoption opt = s.getProductoption();
java.lang.Object[] l = opt.getAllProducts();
   ArrayList myList = new ArrayList(l.length); //这里我认为要再转换回来，要不然下面的代码无法用
for (int i = 0; i < myList.size(); i++) {
Product product = (Product) myList.get(i);
System.out.println("pid is" +product.getPid());
System.out.println("cnt is" +product.getCnt());
System.out.println("ext is" +product.getExt());
System.out.println("pname is" +product.getPname());
System.out.println("price is" +product.getPrice());


}
}
}

SOA

2008年12月07日 09:53

lixiaoming
15
0 0 0

2个答案按时间排序按投票排序

0 0

采纳的答案

第一片红字，直接改为return proList.toArray();或者return proList.toArray(new Object[]{});

第二片红字：
java.lang.Object[] l = opt.getAllProducts();
if(l != null && l.length > 0) {
for(int i = 0; i < l.length; i ++) {
    Product product = (Product) l[i];
    //...
}
}
另外，List的遍历这样写比较好：
for(Iterator itr = myList.iterator(); itr.hasNext();) {
   Product product = (Product) itr.next();
}

2008年12月10日 08:08