java+mysql在tomcat服务器下建立SOAP(axis2)通过KSOAP2访问的诸多问题

本文介绍axis2在tomcat下的搭建及java连接mysql注意问题，及利用eclipse插件将java class打包成arr文件操作及注意事项等

一、搭建

工具：mysql，jdk，tomcat，mysql-connector-java-5.1.7-bin.jar（jdbc），eclipse插件：axis2-eclipse-codegen-wizard.zip&axis2-eclipse-service-archiver-wizard.zip，axis2-1.5.6-war.zip，eclipse。

假定mysql，jdk，tomcat，eclipse都已正确安装。

1、安装eclipse插件，将axis2-eclipse-codegen-wizard.zip&axis2-eclipse-service-archiver-wizard.zip解压到eclipse的\plugins目录下，重启eclipse，点击file-new-other当出现下图时表示安装成功：

2、将axis2-1.5.6-war.zip中的axis2.war解压到\Tomcat\webapps下重启Tomcat，tomcat将自动解压axis2.war到\webapps目录下，会出现axis2文件夹，\axis2\WEB-INF目录下，lib文件夹用于存放axis2框架中要用到的jar文件，因此项目所要用到的jar文件都放在lib文件夹中，services文件夹存放提供服务的aar文件，classes文件夹存放已编译的java类文件，浏览器中键入http://localhost:8080/axis2/，如出现下图表示axis2框架成功搭建，

点击validate进行确认，出现下面的蓝色文字则正常

二、编写调试

java连接mysql数据库要用到mysql-connector-java-5.1.7-bin.jar  jdbc类库：

