首先就是使用JDBC进行数据库数据的查询操作了。
在MyEclipse下建立一个WebService project项目，然后新建com.hxjr.util包，在包下建立连接数据库的类DBUtil.java，具体代码如下：
package com.hxjr.util;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class DBUtil {
private final static String DRIVER = "com.microsoft.sqlserver.jdbc.SQLServerDriver";//数据库驱动
// 数据库连接字符串 192.168.88.220
private final static String URL = "jdbc:sqlserver://数据库的IP地址:1433;DatabaseName=数据库名称";
private final static String USERNAME = "sa";// 数据库用户名
private final static String PASSWORD = "root";// 数据库密码
private Connection conn = null; // 定义一个Connection对象
//--------构造方法--------------------------------
public DBUtil(){
try {
Class.forName(DRIVER); // 加载数据库驱动，注册到驱动管理器
// 创建一个Connection连接
conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
}
//---------获取数据库连接---------------------------
public Connection getConnection(){
if (conn != null) {// 如果连接不为空，说明创建连接成功
return conn; // 连接成功，返回一个Connection对象
} else {
return null; // 如果连接失败，返回空值
}
}
}
然后建立com.hxjr.ben包，在包下建立一个类Container.java，具体代码如下所示。
package com.hxjr.bean;
public class Container {
int id;
String container_no;
String article_no;
float g_v_no;
String name_vessel;
String file_number;
String consignee;
String shipping_company;
String fyco_present;
String descripion_of_goods;
String type_of_declaration;
float declaration_number;
float country_of_origin;
String cmd_input_onitor_instruction;
Byte cmd_check_consignee;
Byte cmd_check_specifications;
Byte cmd_check_number;
Byte cmd_check_weight;
Byte cmd_check_classified;
Byte cmd_check_GaCang;
Byte cmd_check_misrepresenting;
String destination_country;
String customer_name;
String number_of_colli;
String container_contents1;
String container_contents2;
String container_contents3;
String business_no;
String ctn_no;
//省略了get和set方法
｝
下面就要读取数据库中的数据了。在com.hxjr.util包下新建一个GetData类，具体代码如下：
package com.hxjr.util;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import com.hxjr.bean.Container;
public class GetData {
private Connection conn = null; // 数据库连接对象
private PreparedStatement pstmt = null; // 数据库连接操作
public GetData() { // 通过构造函数取得数据库的连接
DBUtil service = new DBUtil();
this.conn = service.getConnection(); // 取得数据库的连接
}
public List<Container> get(String container_no) {
ResultSet rs = null; // 声明ResultSet
List<Container> list = new ArrayList<Container>();// 实例化List对象
// 查询SQL语句
String sql = "select * from EDI_JiJian_Webservice where container_no='" + container_no + "' order by id desc; ";
try {
pstmt = conn.prepareStatement(sql); // 预编译SQL语句
rs = pstmt.executeQuery(); // 执行查询语句
while (rs.next()) {
Container ctn=new Container();
ctn.setId(rs.getInt("id"));
ctn.setContainer_no(rs.getString("container_no"));
ctn.setArticle_no(rs.getString("article_no"));
ctn.setG_v_no(rs.getFloat("g_v_no"));
ctn.setName_vessel(rs.getString("name_vessel"));
ctn.setFile_number(rs.getString("file_number"));
ctn.setConsignee(rs.getString("consignee"));
ctn.setShipping_company(rs.getString("shipping_company"));
ctn.setFyco_present(rs.getString("fyco_present"));
ctn.setDescripion_of_goods(rs.getString("descripion_of_goods"));
ctn.setType_of_declaration(rs.getString("type_of_declaration"));
ctn.setDeclaration_number(rs.getFloat("declaration_number"));
ctn.setCountry_of_origin(rs.getFloat("country_of_origin"));
ctn.setCmd_input_onitor_instruction(rs.getString("cmd_input_onitor_instruction"));
ctn.setCmd_check_consignee(rs.getByte("cmd_check_consignee"));
ctn.setCmd_check_specifications(rs.getByte("cmd_check_specifications"));
ctn.setCmd_check_number(rs.getByte("cmd_check_number"));
ctn.setCmd_check_weight(rs.getByte("cmd_check_weight"));
ctn.setCmd_check_classified(rs.getByte("cmd_check_classified"));
ctn.setCmd_check_GaCang(rs.getByte("cmd_check_GaCang"));
ctn.setCmd_check_misrepresenting(rs.getByte("cmd_check_misrepresenting"));
ctn.setDestination_country(rs.getString("destination_country"));
ctn.setCustomer_name(rs.getString("customer_name"));
ctn.setNumber_of_colli(rs.getString("number_of_colli"));
ctn.setContainer_contents1(rs.getString("container_contents1"));
ctn.setContainer_contents2(rs.getString("container_contents2"));
ctn.setContainer_contents3(rs.getString("container_contents3"));
ctn.setBusiness_no(rs.getString("business_no"));
ctn.setCtn_no(rs.getString("ctn_no"));
list.add(ctn);
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
rs.close(); // 关闭ResultSet对象
pstmt.close(); // 关闭PrepareStatement对象
conn.close(); // 关闭Connection对象
} catch (SQLException e) {
e.printStackTrace();
}
}
return list; // 返回List对象
}
}
这样就可以调用GetData.java类中的get()方法获取需要发布的数据了。下面使用WebService进行内容的发布。
建立com.hxjr.webservice包，在包下新建一个Service1Dao.java类，具体代码如下：
package com.hxjr.webservice;
import javax.jws.WebService;
@WebService
public interface Service1Dao {
public String GetEDI(String container_no);
}
实现类Service1如下：
其实这个实现类叫Service1也是他们规定的，由于他们在使用C#进行调用的时候，也会用到Service1这个类的名称，所以我就这样命名了。
package com.hxjr.webservice;
import java.util.List;
import org.dom4j.Document;
import org.dom4j.DocumentHelper;
import org.dom4j.Element;
import com.hxjr.bean.Container;
import com.hxjr.util.GetData;
import com.hxjr.util.MyTools;
public class Service1 implements Service1Dao {
public String GetEDI(String container_no) {
List<Container> list = new GetData().get(container_no);
Document docXML = DocumentHelper.createDocument();
if (list.size() == 0) {
Element element = DocumentHelper.createElement("return_query"); // 创建普通节点
docXML.setRootElement(element);
element.addText("101:没有数据");
return docXML.asXML();
}
Element element = DocumentHelper.createElement("inputinfo"); // 创建普通节点
docXML.setRootElement(element);
// 设置根节点
// --------------为根节点添加general文档元素---------------------
for (int i = 0; i < list.size(); i++) {
Container ctn = list.get(i);
Element general = element.addElement("general");
Element container_contents = general
.addElement("container_contents");
container_contents.addText(MyTools.isEmptyString(ctn
.getContainer_contents1()));
Element container = general.addElement("container");
Element container_nox = container.addElement("container_no");
container_nox.setText(MyTools.isEmptyString(ctn.getContainer_no()));
Element article_no = container.addElement("article_no");
article_no.setText(MyTools.isEmptyString(ctn.getArticle_no()));
Element g_v_no = container.addElement("g_v_no");
g_v_no.setText(ctn.getG_v_no() + "");
Element name_vessel = container.addElement("name_vessel");
name_vessel.setText(MyTools.isEmptyString(ctn.getName_vessel()));
Element file_number = container.addElement("file_number");
file_number.setText(MyTools.isEmptyString(ctn.getFile_number()));
Element consignee = container.addElement("consignee");
consignee.setText(MyTools.isEmptyString(ctn.getConsignee()));
Element shipping_company = container.addElement("shipping_company");
shipping_company.setText(MyTools.isEmptyString(ctn
.getShipping_company()));
// --------------为根节点添加document文档元素---------------------
Element document = element.addElement("document");
Element control = document.addElement("control");
Element file_numberx = control.addElement("file_number");
file_numberx.setText(MyTools.isEmptyString(ctn.getFile_number()));
Element fyco_present = control.addElement("fyco_present");
fyco_present.setText(MyTools.isEmptyString(ctn.getFyco_present()));
Element descripion_of_goods = control
.addElement("descripion_of_goods");
descripion_of_goods.setText(MyTools.isEmptyString(ctn
.getDescripion_of_goods()));
Element type_of_declaration = control
.addElement("type_of_declaration");
type_of_declaration.setText(MyTools.isEmptyString(ctn
.getType_of_declaration()));
Element declaration_number = control
.addElement("declaration_number");
declaration_number.setText(ctn.getDeclaration_number() + "");
Element country_of_origin = control.addElement("country_of_origin");
country_of_origin.setText(ctn.getCountry_of_origin() + "");
Element destination_country = control
.addElement("destination_country");
destination_country.setText(MyTools.isEmptyString(ctn
.getDestination_country()));
Element customer_name = control.addElement("customer_name");
customer_name
.setText(MyTools.isEmptyString(ctn.getCustomer_name()));
Element number_of_colli = control.addElement("number_of_colli");
number_of_colli.setText(MyTools.isEmptyString(ctn
.getNumber_of_colli()));
}
// 输出XML文档
return docXML.asXML();
}
}
在发布之前，还需要讲解一下XML，由于WebService的数据都是以XML的格式发布出去的，而且必须按照对方要求的格式进行数据的组织，所以有必要先了解一下Java如何生成XML格式的数据。
在这里，我们使用了第三方的组件来生成XML文档，也就是需要在WebService项目中引入dom4j的jar包，然后就可以使用其中的API来生成我们想要的格式了。
如上的类的重点就是方法的定义完全是按照规定的要求进行了，也就是前面文档给出的标准。这样他们在使用已经开发好的C#调用时就不会存在任何问题了。
下一篇就是发布WebService了，将这个方法公布出去，供不同平台的程序进行调用。