package cn.xiezhengcai.exing;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class DataBaseOperate{
    private String url;
    private String user ; 
    private String password;
    private Connection conn;
    public DataBaseOperate(){
        url="jdbc:MySQL://127.0.0.1:3306/exing?user=root&password=";
    //    user = "root";
//password="";
    }
    /**
     * 功能：连接数据库；
     * @author ZhengCai Xie
     * @return
     * @throws SQLException
     * @throws ClassNotFoundException 
     * @throws IllegalAccessException 
     * @throws InstantiationException 
     * 
*/
    public boolean operateStart() throws SQLException{
        
                try {
                    Class.forName("com.mysql.jdbc.Driver").newInstance();
                } catch (InstantiationException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                } catch (IllegalAccessException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                } catch (ClassNotFoundException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                conn = DriverManager.getConnection(url);
                if(conn.isClosed())  
                    return false;  
                else
                    return true;
            
    }
    /**
     * 功能：关闭数据库连接
     * @author ZhengCai Xie
     * @throws SQLException
*/
    public void operateEnd() throws SQLException{
        conn.close();
    }
    /**
     * 功能：操作数据库，Select
     * @author ZhengCai Xie
     * @param sql
     * @return List<Map>,将获取的数据集循环放入list中,每一个Map表示一行的值，键为该行的字段
     * @throws SQLException
*/
    public List<Map<String,String>> operateDataBaseBySelect(String sql) throws SQLException{
        List<Map<String,String>> list=new ArrayList<Map<String,String>>(); 
        Statement statement = conn.createStatement();
        ResultSet rs = statement.executeQuery(sql);
        ResultSetMetaData rsMeta=rs.getMetaData();
        int columnCount=rsMeta.getColumnCount();
        while(rs.next()) {  
            Map<String,String> map =new HashMap<String,String>();
            for(int i=0;i<columnCount;i++){
                map.put(rsMeta.getColumnName(i+1), rs.getString(i+1));
            }
            list.add(map);
            
        }
        rs.close();
        return list;
        
    }
    /**
     * 功能：操作数据库，更新，删除，插入，
     * 对于数据库操作语言，返回行计数，对于什么都不返回的sql返回0
     * @author ZhengCai Xie
     * @param sql
     * @return
     * @throws SQLException
*/
    public int operateDataBaseByOther(String sql) throws SQLException{
        Statement statement = conn.createStatement();
        return statement.executeUpdate(sql);
    }
}

 

注：如果

url="jdbc:MySQL://127.0.0.1:3306/exing;

Class.forName("com.mysql.jdbc.Driver");

Connection conn = DriverManager.getConnection(URL,"root","");

请修改成

URL ="jdbc:MySQL://127.0.0.1:3306/exing?user=root&password=";

Class.forName("com.mysql.jdbc.Driver").newInstance();

Connection conn = DriverManager.getConnection(URL);

否则有可能会出现：no suitable driver found for jdbc:mysql错误

编写服务端：SOAPService.java

package cn.xiezhengcai.exing.soap;

import java.sql.SQLException;
import java.text.SimpleDateFormat;
import java.util.Date;

import cn.xiezhengcai.exing.DataBaseOperate;
/**
 * SOAP Actual Service，提供信息的获取，及数据更新、插入等。
 * 基于底层DataBaseOperate。
 * @author ZhengCai Xie
 *
 */
public class SOAPService{
    private DataBaseOperate dbo;
    public SOAPService(){
        dbo=new DataBaseOperate();
    }
    public int userRegister(String userName,int userSex,String userNickName,String userPassword ) throws SQLException{
        return userRegister(userName,null,null,null,userSex,userNickName,userPassword);
    }
    public int userRegister(String userName,String userEmail,int userSex,String userNickName,String userPassword ) throws SQLException{
        return userRegister(userName,userEmail,null,null,userSex,userNickName,userPassword);
    }
    public int userRegister(String userName,String userEmail,String userPhone,int userSex,String userNickName,String userPassword ) throws SQLException{
        return userRegister(userName,userEmail,userPhone,null,userSex,userNickName,userPassword);
    }
    /**
     * 用户注册，
     * @author ZhengCai Xie
     * @param userName
     * @param userEmail
     * @param userPhone
     * @param userQQ
     * @param userSex
     * @param userNickName
     * @param userPassword
     * @throws SQLException
*/
    public int userRegister(String userName,String userEmail,String userPhone,String userQQ,int userSex,String userNickName,String userPassword) throws SQLException{
        String curDate=new SimpleDateFormat("yyyy-MM-dd").format(new Date());
        String sql="insert into tab_user(USER_NAME,USER_EMAIL,USER_PHONE,USER_QQ,USER_SEX,USER_ADD_TIME,USER_NICKNAME,USER_PASSWORD)values('"+userName+"','"+userEmail+"','"+userPhone+"','"+userQQ+"','"+userSex+"','"+curDate+"','"+userNickName+"','"+userPassword+"')";
        dbo.operateStart();
        int lineCount=dbo.operateDataBaseByOther(sql);
        dbo.operateEnd();
        return lineCount;
    }
}

注：远程调用方法userRegister()不能返回值为void，会出现[ERROR] An access occurred that is not valid.java.lang.UnsupportedOperationException: An access occurred that is not valid. 错误，

编译这两个java文件javac DataBaseOperate.java soap\*.java

打包arr

利用eclipse插件axis2 Srvice Archiver向导将编译的文件打包成arr文件

注：在Class File Loction处要选择整个包文件夹一起，勾选Include .class files only。next...后选中Generate the service xml automatically，next...输入自己定制的severname类名处记得要将包一起带上，next...直到finish之后会得到一个打包好的arr文件

将此arr文件copy到

tomcat\wabapps\axis2\WEB-INF\services下，重启tomcat，

如果用到外部类库，请将类库放置到tomcat\wabapps\axis2\WEB-INF\lib下

打开http://localhost:8080/axis2/services/listServices可看到我们指定的service，

点击可看到相应的wsdl

如上的http://soap.exing.xiezhengcai.cn既是我们service的命名空间，在客服端下需要指定

到此，我们的客服端程序就可以通过KSOAP2与这个wsdl透明地与我们的服务端程序进行交互和通信了。